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,Group,LimitRows,MostFrequentValues,NormalizeValues,Randomize,SampleRandomRows
public abstract class AbstractRecordCompositeOperator extends CompositeOperator implements RecordPipelineOperator
Convenient base class forCompositeOperator's that are alsoRecordPipelineOperator's. Declares an input port and an output port of typeRecordPortso that subclasses don't need to.
-
-
Field Summary
Fields Modifier and Type Field Description protected RecordPortinputThe input portprotected RecordPortoutputThe output port
-
Constructor Summary
Constructors Modifier Constructor Description protectedAbstractRecordCompositeOperator()Default constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RecordPortgetInput()Returns the input portRecordPortgetOutput()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
-
-
Method Detail
-
getInput
public RecordPort getInput()
Description copied from interface:PipelineOperatorReturns the input port- Specified by:
getInputin interfacePipelineOperator<RecordPort>- Returns:
- the input port
-
getOutput
public RecordPort getOutput()
Description copied from interface:PipelineOperatorReturns the output port- Specified by:
getOutputin interfacePipelineOperator<RecordPort>- Returns:
- the output port
-
-