Package | Description |
---|---|
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
Modifier and Type | Field and Description |
---|---|
static ParallelismStrategy |
ParallelismStrategy.ACCEPT_SOURCE
Uses the maximum of the input ports' parallelism as this operator's max parallelism.
|
static ParallelismStrategy |
ParallelismStrategy.CONFIGURED
Indicates that the operator should use whatever parallelism has been explicitly configured via
OperatorSettings.getMaxParallelism() , defaulting to EngineConfig#getParallelism() . |
static ParallelismStrategy |
ParallelismStrategy.NEGOTIATE_BASED_ON_SOURCE
Uses the maximum of the input ports' parallelism as this
operator's max parallelism.
|
static ParallelismStrategy |
ParallelismStrategy.NON_PARALLELIZABLE
Indicates that the operator is non-parallelizable.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamingMetadataContext.parallelize(ParallelismStrategy strategy)
Controls the parallelism of this operator.
|
void |
IterativeMetadataContext.parallelize(ParallelismStrategy strategy)
Controls the parallelism of the ports of this operator.
|
Copyright © 2021 Actian Corporation. All rights reserved.