cascading.operation
Interface AggregatorCall<C>

All Superinterfaces:

OperationCall<C>

All Known Implementing Classes:

ConcreteCall

public interface AggregatorCall<C>
extends OperationCall<C>

Interface AggregatorCall provides access to the current Aggregator invocation arguments.

This interface is generic, allowing the user to set a custom 'context' object when Aggregator.start(cascading.flow.FlowProcess, AggregatorCall) is called. The OperationCall.setContext(Object) and OperationCall.getContext() methods are inherited from OperationCall.

See Also:

Aggregator, OperationCall

Method Summary

TupleEntry	getArguments() Returns TupleEntry of argument values.
TupleEntry	getGroup() Returns the current grouping TupleEntry.
TupleEntryCollector	getOutputCollector() Returns the TupleEntryCollector used to emit result values.

Methods inherited from interface cascading.operation.OperationCall

getContext, setContext

Method Detail

getGroup

TupleEntry getGroup()

Returns the current grouping TupleEntry.

Returns:

TupleEnry

getArguments

TupleEntry getArguments()

Returns TupleEntry of argument values.

Will return null unless called in Aggregator.aggregate(cascading.flow.FlowProcess, AggregatorCall).

Returns:

TupleEntry

getOutputCollector

TupleEntryCollector getOutputCollector()

Returns the TupleEntryCollector used to emit result values.

Will return null unless called in Aggregator.complete(cascading.flow.FlowProcess, AggregatorCall).

Returns:

TupleCollector