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.graph
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.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.operators.testutils
com.pervasive.datarush.ports.record	Provides implementations of port objects related to the flow of record sets between operators.
com.pervasive.datarush.script.operators.group

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

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

Modifier and Type	Class	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	Description
final 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	Description
final 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	Description
final 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	Description
final 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	Description
final class	GetPMML	Specialization of GetModel for PMMLPort's.
final class	PutPMML	Specialization of PutModel for PMMLPort's.
final 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	Description
class	LogisticRegressionPredictor
class	RegressionPredictor	Apply a regression model to the input data.
final 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	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	Description
final 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	Description
final 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	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	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	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	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!
class	ExecutableOperator	ExecutableOperators are the most commonly used operators.

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

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

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

Modifier and Type	Method	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	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.
final class	AssertSorted	Verifies that the input data is sorted by the given set of keys.

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

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

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

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

Modifier and Type	Class	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	Description
final 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	Description
protected static class	AbstractWriteToJDBC.AbstractWriteToJDBCWorker
class	FinalizeSQLWorker
class	InitializeSQLWorker

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

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

Modifier and Type	Class	Description
final 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	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	Description
final 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	Description
class	GetModel<T>	Provides a way to update an in-memory reference to a model object.
final 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	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.

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

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

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	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	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	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	Description
final class	CollectRecords	Collects input data into an in-memory token list.
final 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	Description
final 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	Description
final class	EmitRecords	Emits an in-memory token list as output.
final class	GenerateArithmeticSequence	Generates a sequence of numerical values, with a constant difference between consecutive values.
final class	GenerateConstant	Generates copies of a constant value.
final class	GenerateRandom	Generates rows of random data.
final 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	Description
class	SplitField	Splits a string field into multiple fields, based on a specified pattern.

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

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

Modifier and Type	Class	Description
final class	ErrorSink	A record source sink throws an error either at composition time or execution time.
final class	ErrorSource	A record source that throws an error either at composition time or execution time.
final class	SimulatePartitions	For tests that wish to simulate a partitioned read.

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

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

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

Methods in com.pervasive.datarush.ports.record with parameters of type StreamingOperator

Modifier and Type	Method	Description
void	RecordMetadataTest.run(StreamingOperator plan)

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

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

Modifier and Type	Class	Description
class	ProcessByGroup	Executes an application graph for each distinct key group of data within the input data set.