com.j_spaces.core.cache

Class ExtendedIndexHandler<K>

java.lang.Object

com.j_spaces.core.cache.ExtendedIndexHandler<K>

All Implemented Interfaces:

IExtendedEntriesIndex<K,IEntryCacheInfo>, IExtendedIndex<K,IEntryCacheInfo>, IExtendedIndexScanPositioner<K,IEntryCacheInfo>

public class ExtendedIndexHandler<K>
extends Object
implements IExtendedEntriesIndex<K,IEntryCacheInfo>

Handles data manipulation of space extended index

Since:

8.0

Version:

1.0

Author:

Yechiel Fefer

Constructor Summary

Constructors

Constructor and Description
ExtendedIndexHandler(TypeDataIndex index)

Method Summary

Modifier and Type	Method and Description
IScanListIterator<IEntryCacheInfo>	establishScan(K startPos, short relation, K endPos, boolean endPosInclusive) establish a scan according to the relation given and startPos : the start-scan object , null means scan all values.
IScanListIterator<IEntryCacheInfo>	establishScan(K startPos, short relation, K endPos, boolean endPosInclusive, boolean ordered) establish a scan according to the relation given and startPos : the start-scan object , null means scan all values.
IStoredList<IEntryCacheInfo>	getIndexEntries(K indexValue)
ConcurrentMap<Object,IStoredList<IEntryCacheInfo>>	getNonUniqueEntriesStore()
FastConcurrentSkipListMap<Object,IStoredList<IEntryCacheInfo>>	getOrderedStore()
ConcurrentMap<Object,IEntryCacheInfo>	getUniqueEntriesStore()
IObjectInfo	insertEntryIndexedField(IEntryCacheInfo pEntry, K fieldValue, TypeData pType, boolean alreadyCloned) insert a value for this key- if key already exist insert into the SL of same values
void	onRemove(IEntryCacheInfo eci)
void	onUpdate(IEntryCacheInfo eci)
void	onUpdateEnd(IEntryCacheInfo eci)
int	reapExpired()
void	removeEntryIndexedField(IEntryHolder eh, Object fieldValue, IEntryCacheInfo pEntry, IObjectInfo oi) remove entry indexed field from cache.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExtendedIndexHandler

public ExtendedIndexHandler(TypeDataIndex index)

Method Detail

getOrderedStore

public FastConcurrentSkipListMap<Object,IStoredList<IEntryCacheInfo>> getOrderedStore()

Specified by:

getOrderedStore in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

getNonUniqueEntriesStore

public ConcurrentMap<Object,IStoredList<IEntryCacheInfo>> getNonUniqueEntriesStore()

Specified by:

getNonUniqueEntriesStore in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

getUniqueEntriesStore

public ConcurrentMap<Object,IEntryCacheInfo> getUniqueEntriesStore()

Specified by:

getUniqueEntriesStore in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

getIndexEntries

public IStoredList<IEntryCacheInfo> getIndexEntries(K indexValue)

Specified by:

getIndexEntries in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

insertEntryIndexedField

public IObjectInfo insertEntryIndexedField(IEntryCacheInfo pEntry,
                                           K fieldValue,
                                           TypeData pType,
                                           boolean alreadyCloned)

insert a value for this key- if key already exist insert into the SL of same values

Specified by:

insertEntryIndexedField in interface IExtendedIndex<K,IEntryCacheInfo>

Returns:

the index backref

removeEntryIndexedField

public void removeEntryIndexedField(IEntryHolder eh,
                                    Object fieldValue,
                                    IEntryCacheInfo pEntry,
                                    IObjectInfo oi)

remove entry indexed field from cache.

Specified by:

removeEntryIndexedField in interface IExtendedIndex<K,IEntryCacheInfo>

onUpdate

public void onUpdate(IEntryCacheInfo eci)

Specified by:

onUpdate in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

onUpdateEnd

public void onUpdateEnd(IEntryCacheInfo eci)

Specified by:

onUpdateEnd in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

onRemove

public void onRemove(IEntryCacheInfo eci)

Specified by:

onRemove in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

reapExpired

public int reapExpired()

Specified by:

reapExpired in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

establishScan

public IScanListIterator<IEntryCacheInfo> establishScan(K startPos,
                                                        short relation,
                                                        K endPos,
                                                        boolean endPosInclusive)

establish a scan according to the relation given and startPos : the start-scan object , null means scan all values. The relation is from com.j_spaces.client.TemplateMatchCodes: LT, LE, GT, GE (other codes are not relevant) endPos- key up to (or null if no limit in index) endPosInclusive : is the endPos up to (or down to) and including ? returns an ExtendedIndexIterator object which enables scanning the ordered index, Null if no relevant elements to scan

Specified by:

establishScan in interface IExtendedIndexScanPositioner<K,IEntryCacheInfo>

establishScan

public IScanListIterator<IEntryCacheInfo> establishScan(K startPos,
                                                        short relation,
                                                        K endPos,
                                                        boolean endPosInclusive,
                                                        boolean ordered)

establish a scan according to the relation given and startPos : the start-scan object , null means scan all values. The relation is from com.j_spaces.client.TemplateMatchCodes: LT, LE, GT, GE (other codes are not relevant) endPos- key up to (or null if no limit in index) endPosInclusive : is the endPos up to (or down to) and including ? ordered - according to the condition. GT, GE ==> ascending, LT, LE =====> descending. returns an IOrderedIndexScan object which enables scanning the ordered index, Null if no relevant elements to scan

Specified by:

establishScan in interface IExtendedIndexScanPositioner<K,IEntryCacheInfo>