Package io.debezium.relational

Class Tables.CachingTableFilter

java.lang.Object

io.debezium.relational.Tables.CachingTableFilter

All Implemented Interfaces:

Tables.TableFilter, DataCollectionFilters.DataCollectionFilter<TableId>

Enclosing class:

Tables

private static final class Tables.CachingTableFilter
extends Object
implements Tables.TableFilter

A Tables.TableFilter that caches the results of another filter.

Field Summary

Fields

Modifier and Type	Field	Description
private final ConcurrentMap<TableId,Boolean>	cache
private final Tables.TableFilter	delegate

Constructor Summary

Constructors

Constructor	Description
CachingTableFilter(Tables.TableFilter delegate)

Method Summary

Modifier and Type	Method	Description
boolean	isIncluded(TableId tableId)	Determines whether the given table should be included in the current DatabaseSchema.

Methods inherited from class java.lang.Object

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

Field Details

delegate

private final Tables.TableFilter delegate

cache

private final ConcurrentMap<TableId,Boolean> cache

Constructor Details

CachingTableFilter

CachingTableFilter(Tables.TableFilter delegate)

Method Details

isIncluded

public boolean isIncluded(TableId tableId)

Description copied from interface: Tables.TableFilter

Determines whether the given table should be included in the current DatabaseSchema.

Specified by:

isIncluded in interface DataCollectionFilters.DataCollectionFilter<TableId>

Specified by:

isIncluded in interface Tables.TableFilter