| 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 © 2024 Actian Corporation. All rights reserved.