Uses of Class
com.pervasive.datarush.operators.StreamingOperator

Packages that use StreamingOperator

Package	Description
com.pervasive.datarush.analytics.arm	Provides common classes for Association Rule Mining (ARM).
com.pervasive.datarush.analytics.cluster	Provides base PMML for clustering models.
com.pervasive.datarush.analytics.decisiontree.predictor	Provides the decision tree predictor operator and associated classes.
com.pervasive.datarush.analytics.decisiontree.pruner	Provides the decision tree pruner operator and associated classes.
com.pervasive.datarush.analytics.naivebayes.predictor	Provides an implementation of a Naive Bayes predictor.
com.pervasive.datarush.analytics.pmml	Provides shared and base classes for PMML model representation of Analytics algorithms.
com.pervasive.datarush.analytics.regression	Provides utility, PMML and other classes for shared use by regression related entities.
com.pervasive.datarush.analytics.stats	Provides various statistics, Data Summarizer, and Data Quality Analyzer.
com.pervasive.datarush.analytics.svm.learner	Provides an implementation of an SVM learner.
com.pervasive.datarush.analytics.svm.predictor	Provides an implementation of an SVM predictor.
com.pervasive.datarush.analytics.text	Provides various unstructured text processing operators.
com.pervasive.datarush.analytics.util	Provides some (internal) utility classes for Analytics.
com.pervasive.datarush.matching.block	Provides operators for generating possible candidate pairs.
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	Provides base file I/O components including encoders and decoders.
com.pervasive.datarush.operators.io.jdbc	Provides operators for reading from JDBC sources and writing to JDBC targets.
com.pervasive.datarush.operators.io.paraccel
com.pervasive.datarush.operators.io.staging	Provides operators for reading and writing DataRush staging datasets.
com.pervasive.datarush.operators.io.textfile	Provides operators for reading and writing text data.
com.pervasive.datarush.operators.join	Provides operators for joining together two data sets into a single one.
com.pervasive.datarush.operators.model	Provides operators for handling models.
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.sink	Provides the LogRows operator for writing debugging information about a flow to the logging API.
com.pervasive.datarush.operators.sort	Provides operators for sorting and manipulating sorted flows.
com.pervasive.datarush.operators.source	Provides operators for generating data tokens in various ways.
com.pervasive.datarush.operators.string	Provides operators for operating on string values in records.
com.pervasive.datarush.ports.record	Provides implementations of port objects related to the flow of record sets between operators.

Uses of StreamingOperator in com.pervasive.datarush.analytics.arm

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.arm

Modifier and Type	Class and Description
class	ConvertARMModel An operator that converts an association model in PMML into a target format.

Uses of StreamingOperator in com.pervasive.datarush.analytics.cluster

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.cluster

Modifier and Type	Class and Description
class	ClusterPredictor Assigns input data to clusters based on the provided PMML Clustering Model.

Uses of StreamingOperator in com.pervasive.datarush.analytics.decisiontree.predictor

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.decisiontree.predictor

Modifier and Type	Class and Description
class	DecisionTreePredictor Operator responsible for predicting outcomes based on a Decision Tree PMML model.

Uses of StreamingOperator in com.pervasive.datarush.analytics.decisiontree.pruner

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.decisiontree.pruner

Modifier and Type	Class and Description
class	DecisionTreePruner Performs pruning of the provided input model.

Uses of StreamingOperator in com.pervasive.datarush.analytics.naivebayes.predictor

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.naivebayes.predictor

Modifier and Type	Class and Description
class	NaiveBayesPredictor Operator responsible for predicting outcomes based on a Naive Bayes PMML model.

Uses of StreamingOperator in com.pervasive.datarush.analytics.pmml

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.pmml

Modifier and Type	Class and Description
class	GetPMML Specialization of GetModel for PMMLPort's.
class	PutPMML Specialization of PutModel for PMMLPort's.
class	WritePMML Write a PMML object representation to a file at the given path.

Uses of StreamingOperator in com.pervasive.datarush.analytics.regression

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.regression

Modifier and Type	Class and Description
class	LogisticRegressionPredictor
class	RegressionPredictor Apply a regression model to the input data.
class	SumOfSquares Compute the sum of squares for the given fields of the input data.

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

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.stats

Modifier and Type	Class and Description
class	Rank Rank data using the given rank mode.

Uses of StreamingOperator in com.pervasive.datarush.analytics.svm.learner

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.svm.learner

Modifier and Type	Class and Description
class	SVMLearner Builds a PMMLSupportVectorMachineModel from an input dataset.

Uses of StreamingOperator in com.pervasive.datarush.analytics.svm.predictor

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.svm.predictor

Modifier and Type	Class and Description
class	SVMPredictor Operator responsible for classification based on a SVM PMML model.

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

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.text

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 StreamingOperator in com.pervasive.datarush.analytics.util

Subclasses of StreamingOperator in com.pervasive.datarush.analytics.util

Modifier and Type	Class and Description
class	AbstractPredictor Common base class for "predictor" processes.

Uses of StreamingOperator in com.pervasive.datarush.matching.block

Subclasses of StreamingOperator in com.pervasive.datarush.matching.block

Modifier and Type	Class and Description
class	GroupPairsSortedRows Finds key groupings within the input key fields and, for each key group, generates all pairwise combinations of distinct rows in that group.
class	LargeGroupDetector An operator that issues warnings if a dataflow contains an unusually large number of distinct key values.

Uses of StreamingOperator in com.pervasive.datarush.operators

Subclasses of StreamingOperator in com.pervasive.datarush.operators

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	DeferredCompositeOperator For rare use cases; implementors should use CompositeOperator whenever possible! Similar to CompositeOperator in that this is composed of sub-operators.
class	ExecutableOperator ExecutableOperators are the most commonly used operators.

