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 |
BroadKeyPartitioningStrategy.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 |
KeyPartitioningStrategy.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 |
PartitionEvent.getPartitionSet()
Determine the set of partitions represented by this event.
|
PartitionSet |
PartitionSplittingBackingMap.MapArray.getPartitionSet()
Obtain a PartitionSet containing partition IDs for which there are backing maps.
|
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.
|
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 |
ObservableSplittingBackingMap.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 |
PartitionSplittingBackingMap.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.
|
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).
|
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 |
QueryRecord.PartialResult.getPartitions()
Get the set of partitions associated with this partial result.
|
PartitionSet |
SimpleQueryRecord.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.
|