com.hazelcast.impl

Class AbstractRecord

java.lang.Object

com.hazelcast.impl.AbstractSimpleRecord

com.hazelcast.impl.AbstractRecord

All Implemented Interfaces:

MapEntry, Record, Map.Entry

Direct Known Subclasses:

DefaultRecord

public abstract class AbstractRecord
extends AbstractSimpleRecord
implements Record

Field Summary

Fields

Modifier and Type	Field and Description
protected long	creationTime
protected boolean	dirty
protected long	expirationTime
protected int	hits
protected long	lastAccessTime
protected long	lastStoredTime
protected long	lastUpdateTime
protected DistributedLock	lock
protected long	maxIdleMillis
protected com.hazelcast.impl.AbstractRecord.OptionalInfo	optionalInfo
protected long	removeTime
protected long	version
protected long	writeTime

Fields inherited from class com.hazelcast.impl.AbstractSimpleRecord

active, blockId, cmap, id, key

Constructor Summary

Constructors

Constructor and Description
AbstractRecord(CMap cmap, int blockId, Data key, long ttl, long maxIdleMillis, long id)

Method Summary

Methods

Modifier and Type	Method and Description
void	addBackupOp(VersionedBackupOp bo)
void	addListener(Address address, boolean returnValue)
void	addScheduledAction(ScheduledAction scheduledAction)
void	clearLock()
boolean	equals(Object o)
void	forceBackupOps()
int	getBackupOpCount()
SortedSet<VersionedBackupOp>	getBackupOps()
long	getCreationTime()
long	getExpirationTime()
int	getHits()
Long[]	getIndexes()
byte[]	getIndexTypes()
Object	getKey()
long	getLastAccessTime()
long	getLastStoredTime()
long	getLastUpdateTime()
Map<Address,Boolean>	getListeners()
DistributedLock	getLock()
long	getLockAcquireTime()
Address	getLockAddress()
int	getLockCount()
Collection<ValueHolder>	getMultiValues()
com.hazelcast.impl.AbstractRecord.OptionalInfo	getOptionalInfo()
long	getRemainingIdle()
long	getRemainingTTL()
long	getRemoveTime()
int	getScheduledActionCount()
List<ScheduledAction>	getScheduledActions()
long	getVersion()
long	getWriteTime()
int	hashCode()
boolean	hasListener()
boolean	hasScheduledAction()
void	incrementHits()
void	incrementVersion()
protected void	invalidateValueCache()
boolean	isDirty()
boolean	isEvictable()
boolean	isEvicted()
boolean	isLoadable() True if record is not removed (map.remove() ...) and either is not active or not valid or has not value (may because of locking)
boolean	isLocked()
boolean	isRemovable()
boolean	isRemoved()
boolean	isValid()
boolean	isValid(long now)
boolean	lock(int threadId, Address address)
void	markRemoved()
void	removeListener(Address address)
void	runBackupOps()
void	setActive()
void	setActive(boolean active)
void	setBackupOps(SortedSet<VersionedBackupOp> backupOps)
void	setCreationTime(long newValue)
void	setDirty(boolean dirty)
void	setExpirationTime(long expTime)
void	setIndexes(Long[] indexes, byte[] indexTypes)
void	setInvalid()
void	setLastAccessed()
void	setLastAccessTime(long lastAccessTime)
void	setLastStoredTime(long lastStoredTime)
void	setLastUpdated()
void	setLastUpdateTime(long lastUpdateTime)
void	setLock(DistributedLock lock)
void	setMapListeners(Map<Address,Boolean> mapListeners)
void	setMaxIdle(long idle)
void	setMultiValues(Collection<ValueHolder> lsValues)
void	setRemoveTime(long removeTime)
void	setScheduledActions(List<ScheduledAction> lsScheduledActions)
void	setTTL(long ttl)
void	setVersion(long version)
void	setWriteTime(long writeTime)
boolean	testLock(int threadId, Address address)
String	toString()
boolean	unlock(int threadId, Address address)

Methods inherited from class com.hazelcast.impl.AbstractSimpleRecord

getBlockId, getId, getKeyData, getName, isActive

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.hazelcast.impl.Record

copy, getBlockId, getCost, getId, getKeyData, getName, getValue, getValueData, hasValueData, invalidate, isActive, setValue, setValueData, valueCount

Field Detail

hits

protected volatile int hits

version

protected volatile long version

maxIdleMillis

