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.
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.
Base class for responses from the ResourceManager to a registration attempt by a TaskExecutor.
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.