T
- type of the result for the concrete implementationspublic interface Result<T extends Result> extends IdentifiedDataSerializable
Modifier and Type | Method and Description |
---|---|
void |
add(QueryableEntry entry)
Adds the given entry to this result.
|
void |
combine(T result)
Combines the given result with this result modifying this result.
|
void |
completeConstruction(Collection<Integer> partitionIds)
Completes the construction of this result.
|
T |
createSubResult()
Creates a new empty sub result of the same type as this result.
|
Collection<Integer> |
getPartitionIds() |
void |
onCombineFinished()
Invoked when the result combining phase is finished.
|
void |
orderAndLimit(PagingPredicate pagingPredicate,
Map.Entry<Integer,Map.Entry> nearestAnchorEntry)
Performs the order-and-limit operation on this result for the given
paging predicate.
|
void |
setPartitionIds(Collection<Integer> partitionIds)
Sets the partition IDs of this result.
|
getFactoryId, getId
readData, writeData
Collection<Integer> getPartitionIds()
void setPartitionIds(Collection<Integer> partitionIds)
partitionIds
- the partition IDs to set.void combine(T result)
result
- the result to combine with.onCombineFinished()
void onCombineFinished()
Implementations may release intermediary resources associated with
the combining. No further calls to combine(T)
are expected after
this method invocation.
combine(Result)
void add(QueryableEntry entry)
entry
- the entry to add.T createSubResult()
This method is used by the query execution engine while constructing the partial sub results. These sub results are combined with this result during the final stage of the result construction.
void orderAndLimit(PagingPredicate pagingPredicate, Map.Entry<Integer,Map.Entry> nearestAnchorEntry)
pagingPredicate
- the paging predicate to perform the operation
for.nearestAnchorEntry
- the anchor entry of the paging predicate.void completeConstruction(Collection<Integer> partitionIds)
Implementations may release intermediary resources associated with the construction in this method. No further modifications of the result are expected after this method invocation except combining the result with other results.
partitionIds
- the partition IDs to associate this result with.combine(Result)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.