cascading.operation.assertion
Class AssertSizeLessThan

java.lang.Object
  cascading.operation.BaseOperation<C>
      cascading.operation.assertion.BaseAssertion
          cascading.operation.assertion.AssertSizeLessThan

All Implemented Interfaces:

Assertion, Operation, ValueAssertion, Serializable

public class AssertSizeLessThan
extends BaseAssertion
implements ValueAssertion

Class AssertSizeLessThan asserts that the current Tuple in the stream has a size less than (<) the given size.

On evaluation, Tuple.size() is called (note Tuples may hold null values).

See Also:

Serialized Form

Field Summary

Fields inherited from class cascading.operation.BaseOperation

fieldDeclaration, numArgs, trace

Fields inherited from interface cascading.operation.Operation

ANY

Constructor Summary

AssertSizeLessThan(int size)
Constructor AssertSizeLessThan creates a new AssertSizeLessThan instance.

Method Summary

void	doAssert(FlowProcess flowProcess, ValueAssertionCall assertionCall) Method doAssert performs the assertion.

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

Constructor Detail

AssertSizeLessThan

public AssertSizeLessThan(int size)

Constructor AssertSizeLessThan creates a new AssertSizeLessThan instance.

Parameters:

size - of type int

Method Detail

doAssert

public void doAssert(FlowProcess flowProcess,
                     ValueAssertionCall assertionCall)

Description copied from interface: ValueAssertion

Method doAssert performs the assertion.

Specified by:

doAssert in interface ValueAssertion

See Also:

ValueAssertion.doAssert(cascading.flow.FlowProcess,cascading.operation.ValueAssertionCall)