Uses of Interface
com.pervasive.datarush.operators.RecordPipelineOperator

Packages that use RecordPipelineOperator

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 the RunScript 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 RecordPipelineOperator in com.pervasive.datarush.analytics.arm

Classes in com.pervasive.datarush.analytics.arm that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	FrequentItems Compute the frequent items within the given transactions.

Uses of RecordPipelineOperator in com.pervasive.datarush.analytics.cleansing

Classes in com.pervasive.datarush.analytics.cleansing that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	ReplaceMissingValues Replace missing values in the input data according to the given replacement specifications.

Uses of RecordPipelineOperator in com.pervasive.datarush.analytics.r

Classes in com.pervasive.datarush.analytics.r that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	RunRScript Execute an R script in flow.

Uses of RecordPipelineOperator in com.pervasive.datarush.analytics.stats

Classes in com.pervasive.datarush.analytics.stats that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	DistinctValues Calculates distinct values of the given input field.
class	NormalizeValues Apply normalization methods to fields within an input data flow.
class	Rank Rank data using the given rank mode.

Uses of RecordPipelineOperator in com.pervasive.datarush.analytics.text

Classes in com.pervasive.datarush.analytics.text that implement RecordPipelineOperator

Modifier and Type	Class and 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 RecordPipelineOperator in com.pervasive.datarush.operators

Classes in com.pervasive.datarush.operators that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	AbstractDeferredRecordOperator Convenient base class for DeferredCompositeOperator's that are also RecordPipelineOperator's.
class	AbstractExecutableRecordPipeline A base class for simple record-to-record operators, providing common functions.
class	AbstractRecordCompositeOperator Convenient base class for CompositeOperator's that are also RecordPipelineOperator's.

Uses of RecordPipelineOperator in com.pervasive.datarush.operators.assertion

Classes in com.pervasive.datarush.operators.assertion that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	AssertSorted Verifies that the input data is sorted by the given set of keys.

Uses of RecordPipelineOperator in com.pervasive.datarush.operators.group

Classes in com.pervasive.datarush.operators.group that implement RecordPipelineOperator

Modifier and Type	Class and 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 RecordPipelineOperator in com.pervasive.datarush.operators.io.jdbc

Classes in com.pervasive.datarush.operators.io.jdbc that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	DeleteFromJDBC This operator deletes data in the target table in a database by applying SQL delete statements.
class	ReadFromJDBC The ReadFromJDBC 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 RecordPipelineOperator in com.pervasive.datarush.operators.io.textfile

Classes in com.pervasive.datarush.operators.io.textfile that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	ParseTextFields Parses input text records according to a specified text schema.

Uses of RecordPipelineOperator in com.pervasive.datarush.operators.partition

Classes in com.pervasive.datarush.operators.partition that implement RecordPipelineOperator

Modifier and Type	Class and 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 RecordPipelineOperator in com.pervasive.datarush.operators.record

Classes in com.pervasive.datarush.operators.record that implement RecordPipelineOperator

Modifier and Type	Class and 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 RecordPipelineOperator in com.pervasive.datarush.operators.scripting

Classes in com.pervasive.datarush.operators.scripting that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	RunJavaScript Processes rows using user-defined scripts written in JavaScript.
class	RunScript Processes rows using user-defined scripts.

Uses of RecordPipelineOperator in com.pervasive.datarush.operators.select

Classes in com.pervasive.datarush.operators.select that implement RecordPipelineOperator

Modifier and Type	Class and 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 RecordPipelineOperator in com.pervasive.datarush.operators.sort

Classes in com.pervasive.datarush.operators.sort that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	Sort Sorts the input data.

Uses of RecordPipelineOperator in com.pervasive.datarush.operators.string

Classes in com.pervasive.datarush.operators.string that implement RecordPipelineOperator

Modifier and Type	Class and Description
class	SplitField Splits a string field into multiple fields, based on a specified pattern.