com.hazelcast.elastic.map

Class BinaryElasticHashMap<V extends com.hazelcast.memory.MemoryBlock>

java.lang.Object

com.hazelcast.elastic.map.BinaryElasticHashMap<V>

Type Parameters:

V - the type of memory block used as value

All Implemented Interfaces:

com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,V>, com.hazelcast.nio.Disposable, Map<com.hazelcast.nio.serialization.Data,V>

Direct Known Subclasses:

SampleableElasticHashMap

public class BinaryElasticHashMap<V extends com.hazelcast.memory.MemoryBlock>
extends Object
implements com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,V>

A hash map of Data to MemoryBlock, implemented using open addressing with linear probing for collision resolution.

The internal buffer of this implementation is always allocated to the nearest higher size that is a power of two. When the capacity exceeds the given load factor, the buffer size is doubled.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	BinaryElasticHashMap.KeyIter Key iterator.
protected class	BinaryElasticHashMap.MapEntry Map.Entry implementation for this map.
protected class	BinaryElasticHashMap.RandomKeyIter
protected class	BinaryElasticHashMap.RandomValueIter
protected class	BinaryElasticHashMap.ValueIter Iterator over the map's values.

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
protected BehmSlotAccessor	accessor
static int	HEADER_LENGTH_IN_BYTES Header length when header stored off-heap for zero heap usage
protected MemoryBlockProcessor<V>	memoryBlockProcessor

Constructor Summary

Constructors

Constructor and Description
BinaryElasticHashMap(EnterpriseSerializationService serializationService, com.hazelcast.memory.MemoryBlockAccessor<V> memoryBlockAccessor, com.hazelcast.internal.memory.MemoryAllocator malloc) Creates a hash map with the default capacity of , load factor of .
BinaryElasticHashMap(int initialCapacity, EnterpriseSerializationService serializationService, com.hazelcast.memory.MemoryBlockAccessor<V> memoryBlockAccessor, com.hazelcast.internal.memory.MemoryAllocator malloc) Creates a hash map with the given initial capacity, default load factor of .
BinaryElasticHashMap(int initialCapacity, float loadFactor, EnterpriseSerializationService serializationService, com.hazelcast.memory.MemoryBlockAccessor<V> memoryBlockAccessor, com.hazelcast.internal.memory.MemoryAllocator malloc) Creates a hash map with the given initial capacity, load factor.
BinaryElasticHashMap(int initialCapacity, float loadFactor, MemoryBlockProcessor<V> memoryBlockProcessor) Creates a hash map with the given initial capacity, load factor.
BinaryElasticHashMap(int initialCapacity, MemoryBlockProcessor<V> memoryBlockProcessor) Creates a hash map with the given initial capacity, load factor.

Method Summary

Modifier and Type	Method and Description
int	capacity()
void	clear() Clears the map by removing and disposing all key/value pairs stored.
boolean	containsKey(Object k)
boolean	containsValue(Object v)
boolean	delete(com.hazelcast.nio.serialization.Data key)
void	dispose() Disposes internal backing array of this map.
Iterator<Map.Entry<com.hazelcast.nio.serialization.Data,V>>	entryIter(boolean failFast)
protected com.hazelcast.elastic.SlottableIterator<Map.Entry<com.hazelcast.nio.serialization.Data,V>>	entryIter(int slot)
Set<Map.Entry<com.hazelcast.nio.serialization.Data,V>>	entrySet()
V	get(Object k)
V	getIfSameKey(Object k)
long	getNativeKeyAddress(com.hazelcast.nio.serialization.Data key)
boolean	isEmpty()
protected BinaryElasticHashMap.KeyIter	keyIter(int startSlot)
Set<com.hazelcast.nio.serialization.Data>	keySet()
static <V extends com.hazelcast.memory.MemoryBlock> BinaryElasticHashMap<V>	loadFromOffHeapHeader(EnterpriseSerializationService ss, com.hazelcast.internal.memory.MemoryAllocator malloc, long address)
com.hazelcast.elastic.SlottableIterator<com.hazelcast.nio.serialization.Data>	newRandomEvictionKeyIterator() Returns a key iterator indented to be used for forced evictions - iteration order is (pseudo-)random.
com.hazelcast.elastic.SlottableIterator<V>	newRandomEvictionValueIterator() Returns a key iterator indented to be used for forced evictions - iteration order is (pseudo-)random.
protected com.hazelcast.memory.NativeOutOfMemoryError	onOome(com.hazelcast.memory.NativeOutOfMemoryError e)
V	put(com.hazelcast.nio.serialization.Data key, V value)
void	putAll(Map<? extends com.hazelcast.nio.serialization.Data,? extends V> map)
V	putIfAbsent(com.hazelcast.nio.serialization.Data key, V value)
protected V	readV(long slotValue)
V	remove(Object k)
boolean	remove(Object k, Object v)
V	replace(com.hazelcast.nio.serialization.Data key, V value)
boolean	replace(com.hazelcast.nio.serialization.Data key, V oldValue, V newValue)
boolean	set(com.hazelcast.nio.serialization.Data key, V value)
int	size()
NativeMemoryData	storeHeaderOffHeap(com.hazelcast.internal.memory.MemoryAllocator malloc, long addressGiven)
String	toString()
Iterator<V>	valueIter()
Iterator<V>	valueIter(boolean failFast)
Collection<V>	values()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, replaceAll

