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 |
---|---|
Future<Boolean> |
AbstractInvokable.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
boolean advanceToEndOfEventTime)
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 |
---|---|
Future<Boolean> |
StreamTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
boolean advanceToEndOfEventTime) |
Future<Boolean> |
SourceStreamTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
boolean advanceToEndOfEventTime) |
void |
StreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
CheckpointMetrics checkpointMetrics) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.