com.hazelcast.jet.stream

Interface IStreamMap<K,V>

Type Parameters:

K - the type of keys maintained by this map

V - the type of mapped values

All Superinterfaces:

com.hazelcast.core.BaseMap<K,V>, ConcurrentMap<K,V>, com.hazelcast.core.DistributedObject, com.hazelcast.core.IMap<K,V>, com.hazelcast.map.impl.LegacyAsyncMap<K,V>, Map<K,V>

public interface IStreamMap<K,V>
extends com.hazelcast.core.IMap<K,V>

A decorator for IMap for supporting distributed Stream implementation.

Nested Class Summary

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

Map.Entry<K,V>

Method Summary

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.

Methods inherited from interface com.hazelcast.core.IMap

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

Methods inherited from interface java.util.concurrent.ConcurrentMap

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

Methods inherited from interface java.util.Map

equals, hashCode, isEmpty, size

Methods inherited from interface com.hazelcast.core.BaseMap

isEmpty, size

Methods inherited from interface com.hazelcast.core.DistributedObject

destroy, getName, getPartitionKey, getServiceName

Method Detail

stream

DistributedStream<Map.Entry<K,V>> stream()

Returns a parallel and distributed 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.

Returns:

a parallel Stream over the elements in this collection

Since:

1.8

stream

<T> DistributedStream<T> stream(@Nonnull
                                com.hazelcast.query.Predicate<K,V> predicate,
                                @Nonnull
                                DistributedFunction<Map.Entry<K,V>,T> projectionFn)

Returns a parallel and distributed 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.

Returns:

a parallel Stream over the elements in this collection

Since:

1.8