Package io.debezium.relational
Class CachedTableFilter
- java.lang.Object
-
- io.debezium.relational.CachedTableFilter
-
- All Implemented Interfaces:
io.debezium.relational.Tables.TableFilter,io.debezium.schema.DataCollectionFilters.DataCollectionFilter<io.debezium.relational.TableId>
public class CachedTableFilter extends Object implements io.debezium.relational.Tables.TableFilter
A bounded cache for table filter results.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static CachedTableFilterfrom(io.debezium.relational.Tables.TableFilter tableFilter)Wraps the given filter in a cache, or returns it unchanged if it is already cached.booleanisIncluded(io.debezium.relational.TableId tableId)CachedTableFilterwithAdditionalFilter(io.debezium.relational.Tables.TableFilter additionalFilter)Returns a new cached filter that also requires the additional filter to match.
-
-
-
Method Detail
-
from
public static CachedTableFilter from(io.debezium.relational.Tables.TableFilter tableFilter)
Wraps the given filter in a cache, or returns it unchanged if it is already cached.
-
withAdditionalFilter
public CachedTableFilter withAdditionalFilter(io.debezium.relational.Tables.TableFilter additionalFilter)
Returns a new cached filter that also requires the additional filter to match.
-
isIncluded
public boolean isIncluded(io.debezium.relational.TableId tableId)
- Specified by:
isIncludedin interfaceio.debezium.schema.DataCollectionFilters.DataCollectionFilter<io.debezium.relational.TableId>- Specified by:
isIncludedin interfaceio.debezium.relational.Tables.TableFilter
-
-