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, LogRows, OpenModelSink, OpenRecordSink, ProcessByGroup, SummaryStatistics, SVMLearner, 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

Modifier and Type	Method	Description
T	getInput()	Returns the input port

Methods inherited from interface com.pervasive.datarush.operators.LogicalOperator

disableParallelism, getInputPorts, getOutputPorts

Method Details

getInput

T getInput()

Returns the input port

Returns:

the input port