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