Package | Description |
---|---|
com.hazelcast.client.impl.protocol.task |
Client tasks associated with requests.
|
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.internal.serialization.impl | |
com.hazelcast.internal.util |
This package contains classes to support the inner workings of Hazelcast
as well as some backports of newer Java features / data structures to
support older Java versions in a clean and nice way.
|
com.hazelcast.internal.util.collection |
Primitive-typed collections.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.query |
Modifier and Type | Method and Description |
---|---|
abstract PartitionIdSet |
AbstractMultiPartitionMessageTask.getPartitions() |
Modifier and Type | Method and Description |
---|---|
PartitionIdSet |
MapExecuteOnKeysMessageTask.getPartitions() |
Modifier and Type | Method and Description |
---|---|
static PartitionIdSet |
SerializationUtil.readNullablePartitionIdSet(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
static void |
SerializationUtil.writeNullablePartitionIdSet(PartitionIdSet partitionIds,
ObjectDataOutput out)
Writes a nullable
PartitionIdSet to the given data output. |
Modifier and Type | Method and Description |
---|---|
static PartitionIdSet |
SetUtil.allPartitionIds(int partitionCount) |
static PartitionIdSet |
SetUtil.immutablePartitionIdSet(int partitionCount,
Collection<Integer> partitionIds) |
static PartitionIdSet |
SetUtil.singletonPartitionIdSet(int partitionCount,
int partitionId) |
Modifier and Type | Class and Description |
---|---|
class |
ImmutablePartitionIdSet
An immutable
PartitionIdSet . |
Modifier and Type | Method and Description |
---|---|
void |
ImmutablePartitionIdSet.addAll(PartitionIdSet other) |
void |
PartitionIdSet.addAll(PartitionIdSet other) |
boolean |
PartitionIdSet.containsAll(PartitionIdSet other) |
boolean |
PartitionIdSet.intersects(PartitionIdSet other)
Returns whether the intersection of this set with given argument is not empty.
|
void |
ImmutablePartitionIdSet.removeAll(PartitionIdSet other) |
void |
PartitionIdSet.removeAll(PartitionIdSet other) |
void |
ImmutablePartitionIdSet.union(PartitionIdSet other) |
void |
PartitionIdSet.union(PartitionIdSet other)
Mutates this
PartitionIdSet so it contains the union of this and other 's
partition IDs. |
Constructor and Description |
---|
PartitionIdSet(PartitionIdSet initialPartitionIds) |
Modifier and Type | Method and Description |
---|---|
PartitionIdSet |
MapServiceContext.getOwnedPartitions() |
Modifier and Type | Method and Description |
---|---|
PartitionIdSet |
AggregationResult.getPartitionIds() |
PartitionIdSet |
QueryResult.getPartitionIds() |
PartitionIdSet |
Result.getPartitionIds()
Returns partition IDs associated with this result or
null if this
result is an empty/failure result. |
Modifier and Type | Method and Description |
---|---|
void |
AggregationResult.completeConstruction(PartitionIdSet partitionIds) |
void |
QueryResult.completeConstruction(PartitionIdSet partitionIds) |
void |
Result.completeConstruction(PartitionIdSet partitionIds)
Completes the construction of this result.
|
protected List<Future<Result>> |
QueryEngineImpl.dispatchPartitionScanQueryOnOwnerMemberOnPartitionThread(Query query,
PartitionIdSet partitionIds) |
AggregationResult |
CallerRunsAccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
PartitionIdSet partitionIds) |
AggregationResult |
ParallelAccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
PartitionIdSet partitionIds) |
AggregationResult |
AccumulationExecutor.execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
PartitionIdSet partitionIds) |
protected Result |
QueryRunner.populateNonEmptyResult(Query query,
Collection<QueryableEntry> entries,
PartitionIdSet initialPartitions) |
QueryResult |
QueryResultProcessor.populateResult(Query query,
long resultLimit,
Collection<QueryableEntry> entries,
PartitionIdSet partitionIds) |
AggregationResult |
AggregationResultProcessor.populateResult(Query query,
long resultLimit,
Collection<QueryableEntry> entries,
PartitionIdSet partitionIds) |
T |
ResultProcessor.populateResult(Query query,
long resultLimit,
Collection<QueryableEntry> entries,
PartitionIdSet partitionIds)
Populate an non-empty result for the given query type.
|
protected Result |
QueryRunner.runUsingPartitionScanSafely(Query query,
Predicate predicate,
PartitionIdSet partitions,
int migrationStamp) |
void |
AggregationResult.setPartitionIds(PartitionIdSet partitionIds) |
void |
QueryResult.setPartitionIds(PartitionIdSet partitionIds) |
void |
Result.setPartitionIds(PartitionIdSet partitionIds)
Sets the partition IDs of this result.
|
Copyright © 2019 Hazelcast, Inc.. All rights reserved.