|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.tap.Tap<Config,Void,Output> cascading.tap.SinkTap<Properties,OutputStream> cascading.tap.local.StdErrTap
public class StdErrTap
Class StdErrTap provides a local mode tap for writing data to the stderr
stream.
Constructor Summary | |
---|---|
StdErrTap(Scheme<Properties,?,OutputStream,?,?> scheme)
|
Method Summary | |
---|---|
boolean |
createResource(Properties conf)
Method createResource creates the underlying resource. |
boolean |
deleteResource(Properties conf)
Method deleteResource deletes the resource represented by this instance. |
String |
getIdentifier()
Method getIdentifier returns a String representing the resource this Tap instance represents. |
long |
getModifiedTime(Properties conf)
Method getModifiedTime returns the date this resource was last modified. |
TupleEntryCollector |
openForWrite(FlowProcess<Properties> flowProcess,
OutputStream output)
Method openForWrite opens the resource represented by this Tap instance for writing. |
boolean |
resourceExists(Properties conf)
Method resourceExists returns true if the path represented by this instance exists. |
Methods inherited from class cascading.tap.SinkTap |
---|
getSourceFields, isSource, openForRead, sourceConfInit |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public StdErrTap(Scheme<Properties,?,OutputStream,?,?> scheme)
Method Detail |
---|
public String getIdentifier()
Tap
getIdentifier
in class Tap<Properties,Void,OutputStream>
public TupleEntryCollector openForWrite(FlowProcess<Properties> flowProcess, OutputStream output) throws IOException
Tap
SinkMode
setting. If SinkMode is
SinkMode.REPLACE
, this call may fail. See Tap.openForWrite(cascading.flow.FlowProcess)
.
output
value may be null, if so, sub-classes must inquire with the underlying Scheme
via Scheme.sinkConfInit(cascading.flow.FlowProcess, Tap, Object)
to get the proper
output type and instantiate it before calling super.openForWrite()
.
openForWrite
in class Tap<Properties,Void,OutputStream>
flowProcess
- of type FlowProcessoutput
- of type Output
IOException
- when the resource cannot be openedpublic boolean createResource(Properties conf) throws IOException
Tap
createResource
in class Tap<Properties,Void,OutputStream>
conf
- of type Config
IOException
- when there is an error making directoriespublic boolean deleteResource(Properties conf) throws IOException
Tap
deleteResource
in class Tap<Properties,Void,OutputStream>
conf
- of type Config
IOException
- when the resource cannot be deletedpublic boolean resourceExists(Properties conf) throws IOException
Tap
resourceExists
in class Tap<Properties,Void,OutputStream>
conf
- of type Config
IOException
- when the status cannot be determinedpublic long getModifiedTime(Properties conf) throws IOException
Tap
getModifiedTime
in class Tap<Properties,Void,OutputStream>
conf
- of type Config
IOException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |