com.hazelcast.connector.map

Interface Hz3MapAdapter

public interface Hz3MapAdapter

Adapter between the source and a Map backed by Hz 3 client

Method Summary

Modifier and Type	Method and Description
BooleanSupplier	createWatcher() Returns a BooleanSupplier that will tell if a migration took place since the call to this method.
<K,V> AsyncMap<K,V>	getMap(String mapName) Returns map with given name.
int	getPartitionCount() Return number of partitions for the cluster
<V,K> Map<K,V>	getReplicatedMap(String mapName) Returns replicated map with given name
<F extends CompletableFuture,B,R> Reader<F,B,R>	reader(String mapName, Function<Map.Entry<byte[],byte[]>,Object> toObject) Return reader for a map with given name
void	shutdown() Shutdown the client and any related resources
Object	toHz3Data(byte[] bytes) Wrap payload as Data using Hazelcast 3 version of HeapData

Method Detail

getPartitionCount

int getPartitionCount()

Return number of partitions for the cluster

reader

<F extends CompletableFuture,B,R> Reader<F,B,R> reader(String mapName,
                                                       Function<Map.Entry<byte[],byte[]>,Object> toObject)

Return reader for a map with given name

createWatcher

BooleanSupplier createWatcher()

Returns a BooleanSupplier that will tell if a migration took place since the call to this method.

shutdown

void shutdown()

Shutdown the client and any related resources

getMap

<K,V> AsyncMap<K,V> getMap(String mapName)

Returns map with given name.

The returned type is AsyncMap because of the incompatible interfaces between Hazelcast 3 and 4.

getReplicatedMap

<V,K> Map<K,V> getReplicatedMap(String mapName)

Returns replicated map with given name

toHz3Data

Object toHz3Data(byte[] bytes)

Wrap payload as Data using Hazelcast 3 version of HeapData