Package | Description |
---|---|
org.apache.flink.runtime.metrics.util | |
org.apache.flink.runtime.minicluster | |
org.apache.flink.runtime.rpc | |
org.apache.flink.runtime.rpc.akka |
Modifier and Type | Method and Description |
---|---|
static RpcService |
MetricUtils.startLocalMetricsRpcService(Configuration configuration,
RpcSystem rpcSystem) |
static RpcService |
MetricUtils.startRemoteMetricsRpcService(Configuration configuration,
String externalAddress,
String bindAddress,
RpcSystem rpcSystem) |
Modifier and Type | Method and Description |
---|---|
protected RpcService |
MiniCluster.createLocalRpcService(Configuration configuration,
RpcSystem rpcSystem)
Factory method to instantiate the local RPC service.
|
protected RpcService |
MiniCluster.createRemoteRpcService(Configuration configuration,
String bindAddress,
int bindPort,
RpcSystem rpcSystem)
Factory method to instantiate the remote RPC service.
|
protected RpcService |
MiniCluster.createRemoteRpcService(Configuration configuration,
String externalAddress,
String externalPortRange,
String bindAddress,
RpcSystem rpcSystem)
Factory method to instantiate the remote RPC service.
|
Constructor and Description |
---|
MiniCluster(MiniClusterConfiguration miniClusterConfiguration,
java.util.function.Supplier<Reference<RpcSystem>> rpcSystemSupplier) |
Modifier and Type | Method and Description |
---|---|
static RpcSystem |
RpcSystem.load()
Loads the RpcSystem.
|
static RpcSystem |
RpcSystem.load(Configuration config)
Loads the RpcSystem.
|
RpcSystem |
RpcSystemLoader.loadRpcSystem(Configuration config) |
Modifier and Type | Method and Description |
---|---|
static RpcService |
RpcUtils.createRemoteRpcService(RpcSystem rpcSystem,
Configuration configuration,
String externalAddress,
String externalPortRange,
String bindAddress,
Optional<Integer> bindPort)
Convenient shortcut for constructing a remote RPC Service that takes care of checking for
null and empty optionals.
|
Modifier and Type | Class and Description |
---|---|
class |
AkkaRpcSystem
RpcSystem implementation based on Akka. |
Modifier and Type | Method and Description |
---|---|
RpcSystem |
AkkaRpcSystemLoader.loadRpcSystem(Configuration config) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.