Uses of Class
org.apache.flink.runtime.rpc.RpcEndpoint

Packages that use RpcEndpoint

Package	Description
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.metrics.dump
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active
org.apache.flink.runtime.rpc
org.apache.flink.runtime.rpc.pekko
org.apache.flink.runtime.taskexecutor

Uses of RpcEndpoint in org.apache.flink.runtime.dispatcher

Subclasses of RpcEndpoint in org.apache.flink.runtime.dispatcher

Modifier and Type	Class and Description
class	Dispatcher Base class for the Dispatcher component.
class	MiniDispatcher Mini Dispatcher which is instantiated as the dispatcher component by the JobClusterEntrypoint.
class	StandaloneDispatcher Dispatcher implementation which spawns a JobMaster for each submitted JobGraph within in the same process.

Uses of RpcEndpoint in org.apache.flink.runtime.jobmaster

Subclasses of RpcEndpoint in org.apache.flink.runtime.jobmaster

Modifier and Type	Class and Description
class	JobMaster JobMaster implementation.

Uses of RpcEndpoint in org.apache.flink.runtime.metrics.dump

Subclasses of RpcEndpoint in org.apache.flink.runtime.metrics.dump

Modifier and Type	Class and Description
class	MetricQueryService The MetricQueryService creates a key-value representation of all metrics currently registered with Flink when queried.

Uses of RpcEndpoint in org.apache.flink.runtime.resourcemanager

Subclasses of RpcEndpoint in org.apache.flink.runtime.resourcemanager

Modifier and Type	Class and Description
class	ResourceManager<WorkerType extends ResourceIDRetrievable> ResourceManager implementation.
class	StandaloneResourceManager A standalone implementation of the resource manager.

Uses of RpcEndpoint in org.apache.flink.runtime.resourcemanager.active

Subclasses of RpcEndpoint in org.apache.flink.runtime.resourcemanager.active

Modifier and Type	Class and Description
class	ActiveResourceManager<WorkerType extends ResourceIDRetrievable> An active implementation of ResourceManager.

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

Subclasses of RpcEndpoint in org.apache.flink.runtime.rpc

Modifier and Type	Class and Description
class	FencedRpcEndpoint<F extends Serializable> Base class for fenced RpcEndpoint.

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

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 RpcEndpoint

Modifier and Type	Method and Description
static void	RpcUtils.terminateRpcEndpoint(RpcEndpoint... rpcEndpoints) Shuts the given RpcEndpoints down and awaits their termination.

Constructors in org.apache.flink.runtime.rpc with parameters of type RpcEndpoint

Constructor and Description
MainThreadValidatorUtil(RpcEndpoint endpoint)

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

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

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

Uses of RpcEndpoint in org.apache.flink.runtime.taskexecutor

Subclasses of RpcEndpoint in org.apache.flink.runtime.taskexecutor

Modifier and Type	Class and Description
class	TaskExecutor TaskExecutor implementation.