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

Interface CdcTableOptionsProvider

All Superinterfaces:
Serializable
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface @Experimental public interface CdcTableOptionsProvider extends Serializable
Supplies the desired CDC table contract for each destination.

The default-stream CDC path invokes it when a destination becomes active so the table can be created, verified, or reconciled before the appender opens. It is not invoked per record while that destination stays active.

  • Method Summary

    Modifier and Type
    Method
    Description
    CdcTableOptions
    optionsFor(TableDestination destination)
    Returns the CDC table options for the destination.

  • Method Details

    • optionsFor

      CdcTableOptions optionsFor(TableDestination destination)
      Returns the CDC table options for the destination.
      Parameters:
      destination - the destination table to create, verify, or reconcile
      Returns:
      the desired CDC table contract, never null