- 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, CountTokens, DeleteFromJDBC, DeriveFields, DictionaryFilter, DistinctValues, ExpandTextFrequency, ExpandTextTokens, FilterFields, FilterRows, FilterText, FrequentItems, GatherHint, GenerateBagOfWords, Group, LimitRows, NormalizeValues, ParseTextFields, PartitionHint, Randomize, Rank, ReadFromJDBC, RemapFields, RemoveDuplicates, RemoveFields, ReplaceMissingValues, RetainFields, RowsToColumns, RunJavaScript, RunRScript, RunScript, SampleRandomRows, SelectFields, Sort, SortedGroupHandler, SplitField, 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.