Uses of Interface
com.pervasive.datarush.operators.PipelineOperator
-
Packages that use PipelineOperator Package Description com.pervasive.datarush.analytics.arm Provides common classes for Association Rule Mining (ARM).com.pervasive.datarush.analytics.cleansing Provides operators related to data cleansing.com.pervasive.datarush.analytics.r com.pervasive.datarush.analytics.stats Provides various statistics, Data Summarizer, and Data Quality Analyzer.com.pervasive.datarush.analytics.text Provides various unstructured text processing operators.com.pervasive.datarush.operators Provides classes and interfaces for developing dataflow operators.com.pervasive.datarush.operators.assertion Provides operators for making assertions on flows and files.com.pervasive.datarush.operators.group Provides data aggregation components.com.pervasive.datarush.operators.io.jdbc Provides operators for reading from JDBC sources and writing to JDBC targets.com.pervasive.datarush.operators.io.textfile Provides operators for reading and writing text data.com.pervasive.datarush.operators.partition Provides operators for partitioning and unpartitioning flows of data.com.pervasive.datarush.operators.record Provides operators for manipulating record structure.com.pervasive.datarush.operators.scripting Provides theRunScript
operator for running user-defined scripts on the rows of an input record flow.com.pervasive.datarush.operators.select Provides operators for selecting a subset of the data set.com.pervasive.datarush.operators.sort Provides operators for sorting and manipulating sorted flows.com.pervasive.datarush.operators.string Provides operators for operating on string values in records. -
-
Uses of PipelineOperator in com.pervasive.datarush.analytics.arm
Classes in com.pervasive.datarush.analytics.arm that implement PipelineOperator Modifier and Type Class Description class
FrequentItems
Compute the frequent items within the given transactions. -
Uses of PipelineOperator in com.pervasive.datarush.analytics.cleansing
Classes in com.pervasive.datarush.analytics.cleansing that implement PipelineOperator Modifier and Type Class Description class
ReplaceMissingValues
Replace missing values in the input data according to the given replacement specifications. -
Uses of PipelineOperator in com.pervasive.datarush.analytics.r
Classes in com.pervasive.datarush.analytics.r that implement PipelineOperator Modifier and Type Class Description class
RunRScript
Execute an R script in flow. -
Uses of PipelineOperator in com.pervasive.datarush.analytics.stats
Classes in com.pervasive.datarush.analytics.stats that implement PipelineOperator Modifier and Type Class Description class
CountRanges
Determines which range each value in a field falls within and counts the totals.class
DistinctValues
Calculates distinct values of the given input field.class
MostFrequentValues
Compute the most frequent values within the given fields.class
NormalizeValues
Apply normalization methods to fields within an input data flow.class
Rank
Rank data using the given rank mode. -
Uses of PipelineOperator in com.pervasive.datarush.analytics.text
Classes in com.pervasive.datarush.analytics.text that implement PipelineOperator Modifier and Type Class Description class
CalculateNGramFrequency
Calculates the n-gram frequencies for a tokenized text field.class
CalculateWordFrequency
Calculates the word frequencies for a tokenized text field.class
ConvertTextCase
Converts the case on a TokenizedText field.class
CountTokens
Counts the number of tokens in a tokenized text field.class
DictionaryFilter
Filters a tokenized text field using a dictionary.class
ExpandTextFrequency
Expands text frequency field.class
ExpandTextTokens
Expands a TokenizedText field.class
FilterText
Filters a tokenized text field.class
GenerateBagOfWords
Calculates the bag of words for a tokenized text field.class
TextFrequencyFilter
Filters a frequency map field.class
TextStemmer
Stems a TokenizedText field.class
TextTokenizer
Tokenizes a string field as a TokenizedText object. -
Uses of PipelineOperator in com.pervasive.datarush.operators
Subinterfaces of PipelineOperator in com.pervasive.datarush.operators Modifier and Type Interface Description interface
RecordPipelineOperator
Refinement ofPipelineOperator
, specific to RecortPort's.Classes in com.pervasive.datarush.operators that implement PipelineOperator Modifier and Type Class Description class
AbstractDeferredRecordOperator
Convenient base class forDeferredCompositeOperator
's that are alsoRecordPipelineOperator
's.class
AbstractExecutableRecordPipeline
A base class for simple record-to-record operators, providing common functions.class
AbstractRecordCompositeOperator
Convenient base class forCompositeOperator
's that are alsoRecordPipelineOperator
's. -
Uses of PipelineOperator in com.pervasive.datarush.operators.assertion
Classes in com.pervasive.datarush.operators.assertion that implement PipelineOperator Modifier and Type Class Description class
AssertSorted
Verifies that the input data is sorted by the given set of keys. -
Uses of PipelineOperator in com.pervasive.datarush.operators.group
Classes in com.pervasive.datarush.operators.group that implement PipelineOperator Modifier and Type Class Description class
Group
Performs grouping (aggregation) of sorted input data.class
RemoveDuplicates
Removes duplicate rows based on a specified set of group keys.class
SortedGroupHandler
Common base class for all processes that need to detect group boundaries -
Uses of PipelineOperator in com.pervasive.datarush.operators.io.jdbc
Classes in com.pervasive.datarush.operators.io.jdbc that implement PipelineOperator Modifier and Type Class Description class
DeleteFromJDBC
This operator deletes data in the target table in a database by applying SQL delete statements.class
ReadFromJDBC
TheReadFromJDBC
operator is used to access relational database systems using a supplied JDBC driver.class
UpdateInJDBC
This operator updates the target table in a database by applying SQL update statements. -
Uses of PipelineOperator in com.pervasive.datarush.operators.io.textfile
Classes in com.pervasive.datarush.operators.io.textfile that implement PipelineOperator Modifier and Type Class Description class
ParseTextFields
Parses input text records according to a specified text schema. -
Uses of PipelineOperator in com.pervasive.datarush.operators.partition
Classes in com.pervasive.datarush.operators.partition that implement PipelineOperator Modifier and Type Class Description class
GatherHint
Forces parallel streams of data to be gathered into a single non-parallel stream.class
PartitionHint
Forces the input data to be partitioned into parallel streams of data for subsequent parallel operations.class
Randomize
Operator that re-orders its input in a random fashion. -
Uses of PipelineOperator in com.pervasive.datarush.operators.record
Classes in com.pervasive.datarush.operators.record that implement PipelineOperator Modifier and Type Class Description class
ColumnsToRows
Normalize records by transposing values from row columns into multiple rows.class
DeriveFields
Applies one or more functions to the input record data.class
FilterFields
Base class for operators which filter fields in the input records.class
RemapFields
Rearranges and renames fields in a record.class
RemoveFields
Removes a subset of fields from the input records.class
RetainFields
Preserves a subset of fields from the input records.class
RowsToColumns
The RowsToColumns operator is used to pivot data from a narrow representation (rows) into a wider representation (columns).class
SelectFields
Preserves a subset of fields from the input records. -
Uses of PipelineOperator in com.pervasive.datarush.operators.scripting
Classes in com.pervasive.datarush.operators.scripting that implement PipelineOperator Modifier and Type Class Description class
RunJavaScript
Processes rows using user-defined scripts written in JavaScript.class
RunScript
Processes rows using user-defined scripts. -
Uses of PipelineOperator in com.pervasive.datarush.operators.select
Classes in com.pervasive.datarush.operators.select that implement PipelineOperator Modifier and Type Class Description class
FilterRows
Filters records based on a specified predicate.class
LimitRows
Truncates a flow to a fixed number of records.class
SampleRandomRows
Apply random sampling to the input data. -
Uses of PipelineOperator in com.pervasive.datarush.operators.sort
Classes in com.pervasive.datarush.operators.sort that implement PipelineOperator Modifier and Type Class Description class
Sort
Sorts the input data. -
Uses of PipelineOperator in com.pervasive.datarush.operators.string
Classes in com.pervasive.datarush.operators.string that implement PipelineOperator Modifier and Type Class Description class
SplitField
Splits a string field into multiple fields, based on a specified pattern.
-