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.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.