Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.jobgraph.tasks | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Method and Description |
---|---|
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setAlignmentDurationNanos(CompletableFuture<Long> alignmentDurationNanos) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setAlignmentDurationNanos(long alignmentDurationNanos) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setAsyncDurationMillis(long asyncDurationMillis) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setBytesPersistedDuringAlignment(long bytesPersistedDuringAlignment) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setBytesPersistedOfThisCheckpoint(long bytesPersistedOfThisCheckpoint) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setBytesProcessedDuringAlignment(CompletableFuture<Long> bytesProcessedDuringAlignment) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setBytesProcessedDuringAlignment(long bytesProcessedDuringAlignment) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setCheckpointStartDelayNanos(long checkpointStartDelayNanos) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setSyncDurationMillis(long syncDurationMillis) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setTotalBytesPersisted(long totalBytesPersisted) |
CheckpointMetricsBuilder |
CheckpointMetricsBuilder.setUnalignedCheckpoint(boolean unalignedCheckpoint) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractInvokable.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
CheckpointMetricsBuilder checkpointMetrics) |
void |
CheckpointableTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
CheckpointMetricsBuilder 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 |
SubtaskCheckpointCoordinator.checkpointState(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
CheckpointMetricsBuilder checkpointMetrics,
OperatorChain<?,?> operatorChain,
boolean isTaskFinished,
java.util.function.Supplier<Boolean> isRunning)
Must be called after
SubtaskCheckpointCoordinator.initInputsCheckpoint(long, CheckpointOptions) . |
void |
StreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
CheckpointMetricsBuilder checkpointMetrics) |
void |
MultipleInputStreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData,
CheckpointOptions checkpointOptions,
CheckpointMetricsBuilder checkpointMetrics) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.