Methods in com.pervasive.datarush.operators that return StreamingOperator

Modifier and Type	Method and Description
StreamingOperator	OperatorProxies.StreamingOperatorProxy.getTarget()

Methods in com.pervasive.datarush.operators with parameters of type StreamingOperator

Modifier and Type	Method and Description
static OperatorProxies.StreamingOperatorProxy	OperatorProxies.proxy(StreamingOperator op) Public only as a matter of implementation; not intended for external use Creates a proxy to the given operator that allows the framework to access its protected methods.

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

Subclasses of StreamingOperator in com.pervasive.datarush.operators.assertion

Modifier and Type	Class and Description
class	AssertEqual Verifies that actual rows are equal to expected rows.
class	AssertMetadata Assert that the metadata on the input port is set correctly.
class	AssertPredicate Assert that the given predicate is true for all input values.
class	AssertSorted Verifies that the input data is sorted by the given set of keys.

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

Subclasses of StreamingOperator in com.pervasive.datarush.operators.group

Modifier and Type	Class and Description
class	SortedGroupHandler Common base class for all processes that need to detect group boundaries

Uses of StreamingOperator in com.pervasive.datarush.operators.io

Subclasses of StreamingOperator in com.pervasive.datarush.operators.io

Modifier and Type	Class and Description
class	WriteSink Writes a stream of records to a data sink.

Uses of StreamingOperator in com.pervasive.datarush.operators.io.jdbc

Subclasses of StreamingOperator in com.pervasive.datarush.operators.io.jdbc

Modifier and Type	Class and Description
protected static class	AbstractWriteToJDBC.AbstractWriteToJDBCWorker
class	FinalizeSQLWorker
class	InitializeSQLWorker

Uses of StreamingOperator in com.pervasive.datarush.operators.io.paraccel

Subclasses of StreamingOperator in com.pervasive.datarush.operators.io.paraccel

Modifier and Type	Class and Description
class	CompletionWorkerBase
class	InitializeWorkerBase<ExecState>
class	LoadMatrixDataWorker
class	MatrixSinkCompletionWorker
class	MatrixSinkDataWorker
class	MatrixSinkInitializeWorker

Uses of StreamingOperator in com.pervasive.datarush.operators.io.staging

Subclasses of StreamingOperator in com.pervasive.datarush.operators.io.staging

Modifier and Type	Class and Description
class	ForceRecordStaging Forces staging of record ports.
class	ForceStaging<P extends LogicalPort> Forces the operators on the input and output sides to execute sequentially, instead of concurrently.

Uses of StreamingOperator in com.pervasive.datarush.operators.io.textfile

Subclasses of StreamingOperator in com.pervasive.datarush.operators.io.textfile

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

Uses of StreamingOperator in com.pervasive.datarush.operators.join

Subclasses of StreamingOperator in com.pervasive.datarush.operators.join

Modifier and Type	Class and Description
class	CrossJoin Produce the cartesian product of two sets of records.
class	FilterExistJoinProcess
class	UnionAll Provides a union of two data sources.

Uses of StreamingOperator in com.pervasive.datarush.operators.model

Subclasses of StreamingOperator in com.pervasive.datarush.operators.model

Modifier and Type	Class and Description
class	GetModel<T> Provides a way to update an in-memory reference to a model object.
class	MergeModel<T> This operator is uses to force a merge of a partitioned model into a single model.
class	PutModel<T> Provides a way to inject an in-memory reference to a model object into a graph.

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

Subclasses of StreamingOperator in com.pervasive.datarush.operators.partition

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.

Uses of StreamingOperator in com.pervasive.datarush.operators.record

Subclasses of StreamingOperator in com.pervasive.datarush.operators.record

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	MergeFields Merges two streams of data with an equivalent number of rows into one.
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	SelectFields Preserves a subset of fields from the input records.

Uses of StreamingOperator in com.pervasive.datarush.operators.scripting

Subclasses of StreamingOperator in com.pervasive.datarush.operators.scripting

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 StreamingOperator in com.pervasive.datarush.operators.select

Subclasses of StreamingOperator in com.pervasive.datarush.operators.select

Modifier and Type	Class and Description
class	FilterRows Filters records based on a specified predicate.

Uses of StreamingOperator in com.pervasive.datarush.operators.sink

Subclasses of StreamingOperator in com.pervasive.datarush.operators.sink

Modifier and Type	Class and Description
class	CollectRecords Collects input data into an in-memory token list.
class	LogRows Log information about the input data from a flow.

Uses of StreamingOperator in com.pervasive.datarush.operators.sort

Subclasses of StreamingOperator in com.pervasive.datarush.operators.sort

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

Uses of StreamingOperator in com.pervasive.datarush.operators.source

Subclasses of StreamingOperator in com.pervasive.datarush.operators.source

Modifier and Type	Class and Description
class	EmitRecords Emits an in-memory token list as output.
class	GenerateArithmeticSequence Generates a sequence of numerical values, with a constant difference between consecutive values.
class	GenerateConstant Generates copies of a constant value.
class	GenerateRandom Generates rows of random data.
class	GenerateRepeatingCycle Generates a cycle of repeating values.

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

Subclasses of StreamingOperator in com.pervasive.datarush.operators.string

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

Uses of StreamingOperator in com.pervasive.datarush.ports.record

Subclasses of StreamingOperator in com.pervasive.datarush.ports.record

Modifier and Type	Class and Description
class	ExternalRecordSink Defines an external sink of record data.
class	ExternalRecordSource Defines an external source of record data.