RecordSinkOperator (Dataflow Library Distribution Project 8.0.0-98 API)

All Superinterfaces:

LogicalOperator, SinkOperator<RecordPort>

All Known Implementing Classes:

AbstractTextWriter, AbstractWriter, AssertRowCount, BinaryWriter, CollectRecords, ErrorSink, ExternalRecordSink, FPGrowth, LoadVectorOnHadoop, LogRows, OpenRecordSink, ProcessByGroup, SummaryStatistics, WriteARFF, WriteAvro, WriteDelimitedText, WriteFixedText, WriteORC, WriteSink, WriteStagingDataset
```
public interface RecordSinkOperator
extends SinkOperator<RecordPort>
```
Refinement of SinkOperator, specific to RecortPort's. Implemented by classes that consume but do not produce record data.

See Also:

SinkOperator

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  RecordPort getInput()
  Gets the record port providing the input data to the sink.
  - Methods inherited from interface com.pervasive.datarush.operators.LogicalOperator
    disableParallelism, getInputPorts, getOutputPorts

- Method Detail
  - getInput
```
RecordPort getInput()
```
    Gets the record port providing the input data to the sink.
    
    Specified by:
    
    getInput in interface SinkOperator<RecordPort>
    
    Returns:
    
    the input port for the sink