Module datarush.library

Package com.pervasive.datarush.operators.assertion

Class AssertEqualHash

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

AssertEqualHash

public AssertEqualHash()

Constructs an equal hash assertion.

Method Details

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:

1. Perform any validation of configuration, input types, etc
2. Instantiate and configure sub-operators, adding them to the provided context via the method OperatorComposable.add(O)
3. 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 class CompositeOperator

Parameters:

ctx - the context