Class and Description |
---|
GlobalAggregateManager
This interface gives access to transient, named, global aggregates.
|
Class and Description |
---|
AccumulatorReport
A report about the current values of all accumulators of the TaskExecutor for a given job.
|
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
Class and Description |
---|
FileType
Different file types to request from the
TaskExecutor . |
SlotReport
A report about the current status of all slots of the TaskExecutor, describing
which slots are available and allocated, and what jobs (JobManagers) the allocated slots
have been allocated to.
|
Class and Description |
---|
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
Class and Description |
---|
SlotReport
A report about the current status of all slots of the TaskExecutor, describing
which slots are available and allocated, and what jobs (JobManagers) the allocated slots
have been allocated to.
|
Class and Description |
---|
FileType
Different file types to request from the
TaskExecutor . |
GlobalAggregateManager
This interface gives access to transient, named, global aggregates.
|
JobLeaderListener
Listener for the
JobLeaderService . |
JobLeaderService
This service has the responsibility to monitor the job leaders (the job manager which is leader
for a given job) for all registered jobs.
|
JobManagerConnection
Container class for JobManager specific communication utils used by the
TaskExecutor . |
JobManagerTable
Container for multiple
JobManagerConnection registered under their respective job id. |
QueryableStateConfiguration
Simple configuration object for the parameters for the server-side of queryable state.
|
SlotStatus
This describes the slot current status which located in TaskManager.
|
TaskExecutor
TaskExecutor implementation.
|
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
TaskExecutorRegistrationSuccess
Base class for responses from the ResourceManager to a registration attempt by a
TaskExecutor.
|
TaskExecutorToResourceManagerConnection
The connection between a TaskExecutor and the ResourceManager.
|
TaskManagerConfiguration
Configuration object for
TaskExecutor . |
TaskManagerServices |
TaskManagerServicesConfiguration
Configuration for the task manager services such as the network environment, the memory manager,
the io manager and the metric registry.
|
Class and Description |
---|
GlobalAggregateManager
This interface gives access to transient, named, global aggregates.
|
Class and Description |
---|
SlotReport
A report about the current status of all slots of the TaskExecutor, describing
which slots are available and allocated, and what jobs (JobManagers) the allocated slots
have been allocated to.
|
Class and Description |
---|
GlobalAggregateManager
This interface gives access to transient, named, global aggregates.
|
Class and Description |
---|
GlobalAggregateManager
This interface gives access to transient, named, global aggregates.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.