cascading.scheme

Interface SinkCall<Context,Output>

Type Parameters:

Context -

Output -

All Known Implementing Classes:

ConcreteCall

public interface SinkCall<Context,Output>

SinkCall provides access to the current Scheme.sink(cascading.flow.FlowProcess, SinkCall) invocation arguments.

Use the Context to store thread local values.

Method Summary

Modifier and Type	Method and Description
Context	getContext() Method getContext returns the context of this SinkCall object.
TupleEntry	getOutgoingEntry() Method getOutgoingEntry returns the final TupleEntry to be passed to the getOutput() output handler.
Output	getOutput()
Tap	getTap() Method getTap returns the parent Tap instance that encapsulates the current Scheme instance.
void	setContext(Context context) Method setContext sets the context of this SinkCall object.

Method Detail

getContext

Context getContext()

Method getContext returns the context of this SinkCall object.

Returns:

the context (type C) of this SinkCall object.

setContext

void setContext(Context context)

Method setContext sets the context of this SinkCall object.

Parameters:

context - the context of this SinkCall object.

getOutgoingEntry

TupleEntry getOutgoingEntry()

Method getOutgoingEntry returns the final TupleEntry to be passed to the 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.

Returns:

TupleEntry

getOutput

Output getOutput()

getTap

Tap getTap()

Method getTap returns the parent Tap instance that encapsulates the current Scheme instance.

Returns:

the parent Tap