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

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	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	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	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	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	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	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	Description
protected void	CalculateNGramFrequency.execute(ExecutionContext ctx)
protected void	CalculateWordFrequency.execute(ExecutionContext ctx)
protected void	ConvertTextCase.execute(ExecutionContext ctx)
protected void	CountTokens.execute(ExecutionContext ctx)
protected void	DictionaryFilter.execute(ExecutionContext ctx)
protected void	ExpandTextFrequency.execute(ExecutionContext ctx)
protected void	ExpandTextTokens.execute(ExecutionContext ctx)
protected void	FilterText.execute(ExecutionContext ctx)
protected void	GenerateBagOfWords.execute(ExecutionContext ctx)
protected void	TextFrequencyFilter.execute(ExecutionContext ctx)
protected void	TextStemmer.execute(ExecutionContext ctx)
protected void	TextTokenizer.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	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	Description
protected void	GroupPairsSortedRows.execute(ExecutionContext ctx)
protected void	LargeGroupDetector.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	Description
protected abstract void	ExecutableOperator.execute(ExecutionContext ctx)	Executes the operator.
void	OperatorProxies.ExecutableOperatorProxy.execute(ExecutionContext ctx)	Public only as a matter of implementation; not intended for external use

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	Description
protected void	AssertEqual.execute(ExecutionContext context)
protected void	AssertMetadata.execute(ExecutionContext ctx)
protected void	AssertPredicate.execute(ExecutionContext context)
protected void	AssertSorted.execute(ExecutionContext context)

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

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

Modifier and Type	Method	Description
protected void	MockableExternalRecordSink.execute(ExecutionContext ctx)
protected void	MockableExternalRecordSource.execute(ExecutionContext ctx)
protected void	SubJobExecutor.execute(ExecutionContext ctx)

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	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	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	Description
protected abstract AbstractWriteToJDBC.AbstractWriteHelper	AbstractWriteToJDBC.AbstractWriteToJDBCWorker.createWriteHelper(JDBCConnector connector, RecordPort input, RecordPort output, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties)
void	AbstractWriteToJDBC.AbstractWriteToJDBCWorker.execute(ExecutionContext ctx)
void	FinalizeSQLWorker.execute(ExecutionContext ctx)
void	InitializeSQLWorker.execute(ExecutionContext ctx)

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

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

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	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	Description
protected void	CrossJoin.execute(ExecutionContext ctx)	The controller handles chunking the LHS data into reasonable chunks that can be loaded into memory.
protected void	FilterExistJoinProcess.execute(ExecutionContext ctx)

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	Description
protected void	GetModel.execute(ExecutionContext ctx)
protected void	PutModel.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	Description
protected void	ColumnsToRows.execute(ExecutionContext ctx)
protected void	DeriveFields.execute(ExecutionContext ctx)
protected void	FilterFields.execute(ExecutionContext ctx)
protected void	MergeFields.execute(ExecutionContext ctx)
protected void	RemapFields.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	Description
protected void	RunJavaScript.execute(ExecutionContext ctx)
protected void	RunScript.execute(ExecutionContext context)

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	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	Description
protected void	CollectRecords.execute(ExecutionContext ctx)
protected void	LogRows.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	Description
protected void	EmitRecords.execute(ExecutionContext ctx)
protected void	GenerateArithmeticSequence.execute(ExecutionContext ctx)
protected void	GenerateConstant.execute(ExecutionContext ctx)
protected void	GenerateRandom.execute(ExecutionContext ctx)
protected void	GenerateRepeatingCycle.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	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	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	Description
protected void	ExternalRecordSink.execute(ExecutionContext ctx)
protected void	ExternalRecordSource.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.

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

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

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