Uses of Class
org.apache.flink.runtime.checkpoint.CheckpointMetricsBuilder

Packages that use CheckpointMetricsBuilder

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.

Uses of CheckpointMetricsBuilder in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return CheckpointMetricsBuilder

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)

Uses of CheckpointMetricsBuilder in org.apache.flink.runtime.jobgraph.tasks

Methods in org.apache.flink.runtime.jobgraph.tasks with parameters of type CheckpointMetricsBuilder

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.

Uses of CheckpointMetricsBuilder in org.apache.flink.streaming.runtime.tasks

Methods in org.apache.flink.streaming.runtime.tasks with parameters of type CheckpointMetricsBuilder

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)