Uses of Class
io.debezium.relational.TableId

Packages that use TableId

Package	Description
io.debezium.config
io.debezium.jdbc
io.debezium.pipeline
io.debezium.pipeline.meters
io.debezium.pipeline.metrics
io.debezium.pipeline.notification
io.debezium.pipeline.signal.actions
io.debezium.pipeline.source.snapshot.chunked
io.debezium.pipeline.source.snapshot.incremental
io.debezium.pipeline.source.spi
io.debezium.processors.reselect
io.debezium.relational
io.debezium.relational.ddl
io.debezium.relational.history
io.debezium.relational.mapping
io.debezium.schema

Uses of TableId in io.debezium.config

Fields in io.debezium.config with type parameters of type TableId

Modifier and Type	Field	Description
private final List<TableId>	CommonConnectorConfig.signalingDataCollectionIds

Methods in io.debezium.config that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	CommonConnectorConfig.getSignalingDataCollectionTableIds()

Methods in io.debezium.config with parameters of type TableId

Modifier and Type	Method	Description
int	CommonConnectorConfig.getSnapshotMaxThreadsTableMultiplierAsInteger(TableId tableId)

Uses of TableId in io.debezium.jdbc

Methods in io.debezium.jdbc that return TableId

Modifier and Type	Method	Description
TableId	JdbcConnection.createTableId(String databaseName, String schemaName, String tableName)

Methods in io.debezium.jdbc that return types with arguments of type TableId

Modifier and Type	Method	Description
Set<TableId>	JdbcConnection.getAllTableIds(String catalogName)	Retrieves all TableIds in a given database catalog, mainly used to determine then the captured table.
protected Map<TableId,List<Attribute>>	JdbcConnection.getAttributeDetails(TableId tableId, String tableType)
protected Map<TableId,List<Column>>	JdbcConnection.getColumnsDetails(String catalogName, String schemaName, String tableName, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, DatabaseMetaData metadata, Set<TableId> viewIds)
protected Map<TableId,List<Column>>	JdbcConnection.getColumnsDetails(String catalogName, String schemaName, String tableName, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, DatabaseMetaData metadata, Set<TableId> viewIds, boolean throwOnCaseInsensitiveColumnMismatch)
Set<TableId>	JdbcConnection.readAllTableNames(String[] tableTypes)	Get the identifiers of all available tables.
Set<TableId>	JdbcConnection.readTableNames(String catalogName, String schemaName, String tableNamePattern, String[] tableTypes)	Get the identifiers of the tables.

Methods in io.debezium.jdbc with parameters of type TableId

Modifier and Type	Method	Description
String	JdbcConnection.buildSelectPrimaryKeyBoundaries(TableId tableId, long size, String projection, String orderBy)
String	JdbcConnection.buildSelectWithRowLimits(TableId tableId, int limit, String projection, Optional<String> condition, Optional<String> additionalCondition, String orderBy)
String	JdbcConnection.buildSelectWithRowLimits(TableId tableId, int limit, String projection, Optional<String> condition, Optional<String> additionalCondition, String orderBy, Optional<String> tableAlias)
protected Map<TableId,List<Attribute>>	JdbcConnection.getAttributeDetails(TableId tableId, String tableType)
String	JdbcConnection.getQualifiedTableName(TableId tableId)
String	JdbcConnection.quotedTableIdString(TableId tableId)	Converts a table id into a string with all components of the id quoted so non-alphanumeric characters are properly handled.
List<String>	JdbcConnection.readPrimaryKeyNames(DatabaseMetaData metadata, TableId id)
protected List<String>	JdbcConnection.readPrimaryKeyOrUniqueIndexNames(DatabaseMetaData metadata, TableId id)
protected Optional<ColumnEditor>	JdbcConnection.readTableColumn(ResultSet columnMetadata, TableId tableId, Tables.ColumnNameFilter columnFilter)	Returns a ColumnEditor representing the current record of the given result set of column metadata, if included in column.include.list.
List<String>	JdbcConnection.readTableUniqueIndices(DatabaseMetaData metadata, TableId id)
protected boolean	JdbcConnection.reselectColumns(String query, TableId tableId, List<String> columns, List<Object> bindValues, JdbcConnection.ResultSetConsumer resultConsumer)

Method parameters in io.debezium.jdbc with type arguments of type TableId

Modifier and Type	Method	Description
protected Map<TableId,List<Column>>	JdbcConnection.getColumnsDetails(String catalogName, String schemaName, String tableName, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, DatabaseMetaData metadata, Set<TableId> viewIds)
protected Map<TableId,List<Column>>	JdbcConnection.getColumnsDetails(String catalogName, String schemaName, String tableName, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, DatabaseMetaData metadata, Set<TableId> viewIds, boolean throwOnCaseInsensitiveColumnMismatch)

Uses of TableId in io.debezium.pipeline

