cascading.operation.assertion
Class AssertSizeEquals

java.lang.Object
  extended by cascading.operation.BaseOperation<C>
      extended by cascading.operation.assertion.BaseAssertion
          extended by cascading.operation.assertion.AssertSizeEquals
All Implemented Interfaces:
Assertion, Operation, ValueAssertion, Serializable

public class AssertSizeEquals
extends BaseAssertion
implements ValueAssertion

Class AssertSizeEquals asserts that the current Tuple in the stream is exactly 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
AssertSizeEquals(int size)
          Constructor AssertSizeEquals creates a new AssertSizeEquals 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

AssertSizeEquals

public AssertSizeEquals(int size)
Constructor AssertSizeEquals creates a new AssertSizeEquals 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)


Copyright © 2007-2008 Concurrent, Inc. All Rights Reserved.