public interface GroupAssertion<C> extends Assertion<C>
Assertion
used with the Every
pipe Operator.
Implementers should also extend BaseOperation
.Aggregator
Modifier and Type | Method and Description |
---|---|
void |
aggregate(FlowProcess flowProcess,
GroupAssertionCall<C> assertionCall)
Method aggregate is called for each
TupleEntry value in the current grouping. |
void |
doAssert(FlowProcess flowProcess,
GroupAssertionCall<C> assertionCall)
Method doAssert performs the assertion.
|
void |
start(FlowProcess flowProcess,
GroupAssertionCall<C> assertionCall)
Method start initializes the aggregation procedure and is called for every unique grouping.
|
supportsPlannerLevel
cleanup, flush, getFieldDeclaration, getNumArgs, isSafe, prepare
void start(FlowProcess flowProcess, GroupAssertionCall<C> assertionCall)
aggregate(cascading.flow.FlowProcess, GroupAssertionCall)
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.flowProcess
- of type FlowProcessassertionCall
- of type GroupAssertionCallvoid aggregate(FlowProcess flowProcess, GroupAssertionCall<C> assertionCall)
TupleEntry
value in the current grouping.flowProcess
- of type FlowProcessassertionCall
- of type GroupAssertionCallvoid doAssert(FlowProcess flowProcess, GroupAssertionCall<C> assertionCall)
flowProcess
- of type FlowProcessassertionCall
- of type GroupAssertionCallCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.