cascading.operation.assertion
Class AssertGroupBase
java.lang.Object
cascading.operation.BaseOperation<C>
cascading.operation.assertion.BaseAssertion<AssertGroupBase.Context>
cascading.operation.assertion.AssertGroupBase
- All Implemented Interfaces:
- DeclaresResults, Assertion<AssertGroupBase.Context>, GroupAssertion<AssertGroupBase.Context>, Operation<AssertGroupBase.Context>, PlannedOperation<AssertGroupBase.Context>, Traceable, Serializable
- Direct Known Subclasses:
- AssertGroupSizeEquals, AssertGroupSizeLessThan, AssertGroupSizeMoreThan
public abstract class AssertGroupBase
- extends BaseAssertion<AssertGroupBase.Context>
- implements GroupAssertion<AssertGroupBase.Context>
- See Also:
- Serialized Form
Fields inherited from interface cascading.operation.Operation |
ANY |
patternString
protected String patternString
- Field patternString
size
protected final long size
- Field size
AssertGroupBase
@ConstructorProperties(value={"message","size"})
public AssertGroupBase(String message,
long size)
AssertGroupBase
@ConstructorProperties(value={"message","patternString","size"})
protected AssertGroupBase(String message,
String patternString,
long size)
getPatternString
public String getPatternString()
getSize
public long getSize()
prepare
public void prepare(FlowProcess flowProcess,
OperationCall<AssertGroupBase.Context> operationCall)
- Description copied from class:
BaseOperation
- Method prepare does nothing, and may safely be overridden.
- Specified by:
prepare
in interface Operation<AssertGroupBase.Context>
- Overrides:
prepare
in class BaseOperation<AssertGroupBase.Context>
start
public void start(FlowProcess flowProcess,
GroupAssertionCall<AssertGroupBase.Context> assertionCall)
- Description copied from interface:
GroupAssertion
- 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
GroupAssertion.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.
- Specified by:
start
in interface GroupAssertion<AssertGroupBase.Context>
- Parameters:
flowProcess
- of type FlowProcessassertionCall
- of type GroupAssertionCall
aggregate
public void aggregate(FlowProcess flowProcess,
GroupAssertionCall<AssertGroupBase.Context> assertionCall)
- Description copied from interface:
GroupAssertion
- Method aggregate is called for each
TupleEntry
value in the current grouping.
- Specified by:
aggregate
in interface GroupAssertion<AssertGroupBase.Context>
- Parameters:
flowProcess
- of type FlowProcessassertionCall
- of type GroupAssertionCall
doAssert
public void doAssert(FlowProcess flowProcess,
GroupAssertionCall<AssertGroupBase.Context> assertionCall)
- Description copied from interface:
GroupAssertion
- Method doAssert performs the assertion.
- Specified by:
doAssert
in interface GroupAssertion<AssertGroupBase.Context>
- Parameters:
flowProcess
- of type FlowProcessassertionCall
- of type GroupAssertionCall
assertFails
protected abstract boolean assertFails(Long groupSize)
equals
public boolean equals(Object object)
- Overrides:
equals
in class BaseAssertion<AssertGroupBase.Context>
hashCode
public int hashCode()
- Overrides:
hashCode
in class BaseAssertion<AssertGroupBase.Context>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.