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.conditional
io.github.flink.gcp.connector.bigtable.sink.mutaterows.writer
io.github.flink.gcp.connector.bigtable.sink.readmodifywrite
io.github.flink.gcp.connector.bigtable.sink.singlerow
io.github.flink.gcp.connector.bigtable.sink.singlerow.writer
io.github.flink.gcp.connector.bigtable.sink.tables
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 String	BigtableDataClients.instanceKey(TableDestination destination)	Returns the key under which every client pool shares one client per instance: the project and instance a destination names, in the one spelling the pools and the per-instance bookkeeping all 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.
static org.apache.flink.streaming.api.lineage.SourceLineageVertex	BigtableLineage.source(TableDestination table, org.apache.flink.api.connector.source.Boundedness boundedness, String logicalName)	Reports the configured table with the source's actual boundedness.

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
	BigtableMutateRowsSink(BigtableSinkConfig<T> config, TableDestination initialDestination, TableCreateOptions expectedFamilies)	Creates a Table sink that validates its fixed destination when its writer starts.
	FixedDestinationResolver(TableDestination destination)	Creates a resolver returning the given destination for every record.

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

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

Modifier and Type	Method	Description
TableDestination	ConditionalResult.getDestination()	Returns the destination resolved before serialization, without resolving it again.

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

Modifier and Type	Method	Description
BigtableConditionalAsyncBuilder<T>	BigtableConditionalAsyncBuilder.table(TableDestination table)	Writes to one table; this and destinationResolver are last-writer-wins.
BigtableConditionalSinkBuilder<T>	BigtableConditionalSinkBuilder.table(TableDestination table)	Writes to one table; this and destinationResolver are last-writer-wins.

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

Modifier	Constructor	Description
	ConditionalResult(TableDestination destination, com.google.protobuf.ByteString rowKey, boolean predicateMatched, boolean selectedBranchHasMutations)	Creates a successful response value.

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

Methods in io.github.flink.gcp.connector.bigtable.sink.mutaterows.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	BigtableWriter.prepareTable(TableDestination destination, TableCreateOptions expected)	Checks a fixed aggregate Table destination before the writer admits any records.
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.sink.readmodifywrite

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

Modifier and Type	Method	Description
TableDestination	ReadModifyWriteResult.getDestination()	Returns the actual destination.

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

Modifier and Type	Method	Description
BigtableReadModifyWriteAsyncBuilder<T>	BigtableReadModifyWriteAsyncBuilder.table(TableDestination table)	Writes to one table; this and destinationResolver are last-writer-wins.
BigtableReadModifyWriteSinkBuilder<T>	BigtableReadModifyWriteSinkBuilder.table(TableDestination table)	Writes to one table; this and destinationResolver are last-writer-wins.

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

Modifier	Constructor	Description
	ReadModifyWriteResult(TableDestination destination, BigtableRow row)	Creates an immutable result from a successful request.

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

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

Modifier and Type	Method	Description
TableDestination	BigtableCommittable.getDestination()	Returns the original resolved destination.
TableDestination	FailedRequest.getDestination()	Returns the table the request was routed to.

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

Modifier and Type	Method	Description
static FailedRequest	FailedRequest.of(TableDestination destination, RowOperation operation, com.google.protobuf.ByteString rowKey, String errorMessage, Throwable cause)	Creates a failed request.
static BigtableCommittable	BigtableCommittable.stage(TableDestination destination, String profile, String family, com.google.bigtable.v2.MutateRowsRequest.Entry entry, SecureRandom random)	Freezes a serialized input and creates its random identity exactly once.

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

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

Modifier and Type	Method	Description
protected abstract TableDestination	BigtableRequestFunction.destination(IN input)	Names the table an input's request goes to.

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

Modifier and Type	Method	Description
SingleRowClient	DefaultSingleRowClientFactory.create(TableDestination destination)
SingleRowClient	SingleRowClientFactory.create(TableDestination destination)	Leases a client for a table, building its instance's client on the instance's first lease.
DestinationMetrics.Counters	SingleRowRequestMetrics.forTable(TableDestination destination)	Returns a table's counters, registering them on first use; a no-op when per-table counters are off.
static IOException	RequestFailures.jobFailure(RequestFailures.Kind kind, RowOperation operation, TableDestination destination, Throwable throwable)	Wraps a failure that fails the job — an ambiguous or a fatal one — in the message its class calls for.
void	DefaultSingleRowClientFactory.release(TableDestination destination)
void	SingleRowClientFactory.release(TableDestination destination)	Releases a table's lease; the instance's client closes once no table holds it.
protected abstract OUT	BigtableRequestFunction.result(IN input, R answer, TableDestination destination, RowRequest<R> request)	Maps an answered request to the output.
com.google.api.core.ApiFuture<Boolean>	CheckAndMutateRowRequest.start(SingleRowClient client, TableDestination destination)
com.google.api.core.ApiFuture<BigtableRow>	ReadModifyWriteRowRequest.start(SingleRowClient client, TableDestination destination)
com.google.api.core.ApiFuture<R>	RowRequest.start(SingleRowClient client, TableDestination destination)	Issues the request against the table.

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.
void	BigtableStagedTableAdmin.validate(TableDestination destination, String profile, String markerFamily, Map<String,ColumnFamilyType> expectedFamilies)
void	StagedTableAdmin.validate(TableDestination destination, String profile, String markerFamily, Map<String,ColumnFamilyType> expectedFamilies)	Rejects incompatible routing, marker retention or declared data families before sending.
void	BigtableTableAdmin.validateFamilies(TableDestination destination, Map<String,ColumnFamilyType> expected, boolean allowMissing)
void	TableAdmin.validateFamilies(TableDestination destination, Map<String,ColumnFamilyType> expected, boolean allowMissing)	Checks declared existing family types without changing the table.

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)