Package io.github.flink.gcp.connector.spanner.table
package io.github.flink.gcp.connector.spanner.table
-
ClassDescriptionThe relational changelog emitted from Spanner data-change records.A Table API spelling for one shared Change Streams start position.Maps Table API startup options to the shared change-stream start position.Applies Table API option values to DataStream builder setters, renaming a rejected value's failure to the option key the SQL caller actually wrote (issue #1030, ADR-0133).The Spanner read path selected by a table DDL.The
WITHoptions of thespannertable connector.Creates thespannertable source and sink from a SQL DDL.Lookup options owned by the Spanner table source.Immutable physical identities carried from the Table factory to its runtime providers.The physical DDL schema and its corresponding native Spanner types.One physical column.Parses the table layer's string carrier as a native Spanner UUID value.