Class and Description |
---|
JobResult
Similar to
JobExecutionResult but with an optional
SerializedThrowable when the job failed. |
Class and Description |
---|
JobResult
Similar to
JobExecutionResult but with an optional
SerializedThrowable when the job failed. |
Class and Description |
---|
KvStateLocationOracle
Oracle for
KvStateLocation in the cluster. |
Class and Description |
---|
JobManagerRunner
The runner for the job manager.
|
JobManagerSharedServices
Utility class which holds all auxiliary shared services used by the
JobMaster . |
JobResult
Similar to
JobExecutionResult but with an optional
SerializedThrowable when the job failed. |
RescalingBehaviour
Definition of the rescaling behaviour.
|
Class and Description |
---|
LogicalSlot
A logical slot represents a resource on a TaskManager into
which a single task can be deployed.
|
LogicalSlot.Payload
Payload for a logical slot.
|
Class and Description |
---|
LogicalSlot
A logical slot represents a resource on a TaskManager into
which a single task can be deployed.
|
LogicalSlot.Payload
Payload for a logical slot.
|
SlotContext
Interface for the context of a
LogicalSlot . |
SlotInfo
Interface that provides basic information in the context of a slot.
|
SlotOwner
Interface for components that hold slots and to which slots get released / recycled.
|
SlotRequestId
This ID identifies the request for a logical slot from the Execution to the
SlotPool
oe SlotProvider . |
Class and Description |
---|
LogicalSlot
A logical slot represents a resource on a TaskManager into
which a single task can be deployed.
|
SlotRequestId
This ID identifies the request for a logical slot from the Execution to the
SlotPool
oe SlotProvider . |
Class and Description |
---|
AllocatedSlotInfo
Information about an allocated slot which is owned by a JobMaster.
|
JobManagerException
Base exception thrown by the
JobMaster . |
JobManagerSharedServices
Utility class which holds all auxiliary shared services used by the
JobMaster . |
JobMasterConfiguration
Configuration for the
JobMaster . |
JobMasterGateway
JobMaster rpc gateway interface. |
JobMasterId
The
JobMaster fencing token. |
JobMasterService
Interface which specifies the JobMaster service.
|
JobResult
Similar to
JobExecutionResult but with an optional
SerializedThrowable when the job failed. |
JobResult.Builder
Builder for
JobResult . |
KvStateLocationOracle
Oracle for
KvStateLocation in the cluster. |
KvStateRegistryGateway
Gateway to report key-value state registration and deregistrations.
|
LogicalSlot
A logical slot represents a resource on a TaskManager into
which a single task can be deployed.
|
LogicalSlot.Payload
Payload for a logical slot.
|
RescalingBehaviour
Definition of the rescaling behaviour.
|
SerializedInputSplit |
SlotInfo
Interface that provides basic information in the context of a slot.
|
SlotRequestId
This ID identifies the request for a logical slot from the Execution to the
SlotPool
oe SlotProvider . |
Class and Description |
---|
JobManagerSharedServices
Utility class which holds all auxiliary shared services used by the
JobMaster . |
JobMaster
JobMaster implementation.
|
JobMasterConfiguration
Configuration for the
JobMaster . |
JobMasterService
Interface which specifies the JobMaster service.
|
Class and Description |
---|
AllocatedSlotReport
The report of currently allocated slots from a given TaskExecutor by a JobMaster.
|
JobMasterId
The
JobMaster fencing token. |
LogicalSlot
A logical slot represents a resource on a TaskManager into
which a single task can be deployed.
|
LogicalSlot.Payload
Payload for a logical slot.
|
SlotContext
Interface for the context of a
LogicalSlot . |
SlotInfo
Interface that provides basic information in the context of a slot.
|
SlotOwner
Interface for components that hold slots and to which slots get released / recycled.
|
SlotRequestId
This ID identifies the request for a logical slot from the Execution to the
SlotPool
oe SlotProvider . |
Class and Description |
---|
JobResult
Similar to
JobExecutionResult but with an optional
SerializedThrowable when the job failed. |
Class and Description |
---|
KvStateLocationOracle
Oracle for
KvStateLocation in the cluster. |
Class and Description |
---|
JobMasterId
The
JobMaster fencing token. |
Class and Description |
---|
JobMasterGateway
JobMaster rpc gateway interface. |
JobMasterId
The
JobMaster fencing token. |
Class and Description |
---|
JobResult
Similar to
JobExecutionResult but with an optional
SerializedThrowable when the job failed. |
Class and Description |
---|
JobResult
Similar to
JobExecutionResult but with an optional
SerializedThrowable when the job failed. |
Class and Description |
---|
AllocatedSlotReport
The report of currently allocated slots from a given TaskExecutor by a JobMaster.
|
JMTMRegistrationSuccess
Message indicating a successful
JobMaster and TaskExecutor registration. |
JobMasterGateway
JobMaster rpc gateway interface. |
JobMasterId
The
JobMaster fencing token. |
Class and Description |
---|
JobMasterGateway
JobMaster rpc gateway interface. |
KvStateRegistryGateway
Gateway to report key-value state registration and deregistrations.
|
Class and Description |
---|
KvStateLocationOracle
Oracle for
KvStateLocation in the cluster. |
Class and Description |
---|
JobResult
Similar to
JobExecutionResult but with an optional
SerializedThrowable when the job failed. |
RescalingBehaviour
Definition of the rescaling behaviour.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.