Task interface used by
This interface gives access to transient, named, global aggregates.
Listener for the
Intermediate partition state checker to query the JobManager about the state of the producer of a result partition.
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.
This service has the responsibility to monitor the job leaders (the job manager which is leader for a given job) for all registered jobs.
Container class for JobManager specific communication utils used by the
Container for multiple
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–2020 The Apache Software Foundation. All rights reserved.