|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface AggregatorCall<C>
Interface AggregatorCall provides access to the current Aggregator
invocation arguments.
Aggregator.start(cascading.flow.FlowProcess, AggregatorCall)
is called. The OperationCall.setContext(Object)
and OperationCall.getContext()
methods are
inherited from OperationCall
.
Aggregator
,
OperationCall
Method Summary | |
---|---|
TupleEntry |
getArguments()
Returns TupleEntry of argument values. |
Fields |
getDeclaredFields()
Return the resolved Fields declared by the current Operation . |
TupleEntry |
getGroup()
Returns the current grouping TupleEntry . |
TupleEntryCollector |
getOutputCollector()
Returns the TupleEntryCollector used to emit result values. |
Methods inherited from interface cascading.operation.OperationCall |
---|
getArgumentFields, getContext, setContext |
Method Detail |
---|
TupleEntry getGroup()
TupleEntry
.
TupleEntry getArguments()
TupleEntry
of argument values.
Will return null
unless called in Aggregator.aggregate(cascading.flow.FlowProcess, AggregatorCall)
.
Fields getDeclaredFields()
Fields
declared by the current Operation
.
TupleEntryCollector getOutputCollector()
TupleEntryCollector
used to emit result values.
Will return null
unless called in Aggregator.complete(cascading.flow.FlowProcess, AggregatorCall)
.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |