Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.query |
This package contains all KvState query related classes.
|
org.apache.flink.runtime.registration | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.rpc | |
org.apache.flink.runtime.rpc.akka | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Interface and Description |
---|---|
interface |
CheckpointCoordinatorGateway |
Modifier and Type | Interface and Description |
---|---|
interface |
SlotPoolGateway
The gateway for calls on the
SlotPool . |
Modifier and Type | Interface and Description |
---|---|
interface |
JobMasterGateway
JobMaster rpc gateway interface |
Modifier and Type | Interface and Description |
---|---|
interface |
KvStateRegistryGateway |
Modifier and Type | Class and Description |
---|---|
class |
RegisteredRpcConnection<Gateway extends RpcGateway,Success extends RegistrationResponse.Success>
This utility class implements the basis of RPC connecting from one component to another component,
for example the RPC connection from TaskExecutor to ResourceManager.
|
class |
RetryingRegistration<Gateway extends RpcGateway,Success extends RegistrationResponse.Success>
This utility class implements the basis of registering one component at another component,
for example registering the TaskExecutor at the ResourceManager.
|
Modifier and Type | Interface and Description |
---|---|
interface |
InfoMessageListenerRpcGateway
A gateway to listen for info messages from
ResourceManager |
interface |
ResourceManagerGateway
The
ResourceManager 's RPC gateway interface. |
Modifier and Type | Class and Description |
---|---|
class |
RpcEndpoint<C extends RpcGateway>
Base class for RPC endpoints.
|
Modifier and Type | Method and Description |
---|---|
<C extends RpcGateway> |
RpcService.connect(String address,
Class<C> clazz)
Connect to a remote rpc server under the provided address.
|
<C extends RpcGateway,S extends RpcEndpoint<C>> |
RpcService.startServer(S rpcEndpoint)
Start a rpc server which forwards the remote procedure calls to the provided rpc endpoint.
|
<C extends RpcGateway> |
RpcService.stopServer(C selfGateway)
Stop the underlying rpc server of the provided self gateway.
|
Modifier and Type | Method and Description |
---|---|
<C extends RpcGateway> |
AkkaRpcService.connect(String address,
Class<C> clazz) |
<C extends RpcGateway,S extends RpcEndpoint<C>> |
AkkaRpcService.startServer(S rpcEndpoint) |
Modifier and Type | Method and Description |
---|---|
void |
AkkaRpcService.stopServer(RpcGateway selfGateway) |
Modifier and Type | Interface and Description |
---|---|
interface |
TaskExecutorGateway
TaskExecutor RPC gateway interface |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.