Module datarush.library

Package com.pervasive.datarush.operators

Interface SourceOperator<T extends LogicalPort>

Type Parameters:

T - the type of output port.

All Superinterfaces:

LogicalOperator

All Known Subinterfaces:

RecordSourceOperator

All Known Implementing Classes:

AbstractReader, AbstractTextReader, EmitRecords, ErrorSource, ExternalRecordSource, GenerateArithmeticSequence, GenerateConstant, GenerateRandom, GenerateRepeatingCycle, MergeFields, OpenModelSource, OpenRecordSource, PutModel, PutPMML, ReadARFF, ReadAvro, ReadDelimitedText, ReadFixedText, ReadJSON, ReadLog, ReadMDF, ReadORC, ReadParquet, ReadSource, ReadStagingDataset, SimulatePartitions, UnionAll

public interface SourceOperator<T extends LogicalPort>
extends LogicalOperator

Mix-in interface to be implemented by some operators. By convention, operators that define a single output and zero inputs 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	getOutput()	Returns the output port

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

disableParallelism, getInputPorts, getOutputPorts

Method Details

getOutput

T getOutput()

Returns the output port

Returns:

the output port