Package io.github.flink.gcp.connector.bigquery.sink

Class CdcTableOptions

java.lang.Object

io.github.flink.gcp.connector.bigquery.sink.CdcTableOptions

All Implemented Interfaces:

Serializable

@Experimental
public final class CdcTableOptions
extends Object
implements Serializable

Desired BigQuery table contract for CDC writes.

Primary-key columns create a missing table and detect incompatible existing tables. When they are absent, an existing table may supply them through its metadata, but a missing table cannot be created. Maximum staleness is unmanaged by default; callers may set a duration or explicitly clear the table option.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	CdcTableOptions.Builder	Builder for CdcTableOptions.

Method Summary

Modifier and Type	Method	Description
static CdcTableOptions.Builder	builder()	Creates a new builder.
boolean	clearsMaxStaleness()	Returns whether the desired state has maximum staleness disabled.
static CdcTableOptions	defaults()	Returns an undeclared primary key and unmanaged maximum staleness.
boolean	equals(Object o)
Duration	getMaxStaleness()	Returns the desired maximum staleness, or null when not setting a duration.
List<String>	getPrimaryKeyColumns()	Returns the desired primary-key columns, or an empty list when none is declared.
int	hashCode()
boolean	managesMaxStaleness()	Returns whether maximum staleness is explicitly managed by this contract.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

defaults

public static CdcTableOptions defaults()

Returns an undeclared primary key and unmanaged maximum staleness.

builder

public static CdcTableOptions.Builder builder()

Creates a new builder.

getPrimaryKeyColumns

public List<String> getPrimaryKeyColumns()

Returns the desired primary-key columns, or an empty list when none is declared.

getMaxStaleness

@Nullable
public Duration getMaxStaleness()

Returns the desired maximum staleness, or null when not setting a duration.

managesMaxStaleness

public boolean managesMaxStaleness()

Returns whether maximum staleness is explicitly managed by this contract.

clearsMaxStaleness

public boolean clearsMaxStaleness()

Returns whether the desired state has maximum staleness disabled.

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