Package org.gridgain.internal.structure.map

Class IgniteMapImpl<K,V>

java.lang.Object

org.gridgain.internal.structure.map.IgniteMapImpl<K,V>

Type Parameters:

K - The type of the key.

V - The type of the value.

All Implemented Interfaces:

org.gridgain.structure.IgniteMap<K,V>

public class IgniteMapImpl<K,V>
extends Object
implements org.gridgain.structure.IgniteMap<K,V>

Internal implementation of IgniteMap based on KeyValueView.

Constructor Summary

Constructors

Constructor	Description
IgniteMapImpl(String tableName, String mapName, org.apache.ignite.table.KeyValueView<?,?> kvView, org.apache.ignite.sql.IgniteSql sql, org.apache.ignite.marshalling.Marshaller<K,?> km, org.apache.ignite.marshalling.Marshaller<V,?> vm, MapDestroyer destroyer)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	clear()
CompletableFuture<Void>	clearAsync()
boolean	containsKey(K key)
CompletableFuture<Boolean>	containsKeyAsync(K key)
void	destroy()
CompletableFuture<Void>	destroyAsync()
V	get(K key)
org.apache.ignite.lang.AsyncCursor<Map.Entry<K,V>>	getAll()
CompletableFuture<org.apache.ignite.lang.AsyncCursor<Map.Entry<K,V>>>	getAllAsync()
V	getAndPut(K key, V value)
CompletableFuture<@Nullable V>	getAndPutAsync(K key, V value)
V	getAndRemove(K key)
CompletableFuture<@Nullable V>	getAndRemoveAsync(K key)
CompletableFuture<V>	getAsync(K key)
boolean	isEmpty()
CompletableFuture<Boolean>	isEmptyAsync()
void	put(K key, V value)
void	putAll(Map<? extends K,? extends V> m)
CompletableFuture<Void>	putAllAsync(Map<? extends K,? extends V> m)
CompletableFuture<Void>	putAsync(K key, V value)
boolean	remove(K key)
void	removeAll(Collection<K> keys)
CompletableFuture<Void>	removeAllAsync(Collection<K> keys)
CompletableFuture<Boolean>	removeAsync(K key)
long	size()
CompletableFuture<Long>	sizeAsync()

Methods inherited from class java.lang.Object

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

Constructor Details

IgniteMapImpl

public IgniteMapImpl(String tableName,
 String mapName,
 org.apache.ignite.table.KeyValueView<?,?> kvView,
 org.apache.ignite.sql.IgniteSql sql,
 org.apache.ignite.marshalling.Marshaller<K,?> km,
 org.apache.ignite.marshalling.Marshaller<V,?> vm,
 MapDestroyer destroyer)

Constructor.

Method Details

putAsync

public CompletableFuture<Void> putAsync(K key,
 V value)

Specified by:

putAsync in interface org.gridgain.structure.IgniteMap<K,V>

getAndPutAsync

public CompletableFuture<@Nullable V> getAndPutAsync(K key,
 V value)

Specified by:

getAndPutAsync in interface org.gridgain.structure.IgniteMap<K,V>

removeAsync

public CompletableFuture<Boolean> removeAsync(K key)

Specified by:

removeAsync in interface org.gridgain.structure.IgniteMap<K,V>

getAndRemoveAsync

public CompletableFuture<@Nullable V> getAndRemoveAsync(K key)

Specified by:

getAndRemoveAsync in interface org.gridgain.structure.IgniteMap<K,V>

removeAllAsync

public CompletableFuture<Void> removeAllAsync(Collection<K> keys)

Specified by:

removeAllAsync in interface org.gridgain.structure.IgniteMap<K,V>

putAllAsync

public CompletableFuture<Void> putAllAsync(Map<? extends K,? extends V> m)

Specified by:

putAllAsync in interface org.gridgain.structure.IgniteMap<K,V>

getAsync

public CompletableFuture<V> getAsync(K key)

Specified by:

getAsync in interface org.gridgain.structure.IgniteMap<K,V>

containsKeyAsync

public CompletableFuture<Boolean> containsKeyAsync(K key)

Specified by:

containsKeyAsync in interface org.gridgain.structure.IgniteMap<K,V>

sizeAsync

public CompletableFuture<Long> sizeAsync()

Specified by:

sizeAsync in interface org.gridgain.structure.IgniteMap<K,V>

clearAsync

public CompletableFuture<Void> clearAsync()

Specified by:

clearAsync in interface org.gridgain.structure.IgniteMap<K,V>

getAllAsync

public CompletableFuture<org.apache.ignite.lang.AsyncCursor<Map.Entry<K,V>>> getAllAsync()

Specified by:

getAllAsync in interface org.gridgain.structure.IgniteMap<K,V>

isEmptyAsync

public CompletableFuture<Boolean> isEmptyAsync()

Specified by:

isEmptyAsync in interface org.gridgain.structure.IgniteMap<K,V>

put

public void put(K key,
 V value)

Specified by:

put in interface org.gridgain.structure.IgniteMap<K,V>

getAndPut

public V getAndPut(K key,
 V value)

Specified by:

getAndPut in interface org.gridgain.structure.IgniteMap<K,V>

putAll

public void putAll(Map<? extends K,? extends V> m)

Specified by:

putAll in interface org.gridgain.structure.IgniteMap<K,V>

containsKey

public boolean containsKey(K key)

Specified by:

containsKey in interface org.gridgain.structure.IgniteMap<K,V>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface org.gridgain.structure.IgniteMap<K,V>

remove

public boolean remove(K key)

Specified by:

remove in interface org.gridgain.structure.IgniteMap<K,V>

getAndRemove

public V getAndRemove(K key)

Specified by:

getAndRemove in interface org.gridgain.structure.IgniteMap<K,V>

removeAll

public void removeAll(Collection<K> keys)

Specified by:

removeAll in interface org.gridgain.structure.IgniteMap<K,V>

get

public V get(K key)

Specified by:

get in interface org.gridgain.structure.IgniteMap<K,V>

size

public long size()

Specified by:

size in interface org.gridgain.structure.IgniteMap<K,V>

getAll

public org.apache.ignite.lang.AsyncCursor<Map.Entry<K,V>> getAll()

Specified by:

getAll in interface org.gridgain.structure.IgniteMap<K,V>

clear

public void clear()

Specified by:

clear in interface org.gridgain.structure.IgniteMap<K,V>

destroyAsync

public CompletableFuture<Void> destroyAsync()

Specified by:

destroyAsync in interface org.gridgain.structure.IgniteMap<K,V>

destroy

public void destroy()

Specified by:

destroy in interface org.gridgain.structure.IgniteMap<K,V>