Class WalFilters

    • Constructor Detail

      • WalFilters

        public WalFilters()
    • Method Detail

      • pageOwner

        public static Predicate<IgniteBiTuple<WALPointer,​WALRecord>> pageOwner​(Set<T2<Integer,​Long>> pageOwnerIds)
        Filtering all records whose pageId is contained in pageOwnerIds.
        Parameters:
        pageOwnerIds - Page id for filtering.
        Returns:
        Predicate for filtering record from pageOwnerIds.
      • partitionMetaStateUpdate

        public static Predicate<IgniteBiTuple<WALPointer,​WALRecord>> partitionMetaStateUpdate​(Set<T2<Integer,​Integer>> partsMetaupdate)
        Filtering all records whose partitionId is contained in partsMetaupdate.
        Parameters:
        partsMetaupdate - Partition id for filtering.
        Returns:
        Predicate for filtering record from pageOwnerIds.