public static final class DistributedStream.Cache extends Object
DistributedStream
on javax.cache
. With this approach the
javax.cache
classes will be required only when calling
fromCache(ICacheJet)
.Modifier and Type | Method and Description |
---|---|
static <K,V> DistributedStream<Map.Entry<K,V>> |
fromCache(ICacheJet<K,V> cache)
Returns a
DistributedStream with the supplied cache as its source. |
@Nonnull public static <K,V> DistributedStream<Map.Entry<K,V>> fromCache(@Nonnull ICacheJet<K,V> cache)
DistributedStream
with the supplied cache as its source.
If the cache is is being concurrently modified, there are no guarantees given with respect to missing or duplicate items in a stream operation.
Copyright © 2018 Hazelcast, Inc.. All rights reserved.