public class StdInTap extends SourceTap<java.util.Properties,java.io.InputStream>
stdin
stream.Constructor and Description |
---|
StdInTap(Scheme<java.util.Properties,java.io.InputStream,?,?,?> scheme) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getIdentifier() |
long |
getModifiedTime(java.util.Properties conf) |
TupleEntryIterator |
openForRead(FlowProcess<? extends java.util.Properties> flowProcess,
java.io.InputStream inputStream) |
boolean |
resourceExists(java.util.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 java.lang.String getIdentifier()
getIdentifier
in class Tap<java.util.Properties,java.io.InputStream,java.lang.Void>
public TupleEntryIterator openForRead(FlowProcess<? extends java.util.Properties> flowProcess, java.io.InputStream inputStream) throws java.io.IOException
openForRead
in class Tap<java.util.Properties,java.io.InputStream,java.lang.Void>
java.io.IOException
public boolean resourceExists(java.util.Properties conf) throws java.io.IOException
resourceExists
in class Tap<java.util.Properties,java.io.InputStream,java.lang.Void>
java.io.IOException
public long getModifiedTime(java.util.Properties conf) throws java.io.IOException
getModifiedTime
in class Tap<java.util.Properties,java.io.InputStream,java.lang.Void>
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.