Class and Description |
---|
GlobalAggregateManager
This interface gives access to transient, named, global aggregates.
|
Class and Description |
---|
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
Class and Description |
---|
TaskExecutorOperatorEventGateway
The gateway through which the
OperatorCoordinator can send an event to an Operator on the
Task Manager side. |
Class and Description |
---|
ExecutionDeploymentReport
A report about the currently deployed executions of a TaskExecutor.
|
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
TaskExecutorOperatorEventGateway
The gateway through which the
OperatorCoordinator can send an event to an Operator on the
Task Manager side. |
TaskExecutorToJobManagerHeartbeatPayload
Payload for heartbeats sent from the TaskExecutor to the JobManager.
|
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.
|
TaskExecutorHeartbeatPayload
Payload for heartbeats sent from the TaskExecutor to the ResourceManager.
|
TaskExecutorMemoryConfiguration
TaskExecutorConfiguration collects the configuration of a TaskExecutor instance.
|
TaskExecutorThreadInfoGateway
RPC gateway for requesting
ThreadInfoSample . |
Class and Description |
---|
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
TaskExecutorMemoryConfiguration
TaskExecutorConfiguration collects the configuration of a TaskExecutor instance.
|
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.
|
SlotStatus
This describes the slot current status which located in TaskManager.
|
Class and Description |
---|
TaskExecutorMemoryConfiguration
TaskExecutorConfiguration collects the configuration of a TaskExecutor instance.
|
Class and Description |
---|
AccumulatorReport
A report about the current values of all accumulators of the TaskExecutor for a given job.
|
DefaultJobTable
Default implementation of the
JobTable . |
ExecutionDeploymentReport
A report about the currently deployed executions of a TaskExecutor.
|
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.
|
JobTable
A
JobTable's task is to manage the lifecycle of a job on the TaskExecutor . |
JobTable.Connection
A connection contains services bound to the lifetime of a connection with a JobManager.
|
JobTable.Job
A job contains services which are bound to the lifetime of a Flink job.
|
JobTable.JobServices
Services associated with a job.
|
KvStateService
KvState related components of each
TaskExecutor instance. |
PartitionProducerStateChecker
Intermediate partition state checker to query the JobManager about the state of the producer of a
result partition.
|
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.
|
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
TaskExecutorMemoryConfiguration
TaskExecutorConfiguration collects the configuration of a TaskExecutor instance.
|
TaskExecutorOperatorEventGateway
The gateway through which the
OperatorCoordinator can send an event to an Operator on the
Task Manager side. |
TaskExecutorRegistrationRejection
Rejection response from the
ResourceManager for the TaskExecutor . |
TaskExecutorRegistrationSuccess
Base class for responses from the ResourceManager to a registration attempt by a TaskExecutor.
|
TaskExecutorResourceSpec
Specification of resources to use in running
TaskExecutor . |
TaskExecutorThreadInfoGateway
RPC gateway for requesting
ThreadInfoSample . |
TaskExecutorToJobManagerHeartbeatPayload
Payload for heartbeats sent from the TaskExecutor to the JobManager.
|
TaskExecutorToResourceManagerConnection
The connection between a TaskExecutor and the ResourceManager.
|
TaskExecutorToServiceAdapter
Simple adapter for
TaskExecutor to adapt to TaskManagerRunner.TaskExecutorService . |
TaskManagerConfiguration
Configuration object for
TaskExecutor . |
TaskManagerRunner.Result |
TaskManagerRunner.TaskExecutorService |
TaskManagerRunner.TaskExecutorServiceFactory
Factory for
TaskExecutor . |
TaskManagerServices |
TaskManagerServicesConfiguration
Configuration for the task manager services such as the memory manager, the io manager and the
metric registry.
|
Class and Description |
---|
GlobalAggregateManager
This interface gives access to transient, named, global aggregates.
|
PartitionProducerStateChecker
Intermediate partition state checker to query the JobManager about the state of the producer of a
result partition.
|
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.
|
KvStateService
KvState related components of each
TaskExecutor instance. |
PartitionProducerStateChecker
Intermediate partition state checker to query the JobManager about the state of the producer of a
result partition.
|
Class and Description |
---|
TaskExecutorThreadInfoGateway
RPC gateway for requesting
ThreadInfoSample . |
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–2022 The Apache Software Foundation. All rights reserved.