public class StdInTap extends SourceTap<Properties,InputStream>
stdin
stream.Constructor and Description |
---|
StdInTap(Scheme<Properties,InputStream,?,?,?> scheme) |
Modifier and Type | Method and Description |
---|---|
String |
getIdentifier() |
long |
getModifiedTime(Properties conf) |
TupleEntryIterator |
openForRead(FlowProcess<? extends Properties> flowProcess,
InputStream inputStream) |
boolean |
resourceExists(Properties conf) |
commitResource, createResource, deleteResource, getSinkFields, isSink, openForWrite, prepareResourceForWrite, rollbackResource, sinkConfInit
createResource, deleteResource, equals, flowConfInit, getConfigDef, getFullIdentifier, getFullIdentifier, getModifiedTime, getNodeConfigDef, getScheme, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasNodeConfigDef, hasStepConfigDef, id, isKeep, isReplace, isSource, isTemporary, isUpdate, openForRead, openForWrite, outgoingScopeFor, prepareResourceForRead, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, retrieveSinkFields, retrieveSourceFields, setScheme, sourceConfInit, taps, toString
public StdInTap(Scheme<Properties,InputStream,?,?,?> scheme)
public String getIdentifier()
getIdentifier
in class Tap<Properties,InputStream,Void>
public TupleEntryIterator openForRead(FlowProcess<? extends Properties> flowProcess, InputStream inputStream) throws IOException
openForRead
in class Tap<Properties,InputStream,Void>
IOException
public boolean resourceExists(Properties conf) throws IOException
resourceExists
in class Tap<Properties,InputStream,Void>
IOException
public long getModifiedTime(Properties conf) throws IOException
getModifiedTime
in class Tap<Properties,InputStream,Void>
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.