com.hazelcast.internal.adapter

Class ICacheDataStructureAdapter<K,V>

java.lang.Object

com.hazelcast.internal.adapter.ICacheDataStructureAdapter<K,V>

All Implemented Interfaces:

DataStructureAdapter<K,V>

public class ICacheDataStructureAdapter<K,V>
extends Object
implements DataStructureAdapter<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.internal.adapter.DataStructureAdapter

DataStructureAdapter.DataStructureMethods

Constructor Summary

Constructors

Constructor and Description
ICacheDataStructureAdapter(ICache<K,V> cache)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	close()
boolean	containsKey(K key)
void	delete(K key)
ICompletableFuture<Boolean>	deleteAsync(K key)
void	destroy()
boolean	evict(K key)
void	evictAll()
Map<K,Object>	executeOnEntries(EntryProcessor entryProcessor)
Map<K,Object>	executeOnEntries(EntryProcessor entryProcessor, Predicate predicate)
Object	executeOnKey(K key, EntryProcessor entryProcessor)
Map<K,Object>	executeOnKeys(Set<K> keys, EntryProcessor entryProcessor)
V	get(K key)
Map<K,V>	getAll(Set<K> keys)
ICompletableFuture<V>	getAsync(K key)
LocalMapStats	getLocalMapStats()
<T> T	invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... arguments)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... arguments)
void	loadAll(boolean replaceExistingValues)
void	loadAll(Set<? extends K> keys, boolean replaceExistingValues, javax.cache.integration.CompletionListener completionListener)
void	loadAll(Set<K> keys, boolean replaceExistingValues)
V	put(K key, V value)
void	putAll(Map<K,V> map)
ICompletableFuture<V>	putAsync(K key, V value)
ICompletableFuture<V>	putAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)
ICompletableFuture<V>	putAsync(K key, V value, long time, TimeUnit unit)
boolean	putIfAbsent(K key, V value)
ICompletableFuture<Boolean>	putIfAbsentAsync(K key, V value)
void	putTransient(K key, V value, long ttl, TimeUnit timeunit)
V	remove(K key)
boolean	remove(K key, V oldValue)
void	removeAll()
void	removeAll(Set<K> keys)
ICompletableFuture<V>	removeAsync(K key)
V	replace(K key, V newValue)
boolean	replace(K key, V oldValue, V newValue)
void	set(K key, V value)
ICompletableFuture<Void>	setAsync(K key, V value)
ICompletableFuture<Void>	setAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy)
ICompletableFuture<Void>	setAsync(K key, V value, long ttl, TimeUnit timeunit)
boolean	setExpiryPolicy(K key, javax.cache.expiry.ExpiryPolicy expiryPolicy)
void	setExpiryPolicy(Set<K> keys, javax.cache.expiry.ExpiryPolicy expiryPolicy)
void	setTtl(K key, long duration, TimeUnit timeUnit)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

ICacheDataStructureAdapter

public ICacheDataStructureAdapter(ICache<K,V> cache)

Method Detail

size

public int size()

Specified by:

size in interface DataStructureAdapter<K,V>

get

public V get(K key)

Specified by:

get in interface DataStructureAdapter<K,V>

getAsync

public ICompletableFuture<V> getAsync(K key)

Specified by:

getAsync in interface DataStructureAdapter<K,V>

set

public void set(K key,
                V value)

Specified by:

set in interface DataStructureAdapter<K,V>

setAsync

public ICompletableFuture<Void> setAsync(K key,
                                         V value)

Specified by:

setAsync in interface DataStructureAdapter<K,V>

setAsync

public ICompletableFuture<Void> setAsync(K key,
                                         V value,
                                         long ttl,
                                         TimeUnit timeunit)

Specified by:

setAsync in interface DataStructureAdapter<K,V>

setAsync

public ICompletableFuture<Void> setAsync(K key,
                                         V value,
                                         javax.cache.expiry.ExpiryPolicy expiryPolicy)

Specified by:

setAsync in interface DataStructureAdapter<K,V>

put

public V put(K key,
             V value)

Specified by:

put in interface DataStructureAdapter<K,V>

putAsync

public ICompletableFuture<V> putAsync(K key,
                                      V value)

Specified by:

putAsync in interface DataStructureAdapter<K,V>

putAsync

public ICompletableFuture<V> putAsync(K key,
                                      V value,
                                      long time,
                                      TimeUnit unit)

Specified by:

putAsync in interface DataStructureAdapter<K,V>

putAsync

public ICompletableFuture<V> putAsync(K key,
                                      V value,
                                      javax.cache.expiry.ExpiryPolicy expiryPolicy)

Specified by:

putAsync in interface DataStructureAdapter<K,V>

putTransient

public void putTransient(K key,
                         V value,
                         long ttl,
                         TimeUnit timeunit)

Specified by:

putTransient in interface DataStructureAdapter<K,V>

putIfAbsent

