Module datarush.library

Package com.pervasive.datarush.operators

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, ExpandTextFrequency, ExpandTextTokens, FilterFields, FilterRows, FilterText, FrequentItems, GatherHint, GenerateBagOfWords, Group, LimitRows, MostFrequentValues, 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 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:

PipelineOperator

Method Summary

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

disableParallelism, getInputPorts, getOutputPorts

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

getInput, getOutput