public final class ScanQuery<K,V> extends Query<javax.cache.Cache.Entry<K,V>>
IgniteCache.query(Query),
Serialized FormDFLT_PAGE_SIZE| Constructor and Description |
|---|
ScanQuery()
Create scan query returning all entries.
|
ScanQuery(IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
ScanQuery(int part)
Creates partition scan query returning all entries for given partition.
|
ScanQuery(Integer part,
IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<K,V> |
getFilter()
Gets filter.
|
Integer |
getPartition()
Gets partition number over which this query should iterate.
|
ScanQuery<K,V> |
setFilter(IgniteBiPredicate<K,V> filter)
Sets filter.
|
ScanQuery<K,V> |
setLocal(boolean loc)
Sets whether this query should be executed on local node only.
|
ScanQuery<K,V> |
setPageSize(int pageSize)
Sets optional page size, if
0, then default is used. |
ScanQuery<K,V> |
setPartition(Integer part)
Sets partition number over which this query should iterate.
|
String |
toString() |
getPageSize, isLocalpublic ScanQuery()
public ScanQuery(int part)
part - Partition.public ScanQuery(@Nullable
IgniteBiPredicate<K,V> filter)
filter - Filter. If null then all entries will be returned.public ScanQuery(@Nullable
Integer part,
@Nullable
IgniteBiPredicate<K,V> filter)
part - Partition.filter - Filter. If null then all entries will be returned.public IgniteBiPredicate<K,V> getFilter()
public ScanQuery<K,V> setFilter(@Nullable IgniteBiPredicate<K,V> filter)
filter - Filter. If null then all entries will be returned.this for chaining.public ScanQuery<K,V> setPartition(@Nullable Integer part)
null, query will iterate over
all partitions in the cache. Must be in the range [0, N) where N is partition number in the cache.part - Partition number over which this query should iterate.this for chaining.@Nullable public Integer getPartition()
null if partition was not
set. In this case query will iterate over all partitions in the cache.null.public ScanQuery<K,V> setPageSize(int pageSize)
0, then default is used.setPageSize in class Query<javax.cache.Cache.Entry<K,V>>pageSize - Optional page size.this for chaining.public ScanQuery<K,V> setLocal(boolean loc)
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016