Module datarush.library

Package com.pervasive.datarush.operators

Class AbstractExecutableRecordPipeline

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.StreamingOperator

com.pervasive.datarush.operators.ExecutableOperator

com.pervasive.datarush.operators.AbstractExecutableRecordPipeline

All Implemented Interfaces:

LogicalOperator, PipelineOperator<RecordPort>, RecordPipelineOperator

Direct Known Subclasses:

ColumnsToRows, DeriveFields, FilterFields, FilterRows, ParseTextFields, Rank, RunJavaScript, SplitField, SubJobExecutor

public abstract class AbstractExecutableRecordPipeline
extends ExecutableOperator
implements RecordPipelineOperator

A base class for simple record-to-record operators, providing common functions. AbstractExecutableRecordPipeline provides the declaration of an input and an output port as well as getters for obtaining both.

Field Summary

Fields

Modifier and Type	Field	Description
protected final RecordPort	input	The record port for input to the operator
protected final RecordPort	output	The record port for output from the operator

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractExecutableRecordPipeline()	Default constructor

Method Summary

Modifier and Type	Method	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.

Methods inherited from class com.pervasive.datarush.operators.ExecutableOperator

cloneForExecution, execute, getNumInputCopies, getPortSettings, handleInactiveOutput

Methods inherited from class com.pervasive.datarush.operators.StreamingOperator

computeMetadata

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

Methods inherited from interface com.pervasive.datarush.operators.LogicalOperator

disableParallelism, getInputPorts, getOutputPorts

Field Details

input

protected final RecordPort input

The record port for input to the operator

output

protected final RecordPort output

The record port for output from the operator

Constructor Details

AbstractExecutableRecordPipeline

protected AbstractExecutableRecordPipeline()

Default constructor

Method Details

getInput

public RecordPort getInput()

Gets the record port providing the input data to the operation.

Specified by:

getInput in interface PipelineOperator<RecordPort>

Returns:

the input port for the operation

getOutput

public RecordPort getOutput()

Gets the record port providing the output from the operation.

Specified by:

getOutput in interface PipelineOperator<RecordPort>

Returns:

the output port for the operation