Package | Description |
---|---|
org.apache.flink.runtime.rpc.akka |
Modifier and Type | Method and Description |
---|---|
AkkaRpcService |
AkkaRpcServiceUtils.AkkaRpcServiceBuilder.createAndStart() |
AkkaRpcService |
AkkaRpcServiceUtils.AkkaRpcServiceBuilder.createAndStart(java.util.function.BiFunction<akka.actor.ActorSystem,AkkaRpcServiceConfiguration,AkkaRpcService> constructor) |
static AkkaRpcService |
AkkaRpcServiceUtils.createRemoteRpcService(Configuration configuration,
String externalAddress,
String externalPortRange,
String bindAddress,
Optional<Integer> bindPort) |
Modifier and Type | Method and Description |
---|---|
AkkaRpcService |
AkkaRpcServiceUtils.AkkaRpcServiceBuilder.createAndStart(java.util.function.BiFunction<akka.actor.ActorSystem,AkkaRpcServiceConfiguration,AkkaRpcService> constructor) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.