Method parameters in io.debezium.pipeline with type arguments of type TableId

Modifier and Type	Method	Description
void	GuardrailValidator.validate(Set<TableId> allTableIds)	Validates guardrail limits for table-based connectors.

Uses of TableId in io.debezium.pipeline.meters

Methods in io.debezium.pipeline.meters with parameters of type TableId

Modifier and Type	Method	Description
void	SnapshotMeter.chunkProgress(TableId tableId, long totalChunks, long completedChunks)
void	SnapshotMeter.rowsScanned(TableId tableId, long numRows)

Uses of TableId in io.debezium.pipeline.metrics

Methods in io.debezium.pipeline.metrics with parameters of type TableId

Modifier and Type	Method	Description
void	DefaultSnapshotChangeEventSourceMetrics.chunkProgress(P partition, TableId tableId, long totalChunks, long completedChunks)
void	DefaultSnapshotChangeEventSourceMetrics.rowsScanned(P partition, TableId tableId, long numRows)

Uses of TableId in io.debezium.pipeline.notification

Method parameters in io.debezium.pipeline.notification with type arguments of type TableId

Modifier and Type	Method	Description
<T extends io.debezium.spi.schema.DataCollectionId> void	InitialSnapshotNotificationService.notifyCompletedTableChunkSuccessfully(P partition, OffsetContext offsetContext, String currentCollection, int chunkIndex, int totalChunks, Set<TableId> tables)
<T extends io.debezium.spi.schema.DataCollectionId> void	InitialSnapshotNotificationService.notifyCompletedTableSuccessfully(P partition, OffsetContext offsetContext, String currentCollection, long totalRowsScanned, Set<TableId> tables)
<T extends io.debezium.spi.schema.DataCollectionId> void	InitialSnapshotNotificationService.notifyTableInProgress(P partition, OffsetContext offsetContext, String currentCollection, Set<TableId> tables)

Uses of TableId in io.debezium.pipeline.signal.actions

Fields in io.debezium.pipeline.signal.actions with type parameters of type TableId

Modifier and Type	Field	Description
private final EventDispatcher<P,TableId>	SchemaChanges.dispatcher

Uses of TableId in io.debezium.pipeline.source.snapshot.chunked

Fields in io.debezium.pipeline.source.snapshot.chunked declared as TableId

Modifier and Type	Field	Description
private final TableId	SnapshotChunk.tableId
private final TableId	TableChunkProgress.tableId

Methods in io.debezium.pipeline.source.snapshot.chunked that return TableId

Modifier and Type	Method	Description
TableId	SnapshotChunk.getTableId()
TableId	TableChunkProgress.getTableId()

Methods in io.debezium.pipeline.source.snapshot.chunked with parameters of type TableId

Modifier and Type	Method	Description
private Object[]	ChunkBoundaryCalculator.queryBoundaryAtPosition(TableId tableId, String keyColumnNames, List<Column> keyColumns, long position)

Constructors in io.debezium.pipeline.source.snapshot.chunked with parameters of type TableId

Modifier	Constructor	Description
	SnapshotChunk(TableId tableId, Table table, Object[] lowerBounds, Object[] upperBounds, int chunkIndex, int totalChunks, int tableOrder, int tableCount, String baseSelectStatement, OptionalLong estimatedRowCount)
	TableChunkProgress(TableId tableId, int totalChunks)

Uses of TableId in io.debezium.pipeline.source.snapshot.incremental

Methods in io.debezium.pipeline.source.snapshot.incremental that return TableId

Modifier and Type	Method	Description
TableId	AbstractIncrementalSnapshotContext.getPredicateBasedTableIdForId(TableId id)
TableId	AbstractIncrementalSnapshotContext.getPredicateBasedTableIdForString(String id)

Methods in io.debezium.pipeline.source.snapshot.incremental with parameters of type TableId

Modifier and Type	Method	Description
protected void	AbstractIncrementalSnapshotChangeEventSource.createAndDispatchSchemaChangeEvent(Table newTable, P partition, OffsetContext offsetContext, TableId tableId)	Creates and dispatches a schema change event for the given table.
TableId	AbstractIncrementalSnapshotContext.getPredicateBasedTableIdForId(TableId id)
protected String	AbstractIncrementalSnapshotChangeEventSource.getTableDDL(TableId tableId)
protected Table	AbstractIncrementalSnapshotChangeEventSource.readSchemaForTable(TableId tableId)	Reads the schema for the specified table ID.
private void	AbstractIncrementalSnapshotChangeEventSource.retrieveAndRefreshSchema(TableId tableId, P partition, OffsetContext offsetContext)

Uses of TableId in io.debezium.pipeline.source.spi

Methods in io.debezium.pipeline.source.spi with parameters of type TableId

