org.apache.flink.runtime.checkpoint

Class CompletedCheckpointStatsSummarySnapshot

java.lang.Object

org.apache.flink.runtime.checkpoint.CompletedCheckpointStatsSummarySnapshot

All Implemented Interfaces:

Serializable

@Internal
public class CompletedCheckpointStatsSummarySnapshot
extends Object
implements Serializable

Immutable snapshot of CompletedCheckpointStatsSummary.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompletedCheckpointStatsSummarySnapshot(StatsSummarySnapshot duration, StatsSummarySnapshot processedData, StatsSummarySnapshot persistedData, StatsSummarySnapshot stateSize, StatsSummarySnapshot checkpointedSize)

Method Summary

Modifier and Type	Method and Description
static CompletedCheckpointStatsSummarySnapshot	empty()
StatsSummarySnapshot	getCheckpointedSize()
StatsSummarySnapshot	getEndToEndDurationStats()
StatsSummarySnapshot	getPersistedDataStats()
StatsSummarySnapshot	getProcessedDataStats()
StatsSummarySnapshot	getStateSizeStats()

Methods inherited from class java.lang.Object

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

Constructor Detail

CompletedCheckpointStatsSummarySnapshot

public CompletedCheckpointStatsSummarySnapshot(StatsSummarySnapshot duration,
                                               StatsSummarySnapshot processedData,
                                               StatsSummarySnapshot persistedData,
                                               StatsSummarySnapshot stateSize,
                                               StatsSummarySnapshot checkpointedSize)

Method Detail

empty

public static CompletedCheckpointStatsSummarySnapshot empty()

getEndToEndDurationStats

public StatsSummarySnapshot getEndToEndDurationStats()

getPersistedDataStats

public StatsSummarySnapshot getPersistedDataStats()

getProcessedDataStats

public StatsSummarySnapshot getProcessedDataStats()

getStateSizeStats

public StatsSummarySnapshot getStateSizeStats()

getCheckpointedSize

public StatsSummarySnapshot getCheckpointedSize()