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.
|
Modifier and Type | Class and Description |
---|---|
class |
ConvertARMModel
An operator that converts an association model in PMML into a target format.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterPredictor
Assigns input data to clusters based on the provided PMML Clustering Model.
|
Modifier and Type | Class and Description |
---|---|
class |
DecisionTreePredictor
Operator responsible for predicting outcomes based on a Decision Tree PMML model.
|
Modifier and Type | Class and Description |
---|---|
class |
DecisionTreePruner
Performs pruning of the provided input model.
|
Modifier and Type | Class and Description |
---|---|
class |
NaiveBayesPredictor
Operator responsible for predicting outcomes based on a Naive Bayes PMML model.
|
Modifier and Type | Class and Description |
---|---|
class |
GetPMML
|
class |
PutPMML
|
class |
WritePMML
Write a PMML object representation to a file at the given path.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
Rank
Rank data using the given rank mode.
|
Modifier and Type | Class and Description |
---|---|
class |
SVMLearner
Builds a
PMMLSupportVectorMachineModel from an input dataset. |
Modifier and Type | Class and Description |
---|---|
class |
SVMPredictor
Operator responsible for classification based on a SVM PMML model.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractPredictor
Common base class for "predictor" processes.
|
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
StreamingOperator |
OperatorProxies.StreamingOperatorProxy.getTarget() |
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.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
SortedGroupHandler
Common base class for all processes that need to detect group boundaries
|
Modifier and Type | Class and Description |
---|---|
class |
WriteSink
Writes a stream of records to a data sink.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractWriteToJDBC.AbstractWriteToJDBCWorker |
class |
FinalizeSQLWorker |
class |
InitializeSQLWorker |
Modifier and Type | Class and Description |
---|---|
class |
CompletionWorkerBase |
class |
InitializeWorkerBase<ExecState> |
class |
LoadMatrixDataWorker |
class |
MatrixSinkCompletionWorker |
class |
MatrixSinkDataWorker |
class |
MatrixSinkInitializeWorker |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
ParseTextFields
Parses input text records according to a specified text schema.
|
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.
|
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.
|
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.
|
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.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
FilterRows
Filters records based on a specified predicate.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
Sort
Sorts the input data.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
SplitField
Splits a string field into multiple fields, based on a specified pattern.
|
Modifier and Type | Class and Description |
---|---|
class |
ExternalRecordSink
Defines an external sink of record data.
|
class |
ExternalRecordSource
Defines an external source of record data.
|
Copyright © 2016 Actian Corporation. All rights reserved.