com.hazelcast.internal.adapter

Class ReplicatedMapDataStructureAdapter<K,V>

java.lang.Object

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

All Implemented Interfaces:

DataStructureAdapter<K,V>

public class ReplicatedMapDataStructureAdapter<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
ReplicatedMapDataStructureAdapter(ReplicatedMap<K,V> map)

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatedMapDataStructureAdapter

public ReplicatedMapDataStructureAdapter(ReplicatedMap<K,V> map)

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

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>

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>

getLocalMapStats

public LocalMapStats getLocalMapStats()

Specified by:

getLocalMapStats in interface DataStructureAdapter<K,V>