protected volatile long maxIdleMillis

writeTime

protected volatile long writeTime

removeTime

protected volatile long removeTime

lastAccessTime

protected volatile long lastAccessTime

lastStoredTime

protected volatile long lastStoredTime

creationTime

protected volatile long creationTime

expirationTime

protected volatile long expirationTime

lastUpdateTime

protected volatile long lastUpdateTime

dirty

protected volatile boolean dirty

lock

protected volatile DistributedLock lock

optionalInfo

protected volatile com.hazelcast.impl.AbstractRecord.OptionalInfo optionalInfo

Constructor Detail

AbstractRecord

public AbstractRecord(CMap cmap,
              int blockId,
              Data key,
              long ttl,
              long maxIdleMillis,
              long id)

Method Detail

runBackupOps

public void runBackupOps()

Specified by:

runBackupOps in interface Record

Overrides:

runBackupOps in class AbstractSimpleRecord

addBackupOp

public void addBackupOp(VersionedBackupOp bo)

Specified by:

addBackupOp in interface Record

Overrides:

addBackupOp in class AbstractSimpleRecord

forceBackupOps

public void forceBackupOps()

Specified by:

forceBackupOps in interface Record

Overrides:

forceBackupOps in class AbstractSimpleRecord

getKey

public Object getKey()

Specified by:

getKey in interface Record

Specified by:

getKey in interface Map.Entry

Overrides:

getKey in class AbstractSimpleRecord

getIndexes

public Long[] getIndexes()

Specified by:

getIndexes in interface Record

Overrides:

getIndexes in class AbstractSimpleRecord

getIndexTypes

public byte[] getIndexTypes()

Specified by:

getIndexTypes in interface Record

Overrides:

getIndexTypes in class AbstractSimpleRecord

setIndexes

public void setIndexes(Long[] indexes,
              byte[] indexTypes)

Specified by:

setIndexes in interface Record

Overrides:

setIndexes in class AbstractSimpleRecord

lock

public boolean lock(int threadId,
           Address address)

Specified by:

lock in interface Record

Overrides:

lock in class AbstractSimpleRecord

unlock

public boolean unlock(int threadId,
             Address address)

Specified by:

unlock in interface Record

Overrides:

unlock in class AbstractSimpleRecord

testLock

public boolean testLock(int threadId,
               Address address)

Specified by:

testLock in interface Record

Overrides:

testLock in class AbstractSimpleRecord

getLock

public DistributedLock getLock()

Specified by:

getLock in interface Record

Overrides:

getLock in class AbstractSimpleRecord

setLock

public void setLock(DistributedLock lock)

Specified by:

setLock in interface Record

Overrides:

setLock in class AbstractSimpleRecord

isLocked

public boolean isLocked()

Specified by:

isLocked in interface Record

Overrides:

isLocked in class AbstractSimpleRecord

getLockCount

public int getLockCount()

Specified by:

getLockCount in interface Record

Overrides:

getLockCount in class AbstractSimpleRecord

clearLock

public void clearLock()

Specified by:

clearLock in interface Record

Overrides:

clearLock in class AbstractSimpleRecord

getLockAddress

public Address getLockAddress()

Specified by:

getLockAddress in interface Record

Overrides:

getLockAddress in class AbstractSimpleRecord

getLockAcquireTime

public long getLockAcquireTime()

Specified by:

getLockAcquireTime in interface Record

Overrides:

getLockAcquireTime in class AbstractSimpleRecord

invalidateValueCache

protected void invalidateValueCache()

addScheduledAction

public void addScheduledAction(ScheduledAction scheduledAction)

Specified by:

addScheduledAction in interface Record

Overrides:

addScheduledAction in class AbstractSimpleRecord

isRemovable

public boolean isRemovable()

Specified by:

isRemovable in interface Record

Overrides:

isRemovable in class AbstractSimpleRecord

isEvictable

public boolean isEvictable()

Specified by:

isEvictable in interface Record

Overrides:

isEvictable in class AbstractSimpleRecord

hasListener

public boolean hasListener()

Specified by:

hasListener in interface Record

Overrides:

hasListener in class AbstractSimpleRecord

addListener

public void addListener(Address address,
               boolean returnValue)

Specified by:

addListener in interface Record

Overrides:

addListener in class AbstractSimpleRecord

removeListener

public void removeListener(Address address)

Specified by:

removeListener in interface Record

Overrides:

