Interface RecordPipelineOperator

All Superinterfaces:
LogicalOperator, PipelineOperator<RecordPort>
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 RecordPipelineOperator extends PipelineOperator<RecordPort>
Refinement of PipelineOperator, specific to RecortPort's. Generally implemented by classes that transform a single stream of record data.
See Also: