| 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.