cascading.tap.local
Class StdOutTap
java.lang.Object
cascading.tap.Tap<Config,Void,Output>
cascading.tap.SinkTap<Properties,OutputStream>
cascading.tap.local.StdOutTap
- All Implemented Interfaces:
- FlowElement, Traceable, Serializable
public class StdOutTap
- extends SinkTap<Properties,OutputStream>
Class StdOutTap provides a local mode tap for writing data to the stdout
stream.
- See Also:
- Serialized Form
Methods inherited from class cascading.tap.Tap |
commitResource, createResource, deleteResource, equals, flowConfInit, getConfigDef, getFullIdentifier, getFullIdentifier, getModifiedTime, getScheme, getSinkFields, getSinkMode, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasStepConfigDef, id, isEquivalentTo, isKeep, isReplace, isSink, isTemporary, isUpdate, openForRead, openForWrite, outgoingScopeFor, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, retrieveSinkFields, retrieveSourceFields, rollbackResource, setScheme, sinkConfInit, taps, toString |
StdOutTap
public StdOutTap(Scheme<Properties,?,OutputStream,?,?> scheme)
getIdentifier
public String getIdentifier()
- Specified by:
getIdentifier
in class Tap<Properties,Void,OutputStream>
openForWrite
public TupleEntryCollector openForWrite(FlowProcess<Properties> flowProcess,
OutputStream output)
throws IOException
- Specified by:
openForWrite
in class Tap<Properties,Void,OutputStream>
- Throws:
IOException
createResource
public boolean createResource(Properties conf)
throws IOException
- Specified by:
createResource
in class Tap<Properties,Void,OutputStream>
- Throws:
IOException
deleteResource
public boolean deleteResource(Properties conf)
throws IOException
- Specified by:
deleteResource
in class Tap<Properties,Void,OutputStream>
- Throws:
IOException
resourceExists
public boolean resourceExists(Properties conf)
throws IOException
- Specified by:
resourceExists
in class Tap<Properties,Void,OutputStream>
- Throws:
IOException
getModifiedTime
public long getModifiedTime(Properties conf)
throws IOException
- Specified by:
getModifiedTime
in class Tap<Properties,Void,OutputStream>
- Throws:
IOException
Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.