Uses of Class
io.github.flink.gcp.connector.spanner.DatabaseDestination

Packages that use DatabaseDestination

Package	Description
io.github.flink.gcp.connector.spanner	Google Cloud Spanner connector for Apache Flink.
io.github.flink.gcp.connector.spanner.sink
io.github.flink.gcp.connector.spanner.sink.writer
io.github.flink.gcp.connector.spanner.source
io.github.flink.gcp.connector.spanner.source.batch.enumerator
io.github.flink.gcp.connector.spanner.source.batch.reader
io.github.flink.gcp.connector.spanner.source.changestream.enumerator
io.github.flink.gcp.connector.spanner.source.changestream.reader
io.github.flink.gcp.connector.spanner.table.sink
io.github.flink.gcp.connector.spanner.table.source

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner

Methods in io.github.flink.gcp.connector.spanner that return DatabaseDestination

Modifier and Type	Method	Description
static DatabaseDestination	DatabaseDestination.of(String project, String instance, String database)	Creates a DatabaseDestination from bare ids, not resource paths.

Methods in io.github.flink.gcp.connector.spanner with parameters of type DatabaseDestination

Modifier and Type	Method	Description
static com.google.cloud.spanner.Spanner	SpannerClients.open(DatabaseDestination database, com.google.cloud.spanner.SpannerOptions settings)	Opens a handle from settings already assembled by the owning runtime component.
static com.google.cloud.spanner.Spanner	SpannerClients.open(DatabaseDestination database, EmulatorEndpoint emulatorEndpoint, com.google.auth.Credentials credentialsOverride)	Opens a service handle for a database, with an optional runtime-loaded credential override.
static com.google.cloud.spanner.SpannerOptions	SpannerClients.settings(DatabaseDestination database, EmulatorEndpoint emulatorEndpoint)	Builds the client settings for a database.
static com.google.cloud.spanner.SpannerOptions	SpannerClients.settings(DatabaseDestination database, EmulatorEndpoint emulatorEndpoint, com.google.auth.Credentials credentialsOverride)	Builds client settings with an optional runtime-loaded credential override.

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.sink

Methods in io.github.flink.gcp.connector.spanner.sink that return DatabaseDestination

Modifier and Type	Method	Description
DatabaseDestination	FailedMutation.getDatabase()	Returns the database the mutation was routed to.
DatabaseDestination	SpannerSinkConfig.getDatabase()	Returns the database to write to.

Methods in io.github.flink.gcp.connector.spanner.sink with parameters of type DatabaseDestination

Modifier and Type	Method	Description
SpannerSinkBuilder<T>	SpannerSinkBuilder.database(DatabaseDestination database)	Sets the database to write to.
static FailedMutation	FailedMutation.of(DatabaseDestination database, com.google.cloud.spanner.Mutation mutation, String errorMessage, Throwable cause)	Creates a failed mutation.

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.sink.writer

Constructors in io.github.flink.gcp.connector.spanner.sink.writer with parameters of type DatabaseDestination

Modifier	Constructor	Description
	DefaultSpannerDatabaseAccessFactory(DatabaseDestination database, SpannerWriterOptions writerOptions, EmulatorEndpoint emulatorEndpoint)	Creates the factory.
	DefaultSpannerDatabaseAccessFactory(DatabaseDestination database, SpannerWriterOptions writerOptions, EmulatorEndpoint emulatorEndpoint, com.google.auth.Credentials credentialsOverride)	Creates the factory with credentials loaded by the writer runtime.

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.source

Methods in io.github.flink.gcp.connector.spanner.source that return DatabaseDestination

Modifier and Type	Method	Description
DatabaseDestination	SpannerChangeStreamSourceConfig.getDatabase()
DatabaseDestination	SpannerSourceConfig.getDatabase()	Returns the database to read.

Methods in io.github.flink.gcp.connector.spanner.source with parameters of type DatabaseDestination

Modifier and Type	Method	Description
SpannerChangeStreamSourceBuilder<T>	SpannerChangeStreamSourceBuilder.database(DatabaseDestination database)	Sets the database holding the change stream.
SpannerSourceBuilder<T>	SpannerSourceBuilder.database(DatabaseDestination database)	Sets the database to read.

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.source.batch.enumerator

Constructors in io.github.flink.gcp.connector.spanner.source.batch.enumerator with parameters of type DatabaseDestination

Modifier	Constructor	Description
	BatchClientPartitionPlanner(DatabaseDestination database, EmulatorEndpoint emulatorEndpoint)	Creates the planner.
	DefaultPartitionPlannerFactory(DatabaseDestination database, EmulatorEndpoint emulatorEndpoint)	Creates the factory.

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.source.batch.reader

Constructors in io.github.flink.gcp.connector.spanner.source.batch.reader with parameters of type DatabaseDestination

Modifier	Constructor	Description
	BatchClientStructStreamOpener(DatabaseDestination database, EmulatorEndpoint emulatorEndpoint)	Creates the opener.
	SpannerSplitReader(DatabaseDestination database, StructStreamOpener opener, int maxRowsPerFetch, long maxBytesPerFetch, SpannerSourceReaderMetrics metrics)	Creates the split reader.

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.source.changestream.enumerator

Constructors in io.github.flink.gcp.connector.spanner.source.changestream.enumerator with parameters of type DatabaseDestination

Modifier	Constructor	Description
	DefaultSpannerChangeStreamCoordinatorClientFactory(DatabaseDestination database, String changeStreamName, EmulatorEndpoint emulatorEndpoint)
	DefaultSpannerChangeStreamCoordinatorClientFactory(DatabaseDestination database, String changeStreamName, Duration absentRetentionFallback, EmulatorEndpoint emulatorEndpoint)
	DefaultSpannerChangeStreamCoordinatorClientFactory(DatabaseDestination database, String changeStreamName, Duration absentRetentionFallback, EmulatorEndpoint emulatorEndpoint, String serviceAccountKeyFile)

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.source.changestream.reader

Constructors in io.github.flink.gcp.connector.spanner.source.changestream.reader with parameters of type DatabaseDestination

Modifier	Constructor	Description
	DefaultSpannerChangeStreamQueryClientFactory(DatabaseDestination database, String changeStreamName, SpannerRpcPriority rpcPriority, int maxConcurrentQueries, EmulatorEndpoint emulatorEndpoint)
	DefaultSpannerChangeStreamQueryClientFactory(DatabaseDestination database, String changeStreamName, SpannerRpcPriority rpcPriority, int maxConcurrentQueries, EmulatorEndpoint emulatorEndpoint, String serviceAccountKeyFile)

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.table.sink

Methods in io.github.flink.gcp.connector.spanner.table.sink with parameters of type DatabaseDestination

Modifier and Type	Method	Description
SpannerDynamicSink.Builder	SpannerDynamicSink.Builder.database(DatabaseDestination database)

Uses of DatabaseDestination in io.github.flink.gcp.connector.spanner.table.source

Constructors in io.github.flink.gcp.connector.spanner.table.source with parameters of type DatabaseDestination

Modifier	Constructor	Description
	SpannerDynamicSource(SpannerTableSchemaConverter schema, DatabaseDestination database, String table, org.apache.flink.table.types.DataType producedDataType, org.apache.flink.configuration.ReadableConfig config)
	SpannerDynamicSource(SpannerTableSchemaConverter schema, DatabaseDestination database, String table, org.apache.flink.table.types.DataType producedDataType, org.apache.flink.configuration.ReadableConfig config, SpannerTableLineage lineage)