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:

Assertion<AssertGroupBase.Context>, GroupAssertion<AssertGroupBase.Context>, Operation<AssertGroupBase.Context>, Serializable

Direct Known Subclasses:

AssertGroupSizeEquals, AssertGroupSizeLessThan, AssertGroupSizeMoreThan

public abstract class AssertGroupBase
extends BaseAssertion<AssertGroupBase.Context>
implements GroupAssertion<AssertGroupBase.Context>

See Also:

Serialized Form

Nested Class Summary

static class

AssertGroupBase.Context

Field Summary

protected String	patternString Field patternString
protected long	size Field size

Fields inherited from class cascading.operation.BaseOperation

fieldDeclaration, numArgs, trace

Fields inherited from interface cascading.operation.Operation

ANY

Constructor Summary

	AssertGroupBase(String message, long size)
protected	AssertGroupBase(String message, String patternString, long size)

Method Summary

void	aggregate(FlowProcess flowProcess, GroupAssertionCall<AssertGroupBase.Context> assertionCall) Method aggregate is called for each TupleEntry value in the current grouping.
protected abstract boolean	assertFails(Long groupSize)
void	doAssert(FlowProcess flowProcess, GroupAssertionCall<AssertGroupBase.Context> assertionCall) Method doAssert performs the assertion.
void	start(FlowProcess flowProcess, GroupAssertionCall<AssertGroupBase.Context> assertionCall) Method start initializes the aggregation procedure and is called for every unique grouping.

Methods inherited from class cascading.operation.assertion.BaseAssertion

fail, fail, getMessage, throwFail, throwFail

Methods inherited from class cascading.operation.BaseOperation

cleanup, getFieldDeclaration, getNumArgs, getTrace, prepare, printOperationInternal, toString, toStringInternal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface cascading.operation.Operation

cleanup, getFieldDeclaration, getNumArgs, prepare

Field Detail

patternString

protected String patternString

Field patternString

size

protected long size

Field size

Constructor Detail

AssertGroupBase

public AssertGroupBase(String message,
                       long size)

AssertGroupBase

protected AssertGroupBase(String message,
                          String patternString,
                          long size)

Method Detail

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 FlowProcess

assertionCall - 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 FlowProcess

assertionCall - 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 FlowProcess

assertionCall - of type GroupAssertionCall

assertFails

protected abstract boolean assertFails(Long groupSize)