Package | Description |
---|---|
com.pervasive.datarush.analytics.pmml |
Provides shared and base classes for PMML model representation of Analytics algorithms.
|
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
PMMLPort.setPMMLModelSpec(MetadataCalculationContext ctx,
PMMLModelSpec spec)
Setter to be used to set the PMMLModelSpec for PMML ports.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IterativeMetadataContext
Context used by
IterativeOperator.computeMetadata(IterativeMetadataContext) . |
interface |
StreamingMetadataContext
Context used when computing metadata via
StreamingOperator.computeMetadata(StreamingMetadataContext) . |
Modifier and Type | Method and Description |
---|---|
abstract Integer |
ParallelismStrategy.maxParallelism(Integer configuredParallelism,
MetadataCalculationContext ctx)
Public only as a matter of implementation; operators should not call this method.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractModelPort.setMergeHandler(MetadataCalculationContext ctx,
ModelMergeHandler<T> mergeHandler)
Sets the merge handler for the input port
|
Modifier and Type | Method and Description |
---|---|
static KeyDrivenDataDistribution |
MetadataUtil.negotiateGrouping(MetadataCalculationContext ctx,
RecordPort port,
SortKey... keys)
Negotiates the required data distribution on the specified port
using the given grouping fields with sort ordering.
|
static KeyDrivenDataDistribution |
MetadataUtil.negotiateGrouping(MetadataCalculationContext ctx,
RecordPort port,
String... keys)
Negotiates the required data ordering and distribution on the specified port
using the given grouping fields.
|
static DataOrdering |
MetadataUtil.negotiateOrdering(MetadataCalculationContext ctx,
RecordPort port,
String... keys)
Negotiates the required data ordering on the specified port using
the given key fields.
|
void |
RecordPort.setOutputDataDistribution(MetadataCalculationContext ctx,
DataDistribution distribution)
Sets the data partitioning associated with the given record port.
|
void |
RecordPort.setOutputDataOrdering(MetadataCalculationContext ctx,
DataOrdering ordering)
Sets the data ordering associated with this output port.
|
void |
RecordPort.setRequiredDataDistribution(MetadataCalculationContext ctx,
DataDistribution distribution)
Sets the required data distribution of this input port.
|
void |
RecordPort.setRequiredDataOrdering(MetadataCalculationContext ctx,
DataOrdering ordering)
Sets the required data ordering of the given input.
|
void |
RecordPort.setType(MetadataCalculationContext ctx,
RecordTokenType type)
Sets the type associated with this port.
|
Copyright © 2021 Actian Corporation. All rights reserved.