com.hazelcast.jet.stream

Interface IStreamCache<K,V>

Type Parameters:

K - the type of keys maintained by this map

V - the type of mapped values

All Superinterfaces:

AutoCloseable, javax.cache.Cache<K,V>, Closeable, com.hazelcast.core.DistributedObject, com.hazelcast.cache.ICache<K,V>, Iterable<javax.cache.Cache.Entry<K,V>>, com.hazelcast.core.PrefixedDistributedObject

public interface IStreamCache<K,V>
extends com.hazelcast.cache.ICache<K,V>

A decorator for ICache that provides a distributed Stream implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface javax.cache.Cache

javax.cache.Cache.Entry<K,V>

Method Summary

Modifier and Type	Method and Description
DistributedStream<Map.Entry<K,V>>	stream() Returns a DistributedStream with this cache as its source.

Methods inherited from interface com.hazelcast.cache.ICache

addPartitionLostListener, destroy, get, getAll, getAndPut, getAndPutAsync, getAndPutAsync, getAndRemoveAsync, getAndReplace, getAndReplaceAsync, getAndReplaceAsync, getAsync, getAsync, getLocalCacheStatistics, isDestroyed, iterator, put, putAll, putAsync, putAsync, putIfAbsent, putIfAbsentAsync, putIfAbsentAsync, removeAsync, removeAsync, removePartitionLostListener, replace, replace, replaceAsync, replaceAsync, replaceAsync, replaceAsync, size

Methods inherited from interface javax.cache.Cache

clear, close, containsKey, deregisterCacheEntryListener, get, getAll, getAndPut, getAndRemove, getAndReplace, getCacheManager, getConfiguration, getName, invoke, invokeAll, isClosed, iterator, loadAll, put, putAll, putIfAbsent, registerCacheEntryListener, remove, remove, removeAll, removeAll, replace, replace, unwrap

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface com.hazelcast.core.PrefixedDistributedObject

getPrefixedName

Methods inherited from interface com.hazelcast.core.DistributedObject

getName, getPartitionKey, getServiceName

Method Detail

stream

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

Returns a DistributedStream with this cache as its source.

If the underlying cache is is being concurrently modified, there are no guarantees given with respect to missing or duplicate items in a stream operation.