Field Detail

HEADER_LENGTH_IN_BYTES

public static final int HEADER_LENGTH_IN_BYTES

Header length when header stored off-heap for zero heap usage

See Also:

Constant Field Values

memoryBlockProcessor

protected final MemoryBlockProcessor<V extends com.hazelcast.memory.MemoryBlock> memoryBlockProcessor

accessor

protected BehmSlotAccessor accessor

Constructor Detail

BinaryElasticHashMap

public BinaryElasticHashMap(EnterpriseSerializationService serializationService,
                            com.hazelcast.memory.MemoryBlockAccessor<V> memoryBlockAccessor,
                            com.hazelcast.internal.memory.MemoryAllocator malloc)

Creates a hash map with the default capacity of , load factor of .

BinaryElasticHashMap

public BinaryElasticHashMap(int initialCapacity,
                            EnterpriseSerializationService serializationService,
                            com.hazelcast.memory.MemoryBlockAccessor<V> memoryBlockAccessor,
                            com.hazelcast.internal.memory.MemoryAllocator malloc)

Creates a hash map with the given initial capacity, default load factor of .

Parameters:

initialCapacity - initial capacity (greater than zero and automatically rounded to the next power of two)

BinaryElasticHashMap

public BinaryElasticHashMap(int initialCapacity,
                            float loadFactor,
                            EnterpriseSerializationService serializationService,
                            com.hazelcast.memory.MemoryBlockAccessor<V> memoryBlockAccessor,
                            com.hazelcast.internal.memory.MemoryAllocator malloc)

Creates a hash map with the given initial capacity, load factor.

Parameters:

initialCapacity - initial capacity (greater than zero and automatically rounded to the next power of two)

loadFactor - the load factor (greater than zero and smaller than 1)

BinaryElasticHashMap

public BinaryElasticHashMap(int initialCapacity,
                            MemoryBlockProcessor<V> memoryBlockProcessor)

Creates a hash map with the given initial capacity, load factor.

Parameters:

initialCapacity - initial capacity (greater than zero and automatically rounded to the next power of two)

BinaryElasticHashMap

public BinaryElasticHashMap(int initialCapacity,
                            float loadFactor,
                            MemoryBlockProcessor<V> memoryBlockProcessor)

Creates a hash map with the given initial capacity, load factor.

Parameters:

initialCapacity - initial capacity (greater than zero and automatically rounded to the next power of two)

loadFactor - the load factor (greater than zero and smaller than 1)

Method Detail

onOome

protected com.hazelcast.memory.NativeOutOfMemoryError onOome(com.hazelcast.memory.NativeOutOfMemoryError e)

put

public V put(com.hazelcast.nio.serialization.Data key,
             V value)

Specified by:

put in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

set

public boolean set(com.hazelcast.nio.serialization.Data key,
                   V value)

Specified by:

set in interface com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

putIfAbsent

public V putIfAbsent(com.hazelcast.nio.serialization.Data key,
                     V value)

Specified by:

putIfAbsent in interface com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

Specified by:

putIfAbsent in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

putAll

