public class TcpClientCache<K,V> extends Object implements ClientCache<K,V>
ClientCache over TCP protocol.| Modifier and Type | Method and Description |
|---|---|
void |
clear()
Clears the contents of the cache.
|
void |
clear(K key)
Clears entry with specified key from the cache.
|
void |
clearAll(Set<? extends K> keys)
Clears entries with specified keys from the cache.
|
IgniteClientFuture<Void> |
clearAllAsync(Set<? extends K> keys)
Clears entries with specified keys from the cache asynchronously.
|
IgniteClientFuture<Void> |
clearAsync()
Clears the contents of the cache asynchronously.
|
IgniteClientFuture<Void> |
clearAsync(K key)
Clears entry with specified key from the cache asynchronously.
|
boolean |
containsKey(K key)
Determines if the
ClientCache contains an entry for the specified key. |
IgniteClientFuture<Boolean> |
containsKeyAsync(K key)
Determines if the
ClientCache contains an entry for the specified key asynchronously. |
boolean |
containsKeys(Set<? extends K> keys)
Determines if the
ClientCache contains entries for the specified keys. |
IgniteClientFuture<Boolean> |
containsKeysAsync(Set<? extends K> keys)
Determines if the
ClientCache contains entries for the specified keys asynchronously. |
void |
deregisterCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg)
Deregisters a listener, using the
CacheEntryListenerConfiguration that was used to register it. |
V |
get(K key)
Gets an entry from the cache.
|
Map<K,V> |
getAll(Set<? extends K> keys)
Gets a collection of entries from the
ClientCache, returning them as
Map of the values associated with the set of keys requested. |
IgniteClientFuture<Map<K,V>> |
getAllAsync(Set<? extends K> keys)
Gets a collection of entries from the
ClientCache, returning them as
Map of the values associated with the set of keys requested. |
V |
getAndPut(K key,
V val)
Associates the specified value with the specified key in this cache, returning an existing value if one existed.
|
IgniteClientFuture<V> |
getAndPutAsync(K key,
V val)
Associates the specified value with the specified key in this cache, returning an existing value if one existed.
|
V |
getAndPutIfAbsent(K key,
V val)
Atomically associates the specified key with the given value if it is not already associated with a value.
|
IgniteClientFuture<V> |
getAndPutIfAbsentAsync(K key,
V val)
Atomically associates the specified key with the given value if it is not already associated with a value.
|
V |
getAndRemove(K key)
Atomically removes the entry for a key only if currently mapped to some value.
|
IgniteClientFuture<V> |
getAndRemoveAsync(K key)
Atomically removes the entry for a key only if currently mapped to some value.
|
V |
getAndReplace(K key,
V val)
Atomically replaces the value for a given key if and only if there is a value currently mapped by the key.
|
IgniteClientFuture<V> |
getAndReplaceAsync(K key,
V val)
Atomically replaces the value for a given key if and only if there is a value currently mapped by the key.
|
IgniteClientFuture<V> |
getAsync(K key)
Gets an entry from the cache asynchronously.
|
ClientCacheConfiguration |
getConfiguration() |
IgniteClientFuture<ClientCacheConfiguration> |
getConfigurationAsync()
Gets the cache configuration asynchronously.
|
String |
getName() |
void |
put(K key,
V val)
Associates the specified value with the specified key in the cache.
|
void |
putAll(Map<? extends K,? extends V> map)
Copies all of the entries from the specified map to the
ClientCache. |
IgniteClientFuture<Void> |
putAllAsync(Map<? extends K,? extends V> map)
Copies all of the entries from the specified map to the
ClientCache. |
void |
putAllConflict(Map<? extends K,? extends T3<? extends V,GridCacheVersion,Long>> drMap)
Store DR data.
|
IgniteClientFuture<Void> |
putAllConflictAsync(Map<? extends K,T3<? extends V,GridCacheVersion,Long>> drMap)
Store DR data asynchronously.
|
IgniteClientFuture<Void> |
putAsync(K key,
V val)
Associates the specified value with the specified key in the cache asynchronously.
|
boolean |
putIfAbsent(K key,
V val)
Atomically associates the specified key with the given value if it is not already associated with a value.
|
IgniteClientFuture<Boolean> |
putIfAbsentAsync(K key,
V val)
Atomically associates the specified key with the given value if it is not already associated with a value.
|
<R> QueryCursor<R> |
query(ContinuousQuery<K,V> qry,
ClientDisconnectListener disconnectLsnr)
Start
ContinuousQuery on the cache. |
<R> QueryCursor<R> |
query(Query<R> qry)
Queries cache.
|
FieldsQueryCursor<List<?>> |
query(SqlFieldsQuery qry)
Convenience method to execute
SqlFieldsQuery. |
void |
registerCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg)
Registers a
CacheEntryListener. |
void |
registerCacheEntryListener(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg,
ClientDisconnectListener disconnectLsnr)
Registers a
CacheEntryListener. |
boolean |
remove(K key)
Removes the mapping for a key from this cache if it is present.
|
boolean |
remove(K key,
V oldVal)
Atomically removes the mapping for a key only if currently mapped to the given value.
|
void |
removeAll()
Removes all of the mappings from this cache.
|
void |
removeAll(Set<? extends K> keys)
Removes entries for the specified keys.
|
IgniteClientFuture<Void> |
removeAllAsync()
Removes all of the mappings from this cache.
|
IgniteClientFuture<Void> |
removeAllAsync(Set<? extends K> keys)
Removes entries for the specified keys.
|
void |
removeAllConflict(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
IgniteClientFuture<Void> |
removeAllConflictAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteClientFuture<Boolean> |
removeAsync(K key)
Removes the mapping for a key from this cache if it is present.
|
IgniteClientFuture<Boolean> |
removeAsync(K key,
V oldVal)
Atomically removes the mapping for a key only if currently mapped to the given value.
|
boolean |
replace(K key,
V val)
Atomically replaces the entry for a key only if currently mapped to some
value.
|
boolean |
replace(K key,
V oldVal,
V newVal)
Atomically replaces the entry for a key only if currently mapped to a given value.
|
IgniteClientFuture<Boolean> |
replaceAsync(K key,
V val)
Atomically replaces the entry for a key only if currently mapped to some
value.
|
IgniteClientFuture<Boolean> |
replaceAsync(K key,
V oldVal,
V newVal)
Atomically replaces the entry for a key only if currently mapped to a given value.
|
int |
size(CachePeekMode... peekModes)
Gets the number of all entries cached across all nodes.
|
IgniteClientFuture<Integer> |
sizeAsync(CachePeekMode... peekModes)
Gets the number of all entries cached across all nodes.
|
<K1,V1> ClientCache<K1,V1> |
withExpirePolicy(javax.cache.expiry.ExpiryPolicy expirePlc)
Returns cache with the specified expired policy set.
|
<K1,V1> ClientCache<K1,V1> |
withKeepBinary()
Returns cache that will operate with binary objects.
|
public V get(K key) throws ClientException
get in interface ClientCache<K,V>key - the key whose associated value is to be returnedClientExceptionpublic IgniteClientFuture<V> getAsync(K key)
getAsync in interface ClientCache<K,V>key - Key.public void put(K key, V val) throws ClientException
If the ClientCache previously contained a mapping for the key, the old
value is replaced by the specified value.
put in interface ClientCache<K,V>key - key with which the specified value is to be associatedval - value to be associated with the specified key.ClientExceptionpublic IgniteClientFuture<Void> putAsync(K key, V val) throws ClientException
If the ClientCache previously contained a mapping for the key, the old
value is replaced by the specified value.
putAsync in interface ClientCache<K,V>key - key with which the specified value is to be associatedval - value to be associated with the specified key.ClientExceptionpublic boolean containsKey(K key) throws ClientException
ClientCache contains an entry for the specified key.
More formally, returns true if and only if this cache contains a mapping for a key k such that key.equals(k). (There can be at most one such mapping)
containsKey in interface ClientCache<K,V>key - key whose presence in this cache is to be tested.ClientExceptionpublic IgniteClientFuture<Boolean> containsKeyAsync(K key) throws ClientException
ClientCache contains an entry for the specified key asynchronously.
More formally, returns true if and only if this cache contains a mapping for a key k such that key.equals(k). (There can be at most one such mapping)
containsKeyAsync in interface ClientCache<K,V>key - key whose presence in this cache is to be tested.ClientExceptionpublic boolean containsKeys(Set<? extends K> keys) throws ClientException
ClientCache contains entries for the specified keys.containsKeys in interface ClientCache<K,V>keys - Keys whose presence in this cache is to be tested.True if this cache contains a mapping for the specified keys.ClientExceptionpublic IgniteClientFuture<Boolean> containsKeysAsync(Set<? extends K> keys) throws ClientException
ClientCache contains entries for the specified keys asynchronously.containsKeysAsync in interface ClientCache<K,V>keys - Keys whose presence in this cache is to be tested.true if this map contains a mapping for the specified keys.ClientExceptionpublic String getName()
getName in interface ClientCache<K,V>public ClientCacheConfiguration getConfiguration() throws ClientException
getConfiguration in interface ClientCache<K,V>ClientExceptionpublic IgniteClientFuture<ClientCacheConfiguration> getConfigurationAsync() throws ClientException
getConfigurationAsync in interface ClientCache<K,V>ClientExceptionpublic int size(CachePeekMode... peekModes) throws ClientException
peekModes value isn't provided,
only size of primary copies across all nodes will be returned. This behavior is identical to calling
this method with CachePeekMode.PRIMARY peek mode.
NOTE: this operation is distributed and will query all participating nodes for their cache sizes.
size in interface ClientCache<K,V>peekModes - Optional peek modes. If not provided, then total cache size is returned.ClientExceptionpublic IgniteClientFuture<Integer> sizeAsync(CachePeekMode... peekModes) throws ClientException
peekModes value isn't provided,
only size of primary copies across all nodes will be returned. This behavior is identical to calling
this method with CachePeekMode.PRIMARY peek mode.
NOTE: this operation is distributed and will query all participating nodes for their cache sizes.
sizeAsync in interface ClientCache<K,V>peekModes - Optional peek modes. If not provided, then total cache size is returned.ClientExceptionpublic Map<K,V> getAll(Set<? extends K> keys) throws ClientException
ClientCache, returning them as
Map of the values associated with the set of keys requested.getAll in interface ClientCache<K,V>keys - The keys whose associated values are to be returned.ClientExceptionpublic IgniteClientFuture<Map<K,V>> getAllAsync(Set<? extends K> keys) throws ClientException
ClientCache, returning them as
Map of the values associated with the set of keys requested.getAllAsync in interface ClientCache<K,V>keys - The keys whose associated values are to be returned.ClientExceptionpublic void putAll(Map<? extends K,? extends V> map) throws ClientException
ClientCache.
The effect of this call is equivalent to that of calling
put(k, v) on this cache once for each mapping
from key k to value v in the specified map.
The order in which the individual puts occur is undefined.
The behavior of this operation is undefined if entries in the cache corresponding to entries in the map are modified or removed while this operation is in progress, or if map is modified while the operation is in progress.
putAll in interface ClientCache<K,V>map - Mappings to be stored in this cache.ClientExceptionpublic IgniteClientFuture<Void> putAllAsync(Map<? extends K,? extends V> map) throws ClientException
ClientCache.
The effect of this call is equivalent to that of calling
put(k, v) on this cache once for each mapping
from key k to value v in the specified map.
The order in which the individual puts occur is undefined.
The behavior of this operation is undefined if entries in the cache corresponding to entries in the map are modified or removed while this operation is in progress, or if map is modified while the operation is in progress.
putAllAsync in interface ClientCache<K,V>map - Mappings to be stored in this cache.ClientExceptionpublic boolean replace(K key, V oldVal, V newVal) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key) && equals(cache.get(key), oldValue)) {
cache.put(key, newValue);
return true;
} else {
return false;
}
replace in interface ClientCache<K,V>key - Key with which the specified value is associated.oldVal - Value expected to be associated with the specified key.newVal - Value to be associated with the specified key.ClientExceptionpublic IgniteClientFuture<Boolean> replaceAsync(K key, V oldVal, V newVal) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key) && equals(cache.get(key), oldValue)) {
cache.put(key, newValue);
return true;
} else {
return false;
}
replaceAsync in interface ClientCache<K,V>key - Key with which the specified value is associated.oldVal - Value expected to be associated with the specified key.newVal - Value to be associated with the specified key.ClientExceptionpublic boolean replace(K key, V val) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key)) {
cache.put(key, value);
return true;
} else {
return false;
}replace in interface ClientCache<K,V>key - The key with which the specified value is associated.val - The value to be associated with the specified key.ClientExceptionpublic IgniteClientFuture<Boolean> replaceAsync(K key, V val) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key)) {
cache.put(key, value);
return true;
} else {
return false;
}replaceAsync in interface ClientCache<K,V>key - The key with which the specified value is associated.val - The value to be associated with the specified key.ClientExceptionpublic boolean remove(K key) throws ClientException
More formally, if this cache contains a mapping from key k to value v such that
(key==null ? k==null : key.equals(k)), that mapping is removed.
(The cache can contain at most one such mapping.)
Returns true if this cache previously associated the key, or false if the cache contained no mapping for the key.
The cache will not contain a mapping for the specified key once the call returns.
remove in interface ClientCache<K,V>key - Key whose mapping is to be removed from the cache.ClientExceptionpublic IgniteClientFuture<Boolean> removeAsync(K key) throws ClientException
More formally, if this cache contains a mapping from key k to value v such that
(key==null ? k==null : key.equals(k)), that mapping is removed.
(The cache can contain at most one such mapping.)
Returns true if this cache previously associated the key, or false if the cache contained no mapping for the key.
The cache will not contain a mapping for the specified key once the call returns.
removeAsync in interface ClientCache<K,V>key - Key whose mapping is to be removed from the cache.ClientExceptionpublic boolean remove(K key, V oldVal) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key) && equals(cache.get(key), oldValue) {
cache.remove(key);
return true;
} else {
return false;
}
remove in interface ClientCache<K,V>key - Key whose mapping is to be removed from the cache.oldVal - Value expected to be associated with the specified key.ClientExceptionpublic IgniteClientFuture<Boolean> removeAsync(K key, V oldVal) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key) && equals(cache.get(key), oldValue) {
cache.remove(key);
return true;
} else {
return false;
}
removeAsync in interface ClientCache<K,V>key - Key whose mapping is to be removed from the cache.oldVal - Value expected to be associated with the specified key.ClientExceptionpublic void removeAll(Set<? extends K> keys) throws ClientException
The order in which the individual entries are removed is undefined.
removeAll in interface ClientCache<K,V>keys - The keys to remove.ClientExceptionpublic IgniteClientFuture<Void> removeAllAsync(Set<? extends K> keys) throws ClientException
The order in which the individual entries are removed is undefined.
removeAllAsync in interface ClientCache<K,V>keys - The keys to remove.ClientExceptionpublic void removeAll()
throws ClientException
The order that the individual entries are removed is undefined.
This operation is not transactional. It calls broadcast closure that deletes all primary keys from remote nodes.
This is potentially an expensive operation as listeners are invoked.
Use ClientCache.clear() to avoid this.
removeAll in interface ClientCache<K,V>ClientExceptionpublic IgniteClientFuture<Void> removeAllAsync() throws ClientException
The order that the individual entries are removed is undefined.
This operation is not transactional. It calls broadcast closure that deletes all primary keys from remote nodes.
This is potentially an expensive operation as listeners are invoked.
Use ClientCache.clear() to avoid this.
removeAllAsync in interface ClientCache<K,V>ClientExceptionpublic V getAndPut(K key, V val) throws ClientException
If the cache previously contained a mapping for
the key, the old value is replaced by the specified value. (A cache
c is said to contain a mapping for a key k if and only
if c.containsKey(k) would return
true.)
The previous value is returned, or null if there was no value associated with the key previously.
getAndPut in interface ClientCache<K,V>key - Key with which the specified value is to be associated.val - Value to be associated with the specified key.ClientExceptionpublic IgniteClientFuture<V> getAndPutAsync(K key, V val) throws ClientException
If the cache previously contained a mapping for
the key, the old value is replaced by the specified value. (A cache
c is said to contain a mapping for a key k if and only
if c.containsKey(k) would return
true.)
The previous value is returned, or null if there was no value associated with the key previously.
getAndPutAsync in interface ClientCache<K,V>key - Key with which the specified value is to be associated.val - Value to be associated with the specified key.ClientExceptionpublic V getAndRemove(K key) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key)) {
V oldValue = cache.get(key);
cache.remove(key);
return oldValue;
} else {
return null;
}
getAndRemove in interface ClientCache<K,V>key - Key with which the specified value is associated.ClientExceptionpublic IgniteClientFuture<V> getAndRemoveAsync(K key) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key)) {
V oldValue = cache.get(key);
cache.remove(key);
return oldValue;
} else {
return null;
}
getAndRemoveAsync in interface ClientCache<K,V>key - Key with which the specified value is associated.ClientExceptionpublic V getAndReplace(K key, V val) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key)) {
V oldValue = cache.get(key);
cache.put(key, value);
return oldValue;
} else {
return null;
}
getAndReplace in interface ClientCache<K,V>key - Key with which the specified value is associated.val - Value to be associated with the specified key.ClientExceptionpublic IgniteClientFuture<V> getAndReplaceAsync(K key, V val) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (cache.containsKey(key)) {
V oldValue = cache.get(key);
cache.put(key, value);
return oldValue;
} else {
return null;
}
getAndReplaceAsync in interface ClientCache<K,V>key - Key with which the specified value is associated.val - Value to be associated with the specified key.ClientExceptionpublic boolean putIfAbsent(K key, V val) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (!cache.containsKey(key)) {
cache.put(key, value);
return true;
} else {
return false;
}
putIfAbsent in interface ClientCache<K,V>key - Key with which the specified value is to be associated.val - Value to be associated with the specified key.ClientExceptionpublic IgniteClientFuture<Boolean> putIfAbsentAsync(K key, V val) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (!cache.containsKey(key)) {
cache.put(key, value);
return true;
} else {
return false;
}
putIfAbsentAsync in interface ClientCache<K,V>key - Key with which the specified value is to be associated.val - Value to be associated with the specified key.ClientExceptionpublic V getAndPutIfAbsent(K key, V val) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (!cache.containsKey(key)) {
cache.put(key, value);
return null;
} else {
return cache.get(key);
}
getAndPutIfAbsent in interface ClientCache<K,V>key - Key with which the specified value is to be associated.val - Value to be associated with the specified key.null if no value was associated
with the specified key and a value was set.ClientExceptionpublic IgniteClientFuture<V> getAndPutIfAbsentAsync(K key, V val) throws ClientException
This is equivalent to performing the following operations as a single atomic action:
if (!cache.containsKey(key)) {
cache.put(key, value);
return null;
} else {
return cache.get(key);
}
getAndPutIfAbsentAsync in interface ClientCache<K,V>key - Key with which the specified value is to be associated.val - Value to be associated with the specified key.null if no value was associated with the specified key and a
value was set.ClientExceptionpublic void clear()
throws ClientException
ClientCache.removeAll(), this method does not notify event listeners and cache writers.clear in interface ClientCache<K,V>ClientExceptionpublic IgniteClientFuture<Void> clearAsync() throws ClientException
ClientCache.removeAll(), this method does not notify event listeners and cache writers.clearAsync in interface ClientCache<K,V>ClientExceptionpublic void clear(K key) throws ClientException
ClientCache.remove(Object), this method does not notify event listeners and cache writers.clear in interface ClientCache<K,V>key - Cache entry key to clear.ClientExceptionpublic IgniteClientFuture<Void> clearAsync(K key) throws ClientException
ClientCache.removeAsync(Object), this method does not notify event listeners and cache writers.clearAsync in interface ClientCache<K,V>key - Cache entry key to clear.ClientExceptionpublic void clearAll(Set<? extends K> keys) throws ClientException
ClientCache.removeAll(Set), this method does not notify event listeners and cache writers.clearAll in interface ClientCache<K,V>keys - Cache entry keys to clear.ClientExceptionpublic IgniteClientFuture<Void> clearAllAsync(Set<? extends K> keys) throws ClientException
ClientCache.removeAllAsync(Set), this method does not notify event listeners and cache writers.clearAllAsync in interface ClientCache<K,V>keys - Cache entry keys to clear.ClientExceptionpublic <K1,V1> ClientCache<K1,V1> withKeepBinary()
Cache returned by this method will not be forced to deserialize binary objects, so keys and values will be returned from cache API methods without changes. Therefore, signature of the cache can contain only following types:
org.apache.ignite.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: