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()
boolean	containsKey(K key)
void	destroy()
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)
boolean	putIfAbsent(K key, V value)
ICompletableFuture<Boolean>	putIfAbsentAsync(K key, V value)
void	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)
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)

put

V put(K key,
      V value)

putIfAbsent

boolean putIfAbsent(K key,
                    V value)

putIfAbsentAsync

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

replace

V replace(K key,
          V newValue)

replace

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

remove

void remove(K key)

remove

boolean remove(K key,
               V oldValue)

removeAsync

ICompletableFuture<V> removeAsync(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)

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()

destroy

void destroy()

getLocalMapStats

LocalMapStats getLocalMapStats()