Class WalFilters
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.persistence.wal.reader.WalFilters
-
public class WalFilters extends Object
Class for holding only very basic WAL filters for using inFilteredWalIterator. *
-
-
Constructor Summary
Constructors Constructor Description WalFilters()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Predicate<IgniteBiTuple<WALPointer,WALRecord>>checkpoint()Filtering all checkpoint records.static Predicate<IgniteBiTuple<WALPointer,WALRecord>>pageOwner(Set<T2<Integer,Long>> pageOwnerIds)Filtering all records whose pageId is contained in pageOwnerIds.static Predicate<IgniteBiTuple<WALPointer,WALRecord>>partitionMetaStateUpdate(Set<T2<Integer,Integer>> partsMetaupdate)Filtering all records whose partitionId is contained in partsMetaupdate.
-
-
-
Method Detail
-
checkpoint
public static Predicate<IgniteBiTuple<WALPointer,WALRecord>> checkpoint()
Filtering all checkpoint records.- Returns:
- Predicate for filtering checkpoint records.
-
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.
-
-