Package org.apache.flink.runtime.rpc

Class RpcSystem.ForkJoinExecutorConfiguration

java.lang.Object

org.apache.flink.runtime.rpc.RpcSystem.ForkJoinExecutorConfiguration

Enclosing interface:

RpcSystem

public static class RpcSystem.ForkJoinExecutorConfiguration
extends Object

Descriptor for creating a fork-join thread-pool.

Constructor Summary

Constructors

Constructor	Description
ForkJoinExecutorConfiguration(double parallelismFactor, int minParallelism, int maxParallelism)

Method Summary

Modifier and Type	Method	Description
int	getMaxParallelism()
int	getMinParallelism()
double	getParallelismFactor()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ForkJoinExecutorConfiguration

public ForkJoinExecutorConfiguration(double parallelismFactor,
                                     int minParallelism,
                                     int maxParallelism)

Method Detail

getParallelismFactor

public double getParallelismFactor()

getMinParallelism

public int getMinParallelism()

getMaxParallelism

public int getMaxParallelism()