com.hazelcast.cache.impl

Class CacheEntryProcessorEntry<K,V,R extends CacheRecord>

java.lang.Object

com.hazelcast.cache.impl.CacheEntryProcessorEntry<K,V,R>

Type Parameters:

K - the type of key.

V - the type of value.

All Implemented Interfaces:

javax.cache.Cache.Entry<K,V>, javax.cache.processor.MutableEntry<K,V>

public class CacheEntryProcessorEntry<K,V,R extends CacheRecord>
extends Object
implements javax.cache.processor.MutableEntry<K,V>

This class is an implementation of MutableEntry which is provided into EntryProcessor.process(javax.cache.processor.MutableEntry, Object...).

CacheEntryProcessorEntry may face multiple mutating operations like setValue, remove or CacheLoading, etc.

This implementation may handle multiple operations executed on this entry and persist the resultant state into CacheRecordStore after entry processor get completed.

See Also:

EntryProcessor.process(javax.cache.processor.MutableEntry, Object...)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	CacheEntryProcessorEntry.State

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractCacheRecordStore	cacheRecordStore
protected int	completionId
protected javax.cache.expiry.ExpiryPolicy	expiryPolicy
protected K	key
protected Data	keyData
protected long	now
protected R	record
protected R	recordLoaded
protected long	start
protected CacheEntryProcessorEntry.State	state
protected V	value
protected V	valueLoaded

Constructor Summary

Constructors

Constructor and Description
CacheEntryProcessorEntry(Data keyData, R record, AbstractCacheRecordStore cacheRecordStore, long now, int completionId)

Method Summary

Modifier and Type	Method and Description
void	applyChanges() Provides a similar functionality as committing a transaction.
boolean	exists()
K	getKey()
R	getRecord()
protected V	getRecordValue(R record)
V	getValue()
protected void	onCreate(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, long now, boolean disableWriteThrough, int completionId, boolean saved)
protected void	onLoad(Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, long now, boolean disableWriteThrough, int completionId, boolean saved)
protected void	onRemove(Data key, String source, int completionId, boolean removed)
protected void	onUpdate(Data key, Object value, R record, javax.cache.expiry.ExpiryPolicy expiryPolicy, long now, boolean disableWriteThrough, int completionId, boolean saved)
void	remove()
void	setValue(V value)
<T> T	unwrap(Class<T> clazz)

Methods inherited from class java.lang.Object

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

Field Detail

key

protected K key

value

protected V value

state

protected CacheEntryProcessorEntry.State state

keyData

protected final Data keyData

record

protected R extends CacheRecord record

recordLoaded

protected R extends CacheRecord recordLoaded

valueLoaded

protected V valueLoaded

cacheRecordStore

protected final AbstractCacheRecordStore cacheRecordStore

now

protected final long now

start

protected final long start

expiryPolicy

protected final javax.cache.expiry.ExpiryPolicy expiryPolicy

completionId

protected final int completionId

Constructor Detail

CacheEntryProcessorEntry

public CacheEntryProcessorEntry(Data keyData,
                                R record,
                                AbstractCacheRecordStore cacheRecordStore,
                                long now,
                                int completionId)

Method Detail

exists

public boolean exists()

Specified by:

exists in interface javax.cache.processor.MutableEntry<K,V>

remove

public void remove()

Specified by:

remove in interface javax.cache.processor.MutableEntry<K,V>

setValue

public void setValue(V value)

Specified by:

setValue in interface javax.cache.processor.MutableEntry<K,V>

getKey

public K getKey()

Specified by:

getKey in interface javax.cache.Cache.Entry<K,V>

getValue

public V getValue()

Specified by:

getValue in interface javax.cache.Cache.Entry<K,V>

Specified by:

getValue in interface javax.cache.processor.MutableEntry<K,V>

getRecordValue

protected V getRecordValue(R record)

getRecord

public R getRecord()

applyChanges

public void applyChanges()

Provides a similar functionality as committing a transaction. So, at the end of the process method, applyChanges will be called to apply latest data into CacheRecordStore.

onCreate

protected void onCreate(Data key,
                        Object value,
                        javax.cache.expiry.ExpiryPolicy expiryPolicy,
                        long now,
                        boolean disableWriteThrough,
                        int completionId,
                        boolean saved)

onLoad

protected void onLoad(Data key,
                      Object value,
                      javax.cache.expiry.ExpiryPolicy expiryPolicy,
                      long now,
                      boolean disableWriteThrough,
                      int completionId,
                      boolean saved)

onUpdate

protected void onUpdate(Data key,
                        Object value,
                        R record,
                        javax.cache.expiry.ExpiryPolicy expiryPolicy,
                        long now,
                        boolean disableWriteThrough,
                        int completionId,
                        boolean saved)

onRemove

protected void onRemove(Data key,
                        String source,
                        int completionId,
                        boolean removed)

unwrap

public <T> T unwrap(Class<T> clazz)

Specified by:

unwrap in interface javax.cache.Cache.Entry<K,V>