Uses of Class
io.github.flink.gcp.connector.bigtable.TableDestination

Packages that use TableDestination

Package	Description
io.github.flink.gcp.connector.bigtable	Google Cloud Bigtable connector for Apache Flink.
io.github.flink.gcp.connector.bigtable.sink
io.github.flink.gcp.connector.bigtable.sink.tables
io.github.flink.gcp.connector.bigtable.sink.writer
io.github.flink.gcp.connector.bigtable.source
io.github.flink.gcp.connector.bigtable.source.changestream.enumerator
io.github.flink.gcp.connector.bigtable.source.changestream.reader
io.github.flink.gcp.connector.bigtable.source.readrows.enumerator
io.github.flink.gcp.connector.bigtable.source.readrows.reader
io.github.flink.gcp.connector.bigtable.table.sink
io.github.flink.gcp.connector.bigtable.table.source

Uses of TableDestination in io.github.flink.gcp.connector.bigtable

Methods in io.github.flink.gcp.connector.bigtable that return TableDestination

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

Methods in io.github.flink.gcp.connector.bigtable with parameters of type TableDestination

Modifier and Type	Method	Description
com.google.cloud.bigtable.data.v2.BigtableDataClient	LazyBigtableDataClient.get(TableDestination table)	Returns the client, building it on first use.
static com.google.cloud.bigtable.data.v2.BigtableDataSettings.Builder	BigtableDataClients.settings(TableDestination destination, String appProfileId, EmulatorEndpoint emulatorEndpoint, com.google.api.gax.core.CredentialsProvider credentialsOverride)	Builds the settings for a client that talks to a destination's instance.
com.google.cloud.bigtable.data.v2.BigtableDataSettings	LazyBigtableDataClient.settings(TableDestination table)	Builds the client settings.

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.sink

Methods in io.github.flink.gcp.connector.bigtable.sink that return TableDestination

Modifier and Type	Method	Description
TableDestination	FailedMutation.getDestination()	Returns the table the mutation was routed to.
TableDestination	FixedDestinationResolver.getDestination()	Returns the fixed destination.
TableDestination	DestinationResolver.resolve(T element, org.apache.flink.api.connector.sink2.SinkWriter.Context context)	Returns the destination table for the given record.
TableDestination	FixedDestinationResolver.resolve(Object element, org.apache.flink.api.connector.sink2.SinkWriter.Context context)

Methods in io.github.flink.gcp.connector.bigtable.sink with parameters of type TableDestination

Modifier and Type	Method	Description
static FailedMutation	FailedMutation.of(TableDestination destination, com.google.cloud.bigtable.data.v2.models.RowMutationEntry entry, String errorMessage, Throwable cause)	Creates a failed mutation.
BigtableSinkBuilder<T>	BigtableSinkBuilder.table(TableDestination table)	Writes every mutation to the given table.

Constructors in io.github.flink.gcp.connector.bigtable.sink with parameters of type TableDestination

Modifier	Constructor	Description
	FixedDestinationResolver(TableDestination destination)	Creates a resolver returning the given destination for every record.

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.sink.tables

Methods in io.github.flink.gcp.connector.bigtable.sink.tables with parameters of type TableDestination

Modifier and Type	Method	Description
TableAdmin.EnsureResult	BigtableTableAdmin.ensureTable(TableDestination destination, TableCreateOptions options)
TableAdmin.EnsureResult	TableAdmin.ensureTable(TableDestination destination, TableCreateOptions options)	Ensures the given table exists with every column family the options declare.

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.sink.writer

Methods in io.github.flink.gcp.connector.bigtable.sink.writer with parameters of type TableDestination

Modifier and Type	Method	Description
MutationBatcher	DefaultMutationBatcherFactory.create(TableDestination destination)
MutationBatcher	MutationBatcherFactory.create(TableDestination destination)	Creates the mutation batcher for one table.
void	DefaultMutationBatcherFactory.release(TableDestination destination)
void	MutationBatcherFactory.release(TableDestination destination)	Releases the factory's ownership associated with one successfully created batcher.

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.source

Methods in io.github.flink.gcp.connector.bigtable.source that return TableDestination

