K
- the type of keys maintained by this mapV
- the type of valuespublic interface IMapJet<K,V> extends IMap<K,V>
The entries of the map are distributed across the whole cluster and partitioned by key.
It's possible to use the map as a data source or sink in a Jet Pipeline
,
using Sources.map(String)
or Sinks.map(String)
and the
change stream of the map can be read using
Sources.mapJournal(String, JournalInitialPosition)
.
addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addEntryListener, addIndex, addInterceptor, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addLocalEntryListener, addPartitionLostListener, aggregate, aggregate, aggregate, aggregate, clear, containsKey, containsValue, delete, entrySet, entrySet, evict, evictAll, executeOnEntries, executeOnEntries, executeOnKey, executeOnKeys, flush, forceUnlock, get, getAll, getAsync, getEntryView, getLocalMapStats, getQueryCache, getQueryCache, getQueryCache, isLocked, keySet, keySet, loadAll, loadAll, localKeySet, localKeySet, lock, lock, project, project, put, put, putAll, putAsync, putAsync, putIfAbsent, putIfAbsent, putTransient, remove, remove, removeAll, removeAsync, removeEntryListener, removeInterceptor, removePartitionLostListener, replace, replace, set, set, setAsync, setAsync, submitToKey, submitToKey, tryLock, tryLock, tryLock, tryPut, tryRemove, unlock, values, values
compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, replaceAll
destroy, getName, getPartitionKey, getServiceName
Copyright © 2018 Hazelcast, Inc.. All rights reserved.