Package | Description |
---|---|
org.apache.flink.runtime.jobgraph.tasks | |
org.apache.flink.runtime.state | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractInvokable.triggerCheckpoint(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions)
This method is called to trigger a checkpoint, asynchronously by the checkpoint
coordinator.
|
void |
AbstractInvokable.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
CheckpointMetrics checkpointMetrics)
This method is called when a checkpoint is triggered as a result of receiving checkpoint
barriers on all input streams.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskStateManager.reportTaskStateSnapshots(CheckpointMetaData checkpointMetaData,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot acknowledgedState,
TaskStateSnapshot localState)
Report the state snapshots for the operator instances running in the owning task.
|
void |
TaskStateManagerImpl.reportTaskStateSnapshots(CheckpointMetaData checkpointMetaData,
CheckpointMetrics checkpointMetrics,
TaskStateSnapshot acknowledgedState,
TaskStateSnapshot localState) |
Modifier and Type | Method and Description |
---|---|
boolean |
StreamTask.triggerCheckpoint(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions) |
boolean |
SourceStreamTask.triggerCheckpoint(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions) |
void |
StreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
CheckpointMetrics checkpointMetrics) |
void |
CheckpointExceptionHandler.tryHandleCheckpointException(CheckpointMetaData checkpointMetaData,
Exception exception)
Offers the exception for handling.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.