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

Packages that use ExecutionContext

Package	Description
com.pervasive.datarush.analytics.arm	Provides common classes for Association Rule Mining (ARM).
com.pervasive.datarush.analytics.decisiontree.pruner	Provides the decision tree pruner operator and associated classes.
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.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.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.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.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.model	Provides implementations of port objects dealing with the flow of single objects between operators.
com.pervasive.datarush.ports.record	Provides implementations of port objects related to the flow of record sets between operators.

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

Methods in com.pervasive.datarush.analytics.arm with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	ConvertARMModel.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.analytics.decisiontree.pruner with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	DecisionTreePruner.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.analytics.pmml with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	WritePMML.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.analytics.regression with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	SumOfSquares.execute(ExecutionContext ctx) Compute the inner product for each distributed dataflow.

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

Methods in com.pervasive.datarush.analytics.stats with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	Rank.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.analytics.svm.learner with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	SVMLearner.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.analytics.text with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	TextTokenizer.execute(ExecutionContext ctx)
protected void	TextStemmer.execute(ExecutionContext ctx)
protected void	TextFrequencyFilter.execute(ExecutionContext ctx)
protected void	GenerateBagOfWords.execute(ExecutionContext ctx)
protected void	FilterText.execute(ExecutionContext ctx)
protected void	ExpandTextTokens.execute(ExecutionContext ctx)
protected void	ExpandTextFrequency.execute(ExecutionContext ctx)
protected void	DictionaryFilter.execute(ExecutionContext ctx)
protected void	CountTokens.execute(ExecutionContext ctx)
protected void	ConvertTextCase.execute(ExecutionContext ctx)
protected void	CalculateWordFrequency.execute(ExecutionContext ctx)
protected void	CalculateNGramFrequency.execute(ExecutionContext ctx)

Uses of ExecutionContext in com.pervasive.datarush.analytics.util

Methods in com.pervasive.datarush.analytics.util with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	AbstractPredictor.execute(ExecutionContext ctx) Invokes AbstractPredictor.execute(PMMLModel, RecordValued, ScalarSettable[]) and performs an output.pushEndOfData()

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

Methods in com.pervasive.datarush.matching.block with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	LargeGroupDetector.execute(ExecutionContext ctx)
protected void	GroupPairsSortedRows.execute(ExecutionContext ctx)

Uses of ExecutionContext in com.pervasive.datarush.operators

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

Modifier and Type	Method and Description
void	OperatorProxies.ExecutableOperatorProxy.execute(ExecutionContext ctx) Public only as a matter of implementation; not intended for external use
protected abstract void	ExecutableOperator.execute(ExecutionContext ctx) Executes the operator.

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

Methods in com.pervasive.datarush.operators.assertion with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	AssertSorted.execute(ExecutionContext context)
protected void	AssertPredicate.execute(ExecutionContext context)
protected void	AssertMetadata.execute(ExecutionContext ctx)
protected void	AssertEqual.execute(ExecutionContext context)

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

Methods in com.pervasive.datarush.operators.group with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected RecordInput	SortedGroupHandler.current(ExecutionContext ctx) Returns the current copy of the input port
protected void	SortedGroupHandler.execute(ExecutionContext ctx) Final execute method, subclasses should override the various abstract methods of this class to receive events.
protected RecordInput	SortedGroupHandler.lookahead(ExecutionContext ctx) Returns the lookahead copy of the input port

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

Methods in com.pervasive.datarush.operators.io with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	WriteSink.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.io.jdbc with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected abstract AbstractWriteToJDBC.AbstractWriteHelper	AbstractWriteToJDBC.AbstractWriteToJDBCWorker.createWriteHelper(JDBCConnector connector, RecordPort input, RecordPort output, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties)
void	InitializeSQLWorker.execute(ExecutionContext ctx)
void	FinalizeSQLWorker.execute(ExecutionContext ctx)
void	AbstractWriteToJDBC.AbstractWriteToJDBCWorker.execute(ExecutionContext ctx)

Constructors in com.pervasive.datarush.operators.io.jdbc with parameters of type ExecutionContext

Constructor and Description
AbstractWriteHelper(JDBCConnector connector, RecordPort input, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties properties)

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

Methods in com.pervasive.datarush.operators.io.paraccel with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected Void	MatrixSinkInitializeWorker.createInvoker(ExecutionContext ctx, String invokerId)
protected abstract ExecState	InitializeWorkerBase.createInvoker(ExecutionContext ctx, String invokerId)
protected void	MatrixSinkCompletionWorker.execute(ExecutionContext ctx)
protected void	InitializeWorkerBase.execute(ExecutionContext ctx)
protected void	CompletionWorkerBase.waitForDataWorkers(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.io.textfile with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	ParseTextFields.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.join with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	FilterExistJoinProcess.execute(ExecutionContext ctx)
protected void	CrossJoin.execute(ExecutionContext ctx) The controller handles chunking the LHS data into reasonable chunks that can be loaded into memory.

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

Methods in com.pervasive.datarush.operators.model with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	PutModel.execute(ExecutionContext ctx)
protected void	GetModel.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.record with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	RemapFields.execute(ExecutionContext ctx)
protected void	MergeFields.execute(ExecutionContext ctx)
protected void	FilterFields.execute(ExecutionContext ctx)
protected void	DeriveFields.execute(ExecutionContext ctx)
protected void	ColumnsToRows.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.scripting with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	RunScript.execute(ExecutionContext context)
protected void	RunJavaScript.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.select with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	FilterRows.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.sink with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	LogRows.execute(ExecutionContext ctx)
protected void	CollectRecords.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.source with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	GenerateRepeatingCycle.execute(ExecutionContext ctx)
protected void	GenerateRandom.execute(ExecutionContext ctx)
protected void	GenerateConstant.execute(ExecutionContext ctx)
protected void	GenerateArithmeticSequence.execute(ExecutionContext ctx)
protected void	EmitRecords.execute(ExecutionContext ctx)

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

Methods in com.pervasive.datarush.operators.string with parameters of type ExecutionContext

Modifier and Type	Method and Description
protected void	SplitField.execute(ExecutionContext ctx)

Uses of ExecutionContext in com.pervasive.datarush.ports.model

Methods in com.pervasive.datarush.ports.model with parameters of type ExecutionContext

Modifier and Type	Method and Description
T	AbstractModelPort.getModel(ExecutionContext ctx) Reads the model from this model input port.
void	AbstractModelPort.setModel(ExecutionContext ctx, T model) Outputs the model on this model output port.
void	DoneSignalPort.signalDone(ExecutionContext ctx) Signals downstream operators that we are done
void	DoneSignalPort.waitDone(ExecutionContext ctx) Waits until upstream operator has sent the done signal

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

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

Modifier and Type	Method and Description
protected void	ExternalRecordSource.execute(ExecutionContext ctx)
protected void	ExternalRecordSink.execute(ExecutionContext ctx)
RecordInput	RecordPort.getInput(ExecutionContext ctx) Returns the physical input port associated with this logical input port.
RecordInput	RecordPort.getInput(ExecutionContext ctx, int copyNumber) Returns the physical input port associated with the specified copy number of this logical input port.
RecordOutput	RecordPort.getOutput(ExecutionContext ctx) Returns the physical output port associated with this logical output port.