Package io.debezium.relational

Class RelationalTableFilters

java.lang.Object

io.debezium.relational.RelationalTableFilters

All Implemented Interfaces:

io.debezium.schema.DataCollectionFilters

public class RelationalTableFilters
extends Object
implements io.debezium.schema.DataCollectionFilters

Copied from Debezium 1.9.8.Final.

Line 98: cache table filter results.

Line 148: add a method to update the tableFilter variable.

Nested Class Summary

Nested classes/interfaces inherited from interface io.debezium.schema.DataCollectionFilters

io.debezium.schema.DataCollectionFilters.DataCollectionFilter<T extends io.debezium.schema.DataCollectionId>

Constructor Summary

Constructors

Constructor	Description
RelationalTableFilters(io.debezium.config.Configuration config, io.debezium.relational.Tables.TableFilter systemTablesFilter, io.debezium.relational.Selectors.TableIdToStringMapper tableIdMapper)

Method Summary

Modifier and Type	Method	Description
java.util.function.Predicate<String>	databaseFilter()
io.debezium.relational.Tables.TableFilter	dataCollectionFilter()
io.debezium.relational.Tables.TableFilter	eligibleDataCollectionFilter()
io.debezium.relational.Tables.TableFilter	eligibleForSchemaDataCollectionFilter()
String	getExcludeColumns()
void	setDataCollectionFilters(io.debezium.relational.Tables.TableFilter tableFilter)

Methods inherited from class java.lang.Object

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

Constructor Detail

RelationalTableFilters

public RelationalTableFilters(io.debezium.config.Configuration config,
                              io.debezium.relational.Tables.TableFilter systemTablesFilter,
                              io.debezium.relational.Selectors.TableIdToStringMapper tableIdMapper)

Method Detail

dataCollectionFilter

public io.debezium.relational.Tables.TableFilter dataCollectionFilter()

Specified by:

dataCollectionFilter in interface io.debezium.schema.DataCollectionFilters

eligibleDataCollectionFilter

public io.debezium.relational.Tables.TableFilter eligibleDataCollectionFilter()

eligibleForSchemaDataCollectionFilter

public io.debezium.relational.Tables.TableFilter eligibleForSchemaDataCollectionFilter()

databaseFilter

public java.util.function.Predicate<String> databaseFilter()

getExcludeColumns

public String getExcludeColumns()

setDataCollectionFilters

public void setDataCollectionFilters(io.debezium.relational.Tables.TableFilter tableFilter)