removeListener in class AbstractSimpleRecord

setLastUpdated

public void setLastUpdated()

Specified by:

setLastUpdated in interface Record

Overrides:

setLastUpdated in class AbstractSimpleRecord

setLastAccessed

public void setLastAccessed()

Specified by:

setLastAccessed in interface Record

Overrides:

setLastAccessed in class AbstractSimpleRecord

getExpirationTime

public long getExpirationTime()

Specified by:

getExpirationTime in interface MapEntry

Specified by:

getExpirationTime in interface Record

Overrides:

getExpirationTime in class AbstractSimpleRecord

getRemainingTTL

public long getRemainingTTL()

Specified by:

getRemainingTTL in interface Record

Overrides:

getRemainingTTL in class AbstractSimpleRecord

getRemainingIdle

public long getRemainingIdle()

Specified by:

getRemainingIdle in interface Record

Overrides:

getRemainingIdle in class AbstractSimpleRecord

setMaxIdle

public void setMaxIdle(long idle)

Specified by:

setMaxIdle in interface Record

Overrides:

setMaxIdle in class AbstractSimpleRecord

setExpirationTime

public void setExpirationTime(long expTime)

Specified by:

setExpirationTime in interface Record

Overrides:

setExpirationTime in class AbstractSimpleRecord

setTTL

public void setTTL(long ttl)

Specified by:

setTTL in interface Record

Overrides:

setTTL in class AbstractSimpleRecord

setInvalid

public void setInvalid()

Specified by:

setInvalid in interface Record

Overrides:

setInvalid in class AbstractSimpleRecord

isValid

public boolean isValid(long now)

Specified by:

isValid in interface Record

Overrides:

isValid in class AbstractSimpleRecord

isValid

public boolean isValid()

Specified by:

isValid in interface MapEntry

Specified by:

isValid in interface Record

Overrides:

isValid in class AbstractSimpleRecord

markRemoved

public void markRemoved()

Specified by:

markRemoved in interface Record

Overrides:

markRemoved in class AbstractSimpleRecord

setActive

public void setActive()

Specified by:

setActive in interface Record

Overrides:

setActive in class AbstractSimpleRecord

getVersion

public long getVersion()

Specified by:

getVersion in interface MapEntry

Specified by:

getVersion in interface Record

Overrides:

getVersion in class AbstractSimpleRecord

setVersion

public void setVersion(long version)

Specified by:

setVersion in interface Record

Overrides:

setVersion in class AbstractSimpleRecord

incrementVersion

public void incrementVersion()

Specified by:

incrementVersion in interface Record

Overrides:

incrementVersion in class AbstractSimpleRecord

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime in interface MapEntry

Specified by:

getCreationTime in interface Record

Overrides:

getCreationTime in class AbstractSimpleRecord

setCreationTime

public void setCreationTime(long newValue)

Specified by:

setCreationTime in interface Record

Overrides:

setCreationTime in class AbstractSimpleRecord

getLastAccessTime

public long getLastAccessTime()

Specified by:

getLastAccessTime in interface MapEntry

Specified by:

getLastAccessTime in interface Record

Overrides:

getLastAccessTime in class AbstractSimpleRecord

setLastAccessTime

public void setLastAccessTime(long lastAccessTime)

Specified by:

setLastAccessTime in interface Record

Overrides:

setLastAccessTime in class AbstractSimpleRecord

getLastUpdateTime

public long getLastUpdateTime()

Specified by:

getLastUpdateTime in interface MapEntry

Specified by:

getLastUpdateTime in interface Record

Overrides:

getLastUpdateTime in class AbstractSimpleRecord

setLastUpdateTime

public void setLastUpdateTime(long lastUpdateTime)

Specified by:

setLastUpdateTime in interface Record

Overrides:

setLastUpdateTime in class AbstractSimpleRecord

getHits

public int getHits()

Specified by:

getHits in interface MapEntry

Specified by:

getHits in interface Record

Overrides:

getHits in class AbstractSimpleRecord

incrementHits

public void incrementHits()

Specified by:

incrementHits in interface Record

Overrides:

incrementHits in class AbstractSimpleRecord

setActive

public void setActive(boolean active)

Specified by:

setActive in interface Record

Overrides:

setActive in class AbstractSimpleRecord

getMultiValues

public Collection<ValueHolder> getMultiValues()

Specified by:

getMultiValues in interface Record

Overrides:

