Package org.apache.flink.runtime.taskexecutor

Interface Summary

Interface	Description
GlobalAggregateManager	This interface gives access to transient, named, global aggregates.
JobLeaderListener	Listener for the JobLeaderService.
TaskExecutorGateway	TaskExecutor RPC gateway interface.

Class Summary

Class	Description
AccumulatorReport	A report about the current values of all accumulators of the TaskExecutor for a given job.
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.
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.
SlotStatus	This describes the slot current status which located in TaskManager.
TaskExecutor	TaskExecutor implementation.
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.
TaskManagerRunner	This class is the executable entry point for the task manager in yarn or standalone mode.
TaskManagerServices	Container for TaskExecutor services such as the MemoryManager, IOManager, NetworkEnvironment.
TaskManagerServicesConfiguration	Configuration for the task manager services such as the network environment, the memory manager, the io manager and the metric registry.

Enum Summary

Enum	Description
FileType	Different file types to request from the TaskExecutor.