Module datarush.library

Package 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	Description
protected final RecordPort	input	The input port
protected final RecordPort	output	The output port

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractDeferredRecordOperator()	Default constructor

Method Summary

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

input

protected final RecordPort input

The input port

output

protected final RecordPort output

The output port

Constructor Details

AbstractDeferredRecordOperator

protected AbstractDeferredRecordOperator()

Default constructor

Method Details

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