Uses of Interface
org.apache.flink.runtime.rpc.RpcServer

Packages that use RpcServer

Package	Description
org.apache.flink.runtime.rpc
org.apache.flink.runtime.rpc.pekko

Uses of RpcServer in org.apache.flink.runtime.rpc

Fields in org.apache.flink.runtime.rpc declared as RpcServer

Modifier and Type	Field and Description
protected RpcServer	RpcEndpoint.rpcServer Interface to access the underlying rpc server.

Methods in org.apache.flink.runtime.rpc that return RpcServer

Modifier and Type	Method and Description
<C extends RpcEndpoint & RpcGateway> RpcServer	RpcService.startServer(C rpcEndpoint, Map<String,String> loggingContext) Start a rpc server which forwards the remote procedure calls to the provided rpc endpoint.

Methods in org.apache.flink.runtime.rpc with parameters of type RpcServer

Modifier and Type	Method and Description
<C extends RpcGateway> C	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.

Uses of RpcServer in org.apache.flink.runtime.rpc.pekko

Classes in org.apache.flink.runtime.rpc.pekko that implement RpcServer

Modifier and Type	Class and Description
class	FencedPekkoInvocationHandler<F extends Serializable> Fenced extension of the PekkoInvocationHandler.

Methods in org.apache.flink.runtime.rpc.pekko that return RpcServer

Modifier and Type	Method and Description
<C extends RpcEndpoint & RpcGateway> RpcServer	PekkoRpcService.startServer(C rpcEndpoint, Map<String,String> loggingContext)

Methods in org.apache.flink.runtime.rpc.pekko with parameters of type RpcServer

Modifier and Type	Method and Description
<C extends RpcGateway> C	PekkoRpcService.getSelfGateway(Class<C> selfGatewayType, RpcServer rpcServer)
void	PekkoRpcService.stopServer(RpcServer selfGateway)