com.pervasive.datarush.operators

Interface RecordSinkOperator

All Superinterfaces:

LogicalOperator, SinkOperator<RecordPort>

All Known Implementing Classes:

AbstractTextWriter, AbstractWriter, AssertRowCount, BinaryWriter, CollectRecords, ExternalRecordSink, FPGrowth, LoadMatrix, LoadVectorOnHadoop, LogRows, MatrixOperatorBase, MatrixSink, OpenRecordSink, 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 and 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