Module datarush.library
Package com.pervasive.datarush.operators
Interface SinkOperator<T extends LogicalPort>
-
- Type Parameters:
T
- the type of input port.
- All Superinterfaces:
LogicalOperator
- All Known Subinterfaces:
RecordSinkOperator
- All Known Implementing Classes:
AbstractTextWriter
,AbstractWriter
,AssertRowCount
,BinaryWriter
,CollectRecords
,ErrorSink
,ExternalRecordSink
,FPGrowth
,GetModel
,GetPMML
,LoadVectorOnHadoop
,LogRows
,OpenModelSink
,OpenRecordSink
,ProcessByGroup
,SummaryStatistics
,WriteARFF
,WriteAvro
,WriteDelimitedText
,WriteFixedText
,WriteORC
,WriteSink
,WriteStagingDataset
public interface SinkOperator<T extends LogicalPort> extends LogicalOperator
Mix-in interface to be implemented by some operators. By convention, operators that define a single input and zero outputs should this interface since it make facilitate higher-level composition frameworks. Note that the core DR engine does not currently have any special handling for operators that implement this interface.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description T
getInput()
Returns the input port-
Methods inherited from interface com.pervasive.datarush.operators.LogicalOperator
disableParallelism, getInputPorts, getOutputPorts
-
-
-
-
Method Detail
-
getInput
T getInput()
Returns the input port- Returns:
- the input port
-
-