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.startActorSystem(Configuration configuration,
String listeningAddress,
int listeningPort,
org.slf4j.Logger logger,
BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration)
Starts an Actor System at a specific port.
|
static akka.actor.ActorSystem |
BootstrapTools.startActorSystem(Configuration configuration,
String actorSystemName,
String listeningAddress,
int listeningPort,
org.slf4j.Logger logger,
BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration)
Starts an Actor System at a specific port.
|
static akka.actor.ActorSystem |
BootstrapTools.startActorSystem(Configuration configuration,
String listeningAddress,
String portRangeDefinition,
org.slf4j.Logger logger,
BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration)
Starts an ActorSystem with the given configuration listening at the address/ports.
|
static akka.actor.ActorSystem |
BootstrapTools.startActorSystem(Configuration configuration,
String actorSystemName,
String listeningAddress,
String portRangeDefinition,
org.slf4j.Logger logger,
BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration)
Starts an ActorSystem with the given configuration listening at the address/ports.
|
Modifier and Type | Method and Description |
---|---|
static RpcService |
AkkaRpcServiceUtils.createRpcService(String hostname,
String portRangeDefinition,
Configuration configuration,
String actorSystemName,
BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration)
Utility method to create RPC service from configuration and hostname, port.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.