Package org.apache.flink.runtime.checkpoint

Class CheckpointMetricsBuilder

java.lang.Object

org.apache.flink.runtime.checkpoint.CheckpointMetricsBuilder

@NotThreadSafe
public class CheckpointMetricsBuilder
extends Object

A builder for CheckpointMetrics.

This class is not thread safe, but parts of it can actually be used from different threads.

Constructor Summary

Constructors

Constructor	Description
CheckpointMetricsBuilder()

Method Summary

Modifier and Type	Method	Description
CheckpointMetrics	build()
CheckpointMetrics	buildIncomplete()
CompletableFuture<Long>	getAlignmentDurationNanos()
long	getAlignmentDurationNanosOrDefault()
long	getAsyncDurationMillis()
long	getBytesPersistedOfThisCheckpoint()
CompletableFuture<Long>	getBytesProcessedDuringAlignment()
long	getCheckpointStartDelayNanos()
long	getSyncDurationMillis()
CheckpointMetricsBuilder	setAlignmentDurationNanos(long alignmentDurationNanos)
CheckpointMetricsBuilder	setAlignmentDurationNanos(CompletableFuture<Long> alignmentDurationNanos)
CheckpointMetricsBuilder	setAsyncDurationMillis(long asyncDurationMillis)
CheckpointMetricsBuilder	setBytesPersistedDuringAlignment(long bytesPersistedDuringAlignment)
CheckpointMetricsBuilder	setBytesPersistedOfThisCheckpoint(long bytesPersistedOfThisCheckpoint)
CheckpointMetricsBuilder	setBytesProcessedDuringAlignment(long bytesProcessedDuringAlignment)
CheckpointMetricsBuilder	setBytesProcessedDuringAlignment(CompletableFuture<Long> bytesProcessedDuringAlignment)
CheckpointMetricsBuilder	setCheckpointStartDelayNanos(long checkpointStartDelayNanos)
CheckpointMetricsBuilder	setSyncDurationMillis(long syncDurationMillis)
CheckpointMetricsBuilder	setTotalBytesPersisted(long totalBytesPersisted)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CheckpointMetricsBuilder

public CheckpointMetricsBuilder()

Method Detail

setBytesProcessedDuringAlignment

public CheckpointMetricsBuilder setBytesProcessedDuringAlignment(long bytesProcessedDuringAlignment)

setBytesProcessedDuringAlignment

public CheckpointMetricsBuilder setBytesProcessedDuringAlignment(CompletableFuture<Long> bytesProcessedDuringAlignment)

getBytesProcessedDuringAlignment

public CompletableFuture<Long> getBytesProcessedDuringAlignment()

setBytesPersistedDuringAlignment

public CheckpointMetricsBuilder setBytesPersistedDuringAlignment(long bytesPersistedDuringAlignment)

getAlignmentDurationNanosOrDefault

public long getAlignmentDurationNanosOrDefault()

setAlignmentDurationNanos

public CheckpointMetricsBuilder setAlignmentDurationNanos(long alignmentDurationNanos)

setAlignmentDurationNanos

public CheckpointMetricsBuilder setAlignmentDurationNanos(CompletableFuture<Long> alignmentDurationNanos)

getAlignmentDurationNanos

public CompletableFuture<Long> getAlignmentDurationNanos()

setSyncDurationMillis

public CheckpointMetricsBuilder setSyncDurationMillis(long syncDurationMillis)

getSyncDurationMillis

public long getSyncDurationMillis()

setAsyncDurationMillis

public CheckpointMetricsBuilder setAsyncDurationMillis(long asyncDurationMillis)

getAsyncDurationMillis

public long getAsyncDurationMillis()

setCheckpointStartDelayNanos

public CheckpointMetricsBuilder setCheckpointStartDelayNanos(long checkpointStartDelayNanos)

getCheckpointStartDelayNanos

public long getCheckpointStartDelayNanos()

setTotalBytesPersisted

public CheckpointMetricsBuilder setTotalBytesPersisted(long totalBytesPersisted)

getBytesPersistedOfThisCheckpoint

public long getBytesPersistedOfThisCheckpoint()

setBytesPersistedOfThisCheckpoint

public CheckpointMetricsBuilder setBytesPersistedOfThisCheckpoint(long bytesPersistedOfThisCheckpoint)

build

public CheckpointMetrics build()

buildIncomplete

public CheckpointMetrics buildIncomplete()