Context
- IO
- public class ConcreteCall<Context,IO> extends Object implements SourceCall<Context,IO>, SinkCall<Context,IO>
SourceCall
and SinkCall
.Constructor and Description |
---|
ConcreteCall() |
Modifier and Type | Method and Description |
---|---|
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 SourceCall.getInput() . |
IO |
getInput()
Method getInput returns the input mechanism for the underlying platform used to retrieve new values (records,
lines, etc).
|
TupleEntry |
getOutgoingEntry()
Method getOutgoingEntry returns the final
TupleEntry to be passed to the
SinkCall.getOutput() output handler. |
IO |
getOutput() |
void |
setContext(Context context)
Method setContext sets the context of this SourceCall object.
|
void |
setIncomingEntry(TupleEntry incomingEntry) |
void |
setInput(IO input) |
void |
setOutgoingEntry(TupleEntry outgoingEntry) |
void |
setOutput(IO output) |
public ConcreteCall()
public Context getContext()
SourceCall
getContext
in interface SinkCall<Context,IO>
getContext
in interface SourceCall<Context,IO>
public void setContext(Context context)
SourceCall
setContext
in interface SinkCall<Context,IO>
setContext
in interface SourceCall<Context,IO>
context
- the context of this SourceCall object.public TupleEntry getOutgoingEntry()
SinkCall
TupleEntry
to be passed to the
SinkCall.getOutput()
output handler.
That is, the result of calling getOutgoingEntry() should be passed directly to the
platform specific output handler returned by getOutput().
Note the returned value from this method cannot be modified.getOutgoingEntry
in interface SinkCall<Context,IO>
public void setOutgoingEntry(TupleEntry outgoingEntry)
public TupleEntry getIncomingEntry()
SourceCall
TupleEntry
to be populated
with the input values from SourceCall.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.getIncomingEntry
in interface SourceCall<Context,IO>
public void setIncomingEntry(TupleEntry incomingEntry)
public IO getInput()
SourceCall
getInput
in interface SourceCall<Context,IO>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.