Task interface used by
This interface gives access to transient, named, global aggregates.
Listener for the
This service has the responsibility to monitor the job leaders (the job manager which is leader for a given job) for all registered jobs.
A connection contains services bound to the lifetime of a connection with a JobManager.
A job contains services which are bound to the lifetime of a Flink job.
Services associated with a job.
Intermediate partition state checker to query the JobManager about the state of the producer of a result partition.
The gateway through which the
A report about the current values of all accumulators of the TaskExecutor for a given job.
Samples whether a task is back pressured multi times.
Default implementation of
Default implementation of the
KvState related components of each
Simple configuration object for the parameters for the server-side of queryable state.
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.
This describes the slot current status which located in TaskManager.
Payload for heartbeats sent from the TaskExecutor to the ResourceManager.
Base class for responses from the ResourceManager to a registration attempt by a TaskExecutor.
Specification of resources to use in running
The connection between a TaskExecutor and the ResourceManager.
Configuration object for
This class is the executable entry point for the task manager in yarn or standalone mode.
Configuration for the task manager services such as the memory manager, the io manager and the metric registry.
Different file types to request from the
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.