Class 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 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:
        isIncluded in interface io.debezium.schema.DataCollectionFilters.DataCollectionFilter<io.debezium.relational.TableId>
        Specified by:
        isIncluded in interface io.debezium.relational.Tables.TableFilter