com.j_spaces.core.cache

Class TypeData

java.lang.Object

com.j_spaces.core.cache.TypeData

public class TypeData
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TypeData.TypeDataRecreationReasons

Field Summary

Fields

Modifier and Type	Field and Description
static String	Compound_Fifo_Groups_Index_Name_Suffix

Constructor Summary

Constructors

Constructor and Description
TypeData(IServerTypeDesc serverTypeDesc, TypeDataFactory typeDataFactory, boolean isLocalCache, boolean isResidentEntriesCachePolicy)
TypeData(IServerTypeDesc serverTypeDesc, TypeData originalTypeData, TypeData.TypeDataRecreationReasons reason) given an original type data create a new one- used to add new indexes

Method Summary

Modifier and Type	Method and Description
boolean	anyCompoundIndex()
boolean	anyInitialExtendedIndex()
boolean	anyNonFGCompoundIndex()
static TypeDataIndex	buildCompoundIndex(CompoundIndex definition, Map<String,TypeDataIndex<?>> indexTable, IServerTypeDesc serverTypeDesc, int indexPosition, ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType, int indexCreationNumber, TypeDataFactory typeDataFactory)
int[]	createIndexBackreferenceArray(IEntryCacheInfo pEntry, IEntryData masterEntryData)
int	decM_NumRegularNotifyTemplatesStored()
int	decNumDurableNotificationsStored()
boolean	disableIdIndexForOffHeapEntries(TypeDataIndex index)
List<TemplateInfo>	fillTemplatesInfo(List<TemplateInfo> templates)
CacheManager	getCacheManager()
String	getClassName()
List<TypeDataIndex>	getCompoundIndexes()
IStoredList<IEntryCacheInfo>	getEntries()
IStoredList<TemplateCacheInfo>	getExtendedTemplates(MatchTarget matchTarget)
int	getFieldOrdinal(String fieldName)
TypeDataIndex<Object>	getFifoGroupingIndex()
Set<QueryExtensionIndexManagerWrapper>	getForeignQueriesHandlers()
TypeDataIndex	getIdField()
TypeDataIndex<?>	getIndex(String indexName)
TypeDataIndex[]	getIndexes()
HashSet<String>	getIndexesRelatedDynamicProperties()
boolean[]	getIndexesRelatedFixedProperties()
static ISpaceIndex.FifoGroupsIndexTypes	getIndexFifoGroupingType(SpaceIndex spaceIndex, String fifoGroupingName, Set<String> fifoGroupingIndexes)
int	getLastIndexCreationNumber()
int	getM_NumRegularNotifyTemplatesStored()
IStoredList<TemplateCacheInfo>	getNotifyExtendedTemplates()
IStoredList<TemplateCacheInfo>	getNotifyTemplates()
ConcurrentHashMap<String,IStoredList<TemplateCacheInfo>>	getNotifyUidTemplates()
PropertyInfo	getProperty(int propertyID)
IStoredList<TemplateCacheInfo>	getReadTakeExtendedTemplates()
IStoredList<TemplateCacheInfo>	getReadTakeTemplates()
ConcurrentHashMap<String,IStoredList<TemplateCacheInfo>>	getReadTakeUidTemplates()
SequenceNumberGenerator	getSequenceNumberGenerator()
TypeDataIndex<?>	getSequenceNumberIndex()
IStoredList<TemplateCacheInfo>	getTemplates(MatchTarget matchTarget)
int	getTotalNotifyTemplates()
TypeDataFactory	getTypeDataFactory()
IStoredList<TemplateCacheInfo>	getUidTemplates(MatchTarget matchTarget, String uid)
boolean	hasFifoGroupingIndex()
boolean	hasIndexes()
boolean	hasInitialIndexes()
boolean	hasSequenceNumber()
boolean	hasSequenceNumberIndex()
int	incM_NumRegularNotifyTemplatesStored()
int	incNumDurableNotificationsStored()
boolean	isAllowFifoIndexScans()
boolean	isFifoSupport()
boolean	isOffHeapClass()
boolean	isTypeDataReplaced()
int	numberOfBackRefs()
void	prepareForUpdatingIndexValues(CacheManager cacheManager, IEntryCacheInfo pEntry, IEntryData newEntryData) used only in economy-hash maps index values are about to be replaced in entryData .
void	setTypeDataReplaced()
boolean	supportsDynamicIndexing()
String	toString()
void	updateEntryReferences(CacheManager cacheManager, IEntryHolder eh, IEntryCacheInfo pEntry, IEntryData oldEntryData) update the entry refs in cache.
void	updateEntryReferencesUnderXtn(CacheManager cacheManager, IEntryCacheInfo pEntry, IEntryData oldEntryData) update the entry refs in cache when there is an updating xtn, we keep the master entry and shadow entry as one object pointing at eatch other so we cant remove the original index references

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

Compound_Fifo_Groups_Index_Name_Suffix

public static String Compound_Fifo_Groups_Index_Name_Suffix

Constructor Detail

TypeData

public TypeData(IServerTypeDesc serverTypeDesc,
                TypeDataFactory typeDataFactory,
                boolean isLocalCache,
                boolean isResidentEntriesCachePolicy)

TypeData

public TypeData(IServerTypeDesc serverTypeDesc,
                TypeData originalTypeData,
                TypeData.TypeDataRecreationReasons reason)

given an original type data create a new one- used to add new indexes

Parameters:

reason - - reason for replacing the type-data

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getIndexFifoGroupingType

public static ISpaceIndex.FifoGroupsIndexTypes getIndexFifoGroupingType(SpaceIndex spaceIndex,
                                                                        String fifoGroupingName,
                                                                        Set<String> fifoGroupingIndexes)

