com.hazelcast.internal.adapter

Interface DataStructureAdapter<K,V>

All Known Implementing Classes:

ICacheDataStructureAdapter, IMapDataStructureAdapter, ReplicatedMapDataStructureAdapter, TransactionalMapDataStructureAdapter

public interface DataStructureAdapter<K,V>

Abstracts the Hazelcast data structures with Near Cache support for the Near Cache usage.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	DataStructureAdapter.DataStructureMethods Contains all methods of DataStructureAdapter.

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 ttl, TimeUnit timeunit)
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()

Method Detail

size

int size()

get

V get(K key)

getAsync

ICompletableFuture<V> getAsync(K key)

set

void set(K key,
         V value)

setAsync

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

setAsync

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

setAsync

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

put

V put(K key,
      V value)

putAsync

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

putAsync

ICompletableFuture<V> putAsync(K key,
                               V value,
                               long ttl,
                               TimeUnit timeunit)

putAsync

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

putTransient

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

putIfAbsent

boolean putIfAbsent(K key,
                    V value)

putIfAbsentAsync

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

setTtl

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

replace

V replace(K key,
          V newValue)

replace

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

remove

V remove(K key)

remove

boolean remove(K key,
               V oldValue)

removeAsync

ICompletableFuture<V> removeAsync(K key)

delete

void delete(K key)

deleteAsync

ICompletableFuture<Boolean> deleteAsync(K key)

evict

boolean evict(K key)

invoke

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

Throws:

javax.cache.processor.EntryProcessorException

executeOnKey

Object executeOnKey(K key,
                    EntryProcessor entryProcessor)

executeOnKeys

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

executeOnEntries

Map<K,Object> executeOnEntries(EntryProcessor entryProcessor)

executeOnEntries

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

containsKey

boolean containsKey(K key)

loadAll

void loadAll(boolean replaceExistingValues)

loadAll

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

loadAll

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

getAll

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

putAll

void putAll(Map<K,V> map)

removeAll

void removeAll()

removeAll

void removeAll(Set<K> keys)

evictAll

void evictAll()

invokeAll

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

clear

void clear()

close

void close()

destroy

void destroy()

setExpiryPolicy

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

setExpiryPolicy

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

getLocalMapStats

LocalMapStats getLocalMapStats()