public interface IgniteInternalCache<K,V> extends Iterable<javax.cache.Cache.Entry<K,V>>
'get(..)' methods to synchronously or asynchronously get values from cache.
All 'get(..)' methods are transactional and will participate in an ongoing transaction
if there is one.
'put(..)', 'putIfAbsent(..)', and 'replace(..)' methods to
synchronously or asynchronously put single or multiple entries into cache.
All these methods are transactional and will participate in an ongoing transaction
if there is one.
'remove(..)' methods to synchronously or asynchronously remove single or multiple keys
from cache. All 'remove(..)' methods are transactional and will participate in an ongoing transaction
if there is one.
'contains(..)' method to check if cache contains certain keys or values locally.
'forEach(..)', 'forAny(..)', and 'reduce(..)' methods to visit
every local cache entry within this projection.
flagsOn(..)', 'flagsOff(..)', and 'projection(..)' methods to
set specific flags and filters on a cache projection.
'keySet(..)', 'values(..)', and 'entrySet(..)' to provide
views on cache keys, values, and entries.
'peek(..)' methods to peek at values in global or transactional memory, swap
storage, or persistent storage.
'reload(..)' methods to reload latest values from persistent storage.
'promote(..)' methods to load specified keys from swap storage into
global cache memory.
'lock(..)', 'unlock(..)', and 'isLocked(..)' methods to acquire, release,
and check on distributed locks on a single or multiple keys in cache. All locking methods
are not transactional and will not enlist keys into ongoing transaction, if any.
'clear(..)' methods to clear elements from cache, and optionally from
swap storage. All 'clear(..)' methods are not transactional and will not enlist cleared
keys into ongoing transaction, if any.
'evict(..)' methods to evict elements from cache, and optionally store
them in underlying swap storage for later access. All 'evict(..)' methods are not
transactional and will not enlist evicted keys into ongoing transaction, if any.
'txStart(..)' methods to perform various cache
operations within a transaction (see Transaction for more information).
'gridProjection(..)' methods which provide ClusterGroup only
for nodes on which given keys reside. All 'gridProjection(..)' methods are not
transactional and will not enlist keys into ongoing transaction.
'x' provide the same functionality as their sibling
methods that don't end with 'x', however instead of returning a previous value they
return a boolean flag indicating whether operation succeeded or not. Returning
a previous value may involve a network trip or a persistent store lookup and should be
avoided whenever not needed.
'get(..)', 'put(..)', 'replace(..)',
and 'remove(..)' operations are transactional and will participate in an ongoing transaction,
if any. Other methods like 'peek(..)' or various 'contains(..)' methods may
be transaction-aware, i.e. check in-transaction entries first, but will not affect the current
state of transaction. See Transaction documentation for more information
about transactions.
With affinity-based-group-locking the keys are grouped by affinity-key. This means that
only keys with identical affinity-key (see AffinityKeyMapped) can participate in the
transaction, and only one lock on the affinity-key will be acquired for the whole transaction.
Affinity-group-locked transactions are started via
txStartAffinity(Object, TransactionConcurrency, TransactionIsolation, long, int) method.
With partition-based-group-locking the keys are grouped by partition ID. This means that
only keys belonging to identical partition (see Affinity.partition(Object)) can participate in the
transaction, and only one lock on the whole partition will be acquired for the whole transaction.
Partition-group-locked transactions are started via
txStartPartition(int, TransactionConcurrency, TransactionIsolation, long, int) method.
Group locking should always be used for transactions whenever possible. If your requirements fit either affinity-based or partition-based scenarios outlined above then group-locking can significantly improve performance of your application, often by an order of magnitude.
null keys or values are allowed to be stored in cache. If a null value
happens to be in cache (e.g. after invalidation or remove), then cache will treat this case
as there is no value at all.
Integer is used as a key for a binary object):
IgniteInternalCacheYou won't be able to work with deserialized form if class definition for theprj = Ignition.grid().cache(null); // Value will be serialized and stored in cache in binary format. prj.put(1, new Value()); // Value will be deserialized since it's stored in binary format. Value val = prj.get(1);
Value is not on
classpath. Even if you have the class definition, you should always avoid full deserialization if it's not
needed for performance reasons. To work with binary format directly you should create special projection
using keepBinary() method:
IgniteInternalCacheSeeprj = Ignition.grid().cache(null).keepBinary(); // Value is not deserialized and returned in binary format. GridBinaryObject po = prj.get(1);
keepBinary() method JavaDoc for more details.| Modifier and Type | Method and Description |
|---|---|
Affinity<K> |
affinity()
Gets affinity service to provide information about data partitioning
and distribution.
|
<K1,V1> IgniteInternalCache<K1,V1> |
cache()
Gets base cache for this projection.
|
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<?> |
clearAllAsync(Set<? extends K> keys) |
IgniteInternalFuture<?> |
clearAsync() |
IgniteInternalFuture<?> |
clearAsync(K key) |
void |
clearLocally(boolean srv,
boolean near,
boolean readers)
Clears all entries from this cache only if the entry is not
currently locked or participating in a transaction.
|
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 |
clearLocallyAll(Set<? extends K> keys,
boolean srv,
boolean near,
boolean readers)
Clears entries from this cache and swap storage only if the entry
is not currently locked, and is not participating in a transaction.
|
CacheMetrics |
clusterMetrics()
Gets whole cluster metrics (statistics) for this cache.
|
CacheMetrics |
clusterMetrics(ClusterGroup grp)
Gets cluster group metrics (statistics) for this cache.
|
CacheMetricsMXBean |
clusterMxBean()
Gets whole cluster metrics (statistics) for this cache.
|
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<javax.cache.Cache.Entry<K,V>> |
entrySet()
Gets set of all entries cached on this node.
|
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() |
IgniteInternalCache<K,V> |
forSubjectId(UUID subjId)
Creates projection for specified subject ID.
|
V |
get(K key)
Retrieves value mapped to the specified key from cache.
|
Map<K,V> |
getAll(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
IgniteInternalFuture<Map<K,V>> |
getAllAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
Map<K,V> |
getAllOutTx(Set<? extends K> keys)
Gets values from cache.
|
IgniteInternalFuture<Map<K,V>> |
getAllOutTxAsync(Set<? extends K> keys)
Gets values from cache.
|
V |
getAndPut(K key,
V val)
Stores given key-value pair in cache.
|
IgniteInternalFuture<V> |
getAndPutAsync(K key,
V val)
Asynchronously stores given key-value pair in cache.
|
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.
|
Collection<CacheEntry<K,V>> |
getEntries(Collection<? extends K> keys)
Retrieves values mapped to the specified keys from cache.
|
IgniteInternalFuture<Collection<CacheEntry<K,V>>> |
getEntriesAsync(Collection<? extends K> keys)
Asynchronously retrieves values mapped to the specified keys from cache.
|
CacheEntry<K,V> |
getEntry(K key)
Retrieves value mapped to the specified key from cache.
|
IgniteInternalFuture<CacheEntry<K,V>> |
getEntryAsync(K key)
Asynchronously retrieves value mapped to the specified key from cache.
|
V |
getForcePrimary(K key)
Gets value from cache.
|
IgniteInternalFuture<V> |
getForcePrimaryAsync(K key)
Asynchronously gets value from cache.
|
long |
igfsDataSpaceUsed()
Get current amount of used IGFS space in bytes.
|
<T> javax.cache.processor.EntryProcessorResult<T> |
invoke(AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args) |
<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 |
isEmpty()
Returns
true if this map contains no key-value mappings. |
boolean |
isIgfsDataCache()
Checks whether this cache is IGFS data cache.
|
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.
|
<K1,V1> IgniteInternalCache<K1,V1> |
keepBinary()
Creates projection that will operate with binary objects.
|
Set<K> |
keySet()
Set of keys cached on this node.
|
Iterable<javax.cache.Cache.Entry<K,V>> |
localEntries(CachePeekMode[] peekModes) |
void |
localLoadCache(IgniteBiPredicate<K,V> p,
Object... args)
Delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to load state from the underlying persistent storage. |
IgniteInternalFuture<?> |
localLoadCacheAsync(IgniteBiPredicate<K,V> p,
Object... args)
Asynchronously delegates to
CacheStore.loadCache(IgniteBiInClosure, Object...) method
to reload state from the underlying persistent storage. |
CacheMetrics |
localMetrics()
Gets local metrics (statistics) for this cache.
|
CacheMetricsMXBean |
localMxBean()
Gets local metrics (statistics) for this cache.
|
V |
localPeek(K key,
CachePeekMode[] peekModes,
IgniteCacheExpiryPolicy plc) |
int |
localSize(CachePeekMode[] peekModes) |
long |
localSizeLong(CachePeekMode[] peekModes) |
long |
localSizeLong(int partition,
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> |
lockAllAsync(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.
|
Collection<Integer> |
lostPartitions() |
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.
|
int |
primarySize()
Gets the number of all primary entries cached on this node.
|
long |
primarySizeLong()
Gets the number of all primary entries cached on this node as a long value.
|
boolean |
put(K key,
V val)
Stores given key-value pair in cache.
|
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.
|
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.
|
IgniteInternalFuture<?> |
rebalance()
Forces this cache node to re-balance its partitions.
|
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()
Removes mappings from cache.
|
void |
removeAll(Collection<? extends K> keys)
Removes given key mappings from cache.
|
IgniteInternalFuture<?> |
removeAllAsync() |
IgniteInternalFuture<?> |
removeAllAsync(Collection<? extends K> keys)
Asynchronously removes given key mappings from cache for entries.
|
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,
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. |
Iterator<javax.cache.Cache.Entry<K,V>> |
scanIterator(boolean keepBinary,
IgniteBiPredicate<Object,Object> p) |
IgniteInternalCache<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) |
long |
sizeLong()
Gets the number of all entries cached on this node as a long value.
|
long |
sizeLong(CachePeekMode[] peekModes) |
long |
sizeLong(int partition,
CachePeekMode[] peekModes) |
IgniteInternalFuture<Long> |
sizeLongAsync(CachePeekMode[] peekModes) |
IgniteInternalFuture<Long> |
sizeLongAsync(int partition,
CachePeekMode[] peekModes) |
boolean |
skipStore() |
GridNearTxLocal |
tx()
Gets transaction started by this thread or
null if this thread does
not have a transaction. |
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.
|
GridNearTxLocal |
txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
void |
unlock(K key)
Unlocks given key only if current thread owns the lock.
|
void |
unlockAll(Collection<? extends K> keys)
Unlocks given keys only if current thread owns the locks.
|
IgniteInternalCache<K,V> |
withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc) |
IgniteInternalCache<K,V> |
withNoRetries() |
forEach, iterator, spliteratorString name()
null for default cache).<K1,V1> IgniteInternalCache<K1,V1> cache()
K1 - Cache key type.V1 - Cache value type.boolean skipStore()
IgniteInternalCache<K,V> setSkipStore(boolean skipStore)
skipStore - Skip store flag.<K1,V1> IgniteInternalCache<K1,V1> keepBinary()
Projection returned by this method will force cache not to deserialize binary 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.binary.BinaryObject for binary 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 binary format), you should acquire following projection
to avoid deserialization:
IgniteInternalCacheprj = cache.keepBinary(); // Value is not deserialized and returned in binary format. GridBinaryObject po = prj.get(1);
Note that this method makes sense only if cache is working in binary mode
(org.apache.ignite.configuration.CacheConfiguration#isBinaryEnabled() returns true. If not,
this method is no-op and will return current projection.
boolean isEmpty()
true if this map contains no key-value mappings.true if this map contains no key-value mappings.boolean containsKey(K key)
key - Key.True if cache contains mapping for a given key.IgniteInternalFuture<Boolean> containsKeyAsync(K key)
key - Key.boolean containsKeys(Collection<? extends K> keys)
keys - Keys,True if cache contains all keys.IgniteInternalFuture<Boolean> containsKeysAsync(Collection<? extends K> keys)
keys - Keys to check.@Nullable V localPeek(K key, CachePeekMode[] peekModes, @Nullable IgniteCacheExpiryPolicy plc) throws IgniteCheckedException
key - Key.peekModes - Peek modes.plc - Expiry policy if TTL should be updated.IgniteCheckedException - If failed.Iterable<javax.cache.Cache.Entry<K,V>> localEntries(CachePeekMode[] peekModes) throws IgniteCheckedException
peekModes - Peek modes.IgniteCheckedException - If failed.@Nullable 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.
key - Key to retrieve the value for.IgniteCheckedException - If get operation failed.NullPointerException - if the key is null.@Nullable CacheEntry<K,V> getEntry(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.
key - Key to retrieve the value for.IgniteCheckedException - If get operation failed.NullPointerException - if the key is null.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.
key - Key for the value to get.NullPointerException - if the key is null.IgniteInternalFuture<CacheEntry<K,V>> getEntryAsync(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.
key - Key for the value to get.NullPointerException - if the key is null.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.
keys - Keys to get.IgniteCheckedException - If get operation failed.Collection<CacheEntry<K,V>> getEntries(@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.
keys - Keys to get.IgniteCheckedException - If get operation failed.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.
keys - Key for the value to get.IgniteInternalFuture<Collection<CacheEntry<K,V>>> getEntriesAsync(@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.
keys - Key for the value to get.@Nullable 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.
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.NullPointerException - If either key or value are null.IgniteCheckedException - If put operation failed.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.
key - Key to store in cache.val - Value to be associated with the given key.NullPointerException - If either key or value are null.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.
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.NullPointerException - If either key or value are null.IgniteCheckedException - If put operation failed.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.
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.NullPointerException - If either key or value are null.@Nullable 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 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.
key - Key to store in cache.val - Value to be associated with the given key.NullPointerException - If either key or value are null.IgniteCheckedException - If put operation failed.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 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.
key - Key to store in cache.val - Value to be associated with the given key.NullPointerException - If either key or value are null.boolean putIfAbsent(K key, V val) throws IgniteCheckedException
This method will return true if value is stored in cache and false otherwise.
Unlike 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.
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.NullPointerException - If either key or value are null.IgniteCheckedException - If put operation failed.IgniteInternalFuture<Boolean> putIfAbsentAsync(K key, V val)
This method will return true if value is stored in cache and false otherwise.
Unlike 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.
key - Key to store in cache.val - Value to be associated with the given key.NullPointerException - If either key or value are null.@Nullable 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 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.
key - Key to store in cache.val - Value to be associated with the given key.NullPointerException - If either key or value are null.IgniteCheckedException - If replace operation failed.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 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.
key - Key to store in cache.val - Value to be associated with the given key.NullPointerException - If either key or value are null.boolean replace(K key, V val) throws IgniteCheckedException
This method will return true if value is stored in cache and false otherwise.
Unlike 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.
key - Key to store in cache.val - Value to be associated with the given key.True if replace happened, false otherwise.NullPointerException - If either key or value are null.IgniteCheckedException - If replace operation failed.IgniteInternalFuture<Boolean> replaceAsync(K key, V val)
This method will return true if value is stored in cache and false otherwise.
Unlike 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.
key - Key to store in cache.val - Value to be associated with the given key.NullPointerException - If either key or value are null.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.
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.NullPointerException - If either key or value are null.IgniteCheckedException - If replace operation failed.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.
key - Key to store in cache.oldVal - Old value to match.newVal - Value to be associated with the given key.NullPointerException - If either key or value are null.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.
m - Key-value pairs to store in cache.IgniteCheckedException - If put operation failed.IgniteInternalFuture<?> putAllAsync(@Nullable 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.
m - Key-value pairs to store in cache.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.
Set<javax.cache.Cache.Entry<K,V>> entrySet()
NOTE: this operation is not distributed and returns only the entries cached on this node.
Transaction txStart(TransactionConcurrency concurrency, TransactionIsolation isolation)
concurrency - Concurrency.isolation - Isolation.IllegalStateException - If transaction is already started by this thread.UnsupportedOperationException - If cache is CacheAtomicityMode.ATOMIC.GridNearTxLocal txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
concurrency - Concurrency.isolation - Isolation.Transaction txStart(TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, int txSize)
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.UnsupportedOperationException - If cache is CacheAtomicityMode.ATOMIC.@Nullable GridNearTxLocal tx()
null if this thread does
not have a transaction.null if this thread
does not have a transaction.boolean evict(K key)
key - Key to evict from cache.True if entry could be evicted, false otherwise.void evictAll(@Nullable
Collection<? extends K> keys)
keys - Keys to evict.void clearLocally(boolean srv,
boolean near,
boolean readers)
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.
srv - Whether to clear server cache.near - Whether to clear near cache.readers - Whether to clear readers.boolean clearLocally(K key)
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.
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.void clearLocallyAll(Set<? extends K> keys, boolean srv, boolean near, boolean readers)
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.
keys - Keys to clearLocally.srv - Whether to clear server cache.near - Whether to clear near cache.readers - Whether to clear readers.void clear(K key) throws IgniteCheckedException
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.
key - Key to clear.IgniteCheckedException - In case of cache could not be cleared on any of the nodes.void clearAll(Set<? extends K> keys) throws IgniteCheckedException
clearLocallyAll(Set, boolean, boolean, boolean) 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.
keys - Keys to clear.IgniteCheckedException - In case of cache could not be cleared on any of the nodes.void clear()
throws IgniteCheckedException
clearLocally(boolean, boolean, boolean) 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.
IgniteCheckedException - In case of cache could not be cleared on any of the nodes.IgniteInternalFuture<?> clearAsync()
IgniteInternalFuture<?> clearAsync(K key)
key - Key to clear.IgniteInternalFuture<?> clearAllAsync(Set<? extends K> keys)
keys - Keys to clear.@Nullable 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.
key - Key whose mapping is to be removed from cache.null
if there was no value for this key.NullPointerException - If key is null.IgniteCheckedException - If remove operation failed.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.
key - Key whose mapping is to be removed from cache.NullPointerException - if the key is null.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.
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.NullPointerException - if the key is null.IgniteCheckedException - If remove failed.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.
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.NullPointerException - if the key is null.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.
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.NullPointerException - if the key or value is null.IgniteCheckedException - If remove failed.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.
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.NullPointerException - if the key or value is null.void removeAll(@Nullable
Collection<? extends K> keys)
throws IgniteCheckedException
If write-through is enabled, the values will be removed from CacheStore via IgniteDataStreamer.
keys - Keys whose mappings are to be removed from cache.IgniteCheckedException - If remove failed.IgniteInternalFuture<?> removeAllAsync(@Nullable Collection<? extends K> keys)
If write-through is enabled, the values will be removed from CacheStore via IgniteDataStreamer.
keys - Keys whose mappings are to be removed from cache.void removeAll()
throws IgniteCheckedException
USE WITH CARE - if your cache has many entries then transaction will quickly become very heavy and slow.
If write-through is enabled, the values will be removed from CacheStore via IgniteDataStreamer.
IgniteCheckedException - If remove failed.IgniteInternalFuture<?> removeAllAsync()
boolean lock(K key, long timeout) throws IgniteCheckedException
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.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.IgniteInternalFuture<Boolean> lockAsync(K key, long timeout)
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.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.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.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.IgniteInternalFuture<Boolean> lockAllAsync(@Nullable Collection<? extends K> keys, long timeout)
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.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.void unlock(K key) throws IgniteCheckedException
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.key - Key to unlock.IgniteCheckedException - If unlock execution resulted in error.void unlockAll(@Nullable
Collection<? extends K> keys)
throws IgniteCheckedException
TransactionConcurrency.PESSIMISTIC concurrency control for transaction
which will acquire explicit locks for relevant cache operations.keys - Keys to unlock.IgniteCheckedException - If unlock execution resulted in error.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.
key - Key to check.True if lock is owned by some node.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.
key - Key to check.True if key is locked by current thread.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.
long sizeLong()
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.
int localSize(CachePeekMode[] peekModes) throws IgniteCheckedException
peekModes - Peek modes.IgniteCheckedException - If failed.long localSizeLong(CachePeekMode[] peekModes) throws IgniteCheckedException
peekModes - Peek modes.IgniteCheckedException - If failed.long localSizeLong(int partition,
CachePeekMode[] peekModes)
throws IgniteCheckedException
partition - partition.peekModes - Peek modes.IgniteCheckedException - If failed.int size(CachePeekMode[] peekModes) throws IgniteCheckedException
peekModes - Peek modes.IgniteCheckedException - If failed.long sizeLong(CachePeekMode[] peekModes) throws IgniteCheckedException
peekModes - Peek modes.IgniteCheckedException - If failed.long sizeLong(int partition,
CachePeekMode[] peekModes)
throws IgniteCheckedException
partition - partitionpeekModes - Peek modes.IgniteCheckedException - If failed.IgniteInternalFuture<Integer> sizeAsync(CachePeekMode[] peekModes)
peekModes - Peek modes.IgniteInternalFuture<Long> sizeLongAsync(CachePeekMode[] peekModes)
peekModes - Peek modes.IgniteInternalFuture<Long> sizeLongAsync(int partition, CachePeekMode[] peekModes)
partition - partitonpeekModes - Peek modes.int nearSize()
Note that for LOCAL non-distributed caches this method will always return 0
0 if cache is not CacheMode.PARTITIONED.int primarySize()
CacheMode.LOCAL non-distributed
cache mode, this method is identical to 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.
long primarySizeLong()
CacheMode.LOCAL
non-distributed cache mode, this method is identical to 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.
CacheConfiguration configuration()
Affinity<K> affinity()
CacheMetrics clusterMetrics()
CacheMetrics clusterMetrics(ClusterGroup grp)
grp - Cluster group.CacheMetrics localMetrics()
CacheMetricsMXBean clusterMxBean()
CacheMetricsMXBean localMxBean()
long offHeapEntriesCount()
long offHeapAllocatedSize()
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
IgniteConfiguration.setConsistentId(Serializable) 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.
IgniteInternalCache<K,V> forSubjectId(UUID subjId)
subjId - Client ID.void putAllConflict(Map<KeyCacheObject,GridCacheDrInfo> drMap) throws IgniteCheckedException
drMap - DR map.IgniteCheckedException - If put operation failed.IgniteInternalFuture<?> putAllConflictAsync(Map<KeyCacheObject,GridCacheDrInfo> drMap) throws IgniteCheckedException
drMap - DR map.IgniteCheckedException - If put operation failed.void removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap) throws IgniteCheckedException
drMap - DR map.IgniteCheckedException - If remove failed.IgniteInternalFuture<?> removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap) throws IgniteCheckedException
drMap - DR map.IgniteCheckedException - If remove failed.@Nullable V getForcePrimary(K key) throws IgniteCheckedException
key - Key to get value for.IgniteCheckedException - If failed.IgniteInternalFuture<V> getForcePrimaryAsync(K key)
key - Key to get value for.Map<K,V> getAllOutTx(Set<? extends K> keys) throws IgniteCheckedException
keys - Keys to get values for.IgniteCheckedException - If failed.IgniteInternalFuture<Map<K,V>> getAllOutTxAsync(Set<? extends K> keys)
keys - Keys to get values for.boolean isIgfsDataCache()
True in case this cache is IGFS data cache.long igfsDataSpaceUsed()
boolean isMongoDataCache()
True if this cache is mongo data cache.boolean isMongoMetaCache()
True if this cache is mongo meta cache.Iterator<javax.cache.Cache.Entry<K,V>> scanIterator(boolean keepBinary, @Nullable IgniteBiPredicate<Object,Object> p) throws IgniteCheckedException
keepBinary - Keep binary flag.p - Optional key/value predicate.IgniteCheckedException - If failed.@Nullable javax.cache.expiry.ExpiryPolicy expiry()
ExpiryPolicy associated with this projection.IgniteInternalCache<K,V> withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc)
plc - ExpiryPolicy to associate with this projection.IgniteInternalCache<K,V> withNoRetries()
@Nullable <T> javax.cache.processor.EntryProcessorResult<T> invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args) throws IgniteCheckedException
key - Key.entryProcessor - Entry processor.args - Arguments.IgniteCheckedException - If failed.<T> IgniteInternalFuture<javax.cache.processor.EntryProcessorResult<T>> invokeAsync(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
key - Key.entryProcessor - Entry processor.args - Arguments.<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
keys - Keys.entryProcessor - Entry processor.args - Arguments.IgniteCheckedException - If failed.<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> invokeAllAsync(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
keys - Keys.entryProcessor - Entry processor.args - Arguments.<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
map - Map containing keys and entry processors to be applied to values.args - Arguments.IgniteCheckedException - If failed.<T> IgniteInternalFuture<Map<K,javax.cache.processor.EntryProcessorResult<T>>> invokeAllAsync(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
map - Map containing keys and entry processors to be applied to values.args - Arguments.GridCacheContext<K,V> context()
void localLoadCache(@Nullable
IgniteBiPredicate<K,V> p,
@Nullable
Object... args)
throws IgniteCheckedException
CacheStore.loadCache(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.
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(IgniteBiInClosure, Object...) method.IgniteCheckedException - If loading failed.IgniteInternalFuture<?> localLoadCacheAsync(@Nullable IgniteBiPredicate<K,V> p, @Nullable Object... args)
CacheStore.loadCache(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.
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(IgniteBiInClosure, Object...) method.@Nullable
<T> javax.cache.processor.EntryProcessorResult<T> invoke(@Nullable
AffinityTopologyVersion topVer,
K key,
javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
Object... args)
throws IgniteCheckedException
topVer - Locked topology version.key - Key.entryProcessor - Entry processor.args - Arguments.IgniteCheckedException - If failed.Collection<Integer> lostPartitions()
Follow @ApacheIgnite
Ignite Fabric : ver. 2.4.0 Release Date : March 5 2018