Modifier and Type	Method	Description
TableDestination	BigtableChangeStreamSourceConfig.getTable()	Returns the table whose change stream is read.
TableDestination	BigtableSourceConfig.getTable()	Returns the table being read.

Methods in io.github.flink.gcp.connector.bigtable.source with parameters of type TableDestination

Modifier and Type	Method	Description
BigtableChangeStreamSourceBuilder<T>	BigtableChangeStreamSourceBuilder.table(TableDestination table)	Sets the table whose change stream is read.
BigtableSourceBuilder<T>	BigtableSourceBuilder.table(TableDestination table)	Sets the table to read.

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.source.changestream.enumerator

Constructors in io.github.flink.gcp.connector.bigtable.source.changestream.enumerator with parameters of type TableDestination

Modifier	Constructor	Description
	DefaultChangeStreamCoordinatorClient(TableDestination table, String appProfileId)
	DefaultChangeStreamCoordinatorClient(TableDestination table, String appProfileId, com.google.api.gax.core.CredentialsProvider credentials)	Creates the client with the provider its owner loaded.
	DefaultChangeStreamCoordinatorClientFactory(TableDestination table, String appProfileId, String serviceAccountKeyFile)	Creates the factory.

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.source.changestream.reader

Methods in io.github.flink.gcp.connector.bigtable.source.changestream.reader with parameters of type TableDestination

Modifier and Type	Method	Description
void	ChangeStreamOpener.open(TableDestination table, ChangeStreamPartitionSplit split, Instant boundedTimestamp, com.google.api.gax.rpc.ResponseObserver<com.google.cloud.bigtable.data.v2.models.ChangeStreamRecord> observer)
void	DataClientChangeStreamOpener.open(TableDestination table, ChangeStreamPartitionSplit split, Instant boundedTimestamp, com.google.api.gax.rpc.ResponseObserver<com.google.cloud.bigtable.data.v2.models.ChangeStreamRecord> observer)

Constructors in io.github.flink.gcp.connector.bigtable.source.changestream.reader with parameters of type TableDestination

Modifier	Constructor	Description
	DefaultChangeStreamRestoreResolver(TableDestination table, String appProfileId)

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.source.readrows.enumerator

Methods in io.github.flink.gcp.connector.bigtable.source.readrows.enumerator with parameters of type TableDestination

Modifier and Type	Method	Description
List<RowKeySample>	DataClientRowKeySampler.sample(TableDestination table)
List<RowKeySample>	RowKeySampler.sample(TableDestination table)	Returns the sampled section boundaries of a table.

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.source.readrows.reader

Methods in io.github.flink.gcp.connector.bigtable.source.readrows.reader with parameters of type TableDestination

Modifier and Type	Method	Description
RowStream	DataClientRowStreamOpener.open(TableDestination table, com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange range, com.google.cloud.bigtable.data.v2.models.Filters.Filter filter)
RowStream	RowStreamOpener.open(TableDestination table, com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange range, com.google.cloud.bigtable.data.v2.models.Filters.Filter filter)	Opens a read over one range.

Constructors in io.github.flink.gcp.connector.bigtable.source.readrows.reader with parameters of type TableDestination

Modifier	Constructor	Description
	BigtableSplitReader(TableDestination table, RowStreamOpener opener, com.google.cloud.bigtable.data.v2.models.Filters.Filter filter, int maxRowsPerFetch, long maxBytesPerFetch, BigtableSourceReaderMetrics metrics)	Creates the split reader.

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.table.sink

Methods in io.github.flink.gcp.connector.bigtable.table.sink with parameters of type TableDestination

Modifier and Type	Method	Description
BigtableDynamicSink.Builder	BigtableDynamicSink.Builder.destination(TableDestination destination)

Uses of TableDestination in io.github.flink.gcp.connector.bigtable.table.source

Methods in io.github.flink.gcp.connector.bigtable.table.source with parameters of type TableDestination

Modifier and Type	Method	Description
BigtableChangeStreamDynamicSource.Builder	BigtableChangeStreamDynamicSource.Builder.destination(TableDestination destination)	Sets the table to read.
BigtableDynamicSource.Builder	BigtableDynamicSource.Builder.destination(TableDestination destination)