public abstract class GridCacheAdapter<K,V> extends Object implements IgniteInternalCache<K,V>, Externalizable
| Modifier and Type | Class and Description |
|---|---|
protected class |
GridCacheAdapter.AsyncOp<T>
Cache operation.
|
protected static class |
GridCacheAdapter.CacheExpiryPolicy |
protected static class |
GridCacheAdapter.FutureHolder
Holder for last async operation future.
|
protected static class |
GridCacheAdapter.TopologyVersionAwareJob
Delayed callable class.
|
protected static class |
GridCacheAdapter.UpdateGetTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdatePutAndGetTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdatePutTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdateRemoveTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdateTimeStatClosure<T> |
| Modifier and Type | Field and Description |
|---|---|
protected CacheConfiguration |
cacheCfg
Cache configuration.
|
static int |
CLEAR_ALL_SPLIT_THRESHOLD
clearLocally() split threshold.
|
protected GridCacheContext<K,V> |
ctx
Cache configuration.
|
protected IgniteConfiguration |
gridCfg
Grid configuration.
|
protected boolean |
keyCheck |
protected ThreadLocal<GridCacheAdapter.FutureHolder> |
lastFut
Last asynchronous future.
|
protected UUID |
locNodeId
Local node ID.
|
protected IgniteLogger |
log
Logger.
|
protected GridCacheConcurrentMap |
map
Local map.
|
protected CacheMetricsImpl |
metrics
Cache metrics.
|
protected CacheMetricsMXBean |
mxBean
Cache mxBean.
|
protected static IgniteClosure |
RET2NULL
GridCacheReturn-to-null conversion. |
| Modifier | Constructor and Description |
|---|---|
protected |
GridCacheAdapter()
Empty constructor required by
Externalizable. |
protected |
GridCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap map) |
protected |
GridCacheAdapter(GridCacheContext<K,V> ctx,
int startSize) |
| Modifier and Type | Method and Description |
|---|---|
Affinity<K> |
affinity()
Gets affinity service to provide information about data partitioning
and distribution.
|
Set<GridCacheEntryEx> |
allEntries() |
protected <T> IgniteInternalFuture<T> |
asyncOp(IgniteTxLocalAdapter tx,
GridCacheAdapter.AsyncOp<T> op) |
protected <T> IgniteInternalFuture<T> |
asyncOpAcquire()
Tries to acquire asynchronous operations permit, if limited.
|
protected void |
asyncOpRelease()
Releases asynchronous operations permit, if limited.
|
void |
awaitLastFut()
Awaits for previous async operation to be completed.
|
<K1,V1> IgniteInternalCache<K1,V1> |
cache()
Gets base cache for this projection.
|
protected void |
checkJta()
Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
|
void |
clear()
Clears cache on all nodes that store it's data.
|
void |
clear(K key)
Clears key on all nodes that store it's data.
|
void |
clearAll(Set<? extends K> keys)
Clears keys on all nodes that store it's data.
|
IgniteInternalFuture<?> |
clearAsync() |
IgniteInternalFuture<?> |
clearAsync(K key) |
IgniteInternalFuture<?> |
clearAsync(Set<? extends K> keys) |
void |
clearLocally()
Clears all entries from this cache only if the entry is not
currently locked or participating in a transaction.
|
void |
clearLocally(Collection<KeyCacheObject> keys,
boolean readers) |
boolean |
clearLocally(K key)
Clears an entry from this cache and swap storage only if the entry
is not currently locked, and is not participating in a transaction.
|
void |
clearLocally0(Collection<? extends K> keys,
CacheEntryPredicate... filter) |
boolean |
clearLocally0(K key,
CacheEntryPredicate... filter) |
void |
clearLocallyAll(Set<? extends K> keys)
Clears entries from this cache and swap storage only if the entry
is not currently locked, and is not participating in a transaction.
|
IgniteInternalFuture<IgniteInternalTx> |
commitTxAsync(IgniteInternalTx tx)
Asynchronously commits transaction after all previous asynchronous operations are completed.
|
CacheConfiguration |
configuration()
Gets configuration bean for this cache.
|
boolean |
containsKey(K key) |
IgniteInternalFuture<Boolean> |
containsKeyAsync(K key) |
boolean |
containsKeys(Collection<? extends K> keys) |
IgniteInternalFuture<Boolean> |
containsKeysAsync(Collection<? extends K> keys) |
GridCacheContext<K,V> |
context() |
Set<GridCacheEntryEx> |
entries() |
GridCacheEntryEx |
entryEx(KeyCacheObject key) |
GridCacheEntryEx |
entryEx(KeyCacheObject key,
AffinityTopologyVersion topVer) |
GridCacheEntryEx |
entryEx(KeyCacheObject key,
boolean touch) |
GridCacheEntryEx |
entryEx(Object key) |
protected GridCacheEntryEx |
entryExSafe(KeyCacheObject key,
AffinityTopologyVersion topVer) |
Set<javax.cache.Cache.Entry<K,V>> |
entrySet()
Gets set of all entries cached on this node.
|
Set<javax.cache.Cache.Entry<K,V>> |
entrySet(CacheEntryPredicate... filter) |
Set<javax.cache.Cache.Entry<K,V>> |
entrySet(int part)
Gets set containing cache entries that belong to provided partition or
null
if partition is not found locally. |
Set<javax.cache.Cache.Entry<K,V>> |
entrySetx(CacheEntryPredicate... filter)
Gets entry set containing internal entries.
|
boolean |
evict(K key)
Evicts entry associated with given key from cache.
|
void |
evictAll(Collection<? extends K> keys)
Attempts to evict all entries associated with keys.
|
javax.cache.expiry.ExpiryPolicy |
expiry() |
IgniteCacheExpiryPolicy |
expiryPolicy(javax.cache.expiry.ExpiryPolicy plc) |
GridCacheProxyImpl<K,V> |
forSubjectId(UUID subjId)
Creates projection for specified subject ID.
|
V |
get(K key)
Retrieves value mapped to the specified key from cache.
|
V |
get(K key,
boolean deserializePortable) |
Map<K,V> |
getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
Map<K,V> |
getAll(Collection<? extends K> keys,
boolean deserializePortable) |
IgniteInternalFuture<Map<K,V>> |
getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
IgniteInternalFuture<Map<K,V>> |
getAllAsync(Collection<? extends K> keys,
boolean deserializePortable) |
protected IgniteInternalFuture<Map<K,V>> |
getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<Map<K,V>> |
getAllAsync(Collection<? extends K> keys,
boolean readThrough,
GridCacheEntryEx cached,
boolean checkTx,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean forcePrimary,
IgniteCacheExpiryPolicy expiry,
boolean skipVals) |
<K1,V1> IgniteInternalFuture<Map<K1,V1>> |
getAllAsync0(Collection<KeyCacheObject> keys,
boolean readThrough,
boolean checkTx,
UUID subjId,
String taskName,
boolean deserializePortable,
IgniteCacheExpiryPolicy expiry,
boolean skipVals,
boolean keepCacheObjects) |
Map<K,V> |
getAllOutTx(List<K> keys)
Gets values from cache.
|
V |
getAndPut(K key,
V val)
Stores given key-value pair in cache.
|
V |
getAndPut(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<V> |
getAndPutAsync(K key,
V val)
Asynchronously stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
getAndPutAsync(K key,
V val,
CacheEntryPredicate[] filter) |
IgniteInternalFuture<V> |
getAndPutAsync0(K key,
V val,
CacheEntryPredicate... filter) |
V |
getAndPutIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<V> |
getAndPutIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
V |
getAndRemove(K key)
Removes given key mapping from cache.
|
IgniteInternalFuture<V> |
getAndRemoveAsync(K key)
Asynchronously removes given key mapping from cache.
|
V |
getAndReplace(K key,
V val)
Stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<V> |
getAndReplaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if there is a previous mapping for it.
|
IgniteInternalFuture<V> |
getAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
IgniteInternalFuture<V> |
getAsync(K key,
boolean deserializePortable) |
V |
getForcePrimary(K key)
Gets value from cache.
|
IgniteInternalFuture<V> |
getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
long |
igfsDataSpaceMax()
Get maximum space available for IGFS.
|
long |
igfsDataSpaceUsed()
Get current amount of used IGFS space in bytes.
|
Iterator<javax.cache.Cache.Entry<K,V>> |
igniteIterator() |
protected void |
init()
Post constructor initialization for subclasses.
|
<T> javax.cache.processor.EntryProcessorResult<T> |
invoke(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>> |
invokeAll(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map,
Object... args) |
<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> |
invokeAllAsync(Set<? extends K> keys,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> |
invokeAsync(K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
boolean |
isColocated() |
boolean |
isDht() |
boolean |
isDhtAtomic() |
boolean |
isEmpty()
Returns
true if this map contains no key-value mappings. |
boolean |
isIgfsDataCache()
Checks whether this cache is IGFS data cache.
|
boolean |
isLocal() |
boolean |
isLocked(K key)
Checks if any node owns a lock for this key.
|
boolean |
isLockedByThread(K key)
Checks if current thread owns a lock on this key.
|
boolean |
isMongoDataCache()
Checks whether this cache is Mongo data cache.
|
boolean |
isMongoMetaCache()
Checks whether this cache is Mongo meta cache.
|
boolean |
isNear() |
Iterator<javax.cache.Cache.Entry<K,V>> |
iterator() |
protected Iterator<javax.cache.Cache.Entry<K,V>> |
iterator(Iterator<GridCacheEntryEx> it,
boolean deserializePortable) |
<K1,V1> GridCacheProxyImpl<K1,V1> |
keepPortable()
Creates projection that will operate with portable objects.
|
Set<K> |
keySet()
Set of keys cached on this node.
|
Set<K> |
keySet(CacheEntryPredicate... filter) |
IgniteInternalFuture<?> |
loadAll(Set<? extends K> keys,
boolean replaceExisting) |
Iterable<javax.cache.Cache.Entry<K,V>> |
localEntries(CachePeekMode[] peekModes) |
void |
localLoad(Collection<? extends K> keys,
javax.cache.expiry.ExpiryPolicy plc) |
void |
localLoadCache(IgniteBiPredicate<K,V> p,
Object[] args)
Delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. |
IgniteInternalFuture<?> |
localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object[] args)
Asynchronously delegates to
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
V |
localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
IgniteInternalFuture<?> |
localRemoveAll(CacheEntryPredicate filter) |
int |
localSize(CachePeekMode[] peekModes) |
boolean |
lock(K key,
long timeout)
Synchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
boolean |
lockAll(Collection<? extends K> keys,
long timeout)
All or nothing synchronous lock for passed in keys.
|
IgniteInternalFuture<Boolean> |
lockAsync(K key,
long timeout)
Asynchronously acquires lock on a cached object with given
key only if the passed in filter (if any) passes.
|
protected IgniteLogger |
log() |
GridCacheConcurrentMap |
map() |
CacheMetrics |
metrics()
Gets metrics (statistics) for this cache.
|
CacheMetricsImpl |
metrics0() |
CacheMetricsMXBean |
mxBean()
Gets metrics (statistics) for this cache.
|
String |
name()
Gets name of this cache (
null for default cache). |
int |
nearSize()
Gets size of near cache key set.
|
long |
offHeapAllocatedSize()
Gets memory size allocated in off-heap.
|
long |
offHeapEntriesCount()
Gets number of cache entries stored in off-heap memory.
|
Iterator<Map.Entry<K,V>> |
offHeapIterator()
Gets iterator over keys and values belonging to this cache off-heap memory on local node.
|
abstract void |
onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
void |
onIgfsDataSizeChanged(long delta)
Callback invoked when data is added to IGFS cache.
|
protected void |
onKernalStart()
Kernal start callback.
|
void |
onKernalStop()
Kernal stop callback.
|
void |
onUndeploy(ClassLoader ldr)
Undeploys and removes all entries for class loader.
|
long |
overflowSize()
Gets size (in bytes) of all entries swapped to disk.
|
GridCacheEntryEx |
peekEx(KeyCacheObject key) |
GridCacheEntryEx |
peekEx(Object key) |
abstract GridCachePreloader<K,V> |
preloader() |
Set<javax.cache.Cache.Entry<K,V>> |
primaryEntrySet(CacheEntryPredicate... filter) |
Set<K> |
primaryKeySet()
Set of keys for which this node is primary.
|
Set<K> |
primaryKeySet(CacheEntryPredicate... filter) |
int |
primarySize()
Gets the number of all primary entries cached on this node.
|
void |
printMemoryStats()
Prints memory stats.
|
V |
promote(K key,
boolean deserializePortable) |
void |
promoteAll(Collection<? extends K> keys)
This method unswaps cache entries by given keys, if any, from swap storage
into memory.
|
boolean |
put(K key,
V val)
Stores given key-value pair in cache.
|
boolean |
put(K key,
V val,
CacheEntryPredicate[] filter) |
void |
putAll(Map<? extends K,? extends V> m)
Stores given key-value pairs in cache.
|
IgniteInternalFuture<?> |
putAllAsync(Map<? extends K,? extends V> m)
Asynchronously stores given key-value pairs in cache.
|
void |
putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data.
|
IgniteInternalFuture<?> |
putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap)
Store DR data asynchronously.
|
IgniteInternalFuture<Boolean> |
putAsync(K key,
V val)
Stores given key-value pair in cache.
|
IgniteInternalFuture<Boolean> |
putAsync(K key,
V val,
CacheEntryPredicate... filter) |
IgniteInternalFuture<Boolean> |
putAsync0(K key,
V val,
CacheEntryPredicate... filter) |
boolean |
putIfAbsent(K key,
V val)
Stores given key-value pair in cache only if cache had no previous mapping for it.
|
IgniteInternalFuture<Boolean> |
putIfAbsentAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if cache had no previous mapping for it.
|
javax.cache.Cache.Entry<K,V> |
randomEntry() |
void |
readExternal(ObjectInput in) |
protected Object |
readResolve()
Reconstructs object on unmarshalling.
|
IgniteInternalFuture<Object> |
readThroughAllAsync(Collection<KeyCacheObject> keys,
boolean reload,
boolean skipVals,
IgniteInternalTx tx,
UUID subjId,
String taskName,
IgniteBiInClosure<KeyCacheObject,Object> vis) |
IgniteInternalFuture<?> |
rebalance()
Forces this cache node to re-balance its partitions.
|
IgniteInternalFuture<Map<KeyCacheObject,CacheObject>> |
reloadAllAsync0(Collection<KeyCacheObject> keys,
boolean ret,
boolean skipVals,
UUID subjId,
String taskName) |
boolean |
remove(K key)
Removes given key mapping from cache.
|
boolean |
remove(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
void |
removeAll(Collection<? extends K> keys)
Removes given key mappings from cache for entries for which the optionally passed in filters do
pass.
|
IgniteInternalFuture<?> |
removeAllAsync(Collection<? extends K> keys)
Asynchronously removes given key mappings from cache for entries for which the optionally
passed in filters do pass.
|
void |
removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<Boolean> |
removeAsync(K key)
Asynchronously removes given key mapping from cache.
|
IgniteInternalFuture<Boolean> |
removeAsync(K key,
CacheEntryPredicate... filter) |
IgniteInternalFuture<Boolean> |
removeAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
void |
removeEntry(GridCacheEntryEx entry) |
void |
removeIfObsolete(KeyCacheObject key) |
GridCacheReturn |
removex(K key,
V val)
Removes given key mapping from cache if one exists and value is equal to the passed in value.
|
IgniteInternalFuture<GridCacheReturn> |
removexAsync(K key,
V val)
Asynchronously removes given key mapping from cache if one exists and value is equal to the passed in value.
|
boolean |
replace(K key,
V val)
Stores given key-value pair in cache only if only if there is a previous mapping for it.
|
boolean |
replace(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<Boolean> |
replaceAsync(K key,
V val)
Asynchronously stores given key-value pair in cache only if only if there is a previous mapping for it.
|
IgniteInternalFuture<Boolean> |
replaceAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
GridCacheReturn |
replacex(K key,
V oldVal,
V newVal)
Stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
IgniteInternalFuture<GridCacheReturn> |
replacexAsync(K key,
V oldVal,
V newVal)
Asynchronously stores given key-value pair in cache only if only if the previous value is equal to the
'oldVal' passed in. |
protected void |
saveFuture(GridCacheAdapter.FutureHolder holder,
IgniteInternalFuture<?> fut)
Saves future in thread local holder and adds listener
that will clear holder when future is finished.
|
GridCacheProxyImpl<K,V> |
setSkipStore(boolean skipStore) |
int |
size()
Gets the number of all entries cached on this node.
|
int |
size(CachePeekMode[] peekModes) |
IgniteInternalFuture<Integer> |
sizeAsync(CachePeekMode[] peekModes) |
boolean |
skipStore() |
List<GridCacheClearAllRunnable<K,V>> |
splitClearLocally()
Split clearLocally all task into multiple runnables.
|
void |
start()
Starts this cache.
|
protected String |
startInfo()
Startup info.
|
void |
stop()
Stops this cache.
|
protected String |
stopInfo()
Stop info.
|
Iterator<Map.Entry<K,V>> |
swapIterator()
Gets iterator over keys and values belonging to this cache swap space on local node.
|
long |
swapKeys()
Gets number of swap entries (keys).
|
long |
swapSize()
Gets size in bytes for swap space.
|
String |
toString() |
V |
tryPutIfAbsent(K key,
V val)
Tries to put value in cache.
|
Transaction |
tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
abstract IgniteInternalFuture<Boolean> |
txLockAsync(Collection<KeyCacheObject> keys,
long timeout,
IgniteTxLocalEx tx,
boolean isRead,
boolean retval,
TransactionIsolation isolation,
boolean invalidate,
long accessTtl) |
Transaction |
txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
Transaction |
txStart(TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
IgniteInternalTx |
txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
void |
unlock(K key)
Unlocks given key only if current thread owns the lock.
|
protected void |
validateCacheKey(Object key)
Validates that given cache key has overridden equals and hashCode methods and
implements
Externalizable. |
protected void |
validateCacheKeys(Iterable<?> keys)
Validates that given cache keys have overridden equals and hashCode methods and
implement
Externalizable. |
Collection<V> |
values()
Collection of values cached on this node.
|
Collection<V> |
values(CacheEntryPredicate... filter)
Collection of values cached on this node.
|
GridCacheProxyImpl<K,V> |
withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc) |
void |
writeExternal(ObjectOutput out) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitlockAllAsync, removeAll, removeAllAsync, unlockAllpublic static final int CLEAR_ALL_SPLIT_THRESHOLD
protected static final IgniteClosure RET2NULL
GridCacheReturn-to-null conversion.protected boolean keyCheck
protected ThreadLocal<GridCacheAdapter.FutureHolder> lastFut
@GridToStringExclude protected GridCacheContext<K,V> ctx
@GridToStringExclude protected GridCacheConcurrentMap map
@GridToStringExclude protected UUID locNodeId
@GridToStringExclude protected CacheConfiguration cacheCfg
@GridToStringExclude protected IgniteConfiguration gridCfg
protected CacheMetricsImpl metrics
protected CacheMetricsMXBean mxBean
protected IgniteLogger log
protected GridCacheAdapter()
Externalizable.protected GridCacheAdapter(GridCacheContext<K,V> ctx, int startSize)
ctx - Cache context.startSize - Start size.protected GridCacheAdapter(GridCacheContext<K,V> ctx, GridCacheConcurrentMap map)
ctx - Cache context.map - Concurrent map.public String name()
null for default cache).name in interface IgniteInternalCache<K,V>public void printMemoryStats()
public GridCacheConcurrentMap map()
public GridCacheContext<K,V> context()
context in interface IgniteInternalCache<K,V>protected IgniteLogger log()
public boolean isNear()
True if this is near cache.public boolean isLocal()
True if cache is local.public boolean isColocated()
True if cache is colocated.public boolean isDhtAtomic()
True if cache is DHT Atomic.public boolean isDht()
True if cache is DHT.public abstract GridCachePreloader<K,V> preloader()
public Affinity<K> affinity()
affinity in interface IgniteInternalCache<K,V>public <K1,V1> IgniteInternalCache<K1,V1> cache()
cache in interface IgniteInternalCache<K,V>K1 - Cache key type.V1 - Cache value type.public GridCacheProxyImpl<K,V> forSubjectId(UUID subjId)
forSubjectId in interface IgniteInternalCache<K,V>subjId - Client ID.public boolean skipStore()
skipStore in interface IgniteInternalCache<K,V>public GridCacheProxyImpl<K,V> setSkipStore(boolean skipStore)
setSkipStore in interface IgniteInternalCache<K,V>skipStore - Skip store flag.public <K1,V1> GridCacheProxyImpl<K1,V1> keepPortable()
Projection returned by this method will force cache not to deserialize portable objects, so keys and values will be returned from cache API methods without changes. Therefore, signature of the projection can contain only following types:
org.gridgain.grid.portables.PortableObject for portable classesString and array of StringsUUID and array of UUIDsDate and array of DatesTimestamp and array of Timestamps
For example, if you use Integer as a key and Value class as a value
(which will be stored in portable format), you should acquire following projection
to avoid deserialization:
IgniteInternalCacheprj = cache.keepPortable(); // Value is not deserialized and returned in portable format. GridPortableObject po = prj.get(1);
Note that this method makes sense only if cache is working in portable mode
(org.apache.ignite.configuration.CacheConfiguration#isPortableEnabled() returns true. If not,
this method is no-op and will return current projection.
keepPortable in interface IgniteInternalCache<K,V>@Nullable public javax.cache.expiry.ExpiryPolicy expiry()
expiry in interface IgniteInternalCache<K,V>ExpiryPolicy associated with this projection.public GridCacheProxyImpl<K,V> withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc)
withExpiryPolicy in interface IgniteInternalCache<K,V>plc - ExpiryPolicy to associate with this projection.public CacheConfiguration configuration()
configuration in interface IgniteInternalCache<K,V>public abstract IgniteInternalFuture<Boolean> txLockAsync(Collection<KeyCacheObject> keys, long timeout, IgniteTxLocalEx tx, boolean isRead, boolean retval, TransactionIsolation isolation, boolean invalidate, long accessTtl)
keys - Keys to lock.timeout - Lock timeout.tx - Transaction.isRead - True for read operations.retval - Flag to return value.isolation - Transaction isolation.invalidate - Invalidate flag.accessTtl - TTL for read operation.protected void init()
public void start()
throws IgniteCheckedException
IgniteCheckedException - If start failed.protected final String startInfo()
public void stop()
protected final String stopInfo()
protected void onKernalStart()
throws IgniteCheckedException
IgniteCheckedException - If callback failed.public void onKernalStop()
public boolean isEmpty()
true if this map contains no key-value mappings.isEmpty in interface IgniteInternalCache<K,V>true if this map contains no key-value mappings.public boolean containsKey(K key)
containsKey in interface IgniteInternalCache<K,V>key - Key.True if cache contains mapping for a given key.public IgniteInternalFuture<Boolean> containsKeyAsync(K key)
containsKeyAsync in interface IgniteInternalCache<K,V>key - Key.public boolean containsKeys(Collection<? extends K> keys)
containsKeys in interface IgniteInternalCache<K,V>keys - Keys,True if cache contains all keys.public IgniteInternalFuture<Boolean> containsKeysAsync(Collection<? extends K> keys)
containsKeysAsync in interface IgniteInternalCache<K,V>keys - Keys to check.public Iterable<javax.cache.Cache.Entry<K,V>> localEntries(CachePeekMode[] peekModes) throws IgniteCheckedException
localEntries in interface IgniteInternalCache<K,V>peekModes - Peek modes.IgniteCheckedException - If failed.@Nullable public V localPeek(K key, CachePeekMode[] peekModes, @Nullable IgniteCacheExpiryPolicy plc) throws IgniteCheckedException
localPeek in interface IgniteInternalCache<K,V>key - Key.peekModes - Peek modes.plc - Expiry policy if TTL should be updated.IgniteCheckedException - If failed.public void onUndeploy(ClassLoader ldr)
ldr - Class loader to undeploy.@Nullable public GridCacheEntryEx peekEx(KeyCacheObject key)
key - Entry key.@Nullable public GridCacheEntryEx peekEx(Object key)
key - Entry key.public GridCacheEntryEx entryEx(Object key)
key - Entry key.null).public GridCacheEntryEx entryEx(KeyCacheObject key)
key - Entry key.null).public GridCacheEntryEx entryEx(KeyCacheObject key, boolean touch)
key - Entry key.touch - Whether created entry should be touched.null).public GridCacheEntryEx entryEx(KeyCacheObject key, AffinityTopologyVersion topVer)
topVer - Topology version.key - Entry key.null).public Set<GridCacheEntryEx> entries()
GridCacheInternal keys.public Set<GridCacheEntryEx> allEntries()
GridCacheInternal keys.public Set<javax.cache.Cache.Entry<K,V>> entrySet()
NOTE: this operation is not distributed and returns only the entries cached on this node.
entrySet in interface IgniteInternalCache<K,V>public Set<javax.cache.Cache.Entry<K,V>> entrySetx(CacheEntryPredicate... filter)
entrySetx in interface IgniteInternalCache<K,V>filter - Filter.public Set<javax.cache.Cache.Entry<K,V>> entrySet(int part)
null
if partition is not found locally.
NOTE: this operation is not distributed and returns only the entries cached on this node.
entrySet in interface IgniteInternalCache<K,V>part - Partition.null if partition is
not found locally.public Set<K> keySet()
Iterator over this set will not fail if set was concurrently updated by another thread. This means that iterator may or may not return latest keys depending on whether they were added before or after current iterator position.
NOTE: this operation is not distributed and returns only the keys cached on this node.
keySet in interface IgniteInternalCache<K,V>public Set<K> primaryKeySet()
null because they were invalidated. You can remove elements from
this set, but you cannot add elements to this set. All removal operation will be
reflected on the cache itself.
Iterator over this set will not fail if set was concurrently updated by another thread. This means that iterator may or may not return latest keys depending on whether they were added before or after current iterator position.
NOTE: this operation is not distributed and returns only the keys cached on this node.
primaryKeySet in interface IgniteInternalCache<K,V>public Collection<V> values()
Iterator over this collection will not fail if collection was concurrently updated by another thread. This means that iterator may or may not return latest values depending on whether they were added before or after current iterator position.
NOTE: this operation is not distributed and returns only the values cached on this node.
values in interface IgniteInternalCache<K,V>public Collection<V> values(CacheEntryPredicate... filter)
Iterator over this collection will not fail if collection was concurrently updated by another thread. This means that iterator may or may not return latest values depending on whether they were added before or after current iterator position.
NOTE: this operation is not distributed and returns only the values cached on this node.
filter - Filters.public void removeIfObsolete(KeyCacheObject key)
key - Entry key.public List<GridCacheClearAllRunnable<K,V>> splitClearLocally()
public boolean clearLocally(K key)
If CacheConfiguration.isSwapEnabled() is set to true, the evicted entries will
also be cleared from swap.
Note that this operation is local as it merely clears an entry from local cache. It does not remove entries from remote caches or from underlying persistent storage.
clearLocally in interface IgniteInternalCache<K,V>key - Key to clearLocally.True if entry was successfully cleared from cache, false
if entry was in use at the time of this method invocation and could not be
cleared.public void clearLocallyAll(Set<? extends K> keys)
If CacheConfiguration.isSwapEnabled() is set to true, the evicted entries will
also be cleared from swap.
Note that this operation is local as it merely clears an entry from local cache. It does not remove entries from remote caches or from underlying persistent storage.
clearLocallyAll in interface IgniteInternalCache<K,V>keys - Keys to clearLocally.public void clearLocally()
If CacheConfiguration.isSwapEnabled() is set to true, the evicted entries will
also be cleared from swap.
Note that this operation is local as it merely clears entries from local cache. It does not remove entries from remote caches or from underlying persistent storage.
clearLocally in interface IgniteInternalCache<K,V>public void clearLocally(Collection<KeyCacheObject> keys, boolean readers)
keys - Keys.readers - Readers flag.public void clear()
throws IgniteCheckedException
IgniteInternalCache.clearLocally() method which only
clears local node's cache.
Ignite will make the best attempt to clear caches on all nodes. If some caches could not be cleared, then exception will be thrown.
clear in interface IgniteInternalCache<K,V>IgniteCheckedException - In case of cache could not be cleared on any of the nodes.public void clear(K key) throws IgniteCheckedException
IgniteInternalCache.clearLocally(Object) method which only
clears local node's cache.
Ignite will make the best attempt to clear caches on all nodes. If some caches could not be cleared, then exception will be thrown.
clear in interface IgniteInternalCache<K,V>key - Key to clear.IgniteCheckedException - In case of cache could not be cleared on any of the nodes.public void clearAll(Set<? extends K> keys) throws IgniteCheckedException
IgniteInternalCache.clearLocallyAll(Set) method which only
clears local node's cache.
Ignite will make the best attempt to clear caches on all nodes. If some caches could not be cleared, then exception will be thrown.
clearAll in interface IgniteInternalCache<K,V>keys - Keys to clear.IgniteCheckedException - In case of cache could not be cleared on any of the nodes.public IgniteInternalFuture<?> clearAsync(K key)
clearAsync in interface IgniteInternalCache<K,V>key - Key to clear.public IgniteInternalFuture<?> clearAsync(Set<? extends K> keys)
clearAsync in interface IgniteInternalCache<K,V>keys - Keys to clear.public IgniteInternalFuture<?> clearAsync()
clearAsync in interface IgniteInternalCache<K,V>public void removeEntry(GridCacheEntryEx entry)
entry - Removes entry from cache if currently mapped value is the same as passed.public V getForcePrimary(K key) throws IgniteCheckedException
getForcePrimary in interface IgniteInternalCache<K,V>key - Key to get value for.IgniteCheckedException - If failed.public IgniteInternalFuture<V> getForcePrimaryAsync(K key)
getForcePrimaryAsync in interface IgniteInternalCache<K,V>key - Key to get value for.@Nullable public Map<K,V> getAllOutTx(List<K> keys) throws IgniteCheckedException
getAllOutTx in interface IgniteInternalCache<K,V>keys - Keys to get values for.IgniteCheckedException - If failed.public IgniteInternalFuture<Object> readThroughAllAsync(Collection<KeyCacheObject> keys, boolean reload, boolean skipVals, @Nullable IgniteInternalTx tx, @Nullable UUID subjId, String taskName, IgniteBiInClosure<KeyCacheObject,Object> vis)
keys - Keys.reload - Reload flag.tx - Transaction.subjId - Subject ID.taskName - Task name.vis - Visitor.public IgniteInternalFuture<Map<KeyCacheObject,CacheObject>> reloadAllAsync0(Collection<KeyCacheObject> keys, boolean ret, boolean skipVals, @Nullable UUID subjId, String taskName)
keys - Keys.ret - Return flag.skipVals - Skip values flag.subjId - Subject ID.taskName - Task name.@Nullable protected GridCacheEntryEx entryExSafe(KeyCacheObject key, AffinityTopologyVersion topVer)
key - Key.topVer - Topology version.@Nullable public V get(K key) throws IgniteCheckedException
null
means entry did not pass the provided filter or cache has no mapping for the
key.
If the value is not present in cache, then it will be looked up from swap storage. If
it's not present in swap, or if swap is disable, and if read-through is allowed, value
will be loaded from CacheStore persistent storage via
CacheStore#load(Transaction, Object) method.
get in interface IgniteInternalCache<K,V>key - Key to retrieve the value for.IgniteCheckedException - If get operation failed.public IgniteInternalFuture<V> getAsync(K key)
null
means entry did not pass the provided filter or cache has no mapping for the
key.
If the value is not present in cache, then it will be looked up from swap storage. If
it's not present in swap, or if swap is disabled, and if read-through is allowed, value
will be loaded from CacheStore persistent storage via
CacheStore#load(Transaction, Object) method.
getAsync in interface IgniteInternalCache<K,V>key - Key for the value to get.public Map<K,V> getAll(@Nullable Collection<? extends K> keys) throws IgniteCheckedException
If some value is not present in cache, then it will be looked up from swap storage. If
it's not present in swap, or if swap is disabled, and if read-through is allowed, value
will be loaded from CacheStore persistent storage via
CacheStore#loadAll(Transaction, Collection, org.apache.ignite.lang.IgniteBiInClosure) method.
getAll in interface IgniteInternalCache<K,V>keys - Keys to get.IgniteCheckedException - If get operation failed.public IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable Collection<? extends K> keys)
If some value is not present in cache, then it will be looked up from swap storage. If
it's not present in swap, or if swap is disabled, and if read-through is allowed, value
will be loaded from CacheStore persistent storage via
CacheStore#loadAll(Transaction, Collection, org.apache.ignite.lang.IgniteBiInClosure) method.
getAllAsync in interface IgniteInternalCache<K,V>keys - Key for the value to get.protected IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable Collection<? extends K> keys, boolean forcePrimary, boolean skipTx, @Nullable GridCacheEntryEx entry, @Nullable UUID subjId, String taskName, boolean deserializePortable, boolean skipVals)
keys - Keys.forcePrimary - Force primary.skipTx - Skip tx.entry - Entry.subjId - Subj Id.taskName - Task name.deserializePortable - Deserialize portable.skipVals - Skip values.getAllAsync(Collection)public IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable Collection<? extends K> keys, boolean readThrough, @Nullable GridCacheEntryEx cached, boolean checkTx, @Nullable UUID subjId, String taskName, boolean deserializePortable, boolean forcePrimary, @Nullable IgniteCacheExpiryPolicy expiry, boolean skipVals)
keys - Keys.readThrough - Read through.cached - Cached.checkTx - Check tx.subjId - Subj Id.taskName - Task name.deserializePortable - Deserialize portable.forcePrimary - Froce primary.expiry - Expiry policy.skipVals - Skip values.getAllAsync(Collection)public <K1,V1> IgniteInternalFuture<Map<K1,V1>> getAllAsync0(@Nullable Collection<KeyCacheObject> keys, boolean readThrough, boolean checkTx, @Nullable UUID subjId, String taskName, boolean deserializePortable, @Nullable IgniteCacheExpiryPolicy expiry, boolean skipVals, boolean keepCacheObjects)
keys - Keys.readThrough - Read-through flag.checkTx - Check local transaction flag.subjId - Subject ID.taskName - Task name/deserializePortable - Deserialize portable flag.expiry - Expiry policy.skipVals - Skip values flag.keepCacheObjects - Keep cache objectspublic V getAndPut(K key, V val) throws IgniteCheckedException
CacheMode.PARTITIONED or CacheMode.REPLICATED caches,
the value will be loaded from the primary node, which in its turn may load the value
from the swap storage, and consecutively, if it's not in swap,
from the underlying persistent storage. If value has to be loaded from persistent
storage, CacheStore#load(Transaction, Object) method will be used.
If the returned value is not needed, method #putx(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) should
always be used instead of this one to avoid the overhead associated with returning of the previous value.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
getAndPut in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.null
if entry did not pass the filter, or if there was no mapping for the key in swap
or in persistent storage.IgniteCheckedException - If put operation failed.@Nullable public V getAndPut(K key, V val, @Nullable CacheEntryPredicate[] filter) throws IgniteCheckedException
key - Key.val - Value.filter - Optional filter.IgniteCheckedException - If failed.public IgniteInternalFuture<V> getAndPutAsync(K key, V val)
CacheMode.REPLICATED caches, the value will be loaded from swap
and, if it's not there, and read-through is allowed, from the underlying
CacheStore storage. In case of CacheMode.PARTITIONED caches,
the value will be loaded from the primary node, which in its turn may load the value
from the swap storage, and consecutively, if it's not in swap and read-through is allowed,
from the underlying persistent storage. If value has to be loaded from persistent
storage, CacheStore#load(Transaction, Object) method will be used.
If the returned value is not needed, method #putx(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) should
always be used instead of this one to avoid the overhead associated with returning of the previous value.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
getAndPutAsync in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.public IgniteInternalFuture<V> getAndPutAsync(K key, V val, @Nullable CacheEntryPredicate[] filter)
key - Key.val - Value.filter - Filter.public IgniteInternalFuture<V> getAndPutAsync0(K key, V val, @Nullable CacheEntryPredicate... filter)
key - Key.val - Value.filter - Optional filter.public boolean put(K key, V val) throws IgniteCheckedException
This method will return true if value is stored in cache and false otherwise.
Unlike #put(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) method, it does not return previous
value and, therefore, does not have any overhead associated with returning a value. It
should be used whenever return value is not required.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
put in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.True if optional filter passed and value was stored in cache,
false otherwise. Note that this method will return true if filter is not
specified.IgniteCheckedException - If put operation failed.public boolean put(K key, V val, CacheEntryPredicate[] filter) throws IgniteCheckedException
key - Key.val - Value.filter - Filter.True if optional filter passed and value was stored in cache,
false otherwise. Note that this method will return true if filter is not
specified.IgniteCheckedException - If put operation failed.public void putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap) throws IgniteCheckedException
putAllConflict in interface IgniteInternalCache<K,V>drMap - DR map.IgniteCheckedException - If put operation failed.public IgniteInternalFuture<?> putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap) throws IgniteCheckedException
putAllConflictAsync in interface IgniteInternalCache<K,V>drMap - DR map.IgniteCheckedException - If put operation failed.public <T> javax.cache.processor.EntryProcessorResult<T> invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args) throws IgniteCheckedException
invoke in interface IgniteInternalCache<K,V>key - Key.entryProcessor - Entry processor.args - Arguments.IgniteCheckedException - If failed.public <T> Map<K,javax.cache.processor.EntryProcessorResult<T>> invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args) throws IgniteCheckedException
invokeAll in interface IgniteInternalCache<K,V>keys - Keys.entryProcessor - Entry processor.args - Arguments.IgniteCheckedException - If failed.public <T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> invokeAsync(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args) throws javax.cache.processor.EntryProcessorException
invokeAsync in interface IgniteInternalCache<K,V>key - Key.entryProcessor - Entry processor.args - Arguments.javax.cache.processor.EntryProcessorExceptionpublic <T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> invokeAllAsync(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
invokeAllAsync in interface IgniteInternalCache<K,V>keys - Keys.entryProcessor - Entry processor.args - Arguments.public <T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
invokeAllAsync in interface IgniteInternalCache<K,V>map - Map containing keys and entry processors to be applied to values.args - Arguments.public <T> Map<K,javax.cache.processor.EntryProcessorResult<T>> invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args) throws IgniteCheckedException
invokeAll in interface IgniteInternalCache<K,V>map - Map containing keys and entry processors to be applied to values.args - Arguments.IgniteCheckedException - If failed.public IgniteInternalFuture<Boolean> putAsync(K key, V val)
This method will return true if value is stored in cache and false otherwise.
Unlike #put(Object, Object, org.apache.ignite.lang.IgnitePredicate[]) method, it does not return previous
value and, therefore, does not have any overhead associated with returning of a value. It
should always be used whenever return value is not required.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
putAsync in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.true if optional filter
passed and value was stored in cache, false otherwise. Note that future will
return true if filter is not specified.public IgniteInternalFuture<Boolean> putAsync(K key, V val, @Nullable CacheEntryPredicate... filter)
key - Key.val - Value.filter - Filter.public IgniteInternalFuture<Boolean> putAsync0(K key, V val, @Nullable CacheEntryPredicate... filter)
key - Key.val - Value.filter - Optional filter.@Nullable public V tryPutIfAbsent(K key, V val) throws IgniteCheckedException
GridCacheTryPutFailedException
if topology exchange is in progress.key - Key.val - value.IgniteCheckedException - In case of error.@Nullable public V getAndPutIfAbsent(K key, V val) throws IgniteCheckedException
CacheMode.PARTITIONED or CacheMode.REPLICATED caches,
the value will be loaded from the primary node, which in its turn may load the value
from the swap storage, and consecutively, if it's not in swap,
from the underlying persistent storage. If value has to be loaded from persistent
storage, CacheStore#load(Transaction, Object) method will be used.
If the returned value is not needed, method IgniteInternalCache.putIfAbsent(Object, Object) should
always be used instead of this one to avoid the overhead associated with returning of the
previous value.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
getAndPutIfAbsent in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.IgniteCheckedException - If put operation failed.public IgniteInternalFuture<V> getAndPutIfAbsentAsync(K key, V val)
CacheMode.PARTITIONED or CacheMode.REPLICATED caches,
the value will be loaded from the primary node, which in its turn may load the value
from the swap storage, and consecutively, if it's not in swap,
from the underlying persistent storage. If value has to be loaded from persistent
storage, CacheStore#load(Transaction, Object) method will be used.
If the returned value is not needed, method IgniteInternalCache.putIfAbsentAsync(Object, Object) should
always be used instead of this one to avoid the overhead associated with returning of the
previous value.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
getAndPutIfAbsentAsync in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.public boolean putIfAbsent(K key, V val) throws IgniteCheckedException
This method will return true if value is stored in cache and false otherwise.
Unlike IgniteInternalCache.getAndPutIfAbsent(Object, Object) method, it does not return previous
value and, therefore, does not have any overhead associated with returning of a value. It
should always be used whenever return value is not required.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
putIfAbsent in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.true if value is stored in cache and false otherwise.IgniteCheckedException - If put operation failed.public IgniteInternalFuture<Boolean> putIfAbsentAsync(K key, V val)
This method will return true if value is stored in cache and false otherwise.
Unlike IgniteInternalCache.getAndPutIfAbsent(Object, Object) method, it does not return previous
value and, therefore, does not have any overhead associated with returning of a value. It
should always be used whenever return value is not required.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
putIfAbsentAsync in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.@Nullable public V getAndReplace(K key, V val) throws IgniteCheckedException
CacheMode.PARTITIONED or CacheMode.REPLICATED caches,
the value will be loaded from the primary node, which in its turn may load the value
from the swap storage, and consecutively, if it's not in swap,
from the underlying persistent storage. If value has to be loaded from persistent
storage, CacheStore#load(Transaction, Object) method will be used.
If the returned value is not needed, method IgniteInternalCache.replace(Object, Object) should
always be used instead of this one to avoid the overhead associated with returning of the
previous value.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
getAndReplace in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.IgniteCheckedException - If replace operation failed.public IgniteInternalFuture<V> getAndReplaceAsync(K key, V val)
CacheMode.PARTITIONED caches, the value will be loaded from the primary node,
which in its turn may load the value from the swap storage, and consecutively, if it's not in swap,
from the underlying persistent storage. If value has to be loaded from persistent
storage, CacheStore#load(Transaction, Object) method will be used.
If the returned value is not needed, method IgniteInternalCache.replace(Object, Object) should
always be used instead of this one to avoid the overhead associated with returning of the
previous value.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
getAndReplaceAsync in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.public boolean replace(K key, V val) throws IgniteCheckedException
This method will return true if value is stored in cache and false otherwise.
Unlike IgniteInternalCache.getAndReplace(Object, Object) method, it does not return previous
value and, therefore, does not have any overhead associated with returning of a value. It
should always be used whenever return value is not required.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
replace in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.True if replace happened, false otherwise.IgniteCheckedException - If replace operation failed.public IgniteInternalFuture<Boolean> replaceAsync(K key, V val)
This method will return true if value is stored in cache and false otherwise.
Unlike IgniteInternalCache.getAndReplaceAsync(Object, Object) method, it does not return previous
value and, therefore, does not have any overhead associated with returning of a value. It
should always be used whenever return value is not required.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
replaceAsync in interface IgniteInternalCache<K,V>key - Key to store in cache.val - Value to be associated with the given key.public boolean replace(K key, V oldVal, V newVal) throws IgniteCheckedException
'oldVal' passed in.
This method will return true if value is stored in cache and false otherwise.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
replace in interface IgniteInternalCache<K,V>key - Key to store in cache.oldVal - Old value to match.newVal - Value to be associated with the given key.True if replace happened, false otherwise.IgniteCheckedException - If replace operation failed.public IgniteInternalFuture<Boolean> replaceAsync(K key, V oldVal, V newVal)
'oldVal' passed in.
This method will return true if value is stored in cache and false otherwise.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheStore#put(Transaction, Object, Object) method.
replaceAsync in interface IgniteInternalCache<K,V>key - Key to store in cache.oldVal - Old value to match.newVal - Value to be associated with the given key.public void putAll(@Nullable Map<? extends K,? extends V> m) throws IgniteCheckedException
If write-through is enabled, the stored values will be persisted to CacheStore
via CacheStore#putAll(Transaction, Map) method.
putAll in interface IgniteInternalCache<K,V>m - Key-value pairs to store in cache.IgniteCheckedException - If put operation failed.public IgniteInternalFuture<?> putAllAsync(Map<? extends K,? extends V> m)
If write-through is enabled, the stored values will be persisted to CacheStore
via CacheStore#putAll(Transaction, Map) method.
putAllAsync in interface IgniteInternalCache<K,V>m - Key-value pairs to store in cache.@Nullable public V getAndRemove(K key) throws IgniteCheckedException
CacheMode.PARTITIONED or CacheMode.REPLICATED
caches, the value will be loaded from the primary node, which in its turn may load the value
from the disk-based swap storage, and consecutively, if it's not in swap,
from the underlying persistent storage. If value has to be loaded from persistent
storage, CacheStore#load(Transaction, Object) method will be used.
If the returned value is not needed, method #removex(Object, org.apache.ignite.lang.IgnitePredicate[]) should
always be used instead of this one to avoid the overhead associated with returning of the
previous value.
If write-through is enabled, the value will be removed from CacheStore
via CacheStore#remove(Transaction, Object) method.
getAndRemove in interface IgniteInternalCache<K,V>key - Key whose mapping is to be removed from cache.null
if there was no value for this key.IgniteCheckedException - If remove operation failed.public IgniteInternalFuture<V> getAndRemoveAsync(K key)
CacheMode.PARTITIONED or CacheMode.REPLICATED
caches, the value will be loaded from the primary node, which in its turn may load the value
from the swap storage, and consecutively, if it's not in swap,
from the underlying persistent storage. If value has to be loaded from persistent
storage, CacheStore#load(Transaction, Object) method will be used.
If the returned value is not needed, method #removex(Object, org.apache.ignite.lang.IgnitePredicate[]) should
always be used instead of this one to avoid the overhead associated with returning of the
previous value.
If write-through is enabled, the value will be removed from CacheStore
via CacheStore#remove(Transaction, Object) method.
getAndRemoveAsync in interface IgniteInternalCache<K,V>key - Key whose mapping is to be removed from cache.public void removeAll(Collection<? extends K> keys) throws IgniteCheckedException
If write-through is enabled, the values will be removed from CacheStore
via @link CacheStore#removeAll(Transaction, Collection) method.
removeAll in interface IgniteInternalCache<K,V>keys - Keys whose mappings are to be removed from cache.IgniteCheckedException - If remove failed.public IgniteInternalFuture<?> removeAllAsync(@Nullable Collection<? extends K> keys)
If write-through is enabled, the values will be removed from CacheStore
via @link CacheStore#removeAll(Transaction, Collection) method.
removeAllAsync in interface IgniteInternalCache<K,V>keys - Keys whose mappings are to be removed from cache.public boolean remove(K key) throws IgniteCheckedException
This method will return true if remove did occur, which means that all optionally
provided filters have passed and there was something to remove, false otherwise.
If write-through is enabled, the value will be removed from CacheStore
via CacheStore#remove(Transaction, Object) method.
remove in interface IgniteInternalCache<K,V>key - Key whose mapping is to be removed from cache.True if filter passed validation and entry was removed, false otherwise.
Note that if filter is not specified, this method will return true.IgniteCheckedException - If remove failed.public IgniteInternalFuture<Boolean> removeAsync(K key)
This method will return true if remove did occur, which means that all optionally
provided filters have passed and there was something to remove, false otherwise.
If write-through is enabled, the value will be removed from CacheStore
via CacheStore#remove(Transaction, Object) method.
removeAsync in interface IgniteInternalCache<K,V>key - Key whose mapping is to be removed from cache.true
if optional filters passed validation and remove did occur, false otherwise.
Note that if filter is not specified, this method will return true.public IgniteInternalFuture<Boolean> removeAsync(K key, @Nullable CacheEntryPredicate... filter)
key - Key to remove.filter - Optional filter.public GridCacheReturn removex(K key, V val) throws IgniteCheckedException
If write-through is enabled, the value will be removed from CacheStore
via CacheWriter.delete(Object) method.
removex in interface IgniteInternalCache<K,V>key - Key whose mapping is to be removed from cache.val - Value to match against currently cached value.IgniteCheckedException - If remove failed.public void removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap) throws IgniteCheckedException
removeAllConflict in interface IgniteInternalCache<K,V>drMap - DR map.IgniteCheckedException - If remove failed.public IgniteInternalFuture<?> removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap) throws IgniteCheckedException
removeAllConflictAsync in interface IgniteInternalCache<K,V>drMap - DR map.IgniteCheckedException - If remove failed.public GridCacheReturn replacex(K key, V oldVal, V newVal) throws IgniteCheckedException
'oldVal' passed in.
This method will return true if value is stored in cache and false otherwise.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheWriter.write(javax.cache.Cache.Entry) method.
replacex in interface IgniteInternalCache<K,V>key - Key to store in cache.oldVal - Old value to match.newVal - Value to be associated with the given key.IgniteCheckedException - If replace operation failed.public IgniteInternalFuture<GridCacheReturn> removexAsync(K key, V val)
This method will return true if remove did occur, which means that all optionally
provided filters have passed and there was something to remove, false otherwise.
If write-through is enabled, the value will be removed from CacheStore
via CacheWriter.delete(Object) method.
removexAsync in interface IgniteInternalCache<K,V>key - Key whose mapping is to be removed from cache.val - Value to match against currently cached value.public IgniteInternalFuture<GridCacheReturn> replacexAsync(K key, V oldVal, V newVal)
'oldVal' passed in.
This method will return true if value is stored in cache and false otherwise.
If write-through is enabled, the stored value will be persisted to CacheStore
via CacheWriter.write(javax.cache.Cache.Entry) method.
replacexAsync in interface IgniteInternalCache<K,V>key - Key to store in cache.oldVal - Old value to match.newVal - Value to be associated with the given key.public boolean remove(K key, V val) throws IgniteCheckedException
If write-through is enabled, the value will be removed from CacheStore
via CacheStore#remove(Transaction, Object) method.
remove in interface IgniteInternalCache<K,V>key - Key whose mapping is to be removed from cache.val - Value to match against currently cached value.True if entry was removed and passed in value matched the cached one,
false otherwise.IgniteCheckedException - If remove failed.public IgniteInternalFuture<Boolean> removeAsync(K key, V val)
This method will return true if remove did occur, which means that all optionally
provided filters have passed and there was something to remove, false otherwise.
If write-through is enabled, the value will be removed from CacheStore
via CacheStore#remove(Transaction, Object) method.
removeAsync in interface IgniteInternalCache<K,V>key - Key whose mapping is to be removed from cache.val - Value to match against currently cached value.true
if currently cached value will match the passed in one.public IgniteInternalFuture<?> localRemoveAll(CacheEntryPredicate filter)
filter - Filter.public CacheMetrics metrics()
metrics in interface IgniteInternalCache<K,V>public CacheMetricsMXBean mxBean()
mxBean in interface IgniteInternalCache<K,V>public CacheMetricsImpl metrics0()
@Nullable public Transaction tx()
null if this thread does
not have a transaction.tx in interface IgniteInternalCache<K,V>null if this thread
does not have a transaction.public boolean lock(K key, long timeout) throws IgniteCheckedException
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.lock in interface IgniteInternalCache<K,V>key - Key to lock.timeout - Timeout in milliseconds to wait for lock to be acquired
('0' for no expiration), -1 for immediate failure if
lock cannot be acquired immediately).True if all filters passed and lock was acquired,
false otherwise.IgniteCheckedException - If lock acquisition resulted in error.public boolean lockAll(@Nullable Collection<? extends K> keys, long timeout) throws IgniteCheckedException
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.lockAll in interface IgniteInternalCache<K,V>keys - Keys to lock.timeout - Timeout in milliseconds to wait for lock to be acquired
('0' for no expiration).True if all filters passed and locks were acquired before
timeout has expired, false otherwise.IgniteCheckedException - If lock acquisition resulted in error.public IgniteInternalFuture<Boolean> lockAsync(K key, long timeout)
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.lockAsync in interface IgniteInternalCache<K,V>key - Key to lock.timeout - Timeout in milliseconds to wait for lock to be acquired
('0' for no expiration, -1 for immediate failure if
lock cannot be acquired immediately).true
whenever all filters pass and locks are acquired before timeout is expired,
false otherwise.public void unlock(K key) throws IgniteCheckedException
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.unlock in interface IgniteInternalCache<K,V>key - Key to unlock.IgniteCheckedException - If unlock execution resulted in error.public boolean isLocked(K key)
This is a local in-VM operation and does not involve any network trips or access to persistent storage in any way.
isLocked in interface IgniteInternalCache<K,V>key - Key to check.True if lock is owned by some node.public boolean isLockedByThread(K key)
This is a local in-VM operation and does not involve any network trips or access to persistent storage in any way.
isLockedByThread in interface IgniteInternalCache<K,V>key - Key to check.True if key is locked by current thread.public Transaction txStart(TransactionConcurrency concurrency, TransactionIsolation isolation)
txStart in interface IgniteInternalCache<K,V>concurrency - Concurrency.isolation - Isolation.public IgniteInternalTx txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
txStartEx in interface IgniteInternalCache<K,V>concurrency - Concurrency.isolation - Isolation.public Transaction txStart(TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, int txSize) throws IllegalStateException
txStart in interface IgniteInternalCache<K,V>concurrency - Concurrency.isolation - Isolation.timeout - Timeout.txSize - Number of entries participating in transaction (may be approximate).IllegalStateException - If transaction is already started by this thread.public long overflowSize()
throws IgniteCheckedException
overflowSize in interface IgniteInternalCache<K,V>IgniteCheckedException - In case of error.protected void checkJta()
throws IgniteCheckedException
IgniteCheckedException - In case of error.public void localLoadCache(IgniteBiPredicate<K,V> p, Object[] args) throws IgniteCheckedException
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method
to load state from the underlying persistent storage. The loaded values
will then be given to the optionally passed in predicate, and, if the predicate returns
true, will be stored in cache. If predicate is null, then
all loaded values will be stored in cache.
Note that this method does not receive keys as a parameter, so it is up to
CacheStore implementation to provide all the data to be loaded.
This method is not transactional and may end up loading a stale value into cache if another thread has updated the value immediately after it has been loaded. It is mostly useful when pre-loading the cache from underlying data store before start, or for read-only caches.
localLoadCache in interface IgniteInternalCache<K,V>p - Optional predicate (may be null). If provided, will be used to
filter values to be put into cache.args - Optional user arguments to be passed into
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method.IgniteCheckedException - If loading failed.public IgniteInternalFuture<?> localLoadCacheAsync(IgniteBiPredicate<K,V> p, Object[] args)
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. The reloaded values
will then be given to the optionally passed in predicate, and if the predicate returns
true, will be stored in cache. If predicate is null, then
all reloaded values will be stored in cache.
Note that this method does not receive keys as a parameter, so it is up to
CacheStore implementation to provide all the data to be loaded.
This method is not transactional and may end up loading a stale value into cache if another thread has updated the value immediately after it has been loaded. It is mostly useful when pre-loading the cache from underlying data store before start, or for read-only caches.
localLoadCacheAsync in interface IgniteInternalCache<K,V>p - Optional predicate (may be null). If provided, will be used to
filter values to be put into cache.args - Optional user arguments to be passed into
CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method.public IgniteInternalFuture<?> loadAll(Set<? extends K> keys, boolean replaceExisting)
keys - Keys.replaceExisting - Replace existing values flag.public void localLoad(Collection<? extends K> keys, @Nullable javax.cache.expiry.ExpiryPolicy plc) throws IgniteCheckedException
keys - Keys to load.plc - Optional expiry policy.IgniteCheckedException - If failed.public int size(CachePeekMode[] peekModes) throws IgniteCheckedException
size in interface IgniteInternalCache<K,V>peekModes - Peek modes.IgniteCheckedException - If failed.public IgniteInternalFuture<Integer> sizeAsync(CachePeekMode[] peekModes)
sizeAsync in interface IgniteInternalCache<K,V>peekModes - Peek modes.public int localSize(CachePeekMode[] peekModes) throws IgniteCheckedException
localSize in interface IgniteInternalCache<K,V>peekModes - Peek modes.IgniteCheckedException - If failed.public int size()
IgniteInternalCache. It is essentially the
size of cache key set and is semantically identical to {Cache.keySet().size().
NOTE: this operation is not distributed and returns only the number of entries cached on this node.
size in interface IgniteInternalCache<K,V>public int nearSize()
Note that for LOCAL non-distributed caches this method will always return 0
nearSize in interface IgniteInternalCache<K,V>0 if cache is not CacheMode.PARTITIONED.public int primarySize()
CacheMode.LOCAL non-distributed
cache mode, this method is identical to IgniteInternalCache.size().
For CacheMode.PARTITIONED and CacheMode.REPLICATED modes, this method will
return number of primary entries cached on this node (excluding any backups). The complexity of
this method is O(P), where P is the total number of partitions.
NOTE: this operation is not distributed and returns only the number of primary entries cached on this node.
primarySize in interface IgniteInternalCache<K,V>public Iterator<javax.cache.Cache.Entry<K,V>> igniteIterator()
@Nullable public V promote(K key, boolean deserializePortable) throws IgniteCheckedException
key - Key.deserializePortable - Deserialize portable flag.IgniteCheckedException - If failed.public void promoteAll(@Nullable Collection<? extends K> keys) throws IgniteCheckedException
promoteAll in interface IgniteInternalCache<K,V>keys - Keys to promote entries for.IgniteCheckedException - If promote failed.public Iterator<Map.Entry<K,V>> swapIterator() throws IgniteCheckedException
Returned iterator supports remove operation which delegates to
removex(Object, org.apache.ignite.lang.IgnitePredicate[]) method.
swapIterator in interface IgniteInternalCache<K,V>IgniteCheckedException - If failed.public Iterator<Map.Entry<K,V>> offHeapIterator() throws IgniteCheckedException
Returned iterator supports remove operation which delegates to
removex(Object, org.apache.ignite.lang.IgnitePredicate[])} method.
offHeapIterator in interface IgniteInternalCache<K,V>IgniteCheckedException - If failed.public long offHeapEntriesCount()
offHeapEntriesCount in interface IgniteInternalCache<K,V>public long offHeapAllocatedSize()
offHeapAllocatedSize in interface IgniteInternalCache<K,V>public long swapSize()
throws IgniteCheckedException
swapSize in interface IgniteInternalCache<K,V>IgniteCheckedException - If failed.public long swapKeys()
throws IgniteCheckedException
swapKeys in interface IgniteInternalCache<K,V>IgniteCheckedException - If failed.public IgniteInternalFuture<IgniteInternalTx> commitTxAsync(IgniteInternalTx tx)
tx - Transaction to commit.public void awaitLastFut()
protected <T> IgniteInternalFuture<T> asyncOp(IgniteTxLocalAdapter tx, GridCacheAdapter.AsyncOp<T> op)
T - Return type.tx - Transaction.op - Cache operation.protected void saveFuture(GridCacheAdapter.FutureHolder holder, IgniteInternalFuture<?> fut)
holder - Future holder.fut - Future to save.@Nullable protected <T> IgniteInternalFuture<T> asyncOpAcquire()
protected void asyncOpRelease()
public void writeExternal(ObjectOutput out) throws IOException
writeExternal in interface ExternalizableIOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal in interface ExternalizableIOExceptionClassNotFoundExceptionprotected Object readResolve() throws ObjectStreamException
ObjectStreamException - Thrown in case of unmarshalling error.public IgniteInternalFuture<?> rebalance()
CacheConfiguration.getRebalanceDelay() configuration parameter has non-zero value.
When many nodes are started or stopped almost concurrently, it is more efficient to delay
rebalancing until the node topology is stable to make sure that no redundant re-partitioning
happens.
In case ofCacheMode.PARTITIONED caches, for better efficiency user should
usually make sure that new nodes get placed on the same place of consistent hash ring as
the left nodes, and that nodes are restarted before
rebalanceDelay expires. To place nodes
on the same place in consistent hash ring, use
RendezvousAffinityFunction.setHashIdResolver(AffinityNodeHashResolver) to make sure that
a node maps to the same hash ID if re-started.
See CacheConfiguration.getRebalanceDelay() for more information on how to configure
rebalance re-partition delay.
rebalance in interface IgniteInternalCache<K,V>public boolean isIgfsDataCache()
isIgfsDataCache in interface IgniteInternalCache<K,V>True in case this cache is IGFS data cache.public long igfsDataSpaceUsed()
igfsDataSpaceUsed in interface IgniteInternalCache<K,V>public long igfsDataSpaceMax()
igfsDataSpaceMax in interface IgniteInternalCache<K,V>public boolean isMongoDataCache()
isMongoDataCache in interface IgniteInternalCache<K,V>True if this cache is mongo data cache.public boolean isMongoMetaCache()
isMongoMetaCache in interface IgniteInternalCache<K,V>True if this cache is mongo meta cache.public void onIgfsDataSizeChanged(long delta)
delta - Size delta.public void clearLocally0(Collection<? extends K> keys, @Nullable CacheEntryPredicate... filter)
keys - Keys.filter - Filters to evaluate.public boolean clearLocally0(K key, @Nullable CacheEntryPredicate... filter)
key - Key.filter - Filters to evaluate.True if cleared.public boolean evict(K key)
If CacheConfiguration.isSwapEnabled() is set to true, the evicted entry will
be swapped to offheap, and then to disk.
evict in interface IgniteInternalCache<K,V>key - Key to evict from cache.True if entry could be evicted, false otherwise.public void evictAll(Collection<? extends K> keys)
If CacheConfiguration.isSwapEnabled() is set to true, the evicted entry will
be swapped to offheap, and then to disk.
evictAll in interface IgniteInternalCache<K,V>keys - Keys to evict.public Set<javax.cache.Cache.Entry<K,V>> entrySet(@Nullable CacheEntryPredicate... filter)
filter - Filters to evaluate.public Set<javax.cache.Cache.Entry<K,V>> primaryEntrySet(@Nullable CacheEntryPredicate... filter)
filter - Filters to evaluate.public Set<K> keySet(@Nullable CacheEntryPredicate... filter)
filter - Filters to evaluate.public Set<K> primaryKeySet(@Nullable CacheEntryPredicate... filter)
filter - Primary key set.@Nullable public V get(K key, boolean deserializePortable) throws IgniteCheckedException
key - Key.deserializePortable - Deserialize portable flag.IgniteCheckedException - If failed.public final IgniteInternalFuture<V> getAsync(K key, boolean deserializePortable)
key - Key.deserializePortable - Deserialize portable flag.public Map<K,V> getAll(Collection<? extends K> keys, boolean deserializePortable) throws IgniteCheckedException
keys - Keys.deserializePortable - Deserialize portable flag.IgniteCheckedException - If read failed.public IgniteInternalFuture<Map<K,V>> getAllAsync(@Nullable Collection<? extends K> keys, boolean deserializePortable)
keys - Keys.deserializePortable - Deserialize portable flag.public abstract void onDeferredDelete(GridCacheEntryEx entry, GridCacheVersion ver)
entry - Entry.ver - Version.protected void validateCacheKey(Object key)
Externalizable.key - Cache key.IllegalArgumentException - If validation fails.protected void validateCacheKeys(Iterable<?> keys)
Externalizable.keys - Cache keys.IgniteException - If validation fails.protected Iterator<javax.cache.Cache.Entry<K,V>> iterator(Iterator<GridCacheEntryEx> it, boolean deserializePortable)
it - Internal entry iterator.deserializePortable - Deserialize portable flag.@Nullable public IgniteCacheExpiryPolicy expiryPolicy(@Nullable javax.cache.expiry.ExpiryPolicy plc)
plc - Explicitly specified expiry policy for cache operation.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.1.0-incubating Release Date : May 20 2015