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.