Package io.debezium.relational
package io.debezium.relational
-
ClassDescriptionAbstract base class for
TableMappingStorageimplementations that provides caching functionality.An abstract implementation ofPartitionwhich provides default facilities for logging.An immutable attribute associated with a relational table.An editor forAttributeinstances.Implementation of theAttributeEditorcontract.Relational model implementation ofAttribute.A logical representation of a change table containing changes for a given source table.An immutable definition of a column.An editor forColumninstances.Modes for column name filters, either including a catalog (database) or schema name.Unique identifier for a column in a database table.Default implementation ofTableMappingStorageusingConcurrentHashMap.The registry of all converters that were provided by the connector configuration.Class binding together the schema of the conversion result and the converter code.This interface is used to convert the string default value to a Java type recognized by value converters for a subset of types.Converts the raw JDBC default value expression for a column into an object.Configuration options shared across the relational CDC connectors which use a persistent database schema history.ADatabaseSchemaor a relational database which has a schema history, that can be recovered to the current state when restarting a connector.An immutable definition of a table's key.Custom Key mapper used to override or defining a customKeyDefault Key mapper using PK as key.Provides the column(s) that should be used within the message key for a given table.RelationalChangeRecordEmitter<P extends Partition>Base class forChangeRecordEmitterimplementations based on a relational database.Configuration options shared across the relational CDC connectors.The set of predefined DecimalHandlingMode options or aliases.The set of predefined DecimalHandlingMode options or aliases.ADatabaseSchemaof a relational database such as Postgres.A map of schemas by table id.Base class forSnapshotChangeEventSourcefor relational databases with or without a schema history.Functional interface for operations that may throw SQLException.Functional interface for snapshot work that uses pooled resources.Holds the prepared table information for snapshot processing.RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P extends Partition,O extends OffsetContext> Mutable context which is populated in the course of snapshotting.Determines the appropriate SnapshotRecord marker based on record position.Manages threaded execution of snapshot work using a thread pool.Define predicates determines whether tables or columns should be used.A builder of a database predicate.Implementations convert givenTableIds to strings, so regular expressions can be applied to them for the purpose of table filtering.A builder of a table predicate.SnapshotChangeRecordEmitter<P extends Partition>Emits change data based on a single row read via JDBC.A function that converts one change event row (from a snapshot select, or from before/after state of a log event) into the corresponding Kafka Connect key or valueStruct.Encapsulates a set of a database's system variables.Interface that is used for enums defining the customized scope values for specific DBMSs.An immutable definition of a table.Unique identifier for a database table.Parses identifiers into the corresponding parts of aTableId.Collection of predicate methods used for parsingTableId.Interface for storing mappings betweenTableIdand associated data.Enum representing the type of storage.Structural definitions for a set of tables in a JDBC database.ATables.TableFilterthat caches the results of another filter.A filter for columns.A filter for tables.A set of table ids.A map of tables by id.Defines the Kafka ConnectSchemafunctionality associated with a giventable definition, and which can be used to send rows of data that match the table definition to Kafka Connect.Builder that constructsTableSchemainstances forTabledefinitions.A function that converts from a column data value into another value.A provider ofValueConverterfunctions and theSchemaBuilderused to describe them.