Package | Description |
---|---|
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.rpc.akka |
Modifier and Type | Class and Description |
---|---|
static class |
BootstrapTools.FixedThreadPoolExecutorConfiguration
Configuration for a fixed thread pool executor.
|
static class |
BootstrapTools.ForkJoinExecutorConfiguration
Configuration for a fork join executor.
|
Modifier and Type | Method and Description |
---|---|
static akka.actor.ActorSystem |
BootstrapTools.startLocalActorSystem(Configuration configuration,
String actorSystemName,
org.slf4j.Logger logger,
BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration,
com.typesafe.config.Config customConfig)
Starts a local Actor System.
|
static akka.actor.ActorSystem |
BootstrapTools.startRemoteActorSystem(Configuration configuration,
String actorSystemName,
String externalAddress,
String externalPortRange,
String bindAddress,
Optional<Integer> bindPort,
org.slf4j.Logger logger,
BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration,
com.typesafe.config.Config customConfig)
Starts a remote ActorSystem at given address and specific port range.
|
Modifier and Type | Method and Description |
---|---|
AkkaRpcServiceUtils.AkkaRpcServiceBuilder |
AkkaRpcServiceUtils.AkkaRpcServiceBuilder.withActorSystemExecutorConfiguration(BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.