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

Class CdcTableOptions.Builder

java.lang.Object

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

Enclosing class:

CdcTableOptions

@Experimental
public static final class CdcTableOptions.Builder
extends Object

Builder for CdcTableOptions.

Method Summary

Modifier and Type	Method	Description
CdcTableOptions	build()	Builds the immutable options.
CdcTableOptions.Builder	clearMaxStaleness()	Disables maximum staleness on the destination table.
CdcTableOptions.Builder	maxStaleness(Duration maxStaleness)	Sets the maximum staleness BigQuery applies to CDC queries.
CdcTableOptions.Builder	primaryKeyColumns(List<String> columns)	Declares the columns of the unenforced primary key used by BigQuery CDC.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

primaryKeyColumns

public CdcTableOptions.Builder primaryKeyColumns(List<String> columns)

Declares the columns of the unenforced primary key used by BigQuery CDC.

maxStaleness

public CdcTableOptions.Builder maxStaleness(Duration maxStaleness)

Sets the maximum staleness BigQuery applies to CDC queries.

This overrides an earlier clearMaxStaleness() call.

clearMaxStaleness

public CdcTableOptions.Builder clearMaxStaleness()

Disables maximum staleness on the destination table.

This overrides an earlier maxStaleness(Duration) call.

build

public CdcTableOptions build()

Builds the immutable options.