Uses of Class
com.pervasive.datarush.operators.ParallelismStrategy
Packages that use ParallelismStrategy
Package
Description
Provides classes and interfaces for developing dataflow operators.
-
Uses of ParallelismStrategy in com.pervasive.datarush.operators
Fields in com.pervasive.datarush.operators declared as ParallelismStrategyModifier and TypeFieldDescriptionstatic final ParallelismStrategyParallelismStrategy.ACCEPT_SOURCEUses the maximum of the input ports' parallelism as this operator's max parallelism.static final ParallelismStrategyParallelismStrategy.CONFIGUREDIndicates that the operator should use whatever parallelism has been explicitly configured viaOperatorSettings.getMaxParallelism(), defaulting toEngineConfig#getParallelism().static final ParallelismStrategyParallelismStrategy.NEGOTIATE_BASED_ON_SOURCEUses the maximum of the input ports' parallelism as this operator's max parallelism.static final ParallelismStrategyParallelismStrategy.NON_PARALLELIZABLEIndicates that the operator is non-parallelizable.Methods in com.pervasive.datarush.operators with parameters of type ParallelismStrategyModifier and TypeMethodDescriptionvoidIterativeMetadataContext.parallelize(ParallelismStrategy strategy) Controls the parallelism of the ports of this operator.voidStreamingMetadataContext.parallelize(ParallelismStrategy strategy) Controls the parallelism of this operator.