Package org.apache.ignite.spi.indexing
Class IndexingQueryFilterImpl
- java.lang.Object
-
- org.apache.ignite.spi.indexing.IndexingQueryFilterImpl
-
- All Implemented Interfaces:
IndexingQueryFilter
public class IndexingQueryFilterImpl extends Object implements IndexingQueryFilter
Indexing query filter.
-
-
Constructor Summary
Constructors Constructor Description IndexingQueryFilterImpl(org.apache.ignite.internal.GridKernalContext ctx, @Nullable org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion topVer, @org.jetbrains.annotations.Nullable int[] partsArr)
Constructor.IndexingQueryFilterImpl(org.apache.ignite.internal.GridKernalContext ctx, @Nullable org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion topVer, @org.jetbrains.annotations.Nullable int[] partsArr, boolean treatReplicatedAsPartitioned)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description @Nullable IndexingQueryCacheFilter
forCache(String cacheName)
Creates optional predicate for cache.
-
-
-
Constructor Detail
-
IndexingQueryFilterImpl
public IndexingQueryFilterImpl(org.apache.ignite.internal.GridKernalContext ctx, @Nullable @Nullable org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion topVer, @Nullable @org.jetbrains.annotations.Nullable int[] partsArr, boolean treatReplicatedAsPartitioned)
Constructor.- Parameters:
ctx
- Kernal context.topVer
- Topology version.partsArr
- Partitions array.treatReplicatedAsPartitioned
- If true, only primary partitions of replicated caches will be used.
-
IndexingQueryFilterImpl
public IndexingQueryFilterImpl(org.apache.ignite.internal.GridKernalContext ctx, @Nullable @Nullable org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion topVer, @Nullable @org.jetbrains.annotations.Nullable int[] partsArr)
Constructor.- Parameters:
ctx
- Kernal context.topVer
- Topology version.partsArr
- Partitions array.
-
-
Method Detail
-
forCache
@Nullable public @Nullable IndexingQueryCacheFilter forCache(String cacheName)
Creates optional predicate for cache.- Specified by:
forCache
in interfaceIndexingQueryFilter
- Parameters:
cacheName
- Cache name.- Returns:
- Predicate or
null
if no filtering is needed.
-
-