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.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.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 | Method and Description |
---|---|
protected void |
ConvertARMModel.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
DecisionTreePruner.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
NaiveBayesPredictor.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
WritePMML.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
SumOfSquares.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
Rank.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
SVMLearner.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
SVMPredictor.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
TextTokenizer.computeMetadata(StreamingMetadataContext ctx) |
protected void |
TextStemmer.computeMetadata(StreamingMetadataContext ctx) |
protected void |
TextFrequencyFilter.computeMetadata(StreamingMetadataContext ctx) |
protected void |
GenerateBagOfWords.computeMetadata(StreamingMetadataContext ctx) |
protected void |
FilterText.computeMetadata(StreamingMetadataContext ctx) |
protected void |
ExpandTextTokens.computeMetadata(StreamingMetadataContext ctx) |
protected void |
ExpandTextFrequency.computeMetadata(StreamingMetadataContext ctx) |
protected void |
DictionaryFilter.computeMetadata(StreamingMetadataContext ctx) |
protected void |
CountTokens.computeMetadata(StreamingMetadataContext ctx) |
protected void |
ConvertTextCase.computeMetadata(StreamingMetadataContext ctx) |
protected void |
CalculateWordFrequency.computeMetadata(StreamingMetadataContext ctx) |
protected void |
CalculateNGramFrequency.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractPredictor.computeMetadata(StreamingMetadataContext ctx)
Default implementation of computeMetadata.
|
Modifier and Type | Method and Description |
---|---|
protected void |
GroupPairsSortedRows.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
StreamingOperator.computeMetadata(StreamingMetadataContext ctx)
Implementations must adhere to the following contracts
|
void |
OperatorProxies.StreamingOperatorProxy.computeMetadata(StreamingMetadataContext ctx)
Public only as a matter of implementation; not intended for external use
|
protected abstract void |
DeferredCompositeOperator.computeMetadata(StreamingMetadataContext ctx)
Implementations must adhere to all of the contracts specified
by
StreamingOperator.computeMetadata(com.pervasive.datarush.operators.StreamingMetadataContext) . |
protected void |
DeferredCompositeOperator.computeOutputTypes(StreamingMetadataContext ctx)
Convenience method that implementations of
computeMetadata
may use in order to compute the output types. |
Modifier and Type | Method and Description |
---|---|
protected void |
AssertSorted.computeMetadata(StreamingMetadataContext ctx) |
protected void |
AssertPredicate.computeMetadata(StreamingMetadataContext ctx) |
protected void |
AssertMetadata.computeMetadata(StreamingMetadataContext ctx) |
protected void |
AssertEqual.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
WriteSink.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
InitializeSQLWorker.computeMetadata(StreamingMetadataContext ctx) |
protected void |
FinalizeSQLWorker.computeMetadata(StreamingMetadataContext ctx) |
protected void |
AbstractWriteToJDBC.AbstractWriteToJDBCWorker.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
InitializeWorkerBase.computeMetadata(StreamingMetadataContext ctx) |
protected void |
CompletionWorkerBase.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
ForceStaging.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
ParseTextFields.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
UnionAll.computeMetadata(StreamingMetadataContext ctx)
This operator can execute in parallel.
|
protected void |
FilterExistJoinProcess.computeMetadata(StreamingMetadataContext ctx) |
protected void |
CrossJoin.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
PutModel.computeMetadata(StreamingMetadataContext ctx) |
protected void |
MergeModel.computeMetadata(StreamingMetadataContext ctx) |
protected void |
GetModel.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
PartitionHint.computeMetadata(StreamingMetadataContext ctx) |
protected void |
GatherHint.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
RemapFields.computeMetadata(StreamingMetadataContext ctx) |
protected void |
MergeFields.computeMetadata(StreamingMetadataContext ctx) |
protected void |
FilterFields.computeMetadata(StreamingMetadataContext ctx) |
protected void |
DeriveFields.computeMetadata(StreamingMetadataContext ctx) |
protected void |
ColumnsToRows.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
RunScript.computeMetadata(StreamingMetadataContext ctx) |
protected void |
RunJavaScript.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
FilterRows.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
LogRows.computeMetadata(StreamingMetadataContext ctx) |
protected void |
CollectRecords.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
Sort.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
GenerateRepeatingCycle.computeMetadata(StreamingMetadataContext ctx) |
protected void |
GenerateRandom.computeMetadata(StreamingMetadataContext ctx) |
protected void |
GenerateConstant.computeMetadata(StreamingMetadataContext ctx) |
protected void |
GenerateArithmeticSequence.computeMetadata(StreamingMetadataContext ctx) |
protected void |
EmitRecords.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
SplitField.computeMetadata(StreamingMetadataContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
ExternalRecordSource.computeMetadata(StreamingMetadataContext ctx) |
protected void |
ExternalRecordSink.computeMetadata(StreamingMetadataContext ctx) |
Copyright © 2016 Actian Corporation. All rights reserved.