public class AssertEqual extends ExecutableOperator
Constructor and Description |
---|
AssertEqual()
Construct the operator with default property values.
|
AssertEqual(FloatingPointTolerance errorTolerance,
int logFrequency)
Construct the operator with the given property values.
|
Modifier and Type | Method and Description |
---|---|
protected void |
computeMetadata(StreamingMetadataContext ctx)
Implementations must adhere to the following contracts
|
protected void |
execute(ExecutionContext context)
Executes the operator.
|
RecordPort |
getActualInput()
Get the actual input data port.
|
FloatingPointTolerance |
getErrorTolerance()
Get the error tolerance property for floating point values.
|
RecordPort |
getExpectedInput()
Get the expected input data port.
|
int |
getLogFrequency()
Get the log frequency property.
|
void |
setErrorTolerance(FloatingPointTolerance errorTolerance)
Set the error tolerance for floating point values.
|
void |
setLogFrequency(int logFrequency)
Set the logging frequency property.
|
cloneForExecution, getNumInputCopies, getPortSettings, handleInactiveOutput
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public AssertEqual()
public AssertEqual(FloatingPointTolerance errorTolerance, int logFrequency)
errorTolerance
- error bound used when testing equality of
floating point valueslogFrequency
- Log the number of rows compared once for every
logFrequency
rows. logFrequency <= 0
means log only the total number of comparisons.public FloatingPointTolerance getErrorTolerance()
public void setErrorTolerance(FloatingPointTolerance errorTolerance)
errorTolerance
- error bound used when testing equality of
floating point valuespublic int getLogFrequency()
public void setLogFrequency(int logFrequency)
logFrequency
- Log the number of rows compared once for every
logFrequency
rows. logFrequency <= 0
means log only the total number of comparisons.public RecordPort getExpectedInput()
public RecordPort getActualInput()
protected void computeMetadata(StreamingMetadataContext ctx)
StreamingOperator
StreamingMetadataContext.parallelize(ParallelismStrategy)
.
RecordPort#setRequiredDataOrdering
, otherwise data may arrive in any order.
RecordPort#setRequiredDataDistribution
, otherwise data will arrive in an unspecified partial distribution
.
RecordPort#getSourceDataDistribution
and RecordPort#getSourceDataOrdering
. These should be
viewed as a hints to help chose a more efficient algorithm. In such cases, though, operators must
still declare data ordering and data distribution requirements; otherwise there is no guarantee that
data will arrive sorted/distributed as required.
RecordPort#setType
.RecordPort#setOutputDataOrdering
RecordPort#setOutputDataDistribution
AbstractModelPort#setMergeHandler
.MergeModel
is a convenient, re-usable model reducer, parameterized with
a merge-handler.
SimpleModelPort
's have no associated metadata and therefore there is
never any output metadata to declare. PMMLPort
's, on the other hand,
do have associated metadata. For all PMMLPorts, implementations must declare
the following:
PMMLPort.setPMMLModelSpec
.
computeMetadata
in class StreamingOperator
ctx
- the contextprotected void execute(ExecutionContext context)
ExecutableOperator
execute
in class ExecutableOperator
context
- context in which to lookup physical ports bound to logical portsCopyright © 2021 Actian Corporation. All rights reserved.