public void putAll(Map<? extends com.hazelcast.nio.serialization.Data,? extends V> map)

Specified by:

putAll in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

replace

public boolean replace(com.hazelcast.nio.serialization.Data key,
                       V oldValue,
                       V newValue)

Specified by:

replace in interface com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

Specified by:

replace in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

replace

public V replace(com.hazelcast.nio.serialization.Data key,
                 V value)

Specified by:

replace in interface com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

Specified by:

replace in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

remove

public V remove(Object k)

Specified by:

remove in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

delete

public boolean delete(com.hazelcast.nio.serialization.Data key)

Specified by:

delete in interface com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

remove

public boolean remove(Object k,
                      Object v)

Specified by:

remove in interface com.hazelcast.elastic.map.ElasticMap<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

Specified by:

remove in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

get

public V get(Object k)

Specified by:

get in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

getIfSameKey

public V getIfSameKey(Object k)

Parameters:

k - must be instanceof NativeMemoryData

Returns:

same as get(Object), but with the additional constraint that the argument must refer to exactly the same blob (at the same address) as the one stored by the map

getNativeKeyAddress

public long getNativeKeyAddress(com.hazelcast.nio.serialization.Data key)

containsKey

public boolean containsKey(Object k)

Specified by:

containsKey in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

containsValue

public boolean containsValue(Object v)

Specified by:

containsValue in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

newRandomEvictionKeyIterator

public com.hazelcast.elastic.SlottableIterator<com.hazelcast.nio.serialization.Data> newRandomEvictionKeyIterator()

Returns a key iterator indented to be used for forced evictions - iteration order is (pseudo-)random. It expects a caller will remove each visited entry - failing to do means one entry can be visited more than once and some other entry won't be visited at all.

newRandomEvictionValueIterator

public com.hazelcast.elastic.SlottableIterator<V> newRandomEvictionValueIterator()

Returns a key iterator indented to be used for forced evictions - iteration order is (pseudo-)random. It expects a caller will remove each visited entry - failing to do means one entry can be visited multiple-times and some other entry won't be visited at all.

keySet

public Set<com.hazelcast.nio.serialization.Data> keySet()

Specified by:

keySet in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

keyIter

protected BinaryElasticHashMap.KeyIter keyIter(int startSlot)

values

public Collection<V> values()

Specified by:

values in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

valueIter

public final Iterator<V> valueIter()

valueIter

public final Iterator<V> valueIter(boolean failFast)

Parameters:

failFast - true to enable fail fast behaviour, otherwise set false

Returns:

a new iterator instance

See Also:

modCount

readV

protected V readV(long slotValue)

entrySet

public Set<Map.Entry<com.hazelcast.nio.serialization.Data,V>> entrySet()

Specified by:

entrySet in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

entryIter

public final Iterator<Map.Entry<com.hazelcast.nio.serialization.Data,V>> entryIter(boolean failFast)

Parameters:

failFast - true to enable fail fast behaviour, otherwise set false

Returns:

a new iterator instance

See Also:

modCount

entryIter

protected com.hazelcast.elastic.SlottableIterator<Map.Entry<com.hazelcast.nio.serialization.Data,V>> entryIter(int slot)

clear

public void clear()

Clears the map by removing and disposing all key/value pairs stored.

Specified by:

clear in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

storeHeaderOffHeap

public NativeMemoryData storeHeaderOffHeap(com.hazelcast.internal.memory.MemoryAllocator malloc,
                                           long addressGiven)

loadFromOffHeapHeader

public static <V extends com.hazelcast.memory.MemoryBlock> BinaryElasticHashMap<V> loadFromOffHeapHeader(EnterpriseSerializationService ss,
                                                                                                         com.hazelcast.internal.memory.MemoryAllocator malloc,
                                                                                                         long address)

dispose

public void dispose()

Disposes internal backing array of this map. Does not dispose key/value pairs inside. To dispose key/value pairs, clear() must be called explicitly.

Specified by:

dispose in interface com.hazelcast.nio.Disposable

See Also:

clear()

size

public int size()

Specified by:

size in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

capacity

public int capacity()

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Map<com.hazelcast.nio.serialization.Data,V extends com.hazelcast.memory.MemoryBlock>

toString

public String toString()

Overrides:

toString in class Object