com.pervasive.datarush.operators

Class AbstractRecordCompositeOperator

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.CompositeOperator

com.pervasive.datarush.operators.AbstractRecordCompositeOperator

All Implemented Interfaces:

LogicalOperator, PipelineOperator<RecordPort>, RecordPipelineOperator

Direct Known Subclasses:

DistinctValues, Group, LimitRows, NormalizeValues, Randomize, SampleRandomRows

public abstract class AbstractRecordCompositeOperator
extends CompositeOperator
implements RecordPipelineOperator

Convenient base class for CompositeOperator'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	AbstractRecordCompositeOperator() 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.CompositeOperator

compose

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

AbstractRecordCompositeOperator

protected AbstractRecordCompositeOperator()

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