| Package | Description |
|---|---|
| com.tangosol.net |
Contains basic cluster interfaces and factories.
|
| com.tangosol.net.partition |
Contains interfaces and classes related to partitioned services.
|
| com.tangosol.persistence |
Contains classes and helpers for implementing various types of persistence.
|
| com.tangosol.util |
Contains various generic utilities.
|
| com.tangosol.util.filter |
Contains concrete
Filter implementations and related interfaces. |
| Modifier and Type | Field and Description |
|---|---|
protected PartitionSet |
PartitionedService.PartitionRecoveryAction.m_partsOrphan
The set of orphaned partitions.
|
| Modifier and Type | Method and Description |
|---|---|
PartitionSet |
PartitionedService.PartitionRecoveryAction.getOrphanedPartitions()
Return the set of orphaned partitions.
|
PartitionSet |
PartitionedService.getOwnedPartitions(Member member)
Determine the PartitionSet that is currently owned by a cluster Member.
|
| Modifier and Type | Method and Description |
|---|---|
protected static String |
ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy.reportLastOwnership(PartitionSet parts,
com.tangosol.net.internal.QuorumInfo info)
Report the machine names in the "last good" membership that owned
the specified partitions.
|
| Constructor and Description |
|---|
PartitionRecoveryAction(PartitionSet partsOrphan,
GUIDHelper.GUIDResolver resolver,
com.tangosol.net.internal.QuorumInfo infoQuorum)
Construct a PartitionRecoveryAction for the specified partitions,
GUID resolver and the "last good" membership info.
|
| Modifier and Type | Field and Description |
|---|---|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.m_partsOrphaned
The set of partitions that were determined to be orphaned in the call
to
PartitionAssignmentStrategy.analyzeOrphans(Map). |
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.m_partsUpdated
The set of partitions that have been updated in this analysis context;
may be null.
|
protected PartitionSet |
PartitionEvent.m_setPartitions
The set of affected partitions.
|
protected PartitionSet |
AbstractPartitionedIterator.m_setPids
The remaining set of partitions to iterate.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<Ownership,PartitionSet> |
SimpleAssignmentStrategy.m_mapSuggestLast
The Map containing the last distribution suggested by this strategy.
|
| Modifier and Type | Method and Description |
|---|---|
PartitionSet |
PartitionSet.clear()
Clear the set.
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.collectEndangered(PartitionSet parts)
Return a partition set representing the subset of the specified
partitions that are "endangered".
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.collectOrphaned(PartitionSet parts)
Return a partition set representing the subset of the specified
partitions that are "orphaned".
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.collectWeak(PartitionSet parts)
Return a partition set representing the subset of the specified
partitions that are "weak" or "vulnerable" (as defined by the backup
strength).
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.ensureUpdatedPartitions()
Ensure and return the set of updated partitions.
|
PartitionSet |
PartitionSet.fill()
Fill the set to contain all the partitions.
|
PartitionSet |
KeyPartitioningStrategy.getAssociatedPartitions(Object oKey)
Determine the set of partitions that all keys associated with the
specified key are assigned to.
|
PartitionSet |
DefaultKeyPartitioningStrategy.getAssociatedPartitions(Object oKey)
Determine the set of partitions that all keys associated with the
specified key are assigned to.
|
PartitionSet |
BroadKeyPartitioningStrategy.getAssociatedPartitions(Object oKey)
Determine the set of partitions that all keys associated with the
specified key are assigned to.
|
PartitionSet |
DistributionManager.getIgnoredAdvice()
Return a set of partitions from the previous suggestions that were
ignored or rejected.
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.getOrphanedPartitions()
Return the partitions deemed orphaned as a result of a previous
execution of
analyzeOrphans. |
PartitionSet |
DistributionManager.getOwnedPartitions(Member member,
int iStore)
Return the set of partitions for which the specified member owns the
specified storage index (replica).
|
PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.getOwnedPartitions(Member member,
int iStore)
Return the set of partitions for which the specified member owns (or
has been assigned by this analysis to own) the specified storage
index.
|
PartitionSet |
PartitionSplittingBackingMap.MapArray.getPartitionSet()
Obtain a PartitionSet containing partition IDs for which there are
backing maps.
|
PartitionSet |
PartitionEvent.getPartitionSet()
Determine the set of partitions represented by this event.
|
protected PartitionSet |
SimpleAssignmentStrategy.getUnownedPartitions(PartitionSet parts,
int nMember)
Calculate a subset of the PartitionSet consisting of partitions that are
not owned (primary or backup) by the specified member.
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.getUpdatedPartitions()
Return the set of updated partitions; may be null.
|
PartitionSet |
PartitionSet.invert()
Invert all the partitions.
|
PartitionSet |
PartitionSet.split()
Split this partition set into two partition sets that are mutually
exclusive.
|
static PartitionSet |
PartitionSet.union(PartitionSet partsA,
PartitionSet partsB)
Return a union of the two provided PartitionSets.
|
| Modifier and Type | Method and Description |
|---|---|
protected SortedMap<Integer,PartitionSet> |
SimpleAssignmentStrategy.splitByOwner(PartitionSet parts)
Split the partition set scheduled for distribution by the current
primary owner (all transfers originate from the primary owner).
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
PartitionSet.add(PartitionSet partitions)
Add the specified PartitionSet to this set.
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.collectEndangered(PartitionSet parts)
Return a partition set representing the subset of the specified
partitions that are "endangered".
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.collectOrphaned(PartitionSet parts)
Return a partition set representing the subset of the specified
partitions that are "orphaned".
|
protected PartitionSet |
SimpleAssignmentStrategy.AnalysisContext.collectWeak(PartitionSet parts)
Return a partition set representing the subset of the specified
partitions that are "weak" or "vulnerable" (as defined by the backup
strength).
|
boolean |
PartitionSet.contains(PartitionSet partitions)
Check whether or not the specified partition set belongs to this set.
|
protected int |
SimpleAssignmentStrategy.doBalancePrimary(SimpleAssignmentStrategy.AnalysisContext ctx,
Member memberFrom,
PartitionSet parts,
Member[] aMembersTarget)
Do balancing transfers for primary distribution.
|
protected void |
SimpleAssignmentStrategy.emitLossNotification(PartitionSet partsLost)
Emit a partition loss notification for given partitions.
|
Map[] |
PartitionSplittingBackingMap.MapArray.getBackingMaps(PartitionSet partitions)
Obtain an array of the current backing maps for the partitions
specified in the passed PartitionSet.
|
int |
SimpleAssignmentStrategy.LoadCalculator.getLoad(PartitionSet parts)
Return the load for the specified set of partitions.
|
int |
SimpleAssignmentStrategy.SimpleLoadCalculator.getLoad(PartitionSet parts)
Return the load for the specified set of partitions.
|
Map |
PartitionSplittingBackingMap.getPartitionMap(PartitionSet partitions)
Obtain a Map view for the data in a specific set of partitions.
|
Map |
PartitionAwareBackingMap.getPartitionMap(PartitionSet partitions)
Obtain a Map view for the data in a specific set of partitions.
|
Map |
ReadWriteSplittingBackingMap.getPartitionMap(PartitionSet partitions)
Obtain a Map view for the data in a specific set of partitions.
|
Map |
ObservableSplittingBackingMap.getPartitionMap(PartitionSet partitions)
Obtain a Map view for the data in a specific set of partitions.
|
protected PartitionSet |
SimpleAssignmentStrategy.getUnownedPartitions(PartitionSet parts,
int nMember)
Calculate a subset of the PartitionSet consisting of partitions that are
not owned (primary or backup) by the specified member.
|
boolean |
PartitionSet.intersects(PartitionSet partitions)
Check whether or not the specified partition set intersects with this
set.
|
boolean |
PartitionSet.remove(PartitionSet partitions)
Remove the specified PartitionSet from this set.
|
boolean |
PartitionSet.retain(PartitionSet partitions)
Retain only partitions in this set that are contained in the specified
PartitionSet.
|
protected void |
SimpleAssignmentStrategy.AnalysisContext.setOrphanedPartitions(PartitionSet parts)
Set the orphaned partitions that can be prioritized for transfer in
order to reduce the transfer cost.
|
protected SortedMap<Integer,PartitionSet> |
SimpleAssignmentStrategy.splitByOwner(PartitionSet parts)
Split the partition set scheduled for distribution by the current
primary owner (all transfers originate from the primary owner).
|
void |
DistributionManager.suggest(PartitionSet parts,
Ownership ownership)
Suggest a distribution change for the specified set of partitions,
indicating either primary or backup transfer (or both).
|
static PartitionSet |
PartitionSet.union(PartitionSet partsA,
PartitionSet partsB)
Return a union of the two provided PartitionSets.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PartitionAssignmentStrategy.analyzeOrphans(Map<Member,PartitionSet> mapConstraints)
Analyze and suggest the assignment of orphaned partitions (partitions
without an active primary or backup owner) subject to the specified
constraints.
|
void |
SimpleAssignmentStrategy.analyzeOrphans(Map<Member,PartitionSet> mapConstraints)
Analyze and suggest the assignment of orphaned partitions (partitions
without an active primary or backup owner) subject to the specified
constraints.
|
| Constructor and Description |
|---|
AbstractPartitionedIterator(Filter filter,
NamedCache cache,
PartitionSet setPids)
Create AbstractPartitionedIterator instance.
|
AbstractPartitionedIterator(Filter filter,
NamedCache cache,
PartitionSet setPids,
boolean fByMember,
boolean fRandom)
Create AbstractPartitionedIterator instance.
|
MaskedPartitionMap(PartitionSet partMask)
Construct MaskedPartitionMap based on the specified PartitionSet.
|
PartitionedIterator(NamedCache cache,
Filter filter,
PartitionSet setPids,
int nOptions)
Construct PartitionedIterator that will provide iteration of the
keys of the specified cache using the specified filter, but will
only query one partition or one member at a time.
|
PartitionEvent(PartitionedService svc,
int nId,
PartitionSet setPartitions,
Member memberFrom,
Member memberTo)
Construct a partition event.
|
PartitionSet(PartitionSet partitions)
Copy constructor: construct a new PartitionSet object equivalent to the
specified one.
|
| Modifier and Type | Field and Description |
|---|---|
protected PartitionSet |
GUIDHelper.GUIDResolver.m_partsUnresolved
The PartitionSet containing partitions that don't have corresponding GUIDs.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<Member,PartitionSet> |
GUIDHelper.GUIDResolver.m_mapResolved
The resolved map of members to the associated set of partitions.
|
| Modifier and Type | Method and Description |
|---|---|
static PartitionSet |
CachePersistenceHelper.getGlobalPartitions(PartitionedService service)
Return a PartitionSet that contains partitions to be used to persist
(meta-)data that is logically "global".
|
static PartitionSet |
GUIDHelper.getPartitions(Map<Integer,Object[]> mapStores,
int cParts)
Return a
PartitionSet with all partitions present in the provided
mapStores. |
PartitionSet |
GUIDHelper.GUIDResolver.getUnresolvedPartitions()
Retrieve a PartitionSet containing all partitions that don't have any
corresponding GUIDs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<Member,PartitionSet> |
GUIDHelper.GUIDResolver.resolve()
Resolve the registered GUIDs and return a map associating each member
to the set of partitions that it had registered as having the newest
GUID for.
|
| Modifier and Type | Method and Description |
|---|---|
String[] |
GUIDHelper.GUIDResolver.getNewestGUIDs(PartitionSet parts)
Return the list of the newest GUIDs for the specified set of partitions.
|
| Modifier and Type | Method and Description |
|---|---|
PartitionSet |
SimpleQueryRecord.PartialResult.getPartitions()
Get the set of partitions associated with this partial result.
|
PartitionSet |
QueryRecord.PartialResult.getPartitions()
Get the set of partitions associated with this partial result.
|
| Modifier and Type | Method and Description |
|---|---|
default PartitionedFilter<T> |
Filter.forPartitions(PartitionSet partitions)
Return a partitioned filter for a specified partition set.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NullImplementation.NullPartitionAssignmentStrategy.analyzeOrphans(Map<Member,PartitionSet> mapConstraints)
Analyze and suggest the assignment of orphaned partitions (partitions
without an active primary or backup owner) subject to the specified
constraints.
|
| Constructor and Description |
|---|
PartialResult(PartitionSet partMask)
Construct a PartialResult.
|
PartialResult(QueryContext ctx,
PartitionSet partMask)
Construct a PartialResult.
|
| Modifier and Type | Method and Description |
|---|---|
PartitionSet |
PartitionedFilter.getPartitionSet()
Obtain the PartitionSet that specifies what partitions the wrapped filter
will be applied to.
|
| Constructor and Description |
|---|
PartitionedFilter(Filter<T> filter,
PartitionSet partitions)
Construct a PartitionedFilter.
|