Package | Description |
---|---|
org.apache.flink.runtime.rpc | |
org.apache.flink.runtime.rpc.akka |
Modifier and Type | Field and Description |
---|---|
protected RpcServer |
RpcEndpoint.rpcServer
Interface to access the underlying rpc server.
|
Modifier and Type | Method and Description |
---|---|
<C extends RpcEndpoint & RpcGateway> |
RpcService.startServer(C rpcEndpoint)
Start a rpc server which forwards the remote procedure calls to the provided rpc endpoint.
|
Modifier and Type | Method and Description |
---|---|
<C extends RpcGateway> |
RpcService.getSelfGateway(Class<C> selfGatewayType,
RpcServer rpcServer)
Returns a self gateway of the specified type which can be used to issue asynchronous calls
against the RpcEndpoint.
|
void |
RpcService.stopServer(RpcServer selfGateway)
Stop the underlying rpc server of the provided self gateway.
|
Modifier and Type | Class and Description |
---|---|
class |
FencedAkkaInvocationHandler<F extends Serializable>
Fenced extension of the
AkkaInvocationHandler . |
Modifier and Type | Method and Description |
---|---|
<C extends RpcEndpoint & RpcGateway> |
AkkaRpcService.startServer(C rpcEndpoint) |
Modifier and Type | Method and Description |
---|---|
<C extends RpcGateway> |
AkkaRpcService.getSelfGateway(Class<C> selfGatewayType,
RpcServer rpcServer) |
void |
AkkaRpcService.stopServer(RpcServer selfGateway) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.