cascading.pipe.assembly
Class AggregateBy.CompositeFunction
java.lang.Object
cascading.operation.BaseOperation<AggregateBy.CompositeFunction.Context>
cascading.pipe.assembly.AggregateBy.CompositeFunction
- All Implemented Interfaces:
- DeclaresResults, Function<AggregateBy.CompositeFunction.Context>, Operation<AggregateBy.CompositeFunction.Context>, Traceable, Serializable
- Enclosing class:
- AggregateBy
public static class AggregateBy.CompositeFunction
- extends BaseOperation<AggregateBy.CompositeFunction.Context>
- implements Function<AggregateBy.CompositeFunction.Context>
Class CompositeFunction takes multiple Functor instances and manages them as a single Function
.
- See Also:
AggregateBy.Functor
,
Serialized Form
Fields inherited from interface cascading.operation.Operation |
ANY |
DEFAULT_THRESHOLD
public static final int DEFAULT_THRESHOLD
- See Also:
- Constant Field Values
AggregateBy.CompositeFunction
public AggregateBy.CompositeFunction(Fields groupingFields,
Fields argumentFields,
AggregateBy.Functor functor,
int threshold)
- Constructor CompositeFunction creates a new CompositeFunction instance.
- Parameters:
groupingFields
- of type FieldsargumentFields
- of type Fieldsfunctor
- of type Functorthreshold
- of type int
AggregateBy.CompositeFunction
public AggregateBy.CompositeFunction(Fields groupingFields,
Fields[] argumentFields,
AggregateBy.Functor[] functors,
int threshold)
- Constructor CompositeFunction creates a new CompositeFunction instance.
- Parameters:
groupingFields
- of type FieldsargumentFields
- of type Fields[]functors
- of type Functor[]threshold
- of type int
prepare
public void prepare(FlowProcess flowProcess,
OperationCall<AggregateBy.CompositeFunction.Context> operationCall)
- Description copied from class:
BaseOperation
- Method prepare does nothing, and may safely be overridden.
- Specified by:
prepare
in interface Operation<AggregateBy.CompositeFunction.Context>
- Overrides:
prepare
in class BaseOperation<AggregateBy.CompositeFunction.Context>
operate
public void operate(FlowProcess flowProcess,
FunctionCall<AggregateBy.CompositeFunction.Context> functionCall)
- Description copied from interface:
Function
- Method operate provides the implementation of this Function.
- Specified by:
operate
in interface Function<AggregateBy.CompositeFunction.Context>
- Parameters:
flowProcess
- of type FlowProcessfunctionCall
- of type FunctionCall
flush
public void flush(FlowProcess flowProcess,
OperationCall<AggregateBy.CompositeFunction.Context> operationCall)
- Description copied from interface:
Operation
- The flush method is called when an Operation that is caching values must empty the cache. It is called before
Operation.cleanup(cascading.flow.FlowProcess, OperationCall)
is invoked.
It is safe to cast the OperationCall
to a FunctionCall
, or equivalent, and
get its FunctionCall.getOutputCollector()
.
- Specified by:
flush
in interface Operation<AggregateBy.CompositeFunction.Context>
- Overrides:
flush
in class BaseOperation<AggregateBy.CompositeFunction.Context>
equals
public boolean equals(Object object)
- Overrides:
equals
in class BaseOperation<AggregateBy.CompositeFunction.Context>
hashCode
public int hashCode()
- Overrides:
hashCode
in class BaseOperation<AggregateBy.CompositeFunction.Context>
Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.