public boolean putIfAbsent(K key,
                           V value)

Specified by:

putIfAbsent in interface DataStructureAdapter<K,V>

putIfAbsentAsync

public ICompletableFuture<Boolean> putIfAbsentAsync(K key,
                                                    V value)

Specified by:

putIfAbsentAsync in interface DataStructureAdapter<K,V>

setTtl

public void setTtl(K key,
                   long duration,
                   TimeUnit timeUnit)

Specified by:

setTtl in interface DataStructureAdapter<K,V>

replace

public V replace(K key,
                 V newValue)

Specified by:

replace in interface DataStructureAdapter<K,V>

replace

public boolean replace(K key,
                       V oldValue,
                       V newValue)

Specified by:

replace in interface DataStructureAdapter<K,V>

remove

public V remove(K key)

Specified by:

remove in interface DataStructureAdapter<K,V>

remove

public boolean remove(K key,
                      V oldValue)

Specified by:

remove in interface DataStructureAdapter<K,V>

removeAsync

public ICompletableFuture<V> removeAsync(K key)

Specified by:

removeAsync in interface DataStructureAdapter<K,V>

delete

public void delete(K key)

Specified by:

delete in interface DataStructureAdapter<K,V>

deleteAsync

public ICompletableFuture<Boolean> deleteAsync(K key)

Specified by:

deleteAsync in interface DataStructureAdapter<K,V>

evict

public boolean evict(K key)

Specified by:

evict in interface DataStructureAdapter<K,V>

invoke

public <T> T invoke(K key,
                    javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                    Object... arguments)
             throws javax.cache.processor.EntryProcessorException

Specified by:

invoke in interface DataStructureAdapter<K,V>

Throws:

javax.cache.processor.EntryProcessorException

executeOnKey

public Object executeOnKey(K key,
                           EntryProcessor entryProcessor)

Specified by:

executeOnKey in interface DataStructureAdapter<K,V>

executeOnKeys

public Map<K,Object> executeOnKeys(Set<K> keys,
                                   EntryProcessor entryProcessor)

Specified by:

executeOnKeys in interface DataStructureAdapter<K,V>

executeOnEntries

public Map<K,Object> executeOnEntries(EntryProcessor entryProcessor)

Specified by:

executeOnEntries in interface DataStructureAdapter<K,V>

executeOnEntries

public Map<K,Object> executeOnEntries(EntryProcessor entryProcessor,
                                      Predicate predicate)

Specified by:

executeOnEntries in interface DataStructureAdapter<K,V>

containsKey

public boolean containsKey(K key)

Specified by:

containsKey in interface DataStructureAdapter<K,V>

loadAll

public void loadAll(boolean replaceExistingValues)

Specified by:

loadAll in interface DataStructureAdapter<K,V>

loadAll

public void loadAll(Set<K> keys,
                    boolean replaceExistingValues)

Specified by:

loadAll in interface DataStructureAdapter<K,V>

loadAll

public void loadAll(Set<? extends K> keys,
                    boolean replaceExistingValues,
                    javax.cache.integration.CompletionListener completionListener)

Specified by:

loadAll in interface DataStructureAdapter<K,V>

getAll

public Map<K,V> getAll(Set<K> keys)

Specified by:

getAll in interface DataStructureAdapter<K,V>

putAll

public void putAll(Map<K,V> map)

Specified by:

putAll in interface DataStructureAdapter<K,V>

removeAll

public void removeAll()

Specified by:

removeAll in interface DataStructureAdapter<K,V>

removeAll

public void removeAll(Set<K> keys)

Specified by:

removeAll in interface DataStructureAdapter<K,V>

evictAll

public void evictAll()

Specified by:

evictAll in interface DataStructureAdapter<K,V>

invokeAll

public <T> Map<K,javax.cache.processor.EntryProcessorResult<T>> invokeAll(Set<? extends K> keys,
                                                                          javax.cache.processor.EntryProcessor<K,V,T> entryProcessor,
                                                                          Object... arguments)

Specified by:

invokeAll in interface DataStructureAdapter<K,V>

clear

public void clear()

Specified by:

clear in interface DataStructureAdapter<K,V>

close

public void close()

Specified by:

close in interface DataStructureAdapter<K,V>

destroy

public void destroy()

Specified by:

destroy in interface DataStructureAdapter<K,V>

setExpiryPolicy

public void setExpiryPolicy(Set<K> keys,
                            javax.cache.expiry.ExpiryPolicy expiryPolicy)

Specified by:

setExpiryPolicy in interface DataStructureAdapter<K,V>

setExpiryPolicy

public boolean setExpiryPolicy(K key,
                               javax.cache.expiry.ExpiryPolicy expiryPolicy)

Specified by:

setExpiryPolicy in interface DataStructureAdapter<K,V>

getLocalMapStats

public LocalMapStats getLocalMapStats()

Specified by:

getLocalMapStats in interface DataStructureAdapter<K,V>