|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Context
- Input
- public interface SourceCall<Context,Input>
SourceCall provides access to the current Scheme.source(cascading.flow.FlowProcess, SourceCall)
invocation
arguments.
Method Summary | |
---|---|
Context |
getContext()
Method getContext returns the context of this SourceCall object. |
TupleEntry |
getIncomingEntry()
Method getIncomingEntry returns a pre-prepared TupleEntry to be populated
with the input values from getInput() . |
Input |
getInput()
Method getInput returns the input mechanism for the underlying platform used to retrieve new values (records, lines, etc). |
void |
setContext(Context context)
Method setContext sets the context of this SourceCall object. |
Method Detail |
---|
Context getContext()
void setContext(Context context)
context
- the context of this SourceCall object.TupleEntry getIncomingEntry()
TupleEntry
to be populated
with the input values from getInput()
.
That is, using the getInput() method, retrieve the current incoming values and
place them into the getIncomingEntry() via TupleEntry.setTuple(cascading.tuple.Tuple)
or by modifying the tuple returned from TupleEntry.getTuple()
.
The returned Tuple entry is guaranteed to be the size of the declared incoming source fields.
The returned TupleEntry from this method is modifiable and is intended to be re-used. This is an exception to
the general rule that passed TupleEntry instances must not be modified.
Input getInput()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |