Module datarush.library

Package 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:

CountRanges, DistinctValues, EqualRangeBinning, Group, LimitRows, MostFrequentValues, 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	Description
protected final RecordPort	input	The input port
protected final RecordPort	output	The output port

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractRecordCompositeOperator()	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.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 Details

input

protected final RecordPort input

The input port

output

protected final RecordPort output

The output port

Constructor Details

AbstractRecordCompositeOperator

protected AbstractRecordCompositeOperator()

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