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