Modifier and Type	Method	Description
void	SnapshotProgressListener.chunkProgress(P partition, TableId tableId, long totalChunks, long completedChunks)
void	SnapshotProgressListener.rowsScanned(P partition, TableId tableId, long numRows)

Uses of TableId in io.debezium.processors.reselect

Methods in io.debezium.processors.reselect that return TableId

Modifier and Type	Method	Description
private TableId	ReselectColumnsPostProcessor.getTableIdFromSource(org.apache.kafka.connect.data.Struct source)

Methods in io.debezium.processors.reselect with parameters of type TableId

Modifier and Type	Method	Description
private Object	ReselectColumnsPostProcessor.getConvertedValue(TableId tableId, Column column, org.apache.kafka.connect.data.Field field, Object value)
private List<String>	ReselectColumnsPostProcessor.getRequiredColumnSelections(TableId tableId, org.apache.kafka.connect.data.Struct after)

Uses of TableId in io.debezium.relational

Fields in io.debezium.relational declared as TableId

Modifier and Type	Field	Description
private final TableId	ChangeTable.changeTableId
private TableId	NoOpTableEditorImpl.id
private TableId	TableEditorImpl.id
private final TableId	TableImpl.id
private final TableId	TableSchema.id
private final TableId	RelationalSnapshotChangeEventSource.signalDataCollectionTableId
private final TableId	ChangeTable.sourceTableId
private final TableId	ColumnId.tableId

Fields in io.debezium.relational with type parameters of type TableId

Modifier and Type	Field	Description
private io.debezium.util.BoundedConcurrentHashMap<TableId,V>	AbstractCachedTableMappingStorage.cache
private final ConcurrentMap<TableId,Boolean>	Tables.CachingTableFilter.cache
Set<TableId>	RelationalSnapshotChangeEventSource.RelationalSnapshotContext.capturedSchemaTables
Set<TableId>	RelationalSnapshotChangeEventSource.RelationalSnapshotContext.capturedTables
protected final EventDispatcher<P,TableId>	RelationalSnapshotChangeEventSource.dispatcher
private final Map<TableId,RelationalSnapshotChangeEventSource.SnapshotSelect>	RelationalSnapshotChangeEventSource.PreparedTables.queryTables	The field for the queryTables record component.
private final Map<TableId,OptionalLong>	RelationalSnapshotChangeEventSource.PreparedTables.rowCountTables	The field for the rowCountTables record component.
private final ConcurrentMap<TableId,V>	ConcurrentMapTableMappingStorage.storage
private Predicate<TableId>	Selectors.TableSelectionPredicateBuilder.tableExclusions
private Predicate<TableId>	Selectors.TableSelectionPredicateBuilder.tableInclusions
private final io.debezium.spi.topic.TopicNamingStrategy<TableId>	RelationalDatabaseSchema.topicNamingStrategy
private final Set<TableId>	Tables.TableIds.values

Methods in io.debezium.relational that return TableId

Modifier and Type	Method	Description
TableId	ChangeTable.getChangeTableId()
TableId	ChangeTable.getSourceTableId()
abstract TableId	ColumnFilterMode.getTableIdForFilter(String catalog, String schema, String table)
TableId	Table.id()	Get the identifier for this table.
TableId	TableImpl.id()
TableId	TableSchema.id()
protected TableId	AbstractCachedTableMappingStorage.normalizeTableId(TableId tableId)	Normalizes the table identifier based on case sensitivity settings.
private TableId	ConcurrentMapTableMappingStorage.normalizeTableId(TableId tableId)	Normalizes the table identifier based on case sensitivity settings.
static TableId	TableId.parse(String str)	Parse the supplied string, extracting up to the first 3 parts into a TableID.
protected static TableId	TableId.parse(String[] parts, int numParts, boolean useCatalogBeforeSchema)	Parse the supplied string, extracting up to the first 3 parts into a TableID.
static TableId	TableId.parse(String str, boolean useCatalogBeforeSchema)	Parse the supplied string, extracting up to the first 3 parts into a TableID.
static TableId	TableId.parse(String str, boolean useCatalogBeforeSchema, TableIdPredicates predicates)	Parse the supplied string, extracting up to the first 3 parts into a TableID.
static TableId	TableId.parse(String str, TableIdPredicates predicates)	Parse the supplied string, extracting up to the first 3 parts into a TableID.
TableId	ColumnId.tableId()	Get the identifier for the table that owns this column.
TableId	NoOpTableEditorImpl.tableId()
TableId	TableEditor.tableId()	Get the identifier for this table.
TableId	TableEditorImpl.tableId()
TableId	TableId.toBracketQuoted()	Returns a new TableId with all parts of the identifier enclosed in [ and ] character.
TableId	TableId.toDoubleQuoted()	Returns a new TableId with all parts of the identifier using " character.
TableId	TableId.toLowercase()
private TableId	Tables.TableIds.toLowerCaseIfNeeded(TableId tableId)
TableId	TableId.toQuoted(char openingChar, char closingChar)	Returns a new TableId that has all parts of the identifier quoted.