getMultiValues in class AbstractSimpleRecord

setMultiValues

public void setMultiValues(Collection<ValueHolder> lsValues)

Specified by:

setMultiValues in interface Record

Overrides:

setMultiValues in class AbstractSimpleRecord

getBackupOpCount

public int getBackupOpCount()

Specified by:

getBackupOpCount in interface Record

Overrides:

getBackupOpCount in class AbstractSimpleRecord

getBackupOps

public SortedSet<VersionedBackupOp> getBackupOps()

Specified by:

getBackupOps in interface Record

Overrides:

getBackupOps in class AbstractSimpleRecord

setBackupOps

public void setBackupOps(SortedSet<VersionedBackupOp> backupOps)

Specified by:

setBackupOps in interface Record

Overrides:

setBackupOps in class AbstractSimpleRecord

isDirty

public boolean isDirty()

Specified by:

isDirty in interface Record

Overrides:

isDirty in class AbstractSimpleRecord

setDirty

public void setDirty(boolean dirty)

Specified by:

setDirty in interface Record

Overrides:

setDirty in class AbstractSimpleRecord

getWriteTime

public long getWriteTime()

Specified by:

getWriteTime in interface Record

Overrides:

getWriteTime in class AbstractSimpleRecord

setWriteTime

public void setWriteTime(long writeTime)

Specified by:

setWriteTime in interface Record

Overrides:

setWriteTime in class AbstractSimpleRecord

getRemoveTime

public long getRemoveTime()

Specified by:

getRemoveTime in interface Record

Overrides:

getRemoveTime in class AbstractSimpleRecord

setRemoveTime

public void setRemoveTime(long removeTime)

Specified by:

setRemoveTime in interface Record

Overrides:

setRemoveTime in class AbstractSimpleRecord

hasScheduledAction

public boolean hasScheduledAction()

Specified by:

hasScheduledAction in interface Record

Overrides:

hasScheduledAction in class AbstractSimpleRecord

getScheduledActions

public List<ScheduledAction> getScheduledActions()

Specified by:

getScheduledActions in interface Record

Overrides:

getScheduledActions in class AbstractSimpleRecord

setScheduledActions

public void setScheduledActions(List<ScheduledAction> lsScheduledActions)

Specified by:

setScheduledActions in interface Record

Overrides:

setScheduledActions in class AbstractSimpleRecord

getListeners

public Map<Address,Boolean> getListeners()

Specified by:

getListeners in interface Record

Overrides:

getListeners in class AbstractSimpleRecord

setMapListeners

public void setMapListeners(Map<Address,Boolean> mapListeners)

Specified by:

setMapListeners in interface Record

Overrides:

setMapListeners in class AbstractSimpleRecord

getScheduledActionCount

public int getScheduledActionCount()

Specified by:

getScheduledActionCount in interface Record

Overrides:

getScheduledActionCount in class AbstractSimpleRecord

getOptionalInfo

public com.hazelcast.impl.AbstractRecord.OptionalInfo getOptionalInfo()

Specified by:

getOptionalInfo in interface Record

Overrides:

getOptionalInfo in class AbstractSimpleRecord

setLastStoredTime

public void setLastStoredTime(long lastStoredTime)

Specified by:

setLastStoredTime in interface Record

Overrides:

setLastStoredTime in class AbstractSimpleRecord

getLastStoredTime

public long getLastStoredTime()

Specified by:

getLastStoredTime in interface MapEntry

Specified by:

getLastStoredTime in interface Record

Overrides:

getLastStoredTime in class AbstractSimpleRecord

isEvicted

public boolean isEvicted()

isRemoved

public boolean isRemoved()

Specified by:

isRemoved in interface Record

Overrides:

isRemoved in class AbstractSimpleRecord

isLoadable

public boolean isLoadable()

True if record is not removed (map.remove() ...) and either is not active or not valid or has not value (may because of locking)

Specified by:

isLoadable in interface Record

Overrides:

isLoadable in class AbstractSimpleRecord

hashCode

public int hashCode()

Specified by:

hashCode in interface Record

Specified by:

hashCode in interface Map.Entry

Overrides:

hashCode in class AbstractSimpleRecord

equals

public boolean equals(Object o)

Specified by:

equals in interface Record

Specified by:

equals in interface Map.Entry

Overrides:

equals in class AbstractSimpleRecord

toString

public String toString()

Specified by:

toString in interface Record

Overrides:

toString in class Object