Package org.apache.spark.sql.connector.catalog

Interface ChangelogRange

All Known Implementing Classes:

ChangelogRange.TimestampRange, ChangelogRange.UnboundedRange, ChangelogRange.VersionRange

@Evolving
public sealed interface ChangelogRange
permits ChangelogRange.VersionRange, ChangelogRange.TimestampRange, ChangelogRange.UnboundedRange

Represents the version or timestamp range for a Change Data Capture (CDC) query.

This sealed interface has three implementations:

• ChangelogRange.VersionRange — range defined by version identifiers
• ChangelogRange.TimestampRange — range defined by timestamps
• ChangelogRange.UnboundedRange — no boundaries (used by streaming queries)

Since:

4.2.0

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final record	ChangelogRange.TimestampRange	A changelog range defined by timestamps.
static final record	ChangelogRange.UnboundedRange	An unbounded changelog range with no starting or ending boundaries.
static final record	ChangelogRange.VersionRange	A changelog range defined by version identifiers.

Method Summary

Modifier and Type	Method	Description
boolean	endingBoundInclusive()	Whether the ending bound is inclusive.
boolean	startingBoundInclusive()	Whether the starting bound is inclusive.

Method Details

startingBoundInclusive

boolean startingBoundInclusive()

Whether the starting bound is inclusive.

endingBoundInclusive

boolean endingBoundInclusive()

Whether the ending bound is inclusive.