| Package | Description |
|---|---|
| com.pervasive.datarush.analytics.cluster.kmeans |
Provides the KMeans algorithm.
|
| com.pervasive.datarush.analytics.decisiontree.learner |
Provides the PMML learner operator and associated classes.
|
| com.pervasive.datarush.analytics.regression |
Provides utility, PMML and other classes for shared use by regression related entities.
|
| com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
| 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 |
KMeans.computeMetadata(IterativeMetadataContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DecisionTreeLearner.computeMetadata(IterativeMetadataContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
LinearRegressionLearner.computeMetadata(IterativeMetadataContext context) |
| Modifier and Type | Method and Description |
|---|---|
void |
OperatorProxies.IterativeOperatorProxy.computeMetadata(IterativeMetadataContext ctx)
Public only as a matter of implementation; not intended for external use
|
protected abstract void |
IterativeOperator.computeMetadata(IterativeMetadataContext ctx)
Implementations must adhere to the following contracts
|
| Modifier and Type | Method and Description |
|---|---|
static void |
MetadataUtil.negotiateParallelismBasedOnSourceAssumingParallelizableRecords(IterativeMetadataContext ctx)
Uses the maximum of the input ports' parallelism as the max parallelism of the operator
If there are no parallel inputs, this will use
Integer.MAX_VALUE as its parallelism, forcing
a "scatter" from the inputs. |
void |
RecordPort.setIterationStagingOptions(IterativeMetadataContext ctx,
DatasetOptions options)
Sets the staging options for this input port.
|
Copyright © 2020 Actian Corporation. All rights reserved.