Module datarush.library

Package com.pervasive.datarush.operators

Interface RecordSourceOperator

All Superinterfaces:

LogicalOperator, SourceOperator<RecordPort>

All Known Implementing Classes:

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

public interface RecordSourceOperator
extends SourceOperator<RecordPort>

Refinement of SourceOperator, specific to RecortPort's. Implemented by classes that produce but do not consume record data.

See Also:

• SourceOperator

Method Summary

Modifier and Type	Method	Description
RecordPort	getOutput()	Gets the record port providing the output data from the source.

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

disableParallelism, getInputPorts, getOutputPorts

Method Details

getOutput

RecordPort getOutput()

Gets the record port providing the output data from the source.

Specified by:

getOutput in interface SourceOperator<RecordPort>

Returns:

the output port for the source