com.hazelcast.jet.stream

Class DistributedStream.Cache

java.lang.Object

com.hazelcast.jet.stream.DistributedStream.Cache

Enclosing interface:

DistributedStream<T>

public static final class DistributedStream.Cache
extends Object

Wrapper class that avoids the runtime dependency of DistributedStream on javax.cache. With this approach the javax.cache classes will be required only when calling fromCache(ICacheJet).

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fromCache

@Nonnull
public static <K,V> DistributedStream<Map.Entry<K,V>> fromCache(@Nonnull
                                                                         ICacheJet<K,V> cache)

Returns a 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.