Package com.j_spaces.core.cache

Class FifoGroupsExtendedIndexHandler<K>

java.lang.Object

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

All Implemented Interfaces:

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

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

Handles extended index of fifo groups scans

Since:

9.0

Version:

1.0

Author:

Yechiel Fefer

Constructor Summary

Constructors

Constructor	Description
FifoGroupsExtendedIndexHandler(TypeDataIndex index, IExtendedIndex<K,IEntryCacheInfo> base, ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType)

Method Summary

Modifier and Type	Method	Description
IExtendedIndexIterator<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.
IExtendedIndexIterator<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()
ConcurrentSkipListMap<Object,IStoredList<IEntryCacheInfo>>	getOrderedStore()
ConcurrentMap<Object,IEntryCacheInfo>	getUniqueEntriesStore()
IObjectInfo	insertEntryIndexedField(IEntryCacheInfo pEntry, K fieldValue, TypeData pType, boolean alreadyCloned)
void	onRemove(IEntryCacheInfo eci)
void	onUpdate(IEntryCacheInfo eci)
void	onUpdateEnd(IEntryCacheInfo eci)
int	reapExpired()
void	removeEntryIndexedField(IEntryHolder eh, Object fieldValue, IEntryCacheInfo pEntry, IObjectInfo oi)

Methods inherited from class java.lang.Object

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

Constructor Details

FifoGroupsExtendedIndexHandler

public FifoGroupsExtendedIndexHandler(TypeDataIndex index,
 IExtendedIndex<K,IEntryCacheInfo> base,
 ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType)

Method Details

insertEntryIndexedField

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

Specified by:

insertEntryIndexedField in interface IExtendedIndex<K,IEntryCacheInfo>

removeEntryIndexedField

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

Specified by:

removeEntryIndexedField in interface IExtendedIndex<K,IEntryCacheInfo>

establishScan

public IExtendedIndexIterator<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 IExtendedIndexIterator<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>

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>

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>

getOrderedStore

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

Specified by:

getOrderedStore in interface IExtendedEntriesIndex<K,IEntryCacheInfo>

getIndexEntries

public IStoredList<IEntryCacheInfo> getIndexEntries(K indexValue)

Specified by:

getIndexEntries in interface IExtendedEntriesIndex<K,IEntryCacheInfo>