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

Class ChangelogInfo

Object

org.apache.spark.sql.connector.catalog.ChangelogInfo

@Evolving
public class ChangelogInfo
extends Object

Encapsulates the parameters of a Change Data Capture (CDC) query, passed from the parser / DataFrame API to the catalog's TableCatalog.loadChangelog(Identifier, ChangelogInfo) method.

Since:

4.2.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ChangelogInfo.DeduplicationMode	Deduplication modes controlling how Spark post-processes raw change data.

Constructor Summary

Constructors

Constructor	Description
ChangelogInfo(ChangelogRange range, ChangelogInfo.DeduplicationMode deduplicationMode, boolean computeUpdates)

Method Summary

Modifier and Type	Method	Description
boolean	computeUpdates()	Whether to derive update_preimage/update_postimage from insert/delete pairs.
ChangelogInfo.DeduplicationMode	deduplicationMode()	Returns the deduplication mode for this CDC query.
boolean	equals(Object o)
int	hashCode()
ChangelogRange	range()	Returns the version/timestamp range for this CDC query.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ChangelogInfo

public ChangelogInfo(ChangelogRange range,
 ChangelogInfo.DeduplicationMode deduplicationMode,
 boolean computeUpdates)

Method Details

range

public ChangelogRange range()

Returns the version/timestamp range for this CDC query.

deduplicationMode

public ChangelogInfo.DeduplicationMode deduplicationMode()

Returns the deduplication mode for this CDC query.

computeUpdates

public boolean computeUpdates()

Whether to derive update_preimage/update_postimage from insert/delete pairs.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object