org.apache.ignite.internal.processors.cache.persistence.wal.reader

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 in FilteredWalIterator. *

Constructor Summary

Constructors

Constructor and Description
WalFilters()

Method Summary

Modifier and Type	Method and 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.

Methods inherited from class java.lang.Object

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

Constructor Detail

WalFilters

public WalFilters()

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.