Modifier and Type | Class and Description |
---|---|
class |
MesosResourceManager
The Mesos implementation of the resource manager.
|
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
|
Modifier and Type | Class and Description |
---|---|
class |
JobMaster
JobMaster implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
MetricQueryService
The MetricQueryService creates a key-value representation of all metrics currently registered with Flink when queried.
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceManager<WorkerType extends ResourceIDRetrievable>
ResourceManager implementation.
|
class |
StandaloneResourceManager
A standalone implementation of the resource manager.
|
Modifier and Type | Class and Description |
---|---|
class |
FencedRpcEndpoint<F extends Serializable>
Base class for fenced
RpcEndpoint . |
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 |
---|---|
static void |
RpcUtils.terminateRpcEndpoint(RpcEndpoint rpcEndpoint,
Time timeout)
Shuts the given
RpcEndpoint down and awaits its termination. |
Constructor and Description |
---|
MainThreadValidatorUtil(RpcEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
<C extends RpcEndpoint & RpcGateway> |
AkkaRpcService.startServer(C rpcEndpoint) |
Modifier and Type | Class and Description |
---|---|
class |
TaskExecutor
TaskExecutor implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
YarnResourceManager
The yarn implementation of the resource manager.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.