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 Details

    • getInput

      T getInput()
      Returns the input port
      Returns:
      the input port

    • getOutput

      T getOutput()
      Returns the output port
      Returns:
      the output port