Uses of Class
io.debezium.relational.RelationalDatabaseConnectorConfig
Packages that use RelationalDatabaseConnectorConfig
Package
Description
-
Uses of RelationalDatabaseConnectorConfig in io.debezium.jdbc
Methods in io.debezium.jdbc with parameters of type RelationalDatabaseConnectorConfigModifier and TypeMethodDescription<T extends io.debezium.spi.schema.DataCollectionId>
ChunkQueryBuilder<T> JdbcConnection.chunkQueryBuilder(RelationalDatabaseConnectorConfig connectorConfig) -
Uses of RelationalDatabaseConnectorConfig in io.debezium.pipeline.source.snapshot.incremental
Fields in io.debezium.pipeline.source.snapshot.incremental declared as RelationalDatabaseConnectorConfigModifier and TypeFieldDescriptionprotected final RelationalDatabaseConnectorConfigAbstractChunkQueryBuilder.connectorConfigprotected final RelationalDatabaseConnectorConfigAbstractIncrementalSnapshotChangeEventSource.connectorConfigConstructors in io.debezium.pipeline.source.snapshot.incremental with parameters of type RelationalDatabaseConnectorConfigModifierConstructorDescriptionAbstractChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection) AbstractIncrementalSnapshotChangeEventSource(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection, EventDispatcher<P, T> dispatcher, DatabaseSchema<?> databaseSchema, io.debezium.util.Clock clock, SnapshotProgressListener<P> progressListener, DataChangeEventListener<P> dataChangeEventListener, NotificationService<P, ? extends OffsetContext> notificationService) DefaultChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection) PhysicalRowIdentifierChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection, String physicalColumnName, String physicalIdentifierExpression, int physicalJdbcType, int physicalNativeType, String physicalTypeName, Integer physicalLength, Integer physicalScale, boolean aliasWildcardProjection, String tableAlias) RowValueConstructorChunkQueryBuilder(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection) SignalBasedIncrementalSnapshotChangeEventSource(RelationalDatabaseConnectorConfig config, JdbcConnection jdbcConnection, EventDispatcher<P, T> dispatcher, DatabaseSchema<?> databaseSchema, io.debezium.util.Clock clock, SnapshotProgressListener<P> progressListener, DataChangeEventListener<P> dataChangeEventListener, NotificationService<P, ? extends OffsetContext> notificationService) -
Uses of RelationalDatabaseConnectorConfig in io.debezium.processors.reselect
Fields in io.debezium.processors.reselect declared as RelationalDatabaseConnectorConfig -
Uses of RelationalDatabaseConnectorConfig in io.debezium.relational
Subclasses of RelationalDatabaseConnectorConfig in io.debezium.relationalModifier and TypeClassDescriptionclassConfiguration options shared across the relational CDC connectors which use a persistent database schema history.Fields in io.debezium.relational declared as RelationalDatabaseConnectorConfigModifier and TypeFieldDescriptionprivate final RelationalDatabaseConnectorConfigRelationalDatabaseSchema.configprivate final RelationalDatabaseConnectorConfigRelationalSnapshotChangeEventSource.connectorConfigMethods in io.debezium.relational with parameters of type RelationalDatabaseConnectorConfigModifier and TypeMethodDescriptionvoidAbstractCachedTableMappingStorage.configure(RelationalDatabaseConnectorConfig config, boolean tableIdCaseInsensitive, TableMappingStorage.Type type) voidConcurrentMapTableMappingStorage.configure(RelationalDatabaseConnectorConfig config, boolean tableIdCaseInsensitive, TableMappingStorage.Type type) voidTableMappingStorage.configure(RelationalDatabaseConnectorConfig config, boolean tableIdCaseInsensitive, TableMappingStorage.Type type) Configures this storage instance with connector configuration.protected abstract voidAbstractCachedTableMappingStorage.configureStorage(RelationalDatabaseConnectorConfig config, TableMappingStorage.Type type) Configures the underlying storage implementation.Constructors in io.debezium.relational with parameters of type RelationalDatabaseConnectorConfigModifierConstructorDescriptionRelationalChangeRecordEmitter(P partition, OffsetContext offsetContext, io.debezium.util.Clock clock, RelationalDatabaseConnectorConfig connectorConfig) protectedRelationalDatabaseSchema(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) SnapshotChangeRecordEmitter(P partition, OffsetContext offset, Object[] row, io.debezium.util.Clock clock, RelationalDatabaseConnectorConfig connectorConfig) Tables(boolean tableIdCaseInsensitive, RelationalDatabaseConnectorConfig config) Create an empty set of definitions with connector configuration. -
Uses of RelationalDatabaseConnectorConfig in io.debezium.relational.mapping
Methods in io.debezium.relational.mapping with parameters of type RelationalDatabaseConnectorConfigModifier and TypeMethodDescriptionstatic ColumnMappersColumnMappers.create(RelationalDatabaseConnectorConfig connectorConfig) Builds a newColumnMappersinstance based on the given configuration.