Module datarush.library

Package com.pervasive.datarush.operators

Interface PipelineOperator<T extends LogicalPort>

Type Parameters:

T - the type of input/output port.

All Superinterfaces:

LogicalOperator

All Known Subinterfaces:

RecordPipelineOperator

All Known Implementing Classes:

AbstractDeferredRecordOperator, AbstractExecutableRecordPipeline, AbstractRecordCompositeOperator, AssertSorted, CalculateNGramFrequency, CalculateWordFrequency, ColumnsToRows, ConvertTextCase, CountRanges, CountTokens, DeleteFromJDBC, DeriveFields, DictionaryFilter, DistinctValues, EqualRangeBinning, ExpandTextFrequency, ExpandTextTokens, FilterFields, FilterRows, FilterText, FrequentItems, GatherHint, GenerateBagOfWords, Group, LimitRows, MockableExternalRecordSink, MockableExternalRecordSource, MostFrequentValues, NormalizeValues, ParseTextFields, PartitionHint, Randomize, Rank, ReadFromJDBC, RemapFields, RemoveDuplicates, RemoveFields, ReplaceMissingValues, RetainFields, RowsToColumns, RunJavaScript, RunRScript, RunScript, SampleRandomRows, SelectFields, Sort, SortedGroupHandler, SplitField, SubJobExecutor, TextFrequencyFilter, TextStemmer, TextTokenizer, UpdateInJDBC

public interface PipelineOperator<T extends LogicalPort>
extends LogicalOperator

Mix-in interface to be implemented by some operators. By convention, operators that define a single input and single output of the same type should implement 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
T	getOutput()	Returns the output port

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

disableParallelism, getInputPorts, getOutputPorts

Method Detail

getInput

T getInput()

Returns the input port

Returns:

the input port

getOutput

T getOutput()

Returns the output port

Returns:

the output port