K
- the type of keys maintained by this mapV
- the type of mapped valuespublic interface IStreamMap<K,V>
extends com.hazelcast.core.IMap<K,V>
IMap
for supporting distributed Stream
implementation.Modifier and Type | Method and Description |
---|---|
DistributedStream<Map.Entry<K,V>> |
stream()
Returns a parallel and distributed
Stream with this map as its source. |
<T> DistributedStream<T> |
stream(com.hazelcast.query.Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Returns a parallel and distributed
Stream with this map as its source. |
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
DistributedStream<Map.Entry<K,V>> stream()
Stream
with this map as its source.
If the underlying map is concurrently being modified, there are no guarantees given with respect to missing or duplicate items in a stream operation.
Stream
over the elements in this collection<T> DistributedStream<T> stream(@Nonnull com.hazelcast.query.Predicate<K,V> predicate, @Nonnull DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Stream
with this map as its source.
Entries will be filtered and mapped according to the given predicate and projection.
If the underlying map is concurrently being modified, there are no guarantees given with respect to missing or duplicate items in a stream operation.
Stream
over the elements in this collectionCopyright © 2017 Hazelcast, Inc.. All Rights Reserved.