Methods in io.debezium.relational that return types with arguments of type TableId

Modifier and Type	Method	Description
private Set<TableId>	RelationalSnapshotChangeEventSource.addSignalingCollectionAndSort(Set<TableId> capturedTables)
Predicate<TableId>	Selectors.TableSelectionPredicateBuilder.build()	Build the Predicate that determines whether a table identified by a given TableId is to be included.
private Predicate<TableId>	Selectors.TableSelectionPredicateBuilder.buildStartingFromDbFilter(Predicate<String> dbFilter, Predicate<String> schemaFilter, Predicate<TableId> tableFilter)
private Predicate<TableId>	Selectors.TableSelectionPredicateBuilder.buildStartingFromSchemaFilter(Predicate<String> schemaFilter, Predicate<TableId> tableFilter)
Collection<TableId>	RelationalDatabaseSchema.dataCollectionIds()
Set<TableId>	Tables.drainChanges()
static Map<TableId,Predicate<Column>>	ColumnId.filter(String columnExcludeList)	Create the map of predicate functions that specify which columns are to be included.
protected abstract Set<TableId>	RelationalSnapshotChangeEventSource.getAllTableIds(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext)	Returns all candidate tables; the current filter configuration will be applied to the result set, resulting in the effective set of captured tables.
protected Collection<TableId>	RelationalSnapshotChangeEventSource.getTablesForSchemaChange(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext)
Set<TableId>	Tables.TablesById.ids()
abstract Set<TableId>	AbstractCachedTableMappingStorage.keySet()
Set<TableId>	ConcurrentMapTableMappingStorage.keySet()
Set<TableId>	TableMappingStorage.keySet()	Returns a set view of the table identifiers contained in this storage.
Map<TableId,RelationalSnapshotChangeEventSource.SnapshotSelect>	RelationalSnapshotChangeEventSource.PreparedTables.queryTables()	Returns the value of the queryTables record component.
Map<TableId,OptionalLong>	RelationalSnapshotChangeEventSource.PreparedTables.rowCountTables()	Returns the value of the rowCountTables record component.
private Map<TableId,OptionalLong>	RelationalSnapshotChangeEventSource.sortByRowCount(Map<TableId,OptionalLong> rowCountTables, RelationalDatabaseConnectorConfig.SnapshotTablesRowCountOrder order)
Set<TableId>	RelationalDatabaseSchema.tableIds()	Returns the set of table ids included in the current filter configuration.
Set<TableId>	Tables.tableIds()	Get the set of TableIds for which there is a Schema.
Set<TableId>	Tables.TableIds.toSet()
private Stream<TableId>	RelationalSnapshotChangeEventSource.toTableIds(Set<TableId> tableIds, Pattern pattern)

Methods in io.debezium.relational with parameters of type TableId

