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.graph
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	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	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	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	Description
class	CountRanges	Determines which range each value in a field falls within and counts the totals.
final class	DistinctValues	Calculates distinct values of the given input field.
class	EqualRangeBinning	The EqualRangeBinning operator can be used to divide a set of numeric data into equal range bins.
class	MostFrequentValues	Compute the most frequent values within the given fields.
final 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	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	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	Description
final class	AssertSorted	Verifies that the input data is sorted by the given set of keys.

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

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

Modifier and Type	Class	Description
class	MockableExternalRecordSink	A mockable sink that can be utilized with the SubJobExecutor to pass data back to the launcher.
class	MockableExternalRecordSource	A mockable source that can be utilized with the SubJobExecutor to insert parameter data.
class	SubJobExecutor	The SubJobExecutor operator can be used to execute JSON serialized subgraphs within the current workflow.

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

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

Modifier and Type	Class	Description
final 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	Description
final 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.
final 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	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	Description
final class	GatherHint	Forces parallel streams of data to be gathered into a single non-parallel stream.
final 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	Description
class	ColumnsToRows	Normalize records by transposing values from row columns into multiple rows.
final 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	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	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	Description
final 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	Description
class	SplitField	Splits a string field into multiple fields, based on a specified pattern.