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

Enum Class ChangelogInfo.DeduplicationMode

Object

Enum<ChangelogInfo.DeduplicationMode>

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

All Implemented Interfaces:

Serializable, Comparable<ChangelogInfo.DeduplicationMode>, Constable

Enclosing class:

ChangelogInfo

public static enum ChangelogInfo.DeduplicationMode
extends Enum<ChangelogInfo.DeduplicationMode>

Deduplication modes controlling how Spark post-processes raw change data.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Enum

Enum.EnumDesc<E extends Enum<E>>

Enum Constant Summary

Enum Constants

Enum Constant	Description
DROP_CARRYOVERS	Remove identical insert/delete pairs from copy-on-write file rewrites (default).
NET_CHANGES	Collapse to one net change per row identity across the entire changelog range.
NONE	Raw change rows as-is from the connector — no post-processing.

Method Summary

Modifier and Type	Method	Description
static ChangelogInfo.DeduplicationMode	valueOf(String name)	Returns the enum constant of this class with the specified name.
static ChangelogInfo.DeduplicationMode[]	values()	Returns an array containing the constants of this enum class, in the order they are declared.

Methods inherited from class java.lang.Enum

compareTo, describeConstable, equals, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Details

NONE

public static final ChangelogInfo.DeduplicationMode NONE

Raw change rows as-is from the connector — no post-processing.

DROP_CARRYOVERS

public static final ChangelogInfo.DeduplicationMode DROP_CARRYOVERS

Remove identical insert/delete pairs from copy-on-write file rewrites (default).

NET_CHANGES

public static final ChangelogInfo.DeduplicationMode NET_CHANGES

Collapse to one net change per row identity across the entire changelog range.

Method Details

values

public static ChangelogInfo.DeduplicationMode[] values()

Returns an array containing the constants of this enum class, in the order they are declared.

Returns:

an array containing the constants of this enum class, in the order they are declared

valueOf

public static ChangelogInfo.DeduplicationMode valueOf(String name)

Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum class has no constant with the specified name

NullPointerException - if the argument is null