cascading.operation.aggregator
Class Sum

java.lang.Object
  cascading.operation.BaseOperation<Double[]>
      cascading.operation.aggregator.Sum

All Implemented Interfaces:

Aggregator<Double[]>, Operation<Double[]>, Serializable

public class Sum
extends BaseOperation<Double[]>
implements Aggregator<Double[]>

Class Sum is an Aggregator that returns the sum of all numeric values in the current group.

See Also:

Serialized Form

Field Summary

static String

FIELD_NAME Field FIELD_NAME

Fields inherited from class cascading.operation.BaseOperation

fieldDeclaration, numArgs, trace

Fields inherited from interface cascading.operation.Operation

ANY

Constructor Summary

Sum()
Constructor Sum creates a new Sum instance that accepts one argument and returns a single field named "sum".

Sum(Fields fieldDeclaration)
Constructs a new instance that returns the fields declared in fieldDeclaration and accepts only 1 argument.

Sum(Fields fieldDeclaration, Class type)
Constructs a new instance that returns the fields declared in fieldDeclaration and accepts only 1 argument.

Method Summary

void	aggregate(FlowProcess flowProcess, AggregatorCall<Double[]> aggregatorCall) Method aggregate is called for each TupleEntry value in the current grouping.
void	complete(FlowProcess flowProcess, AggregatorCall<Double[]> aggregatorCall) Method complete will be issued last after every TupleEntry has been passed to the Aggregator.aggregate(cascading.flow.FlowProcess, AggregatorCall) method.
protected Tuple	getResult(AggregatorCall<Double[]> aggregatorCall)
void	start(FlowProcess flowProcess, AggregatorCall<Double[]> aggregatorCall) Method start initializes the aggregation procedure and is called for every unique grouping.

Methods inherited from class cascading.operation.BaseOperation

cleanup, getFieldDeclaration, getNumArgs, getTrace, prepare, printOperationInternal, toString, toStringInternal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface cascading.operation.Operation

cleanup, getFieldDeclaration, getNumArgs, prepare

Field Detail

FIELD_NAME

public static final String FIELD_NAME

Field FIELD_NAME

See Also:

Constant Field Values

Constructor Detail

Sum

public Sum()

Constructor Sum creates a new Sum instance that accepts one argument and returns a single field named "sum".

Sum

public Sum(Fields fieldDeclaration)

Constructs a new instance that returns the fields declared in fieldDeclaration and accepts only 1 argument.

Parameters:

fieldDeclaration - of type Fields

Sum

public Sum(Fields fieldDeclaration,
           Class type)

Constructs a new instance that returns the fields declared in fieldDeclaration and accepts only 1 argument. The return result is coerced into the given Class type.

Parameters:

fieldDeclaration - of type Fields

type - of type Class

Method Detail

start

public void start(FlowProcess flowProcess,
                  AggregatorCall<Double[]> aggregatorCall)

Description copied from interface: Aggregator

Method start initializes the aggregation procedure and is called for every unique grouping.

The AggregatorCall context should be initialized here if necessary.

The first time this method is called for a given 'process', the AggregatorCall context will be null. This method should set a new instance of the user defined context object. When the AggregatorCall context is not null, it is up to the developer to create a new instance, or 'recycle' the given instance. If recycled, it must be re-initialized to remove any previous state/values.

For example, if a Map is used to hold the intermediate data for each subsequent Aggregator.aggregate(cascading.flow.FlowProcess, AggregatorCall) call, new HashMap() should be set on the AggregatorCall instance when OperationCall.getContext() is null. On the next grouping, start() will be called again, but this time with the old Map instance. In this case, map.clear() should be invoked before returning.

Specified by:

start in interface Aggregator<Double[]>

Parameters:

flowProcess - of type FlowProcess

aggregatorCall - of type AggregatorCall

aggregate

public void aggregate(FlowProcess flowProcess,
                      AggregatorCall<Double[]> aggregatorCall)

Description copied from interface: Aggregator

Method aggregate is called for each TupleEntry value in the current grouping.

TupleEntry entry, or entry.getTuple() should not be stored directly in the context. A copy of the tuple should be made via the new Tuple( entry.getTuple() ) copy constructor.

Specified by:

aggregate in interface Aggregator<Double[]>

Parameters:

flowProcess - of type FlowProcess

aggregatorCall - of type AggregatorCall

complete

public void complete(FlowProcess flowProcess,
                     AggregatorCall<Double[]> aggregatorCall)

Description copied from interface: Aggregator

Method complete will be issued last after every TupleEntry has been passed to the Aggregator.aggregate(cascading.flow.FlowProcess, AggregatorCall) method. Any final calculation should be completed here and passed to the outputCollector.

Specified by:

complete in interface Aggregator<Double[]>

Parameters:

flowProcess - of type FlowProcess

aggregatorCall - of type AggregatorCall

getResult

protected Tuple getResult(AggregatorCall<Double[]> aggregatorCall)