- java.lang.Object
-
- com.pervasive.datarush.operators.AbstractLogicalOperator
-
- com.pervasive.datarush.operators.CompositeOperator
-
- com.pervasive.datarush.operators.assertion.AssertEqualHash
-
- All Implemented Interfaces:
LogicalOperator
public class AssertEqualHash extends CompositeOperator
Verifies that actual rows are equal to expected rows without regard to order. Used in operator unit testing, when the order of rows is allowed to vary.
-
-
Constructor Summary
Constructors Constructor Description AssertEqualHash()
Constructs an equal hash assertion.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
compose(CompositionContext ctx)
Compose the body of this operator.RecordPort
getActualInput()
Get the actual data input port.RecordPort
getExpectedInput()
Get the expected data input port.-
Methods inherited from class com.pervasive.datarush.operators.AbstractLogicalOperator
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
-
-
-
-
Method Detail
-
getExpectedInput
public RecordPort getExpectedInput()
Get the expected data input port.- Returns:
- expected data input port
-
getActualInput
public RecordPort getActualInput()
Get the actual data input port. This data should have the same schema as the expected data and contain the same rows but possibly in some other order.- Returns:
- actual data input port
-
compose
protected void compose(CompositionContext ctx)
Description copied from class:CompositeOperator
Compose the body of this operator. Implementations should do the following:- Perform any validation of configuration, input types, etc
- Instantiate and configure sub-operators, adding them to the provided context via
the method
OperatorComposable.add(O)
- Create necessary connections via the method
OperatorComposable.connect(P, P)
. This includes connections from the composite's input ports to sub-operators, connections between sub-operators, and connections from sub-operators output ports to the composite's output ports
- Specified by:
compose
in classCompositeOperator
- Parameters:
ctx
- the context
-
-