Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.minicluster | |
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 | |
org.apache.flink.yarn |
Class and Description |
---|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
Class and Description |
---|
RpcEndpoint
Base class for RPC endpoints.
|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
RpcMethod
Annotation for rpc method in a
RpcEndpoint implementation. |
RpcService
Interface for rpc services.
|
RpcTimeout
Annotation for
RpcGateway methods to specify an additional timeout parameter for the
returned future to be completed. |
Class and Description |
---|
FatalErrorHandler |
RpcEndpoint
Base class for RPC endpoints.
|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
RpcMethod
Annotation for rpc method in a
RpcEndpoint implementation. |
RpcService
Interface for rpc services.
|
RpcTimeout
Annotation for
RpcGateway methods to specify an additional timeout parameter for the
returned future to be completed. |
Class and Description |
---|
RpcService
Interface for rpc services.
|
Class and Description |
---|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
Class and Description |
---|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
RpcService
Interface for rpc services.
|
Class and Description |
---|
FatalErrorHandler |
RpcEndpoint
Base class for RPC endpoints.
|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
RpcMethod
Annotation for rpc method in a
RpcEndpoint implementation. |
RpcService
Interface for rpc services.
|
RpcTimeout
Annotation for
RpcGateway methods to specify an additional timeout parameter for the
returned future to be completed. |
Class and Description |
---|
RpcEndpoint
Base class for RPC endpoints.
|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
RpcService
Interface for rpc services.
|
Class and Description |
---|
RpcEndpoint
Base class for RPC endpoints.
|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
RpcService
Interface for rpc services.
|
Class and Description |
---|
FatalErrorHandler |
RpcEndpoint
Base class for RPC endpoints.
|
RpcGateway
Rpc gateway interface which has to be implemented by Rpc gateways.
|
RpcMethod
Annotation for rpc method in a
RpcEndpoint implementation. |
RpcService
Interface for rpc services.
|
RpcTimeout
Annotation for
RpcGateway methods to specify an additional timeout parameter for the
returned future to be completed. |
Class and Description |
---|
FatalErrorHandler |
RpcEndpoint
Base class for RPC endpoints.
|
RpcService
Interface for rpc services.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.