Uses of Interface
io.debezium.relational.Tables.TableFilter
Packages that use Tables.TableFilter
-
Uses of Tables.TableFilter in io.debezium.jdbc
Methods in io.debezium.jdbc with parameters of type Tables.TableFilterModifier and TypeMethodDescriptionJdbcConnection.getColumnsDetails(String catalogName, String schemaName, String tableName, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, DatabaseMetaData metadata, Set<TableId> viewIds) JdbcConnection.getColumnsDetails(String catalogName, String schemaName, String tableName, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, DatabaseMetaData metadata, Set<TableId> viewIds, boolean throwOnCaseInsensitiveColumnMismatch) voidJdbcConnection.readSchema(Tables tables, String catalogName, String schemaName, Tables.TableFilter tableFilter, Tables.ColumnNameFilter columnFilter, boolean removeTablesNotFoundInJdbc) Create definitions for each tables in the database, given the catalog name, schema pattern, table filter, and column filter. -
Uses of Tables.TableFilter in io.debezium.relational
Classes in io.debezium.relational that implement Tables.TableFilterModifier and TypeClassDescriptionprivate static final classATables.TableFilterthat caches the results of another filter.Fields in io.debezium.relational declared as Tables.TableFilterModifier and TypeFieldDescriptionprivate final Tables.TableFilterTables.CachingTableFilter.delegateprivate final Tables.TableFilterRelationalTableFilters.eligibleTableFilterprivate final Tables.TableFilterRelationalTableFilters.schemaSnapshotFilterEvaluate whether the table is eligible for schema snapshotting or not.private final Tables.TableFilterRelationalDatabaseSchema.tableFilterprivate final Tables.TableFilterRelationalTableFilters.tableFilterMethods in io.debezium.relational that return Tables.TableFilterModifier and TypeMethodDescriptionstatic Tables.TableFilterTables.TableFilter.cached(Tables.TableFilter filter) Creates aTables.TableFilterthat caches the results of the given filter.RelationalTableFilters.dataCollectionFilter()RelationalTableFilters.eligibleDataCollectionFilter()RelationalTableFilters.eligibleForSchemaDataCollectionFilter()static Tables.TableFilterTables.TableFilter.fromPredicate(Predicate<TableId> predicate) Creates aTables.TableFilterfrom the given predicate.protected Tables.TableFilterRelationalDatabaseSchema.getTableFilter()static Tables.TableFilterTables.TableFilter.includeAll()Creates aTables.TableFilterthat includes all tables.Methods in io.debezium.relational with parameters of type Tables.TableFilterModifier and TypeMethodDescriptionstatic Tables.TableFilterTables.TableFilter.cached(Tables.TableFilter filter) Creates aTables.TableFilterthat caches the results of the given filter.Tables.subset(Tables.TableFilter filter) Constructors in io.debezium.relational with parameters of type Tables.TableFilterModifierConstructorDescription(package private)CachingTableFilter(Tables.TableFilter delegate) protectedHistorizedRelationalDatabaseConnectorConfig(Class<? extends org.apache.kafka.connect.source.SourceConnector> connectorClass, io.debezium.config.Configuration config, Tables.TableFilter systemTablesFilter, boolean useCatalogBeforeSchema, int defaultSnapshotFetchSize, ColumnFilterMode columnFilterMode, boolean multiPartitionMode) protectedHistorizedRelationalDatabaseConnectorConfig(Class<? extends org.apache.kafka.connect.source.SourceConnector> connectorClass, io.debezium.config.Configuration config, Tables.TableFilter systemTablesFilter, Selectors.TableIdToStringMapper tableIdMapper, boolean useCatalogBeforeSchema, int defaultSnapshotFetchSize, ColumnFilterMode columnFilterMode, boolean multiPartitionMode) protectedHistorizedRelationalDatabaseConnectorConfig(Class<? extends org.apache.kafka.connect.source.SourceConnector> connectorClass, io.debezium.config.Configuration config, Tables.TableFilter systemTablesFilter, Selectors.TableIdToStringMapper tableIdMapper, boolean useCatalogBeforeSchema, ColumnFilterMode columnFilterMode, boolean multiPartitionMode) protectedHistorizedRelationalDatabaseSchema(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) protectedRelationalDatabaseConnectorConfig(io.debezium.config.Configuration config, Tables.TableFilter systemTablesFilter, Selectors.TableIdToStringMapper tableIdMapper, int defaultSnapshotFetchSize, ColumnFilterMode columnFilterMode, boolean useCatalogBeforeSchema) 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) RelationalTableFilters(io.debezium.config.Configuration config, Tables.TableFilter systemTablesFilter, Selectors.TableIdToStringMapper tableIdMapper, boolean useCatalogBeforeSchema)