com.pervasive.datarush.operators

Class AbstractDeferredRecordOperator

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.StreamingOperator

com.pervasive.datarush.operators.DeferredCompositeOperator

com.pervasive.datarush.operators.AbstractDeferredRecordOperator

All Implemented Interfaces:

LogicalOperator, PipelineOperator<RecordPort>, RecordPipelineOperator

Direct Known Subclasses:

GatherHint, PartitionHint, Sort

public abstract class AbstractDeferredRecordOperator
extends DeferredCompositeOperator
implements RecordPipelineOperator

Convenient base class for DeferredCompositeOperator's that are also RecordPipelineOperator's. Declares an input port and an output port of type RecordPort so that subclasses don't need to.

Field Summary

Fields

Modifier and Type	Field and Description
protected RecordPort	input The input port
protected RecordPort	output The output port

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDeferredRecordOperator() Default constructor

Method Summary

Modifier and Type	Method and Description
RecordPort	getInput() Returns the input port
RecordPort	getOutput() Returns the output port

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

compose, computeMetadata, computeOutputTypes

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 Detail

input

protected final RecordPort input

The input port

output

protected final RecordPort output

The output port

Constructor Detail

AbstractDeferredRecordOperator

protected AbstractDeferredRecordOperator()

Default constructor

Method Detail

getInput

public RecordPort getInput()

Description copied from interface: PipelineOperator

Returns the input port

Specified by:

getInput in interface PipelineOperator<RecordPort>

Returns:

the input port

getOutput

public RecordPort getOutput()

Description copied from interface: PipelineOperator

Returns the output port

Specified by:

getOutput in interface PipelineOperator<RecordPort>

Returns:

the output port