Package io.github.flink.gcp.connector.spanner
package io.github.flink.gcp.connector.spanner
Google Cloud Spanner connector for Apache Flink.
-
ClassDescriptionA fully-qualified Spanner database reference: project, instance and database.The Spanner client's own metrics, registered as
rpcMethod.METHOD.leafon a component's metric group through aClientMetrics.Builds the Spanner service handle both directions of this connector open.Loads credentials shared by every direction of this connector: the sink writer, the bounded source's planner and readers, the Change Streams coordinator and query clients, and the table lookup path.Every metric name this connector registers, in one place.A table's schema and name as one Flink object name: the default schema's tables unqualified, a named schema's asschema.table, each part in the dialect's canonical quoting.The priority Spanner schedules this connector's requests at.A table name as rendered for Spanner APIs and compared withINFORMATION_SCHEMA.The name of one table-local access path, such as an index.A column's type asINFORMATION_SCHEMA.COLUMNS.SPANNER_TYPEspells it, parsed into the kind the connector's type mapping is written in.The scalar kinds of the connector's type mapping, plus the two that are not mapped.