public class FileTap extends Tap<Properties,InputStream,OutputStream> implements FileType<Properties>
Tap
sub-class that allows for direct local file access.
FileTap must be used with the LocalFlowConnector
to create
Flow
instances that run in "local" mode.Constructor and Description |
---|
FileTap(Scheme<Properties,InputStream,OutputStream,?,?> scheme,
String path)
Constructor FileTap creates a new FileTap instance using the given
Scheme and file path . |
FileTap(Scheme<Properties,InputStream,OutputStream,?,?> scheme,
String path,
SinkMode sinkMode)
|
createResource, deleteResource, equals, flowConfInit, getConfigDef, getFullIdentifier, getModifiedTime, getNodeConfigDef, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasNodeConfigDef, hasStepConfigDef, id, isKeep, isReplace, isSink, isSource, isTemporary, isUpdate, openForRead, openForWrite, outgoingScopeFor, prepareResourceForRead, prepareResourceForWrite, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, retrieveSinkFields, retrieveSourceFields, rollbackResource, setScheme, sinkConfInit, sourceConfInit, taps, toString
public FileTap(Scheme<Properties,InputStream,OutputStream,?,?> scheme, String path)
Scheme
and file path
.scheme
- of type LocalSchemepath
- of type Stringpublic FileTap(Scheme<Properties,InputStream,OutputStream,?,?> scheme, String path, SinkMode sinkMode)
scheme
- of type LocalSchemepath
- of type StringsinkMode
- of type SinkModepublic String getIdentifier()
getIdentifier
in class Tap<Properties,InputStream,OutputStream>
public String getFullIdentifier(Properties conf)
getFullIdentifier
in class Tap<Properties,InputStream,OutputStream>
public TupleEntryIterator openForRead(FlowProcess<? extends Properties> flowProcess, InputStream input) throws IOException
openForRead
in class Tap<Properties,InputStream,OutputStream>
IOException
public TupleEntryCollector openForWrite(FlowProcess<? extends Properties> flowProcess, OutputStream output) throws IOException
openForWrite
in class Tap<Properties,InputStream,OutputStream>
IOException
public boolean createResource(Properties conf) throws IOException
createResource
in class Tap<Properties,InputStream,OutputStream>
IOException
public boolean deleteResource(Properties conf) throws IOException
deleteResource
in class Tap<Properties,InputStream,OutputStream>
IOException
public boolean commitResource(Properties conf) throws IOException
commitResource
in class Tap<Properties,InputStream,OutputStream>
IOException
public boolean resourceExists(Properties conf) throws IOException
resourceExists
in class Tap<Properties,InputStream,OutputStream>
IOException
public long getModifiedTime(Properties conf) throws IOException
getModifiedTime
in class Tap<Properties,InputStream,OutputStream>
IOException
public boolean isDirectory(FlowProcess<? extends Properties> flowProcess) throws IOException
isDirectory
in interface FileType<Properties>
IOException
public boolean isDirectory(Properties conf) throws IOException
isDirectory
in interface FileType<Properties>
IOException
public String[] getChildIdentifiers(FlowProcess<? extends Properties> flowProcess) throws IOException
getChildIdentifiers
in interface FileType<Properties>
IOException
public String[] getChildIdentifiers(Properties conf) throws IOException
getChildIdentifiers
in interface FileType<Properties>
IOException
public String[] getChildIdentifiers(FlowProcess<? extends Properties> flowProcess, int depth, boolean fullyQualified) throws IOException
getChildIdentifiers
in interface FileType<Properties>
IOException
public String[] getChildIdentifiers(Properties conf, int depth, boolean fullyQualified) throws IOException
getChildIdentifiers
in interface FileType<Properties>
IOException
public long getSize(FlowProcess<? extends Properties> flowProcess) throws IOException
getSize
in interface FileType<Properties>
IOException
public long getSize(Properties conf) throws IOException
getSize
in interface FileType<Properties>
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.