Package io.github.flink.gcp.connector.spanner.source
package io.github.flink.gcp.connector.spanner.source
-
ClassDescriptionFLIP-27 source for Cloud Spanner Change Streams.Builds a
SpannerChangeStreamSource.Immutable configuration assembled bySpannerChangeStreamSourceBuilder.What the batch source reads: either a query, or a table with its columns and key set, optionally through an index.Internal bridge between a table-layer deferred read and the batch partition planner.Resolves a table-layer read after the batch transaction has selected its snapshot.Reads rows from a Cloud Spanner database.Builds aSpannerSource.Everything the batch source was built with, assembled by the builder and carried into the job graph.