Modifier and Type	Method	Description
void	Tables.TableIds.add(TableId tableId)
protected boolean	RelationalSnapshotChangeEventSource.additionalColumnFilter(P partition, TableId tableId, String columnName)	Additional filter handling for preparing column names for snapshot select
private static String	ColumnId.columnId(TableId tableId, String columnName)
int	TableId.compareTo(TableId that)
int	TableId.compareToIgnoreCase(TableId that)
protected ValueConverter[]	TableSchemaBuilder.convertersForColumns(org.apache.kafka.connect.data.Schema schema, TableId tableId, List<Column> columns, ColumnMappers mappers)	Obtain the array of converters for each column in a row.
protected StructGenerator	TableSchemaBuilder.createKeyGenerator(org.apache.kafka.connect.data.Schema schema, TableId columnSetName, List<Column> columns, io.debezium.spi.topic.TopicNamingStrategy topicNamingStrategy)	Creates the function that produces a Kafka Connect key object for a row of data.
protected ValueConverter	TableSchemaBuilder.createValueConverterFor(TableId tableId, Column column, org.apache.kafka.connect.data.Field fieldDefn)	Create a ValueConverter that can be used to convert row values for the given column into the Kafka Connect value object described by the field definition.
protected StructGenerator	TableSchemaBuilder.createValueGenerator(org.apache.kafka.connect.data.Schema schema, TableId tableId, List<Column> columns, Tables.ColumnNameFilter filter, ColumnMappers mappers)	Creates the function that produces a Kafka Connect value object for a row of data.
private RelationalSnapshotChangeEventSource.SnapshotSelect	RelationalSnapshotChangeEventSource.determineSnapshotSelect(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, TableId tableId, Map<io.debezium.spi.schema.DataCollectionId,String> snapshotSelectOverridesByTable)	Returns a valid query string for the specified table, either given by the user via snapshot select overrides or defaulting to a statement provided by the DB-specific change event source.
TableEditor	Tables.editOrCreateTable(TableId tableId)	Obtain an editor for the table with the given ID.
TableEditor	Tables.editTable(TableId tableId)	Obtain an editor for the table with the given ID.
private void	RelationalSnapshotChangeEventSource.emitRecordWithCoordination(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, O offset, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, SnapshotChunk chunk, TableChunkProgress progress, SnapshotProgress snapshotProgress, TableId tableId, Object[] row, Instant sourceTableSnapshotTimestamp, boolean isFirstRecord, boolean isLastRecord)	Emits a record with proper coordination to ensure correct snapshot marker ordering.
protected String	RelationalSnapshotChangeEventSource.enhanceOverriddenSelect(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, String overriddenSelect, TableId tableId)	This method is overridden for Oracle to implement "as of SCN" predicate
Table	Tables.forTable(TableId tableId)	Obtain the definition of the identified table.
private String	CustomConverterRegistry.fullColumnName(TableId table, Column column)
V	AbstractCachedTableMappingStorage.get(TableId tableId)
V	ConcurrentMapTableMappingStorage.get(TableId tableId)
TableSchema	RelationalDatabaseSchema.SchemasByTableId.get(TableId tableId)
V	TableMappingStorage.get(TableId tableId)	Retrieves the value associated with the given table identifier.
Table	Tables.TablesById.get(TableId tableId)
protected ChangeRecordEmitter<P>	RelationalSnapshotChangeEventSource.getChangeRecordEmitter(P partition, O offset, TableId tableId, Object[] row, Instant timestamp)	Returns a ChangeRecordEmitter producing the change records for the given table row.
protected abstract V	AbstractCachedTableMappingStorage.getFromStorage(TableId tableId)	Retrieves a value from the underlying storage.
protected Optional<String>	RelationalSnapshotChangeEventSource.getSnapshotConnectionFirstSelect(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, TableId tableId)
protected abstract Optional<String>	RelationalSnapshotChangeEventSource.getSnapshotSelect(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, TableId tableId, List<String> columns)	Returns the SELECT statement to be used for scanning the given table or empty value if the table will be streamed from but not snapshotted
protected String	RelationalSnapshotChangeEventSource.getSnapshotSelectOverridesByTable(TableId tableId, Map<io.debezium.spi.schema.DataCollectionId,String> snapshotSelectOverrides)
protected Instant	RelationalSnapshotChangeEventSource.getSnapshotSourceTimestamp(JdbcConnection jdbcConnection, O offset, TableId tableId)	For the given table gets source.ts_ms value from the database for snapshot data!
Optional<ValueConverter>	CustomConverterRegistry.getValueConverter(TableId table, Column column)	Obtain a pre-registered converter for a given column.
boolean	Tables.CachingTableFilter.isIncluded(TableId tableId)
boolean	Tables.TableFilter.isIncluded(TableId tableId)	Determines whether the given table should be included in the current DatabaseSchema.
static TableEditor	TableEditor.noOp(TableId id)	Create a new editor that does nothing.
protected TableId	AbstractCachedTableMappingStorage.normalizeTableId(TableId tableId)	Normalizes the table identifier based on case sensitivity settings.
private TableId	ConcurrentMapTableMappingStorage.normalizeTableId(TableId tableId)	Normalizes the table identifier based on case sensitivity settings.
Table	Tables.overwriteTable(TableId tableId, List<Column> columnDefs, List<String> primaryKeyColumnNames, String defaultCharsetName, List<Attribute> attributes)	Add or update the definition for the identified table.
private Object	TableSchemaBuilder.parseDefaultValue(TableId tableId, Column column)
V	AbstractCachedTableMappingStorage.put(TableId tableId, V value)
V	ConcurrentMapTableMappingStorage.put(TableId tableId, V value)
TableSchema	RelationalDatabaseSchema.SchemasByTableId.put(TableId tableId, TableSchema updated)
V	TableMappingStorage.put(TableId tableId, V value)	Associates the specified value with the specified table identifier.
Table	Tables.TablesById.put(TableId tableId, Table updated)
protected abstract void	AbstractCachedTableMappingStorage.putToStorage(TableId tableId, V value)	Stores a value in the underlying storage.
protected void	RelationalDatabaseSchema.refreshSchema(TableId id)
Optional<org.apache.kafka.connect.data.SchemaBuilder>	CustomConverterRegistry.registerConverterFor(TableId table, Column column, Object defaultValue)	Create and register a converter for a given database column.
V	AbstractCachedTableMappingStorage.remove(TableId tableId)
V	ConcurrentMapTableMappingStorage.remove(TableId tableId)
TableSchema	RelationalDatabaseSchema.SchemasByTableId.remove(TableId tableId)
V	TableMappingStorage.remove(TableId tableId)	Removes the mapping for the specified table identifier.
Table	Tables.TablesById.remove(TableId tableId)
protected abstract void	AbstractCachedTableMappingStorage.removeFromStorage(TableId tableId)	Removes a value from the underlying storage.
protected void	RelationalDatabaseSchema.removeSchema(TableId id)
Table	Tables.removeTable(TableId tableId)	Remove the definition of the identified table.
Table	Tables.renameTable(TableId existingTableId, TableId newTableId)	Rename an existing table.
protected OptionalLong	RelationalSnapshotChangeEventSource.rowCountForTable(TableId tableId)	If connector is able to provide statistics-based number of records per table.
protected Long	RelationalSnapshotChangeEventSource.rowCountForTableChunked(TableId tableId)
TableSchema	RelationalDatabaseSchema.schemaFor(TableId id)	Get the Schema information for the table with the given identifier, if that table exists and is included by the filter configuration.
Table	RelationalDatabaseSchema.tableFor(TableId id)	Get the Table meta-data for the table with the given identifier, if that table exists and is included by the filter configuration
TableEditor	NoOpTableEditorImpl.tableId(TableId id)
TableEditor	TableEditor.tableId(TableId tableId)	Set the table identifier.
TableEditor	TableEditorImpl.tableId(TableId id)
private TableId	Tables.TableIds.toLowerCaseIfNeeded(TableId tableId)
String	Selectors.TableIdToStringMapper.toString(TableId tableId)
Table	Tables.updateTable(TableId tableId, Function<Table,Table> changer)	Add or update the definition for the identified table.
private void	TableSchemaBuilder.validateIncomingRowToInternalMetadata(TableId tableId, int[] recordIndexes, org.apache.kafka.connect.data.Field[] fields, ValueConverter[] converters, Object[] row, int position)
private ValueConverter	TableSchemaBuilder.wrapInMappingConverterIfNeeded(ColumnMappers mappers, TableId tableId, Column column, ValueConverter converter)

