@NotThreadSafe public class CheckpointMetricsBuilder extends Object
CheckpointMetrics
.
This class is not thread safe, but parts of it can actually be used from different threads.
Constructor and Description |
---|
CheckpointMetricsBuilder() |
public CheckpointMetricsBuilder setBytesProcessedDuringAlignment(long bytesProcessedDuringAlignment)
public CheckpointMetricsBuilder setBytesProcessedDuringAlignment(CompletableFuture<Long> bytesProcessedDuringAlignment)
public CompletableFuture<Long> getBytesProcessedDuringAlignment()
public CheckpointMetricsBuilder setBytesPersistedDuringAlignment(long bytesPersistedDuringAlignment)
public long getAlignmentDurationNanosOrDefault()
public CheckpointMetricsBuilder setAlignmentDurationNanos(long alignmentDurationNanos)
public CheckpointMetricsBuilder setAlignmentDurationNanos(CompletableFuture<Long> alignmentDurationNanos)
public CompletableFuture<Long> getAlignmentDurationNanos()
public CheckpointMetricsBuilder setSyncDurationMillis(long syncDurationMillis)
public long getSyncDurationMillis()
public CheckpointMetricsBuilder setAsyncDurationMillis(long asyncDurationMillis)
public long getAsyncDurationMillis()
public CheckpointMetricsBuilder setCheckpointStartDelayNanos(long checkpointStartDelayNanos)
public long getCheckpointStartDelayNanos()
public CheckpointMetrics build()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.