cascading.pipe.assembly
Class AggregateBy.CompositeFunction
java.lang.Object
cascading.operation.BaseOperation<LinkedHashMap<Tuple,Tuple[]>>
cascading.pipe.assembly.AggregateBy.CompositeFunction
- All Implemented Interfaces:
- Function<LinkedHashMap<Tuple,Tuple[]>>, Operation<LinkedHashMap<Tuple,Tuple[]>>, Serializable
- Enclosing class:
- AggregateBy
public static class AggregateBy.CompositeFunction
- extends BaseOperation<LinkedHashMap<Tuple,Tuple[]>>
- implements Function<LinkedHashMap<Tuple,Tuple[]>>
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<LinkedHashMap<Tuple,Tuple[]>> operationCall)
- Description copied from class:
BaseOperation
- Method prepare does nothing, and may safely be overridden.
- Specified by:
prepare
in interface Operation<LinkedHashMap<Tuple,Tuple[]>>
- Overrides:
prepare
in class BaseOperation<LinkedHashMap<Tuple,Tuple[]>>
operate
public void operate(FlowProcess flowProcess,
FunctionCall<LinkedHashMap<Tuple,Tuple[]>> functionCall)
- Description copied from interface:
Function
- Method operate provides the implementation of this Function.
- Specified by:
operate
in interface Function<LinkedHashMap<Tuple,Tuple[]>>
- Parameters:
flowProcess
- of type FlowProcessfunctionCall
- of type FunctionCall
cleanup
public void cleanup(FlowProcess flowProcess,
OperationCall<LinkedHashMap<Tuple,Tuple[]>> operationCall)
- Description copied from class:
BaseOperation
- Method cleanup does nothing, and may safely be overridden.
- Specified by:
cleanup
in interface Operation<LinkedHashMap<Tuple,Tuple[]>>
- Overrides:
cleanup
in class BaseOperation<LinkedHashMap<Tuple,Tuple[]>>
equals
public boolean equals(Object object)
- Overrides:
equals
in class BaseOperation<LinkedHashMap<Tuple,Tuple[]>>
hashCode
public int hashCode()
- Overrides:
hashCode
in class BaseOperation<LinkedHashMap<Tuple,Tuple[]>>
Copyright © 2007-2010 Concurrent, Inc. All Rights Reserved.