Class and Description |
---|
CheckpointCoordinatorConfiguration
Configuration settings for the
CheckpointCoordinator . |
Class and Description |
---|
InputSplitProvider
An input split provider can be successively queried to provide a series of
InputSplit
objects a task is supposed to consume in the course of its execution. |
TaskOperatorEventGateway
Gateway to send an
OperatorEvent from a Task to to the OperatorCoordinator
JobManager side. |
Class and Description |
---|
CheckpointCoordinatorConfiguration
Configuration settings for the
CheckpointCoordinator . |
JobCheckpointingSettings
The JobCheckpointingSettings are attached to a JobGraph and describe the settings for the
asynchronous checkpoints of the JobGraph, such as interval.
|
Class and Description |
---|
AbstractInvokable
A base implementation of
TaskInvokable , CheckpointableTask , and CoordinatedTask with most methods throwing UnsupportedOperationException or doing
nothing. |
CheckpointableTask
A task that participates in checkpointing.
|
CoordinatedTask
An task that is coordinated, i.e.
|
TaskInvokable
An invokable part of the task.
|
Class and Description |
---|
JobCheckpointingSettings
The JobCheckpointingSettings are attached to a JobGraph and describe the settings for the
asynchronous checkpoints of the JobGraph, such as interval.
|
TaskInvokable
An invokable part of the task.
|
Class and Description |
---|
CheckpointableTask
A task that participates in checkpointing.
|
CheckpointCoordinatorConfiguration
Configuration settings for the
CheckpointCoordinator . |
CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder
CheckpointCoordinatorConfiguration builder. |
CoordinatedTask
An task that is coordinated, i.e.
|
InputSplitProviderException |
TaskInvokable
An invokable part of the task.
|
Class and Description |
---|
JobCheckpointingSettings
The JobCheckpointingSettings are attached to a JobGraph and describe the settings for the
asynchronous checkpoints of the JobGraph, such as interval.
|
Class and Description |
---|
AbstractInvokable
A base implementation of
TaskInvokable , CheckpointableTask , and CoordinatedTask with most methods throwing UnsupportedOperationException or doing
nothing. |
CheckpointableTask
A task that participates in checkpointing.
|
CoordinatedTask
An task that is coordinated, i.e.
|
TaskInvokable
An invokable part of the task.
|
Class and Description |
---|
AbstractInvokable
A base implementation of
TaskInvokable , CheckpointableTask , and CoordinatedTask with most methods throwing UnsupportedOperationException or doing
nothing. |
Class and Description |
---|
AbstractInvokable
A base implementation of
TaskInvokable , CheckpointableTask , and CoordinatedTask with most methods throwing UnsupportedOperationException or doing
nothing. |
Class and Description |
---|
AbstractInvokable
A base implementation of
TaskInvokable , CheckpointableTask , and CoordinatedTask with most methods throwing UnsupportedOperationException or doing
nothing. |
Class and Description |
---|
AbstractInvokable
A base implementation of
TaskInvokable , CheckpointableTask , and CoordinatedTask with most methods throwing UnsupportedOperationException or doing
nothing. |
TaskInvokable
An invokable part of the task.
|
Class and Description |
---|
JobCheckpointingSettings
The JobCheckpointingSettings are attached to a JobGraph and describe the settings for the
asynchronous checkpoints of the JobGraph, such as interval.
|
Class and Description |
---|
InputSplitProvider
An input split provider can be successively queried to provide a series of
InputSplit
objects a task is supposed to consume in the course of its execution. |
InputSplitProviderException |
TaskOperatorEventGateway
Gateway to send an
OperatorEvent from a Task to to the OperatorCoordinator
JobManager side. |
Class and Description |
---|
InputSplitProvider
An input split provider can be successively queried to provide a series of
InputSplit
objects a task is supposed to consume in the course of its execution. |
TaskOperatorEventGateway
Gateway to send an
OperatorEvent from a Task to to the OperatorCoordinator
JobManager side. |
Class and Description |
---|
InputSplitProvider
An input split provider can be successively queried to provide a series of
InputSplit
objects a task is supposed to consume in the course of its execution. |
TaskOperatorEventGateway
Gateway to send an
OperatorEvent from a Task to to the OperatorCoordinator
JobManager side. |
Class and Description |
---|
TaskInvokable
An invokable part of the task.
|
Class and Description |
---|
InputSplitProvider
An input split provider can be successively queried to provide a series of
InputSplit
objects a task is supposed to consume in the course of its execution. |
Class and Description |
---|
TaskInvokable
An invokable part of the task.
|
Class and Description |
---|
TaskInvokable
An invokable part of the task.
|
Class and Description |
---|
CheckpointableTask
A task that participates in checkpointing.
|
Class and Description |
---|
CheckpointableTask
A task that participates in checkpointing.
|
CoordinatedTask
An task that is coordinated, i.e.
|
TaskInvokable
An invokable part of the task.
|
TaskOperatorEventGateway
Gateway to send an
OperatorEvent from a Task to to the OperatorCoordinator
JobManager side. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.