|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.tap.Tap cascading.tap.SinkTap
public abstract class SinkTap
Class SinkTap is the base class for TemplateTap
. Some Tap
instances may only be sinks (as opposed
to being a source). These types should subclass SinkTap for convenience.
Constructor Summary | |
---|---|
protected |
SinkTap()
|
protected |
SinkTap(Scheme scheme)
|
protected |
SinkTap(Scheme scheme,
SinkMode sinkMode)
|
Method Summary | |
---|---|
Fields |
getSourceFields()
Method getSourceFields returns the sourceFields of this Tap object. |
boolean |
isSource()
Method isSource returns true if this Tap instance can be used as a source. |
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. |
Tuple |
source(Object key,
Object value)
Method source returns the source value as an instance of Tuple |
void |
sourceInit(JobConf conf)
Method sourceInit initializes this instance as a source. |
Methods inherited from class cascading.tap.Tap |
---|
deletePath, equals, flowInit, getIdentifier, getPath, getPathModified, getQualifiedPath, getScheme, getSinkFields, getSinkMode, hashCode, isAppend, isEquivalentTo, isKeep, isReplace, isSink, isUpdate, isWriteDirect, makeDirs, outgoingScopeFor, pathExists, resolveFields, resolveIncomingOperationFields, setScheme, setWriteDirect, sink, sinkInit, taps |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected SinkTap()
protected SinkTap(Scheme scheme)
protected SinkTap(Scheme scheme, SinkMode sinkMode)
Method Detail |
---|
public Fields getSourceFields()
Tap
getSourceFields
in class Tap
public Tuple source(Object key, Object value)
Tap
Tuple
source
in class Tap
key
- of type WritableComparablevalue
- of type Writable
public boolean isSource()
Tap
isSource
in class Tap
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
- whenpublic void sourceInit(JobConf conf) throws IOException
Tap
Flow
instance or if it participates in multiple times in a given Flow or across different Flows in
a Cascade
.
In the context of a Flow, it will be called after
FlowListener.onStarting(cascading.flow.Flow)
sourceInit
in class Tap
conf
- of type JobConf
IOException
- on resource initialization failure.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |