Module datarush.library

Package com.pervasive.datarush.operators

Interface RecordSinkOperator

All Superinterfaces:

LogicalOperator, SinkOperator<RecordPort>

All Known Implementing Classes:

AbstractTextWriter, AbstractWriter, AssertRowCount, BinaryWriter, CollectRecords, ErrorSink, ExternalRecordSink, FPGrowth, LogRows, OpenRecordSink, ProcessByGroup, SummaryStatistics, SVMLearner, 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

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 Details

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