public class CheckpointMetrics extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static long |
UNSET |
Constructor and Description |
---|
CheckpointMetrics() |
CheckpointMetrics(long bytesProcessedDuringAlignment,
long bytesPersistedDuringAlignment,
long alignmentDurationNanos,
long syncDurationMillis,
long asyncDurationMillis,
long checkpointStartDelayNanos,
boolean unalignedCheckpoint,
long totalBytesPersisted) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
long |
getAlignmentDurationNanos() |
long |
getAsyncDurationMillis() |
long |
getBytesPersistedDuringAlignment() |
long |
getBytesProcessedDuringAlignment() |
long |
getCheckpointStartDelayNanos() |
long |
getSyncDurationMillis() |
long |
getTotalBytesPersisted() |
boolean |
getUnalignedCheckpoint() |
int |
hashCode() |
String |
toString() |
public static final long UNSET
@VisibleForTesting public CheckpointMetrics()
public CheckpointMetrics(long bytesProcessedDuringAlignment, long bytesPersistedDuringAlignment, long alignmentDurationNanos, long syncDurationMillis, long asyncDurationMillis, long checkpointStartDelayNanos, boolean unalignedCheckpoint, long totalBytesPersisted)
public long getBytesProcessedDuringAlignment()
public long getBytesPersistedDuringAlignment()
public long getAlignmentDurationNanos()
public long getSyncDurationMillis()
public long getAsyncDurationMillis()
public long getCheckpointStartDelayNanos()
public boolean getUnalignedCheckpoint()
public long getTotalBytesPersisted()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.