Package io.debezium.relational

Class RelationalDatabaseSchema.SchemasByTableId

java.lang.Object

io.debezium.relational.RelationalDatabaseSchema.SchemasByTableId

Enclosing class:

RelationalDatabaseSchema

private static class RelationalDatabaseSchema.SchemasByTableId
extends Object

A map of schemas by table id. Table names are stored lower-case if required as per the config.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
SchemasByTableId(TableMappingStorage<TableSchema> storage)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	close()
TableSchema	get(TableId tableId)
TableSchema	put(TableId tableId, TableSchema updated)
TableSchema	remove(TableId tableId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

storage

private final TableMappingStorage<TableSchema> storage

Constructor Details

SchemasByTableId

SchemasByTableId(TableMappingStorage<TableSchema> storage)

Method Details

clear

public void clear()

remove

public TableSchema remove(TableId tableId)

get

public TableSchema get(TableId tableId)

put

public TableSchema put(TableId tableId,
 TableSchema updated)

close

public void close()