public class StdErrTap extends SinkTap<Properties,OutputStream>
stderr
stream.Constructor and Description |
---|
StdErrTap(Scheme<Properties,?,OutputStream,?,?> scheme) |
Modifier and Type | Method and Description |
---|---|
boolean |
createResource(Properties conf) |
boolean |
deleteResource(Properties conf) |
String |
getIdentifier() |
long |
getModifiedTime(Properties conf) |
TupleEntryCollector |
openForWrite(FlowProcess<? extends Properties> flowProcess,
OutputStream output) |
boolean |
resourceExists(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 StdErrTap(Scheme<Properties,?,OutputStream,?,?> scheme)
public String getIdentifier()
getIdentifier
in class Tap<Properties,Void,OutputStream>
public TupleEntryCollector openForWrite(FlowProcess<? extends Properties> flowProcess, OutputStream output) throws IOException
openForWrite
in class Tap<Properties,Void,OutputStream>
IOException
public boolean createResource(Properties conf) throws IOException
createResource
in class Tap<Properties,Void,OutputStream>
IOException
public boolean deleteResource(Properties conf) throws IOException
deleteResource
in class Tap<Properties,Void,OutputStream>
IOException
public boolean resourceExists(Properties conf) throws IOException
resourceExists
in class Tap<Properties,Void,OutputStream>
IOException
public long getModifiedTime(Properties conf) throws IOException
getModifiedTime
in class Tap<Properties,Void,OutputStream>
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.