public static class AggregateBy.CompositeFunction extends BaseOperation<AggregateBy.CompositeFunction.Context> implements Function<AggregateBy.CompositeFunction.Context>
Function
.AggregateBy.Functor
,
Serialized FormModifier and Type | Class and Description |
---|---|
static class |
AggregateBy.CompositeFunction.Context |
fieldDeclaration, numArgs, trace
Constructor and Description |
---|
AggregateBy.CompositeFunction(Fields groupingFields,
Fields[] argumentFields,
AggregateBy.Functor[] functors,
int capacity)
Constructor CompositeFunction creates a new CompositeFunction instance.
|
AggregateBy.CompositeFunction(Fields groupingFields,
Fields argumentFields,
AggregateBy.Functor functor,
int capacity)
Constructor CompositeFunction creates a new CompositeFunction instance.
|
Modifier and Type | Method and Description |
---|---|
void |
cleanup(FlowProcess flowProcess,
OperationCall<AggregateBy.CompositeFunction.Context> operationCall)
Method cleanup does nothing, and may safely be overridden.
|
boolean |
equals(Object object) |
void |
flush(FlowProcess flowProcess,
OperationCall<AggregateBy.CompositeFunction.Context> operationCall)
The flush method is called when an Operation that is caching values must empty the cache.
|
int |
hashCode() |
void |
operate(FlowProcess flowProcess,
FunctionCall<AggregateBy.CompositeFunction.Context> functionCall)
Method operate provides the implementation of this Function.
|
void |
prepare(FlowProcess flowProcess,
OperationCall<AggregateBy.CompositeFunction.Context> operationCall)
Method prepare does nothing, and may safely be overridden.
|
getFieldDeclaration, getNumArgs, getTrace, isSafe, printOperationInternal, toString, toStringInternal
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getFieldDeclaration, getNumArgs, isSafe
public AggregateBy.CompositeFunction(Fields groupingFields, Fields argumentFields, AggregateBy.Functor functor, int capacity)
groupingFields
- of type FieldsargumentFields
- of type Fieldsfunctor
- of type Functorcapacity
- of type intpublic AggregateBy.CompositeFunction(Fields groupingFields, Fields[] argumentFields, AggregateBy.Functor[] functors, int capacity)
groupingFields
- of type FieldsargumentFields
- of type Fields[]functors
- of type Functor[]capacity
- of type intpublic void prepare(FlowProcess flowProcess, OperationCall<AggregateBy.CompositeFunction.Context> operationCall)
BaseOperation
prepare
in interface Operation<AggregateBy.CompositeFunction.Context>
prepare
in class BaseOperation<AggregateBy.CompositeFunction.Context>
public void operate(FlowProcess flowProcess, FunctionCall<AggregateBy.CompositeFunction.Context> functionCall)
Function
operate
in interface Function<AggregateBy.CompositeFunction.Context>
flowProcess
- of type FlowProcessfunctionCall
- of type FunctionCallpublic void flush(FlowProcess flowProcess, OperationCall<AggregateBy.CompositeFunction.Context> operationCall)
Operation
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()
.flush
in interface Operation<AggregateBy.CompositeFunction.Context>
flush
in class BaseOperation<AggregateBy.CompositeFunction.Context>
public void cleanup(FlowProcess flowProcess, OperationCall<AggregateBy.CompositeFunction.Context> operationCall)
BaseOperation
cleanup
in interface Operation<AggregateBy.CompositeFunction.Context>
cleanup
in class BaseOperation<AggregateBy.CompositeFunction.Context>
public boolean equals(Object object)
equals
in class BaseOperation<AggregateBy.CompositeFunction.Context>
public int hashCode()
hashCode
in class BaseOperation<AggregateBy.CompositeFunction.Context>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.