getForeignQueriesHandlers

public Set<QueryExtensionIndexManagerWrapper> getForeignQueriesHandlers()

buildCompoundIndex

public static TypeDataIndex buildCompoundIndex(CompoundIndex definition,
                                               Map<String,TypeDataIndex<?>> indexTable,
                                               IServerTypeDesc serverTypeDesc,
                                               int indexPosition,
                                               ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType,
                                               int indexCreationNumber,
                                               TypeDataFactory typeDataFactory)

getEntries

public IStoredList<IEntryCacheInfo> getEntries()

Returns:

Returns the entries.

getProperty

public PropertyInfo getProperty(int propertyID)

getTemplates

public IStoredList<TemplateCacheInfo> getTemplates(MatchTarget matchTarget)

getNotifyTemplates

public IStoredList<TemplateCacheInfo> getNotifyTemplates()

getReadTakeTemplates

public IStoredList<TemplateCacheInfo> getReadTakeTemplates()

hasIndexes

public boolean hasIndexes()

getClassName

public String getClassName()

getCacheManager

public CacheManager getCacheManager()

getFieldOrdinal

public int getFieldOrdinal(String fieldName)

Returns:

field ordinal by name

getIndex

public TypeDataIndex<?> getIndex(String indexName)

getIndexes

public TypeDataIndex[] getIndexes()

numberOfBackRefs

public int numberOfBackRefs()

getExtendedTemplates

public IStoredList<TemplateCacheInfo> getExtendedTemplates(MatchTarget matchTarget)

getNotifyExtendedTemplates

public IStoredList<TemplateCacheInfo> getNotifyExtendedTemplates()

getReadTakeExtendedTemplates

public IStoredList<TemplateCacheInfo> getReadTakeExtendedTemplates()

getUidTemplates

public IStoredList<TemplateCacheInfo> getUidTemplates(MatchTarget matchTarget,
                                                      String uid)

getNotifyUidTemplates

public ConcurrentHashMap<String,IStoredList<TemplateCacheInfo>> getNotifyUidTemplates()

getReadTakeUidTemplates

public ConcurrentHashMap<String,IStoredList<TemplateCacheInfo>> getReadTakeUidTemplates()

fillTemplatesInfo

public List<TemplateInfo> fillTemplatesInfo(List<TemplateInfo> templates)

getTotalNotifyTemplates

public int getTotalNotifyTemplates()

getM_NumRegularNotifyTemplatesStored

public int getM_NumRegularNotifyTemplatesStored()

decM_NumRegularNotifyTemplatesStored

public int decM_NumRegularNotifyTemplatesStored()

incM_NumRegularNotifyTemplatesStored

public int incM_NumRegularNotifyTemplatesStored()

decNumDurableNotificationsStored

public int decNumDurableNotificationsStored()

incNumDurableNotificationsStored

public int incNumDurableNotificationsStored()

isFifoSupport

public boolean isFifoSupport()

isAllowFifoIndexScans

public boolean isAllowFifoIndexScans()

getIdField

public TypeDataIndex getIdField()

disableIdIndexForOffHeapEntries

public boolean disableIdIndexForOffHeapEntries(TypeDataIndex index)

isOffHeapClass

public boolean isOffHeapClass()

getIndexesRelatedFixedProperties

public boolean[] getIndexesRelatedFixedProperties()

getIndexesRelatedDynamicProperties

public HashSet<String> getIndexesRelatedDynamicProperties()

hasSequenceNumber

public boolean hasSequenceNumber()

getSequenceNumberGenerator

public SequenceNumberGenerator getSequenceNumberGenerator()

hasSequenceNumberIndex

public boolean hasSequenceNumberIndex()

getSequenceNumberIndex

public TypeDataIndex<?> getSequenceNumberIndex()

updateEntryReferences

public void updateEntryReferences(CacheManager cacheManager,
                                  IEntryHolder eh,
                                  IEntryCacheInfo pEntry,
                                  IEntryData oldEntryData)

update the entry refs in cache.

prepareForUpdatingIndexValues

public void prepareForUpdatingIndexValues(CacheManager cacheManager,
                                          IEntryCacheInfo pEntry,
                                          IEntryData newEntryData)

used only in economy-hash maps index values are about to be replaced in entryData . protect against possible inconsistency in data structures

updateEntryReferencesUnderXtn

public void updateEntryReferencesUnderXtn(CacheManager cacheManager,
                                          IEntryCacheInfo pEntry,
                                          IEntryData oldEntryData)

update the entry refs in cache when there is an updating xtn, we keep the master entry and shadow entry as one object pointing at eatch other so we cant remove the original index references

Parameters:

pEntry - TODO

oldEntryData - TODO

createIndexBackreferenceArray

public int[] createIndexBackreferenceArray(IEntryCacheInfo pEntry,
                                           IEntryData masterEntryData)

isTypeDataReplaced

public boolean isTypeDataReplaced()

setTypeDataReplaced

public void setTypeDataReplaced()

supportsDynamicIndexing

public boolean supportsDynamicIndexing()

getLastIndexCreationNumber

public int getLastIndexCreationNumber()

hasInitialIndexes

public boolean hasInitialIndexes()

anyInitialExtendedIndex

public boolean anyInitialExtendedIndex()

getTypeDataFactory

public TypeDataFactory getTypeDataFactory()

hasFifoGroupingIndex

public boolean hasFifoGroupingIndex()

getFifoGroupingIndex

public TypeDataIndex<Object> getFifoGroupingIndex()

anyCompoundIndex

public boolean anyCompoundIndex()

getCompoundIndexes

public List<TypeDataIndex> getCompoundIndexes()

anyNonFGCompoundIndex

public boolean anyNonFGCompoundIndex()