org.apache.ignite.springdata.proxy

Class IgniteCacheProxyImpl<K,V>

java.lang.Object

org.apache.ignite.springdata.proxy.IgniteCacheProxyImpl<K,V>

All Implemented Interfaces:

Iterable<javax.cache.Cache.Entry<K,V>>, IgniteCacheProxy<K,V>

public class IgniteCacheProxyImpl<K,V>
extends Object
implements IgniteCacheProxy<K,V>

Implementation of IgniteCacheProxy that provides access to Ignite cache through IgniteCache instance.

Constructor Summary

Constructors

Constructor and Description
IgniteCacheProxyImpl(IgniteCache<K,V> cache)

Method Summary

Modifier and Type	Method and Description
void	clear() Clears the contents of the cache.
boolean	containsKey(K key) Determines if the ClientCache contains an entry for the specified key.
IgniteCache<K,V>	delegate()
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 Ignite cache, returning them as Map of the values associated with the set of keys requested.
@NotNull Iterator<javax.cache.Cache.Entry<K,V>>	iterator()
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 Ignite cache.
<R> QueryCursor<R>	query(Query<R> qry) Execute SQL query and get cursor to iterate over results.
boolean	remove(K key) Removes the mapping for a key from this cache if it is present.
void	removeAll(Set<? extends K> keys) Removes entries for the specified keys.
int	size(CachePeekMode... peekModes) Gets the number of all entries cached across all nodes.
IgniteCacheProxy<K,V>	withExpiryPolicy(javax.cache.expiry.ExpiryPolicy expirePlc) Returns cache with the specified expired policy set.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

IgniteCacheProxyImpl

public IgniteCacheProxyImpl(IgniteCache<K,V> cache)

Method Detail

get

public V get(K key)
      throws ClientException

Gets an entry from the cache.

Specified by:

get in interface IgniteCacheProxy<K,V>

Parameters:

key - the key whose associated value is to be returned

Returns:

the element, or null, if it does not exist.

Throws:

ClientException

put

public void put(K key,
                V val)
         throws ClientException

Associates the specified value with the specified key in the cache.

Specified by:

put in interface IgniteCacheProxy<K,V>

Parameters:

key - key with which the specified value is to be associated

val - value to be associated with the specified key.

Throws:

ClientException

size

public int size(CachePeekMode... peekModes)
         throws ClientException

Gets the number of all entries cached across all nodes.

Specified by:

size in interface IgniteCacheProxy<K,V>

Parameters:

peekModes - Optional peek modes. If not provided, then total cache size is returned.

Throws:

ClientException

getAll

public Map<K,V> getAll(Set<? extends K> keys)
                throws ClientException

Gets a collection of entries from the Ignite cache, returning them as Map of the values associated with the set of keys requested.

Specified by:

getAll in interface IgniteCacheProxy<K,V>

Parameters:

keys - The keys whose associated values are to be returned.

Returns:

A map of entries that were found for the given keys.

Throws:

ClientException

putAll

public void putAll(Map<? extends K,? extends V> map)
            throws ClientException

Copies all of the entries from the specified map to the Ignite cache.

Specified by:

putAll in interface IgniteCacheProxy<K,V>

Parameters:

map - Mappings to be stored in this cache.

Throws:

ClientException

remove

public boolean remove(K key)
               throws ClientException

Removes the mapping for a key from this cache if it is present.

Specified by:

remove in interface IgniteCacheProxy<K,V>

Parameters:

key - Key whose mapping is to be removed from the cache.

Returns:

false if there was no matching key.

Throws:

ClientException

removeAll

public void removeAll(Set<? extends K> keys)
               throws ClientException

Removes entries for the specified keys.

Specified by:

removeAll in interface IgniteCacheProxy<K,V>

Parameters:

keys - The keys to remove.

Throws:

ClientException

clear

public void clear()
           throws ClientException

Clears the contents of the cache.

Specified by:

clear in interface IgniteCacheProxy<K,V>

Throws:

ClientException

withExpiryPolicy

public IgniteCacheProxy<K,V> withExpiryPolicy(javax.cache.expiry.ExpiryPolicy expirePlc)

Returns cache with the specified expired policy set. This policy will be used for each operation invoked on the returned cache.

Specified by:

withExpiryPolicy in interface IgniteCacheProxy<K,V>

Returns:

Cache instance with the specified expiry policy set.

query

public <R> QueryCursor<R> query(Query<R> qry)

Execute SQL query and get cursor to iterate over results.

Specified by:

query in interface IgniteCacheProxy<K,V>

Parameters:

qry - SQL query.

Returns:

Query result cursor.

containsKey

public boolean containsKey(K key)

Determines if the ClientCache contains an entry for the specified key.

Specified by:

containsKey in interface IgniteCacheProxy<K,V>

Parameters:

key - key whose presence in this cache is to be tested.

Returns:

true if this map contains a mapping for the specified key.

iterator

@NotNull
public @NotNull Iterator<javax.cache.Cache.Entry<K,V>> iterator()

Specified by:

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

delegate

public IgniteCache<K,V> delegate()

Returns:

IgniteCache instance to which operations are delegated.