Class and Description |
---|
ExternalizedCheckpointSettings
Grouped settings for externalized checkpoints.
|
JobCheckpointingSettings
The JobCheckpointingSettings are attached to a JobGraph and describe the settings
for the asynchronous checkpoints of the JobGraph, such as interval, and which vertices
need to participate.
|
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 |
---|
ExternalizedCheckpointSettings
Grouped settings for externalized checkpoints.
|
JobCheckpointingSettings
The JobCheckpointingSettings are attached to a JobGraph and describe the settings
for the asynchronous checkpoints of the JobGraph, such as interval, and which vertices
need to participate.
|
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
JobCheckpointingSettings
The JobCheckpointingSettings are attached to a JobGraph and describe the settings
for the asynchronous checkpoints of the JobGraph, such as interval, and which vertices
need to participate.
|
Class and Description |
---|
ExternalizedCheckpointSettings
Grouped settings for externalized checkpoints.
|
InputSplitProviderException |
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
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 |
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 |
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
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 |
---|
StatefulTask
This interface must be implemented by any invokable that has recoverable state and participates
in checkpointing.
|
Class and Description |
---|
AbstractInvokable
This is the abstract base class for every task that can be executed by a
TaskManager.
|
StatefulTask
This interface must be implemented by any invokable that has recoverable state and participates
in checkpointing.
|
StoppableTask
Implemented by tasks that can receive STOP signal.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.