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 typeRecordPort
so that subclasses don't need to.
-
-
Field Summary
Fields Modifier and Type Field Description protected RecordPort
input
The input portprotected RecordPort
output
The output port
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractRecordCompositeOperator()
Default constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RecordPort
getInput()
Returns the input portRecordPort
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
-
-
Method Detail
-
getInput
public RecordPort getInput()
Description copied from interface:PipelineOperator
Returns the input port- Specified by:
getInput
in interfacePipelineOperator<RecordPort>
- Returns:
- the input port
-
getOutput
public RecordPort getOutput()
Description copied from interface:PipelineOperator
Returns the output port- Specified by:
getOutput
in interfacePipelineOperator<RecordPort>
- Returns:
- the output port
-
-