org.apache.flink.runtime.state.changelog

Interface SequenceNumber

All Superinterfaces:

Comparable<SequenceNumber>, Serializable

All Known Implementing Classes:

SequenceNumber.GenericSequenceNumber

@Internal
public interface SequenceNumber
extends Comparable<SequenceNumber>, Serializable

A logical timestamp to draw a boundary between the materialized and non-materialized changes. Maintained by the state backend but implementations may choose to move its generation to StateChangelogStorage as an optimization.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	SequenceNumber.GenericSequenceNumber Generic SequenceNumber.

Method Summary

Modifier and Type	Method and Description
SequenceNumber	next()
static SequenceNumber	of(long number)

Methods inherited from interface java.lang.Comparable

compareTo

Method Detail

next

SequenceNumber next()

of

static SequenceNumber of(long number)