Method parameters in io.debezium.relational with type arguments of type TableId

Modifier and Type	Method	Description
private Set<TableId>	RelationalSnapshotChangeEventSource.addSignalingCollectionAndSort(Set<TableId> capturedTables)
protected Callable<Void>	RelationalSnapshotChangeEventSource.createDataEventsForChunkedTableCallable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, SnapshotChunk chunk, Map<TableId,TableChunkProgress> progressMap, SnapshotProgress snapshotProgress, Queue<JdbcConnection> connectionPool, Queue<O> offsets)
protected Callable<Void>	RelationalSnapshotChangeEventSource.createDataEventsForTableCallable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, Table table, boolean firstTable, boolean lastTable, int tableOrder, int tableCount, String selectStatement, OptionalLong rowCount, Set<TableId> rowCountTablesKeySet, Queue<JdbcConnection> connectionPool, Queue<O> offsets)
protected void	RelationalSnapshotChangeEventSource.doCreateDataEventsForChunk(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, O offset, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, SnapshotChunk chunk, Map<TableId,TableChunkProgress> progressMap, SnapshotProgress snapshotProgress, JdbcConnection jdbcConnection)
protected void	RelationalSnapshotChangeEventSource.doCreateDataEventsForTable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, O offset, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, Table table, boolean firstTable, boolean lastTable, int tableOrder, int tableCount, String selectStatement, OptionalLong rowCount, Set<TableId> rowCountTablesKeySet, JdbcConnection jdbcConnection)
abstract void	AbstractCachedTableMappingStorage.forEach(BiConsumer<? super TableId,? super V> action)
void	ConcurrentMapTableMappingStorage.forEach(BiConsumer<? super TableId,? super V> action)
void	TableMappingStorage.forEach(BiConsumer<? super TableId,? super V> action)	Performs the given action for each entry in this storage until all entries have been processed or the action throws an exception.
(package private) void	Tables.TablesById.forEach(BiConsumer<? super TableId,? super Table> action)
static Tables.TableFilter	Tables.TableFilter.fromPredicate(Predicate<TableId> predicate)	Creates a Tables.TableFilter from the given predicate.
private RelationalSnapshotChangeEventSource.PreparedTables	RelationalSnapshotChangeEventSource.prepareTables(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, Function<TableId,RelationalSnapshotChangeEventSource.SnapshotSelect> selectGenerator, RelationalSnapshotChangeEventSource.CheckedFunction<TableId,OptionalLong> rowCountProvider)	Prepares tables for snapshot by generating select statements and row counts.
private RelationalSnapshotChangeEventSource.PreparedTables	RelationalSnapshotChangeEventSource.prepareTables(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, Function<TableId,RelationalSnapshotChangeEventSource.SnapshotSelect> selectGenerator, RelationalSnapshotChangeEventSource.CheckedFunction<TableId,OptionalLong> rowCountProvider)	Prepares tables for snapshot by generating select statements and row counts.
private Map<TableId,OptionalLong>	RelationalSnapshotChangeEventSource.sortByRowCount(Map<TableId,OptionalLong> rowCountTables, RelationalDatabaseConnectorConfig.SnapshotTablesRowCountOrder order)
private Stream<TableId>	RelationalSnapshotChangeEventSource.toTableIds(Set<TableId> tableIds, Pattern pattern)

Constructors in io.debezium.relational with parameters of type TableId

Modifier	Constructor	Description
	ChangeTable(String captureInstance, TableId sourceTableId, TableId changeTableId, int changeTableObjectId)	Creates an object that represents a source table's change table.
	ColumnId(TableId tableId, String columnName)	Create a new column identifier.
(package private)	TableImpl(TableId id, List<Column> sortedColumns, List<String> pkColumnNames, String defaultCharsetName, String comment, List<Attribute> attributes)
	TableSchema(TableId id, org.apache.kafka.connect.data.Schema keySchema, StructGenerator keyGenerator, Envelope envelopeSchema, org.apache.kafka.connect.data.Schema valueSchema, StructGenerator valueGenerator)	Create an instance with the specified Schemas for the keys and values, and the functions that generate the key and value for a given row of data.

Constructor parameters in io.debezium.relational with type arguments of type TableId

Modifier	Constructor	Description
protected	HistorizedRelationalDatabaseSchema(HistorizedRelationalDatabaseConnectorConfig config, io.debezium.spi.topic.TopicNamingStrategy<TableId> topicNamingStrategy, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, TableSchemaBuilder schemaBuilder, boolean tableIdCaseInsensitive, Key.KeyMapper customKeysMapper, CdcSourceTaskContext<? extends CommonConnectorConfig> taskContext)
private	PreparedTables(Map<TableId,RelationalSnapshotChangeEventSource.SnapshotSelect> queryTables, Map<TableId,OptionalLong> rowCountTables)	Creates an instance of a PreparedTables record class.
protected	RelationalDatabaseSchema(RelationalDatabaseConnectorConfig config, io.debezium.spi.topic.TopicNamingStrategy<TableId> topicNamingStrategy, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, TableSchemaBuilder schemaBuilder, boolean tableIdCaseInsensitive, Key.KeyMapper customKeysMapper, CdcSourceTaskContext<? extends CommonConnectorConfig> taskContext)
	RelationalSnapshotChangeEventSource(RelationalDatabaseConnectorConfig connectorConfig, MainConnectionProvidingConnectionFactory<? extends JdbcConnection> jdbcConnectionFactory, RelationalDatabaseSchema schema, EventDispatcher<P,TableId> dispatcher, io.debezium.util.Clock clock, SnapshotProgressListener<P> snapshotProgressListener, NotificationService<P,O> notificationService, SnapshotterService snapshotterService)

Uses of TableId in io.debezium.relational.ddl

Fields in io.debezium.relational.ddl declared as TableId

Modifier and Type	Field	Description
private final TableId	DdlParserListener.TableAlteredEvent.previousTableId
private final TableId	DdlParserListener.TableEvent.tableId
private final TableId	DdlParserListener.TableIndexEvent.tableId

Methods in io.debezium.relational.ddl that return TableId

Modifier and Type	Method	Description
TableId	DdlParserListener.TableAlteredEvent.previousTableId()	If the table was renamed, then get the old identifier of the table before it was renamed.
TableId	AbstractDdlParser.resolveTableId(String schemaName, String tableName)	Create a TableId from the supplied schema and table names.
TableId	DdlParserListener.TableEvent.tableId()	Get the identifier of the primary table affected by this event.
TableId	DdlParserListener.TableIndexEvent.tableId()	Get the identifier of the table to which the index applies.

Methods in io.debezium.relational.ddl with parameters of type TableId

Modifier and Type	Method	Description
protected void	AbstractDdlParser.signalAlterTable(TableId id, TableId previousId, String statement)	Signal an alter table event to ddl changes listener.
protected void	AbstractDdlParser.signalAlterView(TableId id, TableId previousId, String statement)	Signal an alter view event to ddl changes listener.
protected void	AbstractDdlParser.signalCreateIndex(String indexName, TableId id, String statement)	Signal a create index event to ddl changes listener.
protected void	AbstractDdlParser.signalCreateTable(TableId id, String statement)	Signal a create table event to ddl changes listener.
protected void	AbstractDdlParser.signalCreateView(TableId id, String statement)	Signal a create view event to ddl changes listener.
protected void	AbstractDdlParser.signalDropIndex(String indexName, TableId id, String statement)	Signal a drop index event to ddl changes listener.
protected void	AbstractDdlParser.signalDropTable(TableId id, String statement)	Signal a drop table event to ddl changes listener.
protected void	AbstractDdlParser.signalDropView(TableId id, String statement)	Signal a drop view event to ddl changes listener.
protected void	AbstractDdlParser.signalTruncateTable(TableId id, String statement)	Signal a truncate table event to ddl changes listener.

Constructors in io.debezium.relational.ddl with parameters of type TableId

Modifier	Constructor	Description
	TableAlteredEvent(TableId tableId, TableId previousTableId, String ddlStatement, boolean isView)
	TableCreatedEvent(TableId tableId, String ddlStatement, boolean isView)
	TableDroppedEvent(TableId tableId, String ddlStatement, boolean isView)
	TableEvent(DdlParserListener.EventType type, TableId tableId, String ddlStatement, boolean isView)
	TableIndexCreatedEvent(String indexName, TableId tableId, String ddlStatement)
	TableIndexDroppedEvent(String indexName, TableId tableId, String ddlStatement)
	TableIndexEvent(DdlParserListener.EventType type, String indexName, TableId tableId, String ddlStatement)
	TableTruncatedEvent(TableId tableId, String ddlStatement, boolean isView)

Uses of TableId in io.debezium.relational.history

Fields in io.debezium.relational.history declared as TableId

Modifier and Type	Field	Description
private final TableId	TableChanges.TableChange.id
private final TableId	TableChanges.TableChange.previousId

Methods in io.debezium.relational.history that return TableId

Modifier and Type	Method	Description
TableId	TableChanges.TableChange.getId()
TableId	TableChanges.TableChange.getPreviousId()

Methods in io.debezium.relational.history with parameters of type TableId

Modifier and Type	Method	Description
TableChanges	TableChanges.drop(TableId id)
private static Table	JsonTableChangeSerializer.fromDocument(TableId id, Document document)
TableChanges	TableChanges.rename(Table table, TableId previousId)

Constructors in io.debezium.relational.history with parameters of type TableId

Modifier	Constructor	Description
	TableChange(TableChanges.TableChangeType type, TableId id)
	TableChange(TableChanges.TableChangeType type, Table table, TableId previousId)

Uses of TableId in io.debezium.relational.mapping

Fields in io.debezium.relational.mapping with type parameters of type TableId

Modifier and Type	Field	Description
protected final BiPredicate<TableId,Column>	ColumnMappers.MapperRule.predicate

Methods in io.debezium.relational.mapping that return TableId

Modifier and Type	Method	Description
private TableId	ColumnMappers.Builder.mappedTableId(TableId tableId)

Methods in io.debezium.relational.mapping with parameters of type TableId

Modifier and Type	Method	Description
String	ColumnMappers.Builder.fullyQualifiedColumnDatatype(TableId tableId, Column column)
String	ColumnMappers.Builder.fullyQualifiedColumnName(TableId tableId, Column column)
String	ColumnMappers.Builder.mappedTableColumnDatatype(TableId tableId, Column column)
String	ColumnMappers.Builder.mappedTableColumnName(TableId tableId, Column column)
private TableId	ColumnMappers.Builder.mappedTableId(TableId tableId)
ColumnMapper	ColumnMappers.mapperFor(TableId tableId, Column column)	Get the value mapping function for the given column.
ValueConverter	ColumnMappers.mappingConverterFor(TableId tableId, Column column)	Get the value mapping function for the given column.
protected boolean	ColumnMappers.MapperRule.matches(TableId tableId, Column column)

Constructor parameters in io.debezium.relational.mapping with type arguments of type TableId

Modifier	Constructor	Description
protected	MapperRule(BiPredicate<TableId,Column> predicate, ColumnMapper mapper)

Uses of TableId in io.debezium.schema

Methods in io.debezium.schema with parameters of type TableId

Modifier and Type	Method	Description
static SchemaChangeEvent	SchemaChangeEvent.ofRename(Partition partition, OffsetContext offsetContext, String databaseName, String schemaName, String ddl, Table table, TableId previousTableId)	Create a schema change event for a ALTER TABLE RENAME event.

Method parameters in io.debezium.schema with type arguments of type TableId

Modifier and Type	Method	Description
void	HistorizedDatabaseSchema.SchemaChangeEventConsumer.consume(SchemaChangeEvent event, Collection<TableId> tableIds)

Constructors in io.debezium.schema with parameters of type TableId

Modifier	Constructor	Description
private	SchemaChangeEvent(Map<String,?> partition, Map<String,?> offset, org.apache.kafka.connect.data.Struct source, String database, String schema, String ddl, Table table, SchemaChangeEvent.SchemaChangeEventType type, boolean isFromSnapshot, TableId previousTableId)
private	SchemaChangeEvent(Map<String,?> partition, Map<String,?> offset, org.apache.kafka.connect.data.Struct source, String database, String schema, String ddl, Set<Table> tables, SchemaChangeEvent.SchemaChangeEventType type, boolean isFromSnapshot, Instant timestamp, TableId previousTableId)