public abstract class AbstractExecutableRecordPipeline extends ExecutableOperator implements RecordPipelineOperator
AbstractExecutableRecordPipeline
provides the declaration of an input and an output port
as well as getters for obtaining both.Modifier and Type | Field and Description |
---|---|
protected RecordPort |
input
The record port for input to the operator
|
protected RecordPort |
output
The record port for output from the operator
|
Modifier | Constructor and Description |
---|---|
protected |
AbstractExecutableRecordPipeline()
Default constructor
|
Modifier and Type | Method and Description |
---|---|
RecordPort |
getInput()
Gets the record port providing the input data to the operation.
|
RecordPort |
getOutput()
Gets the record port providing the output from the operation.
|
cloneForExecution, execute, getNumInputCopies, getPortSettings, handleInactiveOutput
computeMetadata
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
disableParallelism, getInputPorts, getOutputPorts
protected final RecordPort input
protected final RecordPort output
protected AbstractExecutableRecordPipeline()
public RecordPort getInput()
getInput
in interface PipelineOperator<RecordPort>
public RecordPort getOutput()
getOutput
in interface PipelineOperator<RecordPort>
Copyright © 2024 Actian Corporation. All rights reserved.