public class AssertRowCount extends CompositeOperator implements RecordSinkOperator
Constructor and Description |
---|
AssertRowCount()
Default constructor
|
AssertRowCount(long rowCount)
Create an
AssertRowCountPlan with all the
required parameters. |
Modifier and Type | Method and Description |
---|---|
protected void |
compose(CompositionContext ctx)
Compose the body of this operator.
|
RecordPort |
getInput()
Gets the record port providing the input data to the sink.
|
int |
getLogFrequency()
Returns the frequency with which to log row count.
|
long |
getRowCount()
Returns the expected number of rows
|
void |
setLogFrequency(int logFrequency)
Sets the frequency with which to log row count
|
void |
setRowCount(long rowCount)
Sets the expected number of rows
|
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
disableParallelism, getInputPorts, getOutputPorts
public AssertRowCount()
public AssertRowCount(long rowCount)
AssertRowCountPlan
with all the
required parameters.rowCount
- the expected row countpublic int getLogFrequency()
public void setLogFrequency(int logFrequency)
logFrequency
- the frequency with which to log row count.public long getRowCount()
public void setRowCount(long rowCount)
rowCount
- the expected number of rowspublic RecordPort getInput()
RecordSinkOperator
getInput
in interface RecordSinkOperator
getInput
in interface SinkOperator<RecordPort>
protected void compose(CompositionContext ctx)
CompositeOperator
OperatorComposable.add(O)
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 portscompose
in class CompositeOperator
ctx
- the contextCopyright © 2021 Actian Corporation. All rights reserved.