|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcascading.tap.Tap
cascading.tap.SourceTap
public abstract class SourceTap
Class SourceTap is the base class for MultiSourceTap
. Some Tap
instances may only be sources (as opposed
to being a sink). These types should subclass SourceTap for convenience.
Constructor Summary | |
---|---|
protected |
SourceTap()
|
protected |
SourceTap(Scheme scheme)
|
Method Summary | |
---|---|
boolean |
deletePath(JobConf conf)
Method deletePath deletes the resource represented by this instance. |
Fields |
getSinkFields()
Method getSinkFields returns the sinkFields of this Tap object. |
boolean |
isSink()
Method isSink returns true if this Tap instance can be used as a sink. |
boolean |
makeDirs(JobConf conf)
Method makeDirs makes all the directories this Tap instance represents. |
TupleEntryIterator |
openForRead(JobConf conf)
Method openForRead opens the resource represented by this Tap instance. |
TupleEntryCollector |
openForWrite(JobConf conf)
Method openForWrite opens the resource represented by this Tap instance. |
void |
sink(TupleEntry tupleEntry,
OutputCollector outputCollector)
Method sink emits the sink value(s) to the OutputCollector |
Methods inherited from class cascading.tap.Tap |
---|
equals, flowInit, getIdentifier, getPath, getPathModified, getQualifiedPath, getScheme, getSinkMode, getSourceFields, hashCode, isAppend, isEquivalentTo, isKeep, isReplace, isSource, isUpdate, isWriteDirect, outgoingScopeFor, pathExists, resolveFields, resolveIncomingOperationFields, setScheme, setWriteDirect, sinkInit, source, sourceInit, taps |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected SourceTap()
protected SourceTap(Scheme scheme)
Method Detail |
---|
public Fields getSinkFields()
Tap
getSinkFields
in class Tap
public void sink(TupleEntry tupleEntry, OutputCollector outputCollector) throws IOException
Tap
sink
in class Tap
tupleEntry
- of type TupleEntryoutputCollector
- of type OutputCollector
IOException
- when the resource cannot be written topublic final boolean isSink()
Tap
isSink
in class Tap
public boolean deletePath(JobConf conf) throws IOException
Tap
deletePath
in class Tap
conf
- of type JobConf
IOException
- when the resource cannot be deletedTap.deletePath(JobConf)
public boolean makeDirs(JobConf conf) throws IOException
Tap
makeDirs
in class Tap
conf
- of type JobConf
IOException
- when there is an error making directoriesTap.makeDirs(JobConf)
public TupleEntryIterator openForRead(JobConf conf) throws IOException
Tap
openForRead
in class Tap
conf
- of type JobConf
IOException
- when the resource cannot be openedpublic TupleEntryCollector openForWrite(JobConf conf) throws IOException
Tap
openForWrite
in class Tap
conf
- of type JobConf
IOException
- when
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |