Uses of Class
io.debezium.relational.TableSchema

Packages that use TableSchema

Package	Description
io.debezium.relational

Uses of TableSchema in io.debezium.relational

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

Modifier and Type	Field	Description
private final TableMappingStorage<TableSchema>	RelationalDatabaseSchema.SchemasByTableId.storage

Methods in io.debezium.relational that return TableSchema

Modifier and Type	Method	Description
TableSchema	TableSchemaBuilder.create(io.debezium.spi.topic.TopicNamingStrategy topicNamingStrategy, Table table, Tables.ColumnNameFilter filter, ColumnMappers mappers, Key.KeyMapper keysMapper)	Create a TableSchema from the given table definition.
TableSchema	RelationalDatabaseSchema.SchemasByTableId.get(TableId tableId)
TableSchema	RelationalDatabaseSchema.SchemasByTableId.put(TableId tableId, TableSchema updated)
TableSchema	RelationalDatabaseSchema.SchemasByTableId.remove(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.

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

Modifier and Type	Method	Description
TableMappingStorage<TableSchema>	RelationalDatabaseConnectorConfig.createSchemaStorage(boolean tableIdCaseInsensitive)	Creates and configures a schema storage instance.

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

Modifier and Type	Method	Description
protected void	RelationalChangeRecordEmitter.emitCreateRecord(ChangeRecordEmitter.Receiver<P> receiver, TableSchema tableSchema)
protected void	RelationalChangeRecordEmitter.emitDeleteRecord(ChangeRecordEmitter.Receiver<P> receiver, TableSchema tableSchema)
protected void	RelationalChangeRecordEmitter.emitReadRecord(ChangeRecordEmitter.Receiver<P> receiver, TableSchema tableSchema)
protected void	RelationalChangeRecordEmitter.emitTruncateRecord(ChangeRecordEmitter.Receiver<P> receiver, TableSchema schema)
protected void	RelationalChangeRecordEmitter.emitUpdateAsPrimaryKeyChangeRecord(ChangeRecordEmitter.Receiver<P> receiver, TableSchema tableSchema, org.apache.kafka.connect.data.Struct oldKey, org.apache.kafka.connect.data.Struct newKey, org.apache.kafka.connect.data.Struct oldValue, org.apache.kafka.connect.data.Struct newValue)
protected void	RelationalChangeRecordEmitter.emitUpdateRecord(ChangeRecordEmitter.Receiver<P> receiver, TableSchema tableSchema)
TableSchema	RelationalDatabaseSchema.SchemasByTableId.put(TableId tableId, TableSchema updated)

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

Modifier	Constructor	Description
(package private)	SchemasByTableId(TableMappingStorage<TableSchema> storage)