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(@Nullable IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
ScanQuery(int part)
Creates partition scan query returning all entries for given partition.
|
ScanQuery(@Nullable Integer part,
@Nullable IgniteBiPredicate<K,V> filter)
Create scan query with filter.
|
Modifier and Type | Method and Description |
---|---|
IgniteBiPredicate<K,V> |
getFilter()
Gets filter.
|
@Nullable Integer |
getPartition()
Gets partition number over which this query should iterate.
|
ScanQuery<K,V> |
setFilter(@Nullable 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(@Nullable Integer part)
Sets partition number over which this query should iterate.
|
String |
toString() |
getPageSize, isLocal, prepare
public ScanQuery()
public ScanQuery(int part)
part
- Partition.public ScanQuery(@Nullable @Nullable IgniteBiPredicate<K,V> filter)
filter
- Filter. If null
then all entries will be returned.public ScanQuery(@Nullable @Nullable Integer part, @Nullable @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 @Nullable IgniteBiPredicate<K,V> filter)
filter
- Filter. If null
then all entries will be returned.this
for chaining.public ScanQuery<K,V> setPartition(@Nullable @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 @Nullable 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)
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024