Uses of Interface
com.hazelcast.jet.stream.DistributedStream

Packages that use DistributedStream

Package	Description
com.hazelcast.jet.stream	java.util.stream implementation using Hazelcast Jet

Uses of DistributedStream in com.hazelcast.jet.stream

Methods in com.hazelcast.jet.stream that return DistributedStream

Modifier and Type	Method and Description
DistributedStream<Long>	DistributedLongStream.boxed()
DistributedStream<Integer>	DistributedIntStream.boxed()
DistributedStream<Double>	DistributedDoubleStream.boxed()
DistributedStream<T>	DistributedStream.configure(JobConfig jobConfig)
DistributedStream<T>	DistributedStream.distinct()
default DistributedStream<T>	DistributedStream.filter(DistributedPredicate<? super T> predicate) Serializable variant of java.util.stream.Stream#filter(Predicate).
DistributedStream<T>	DistributedStream.filter(Predicate<? super T> predicate)
default <R> DistributedStream<R>	DistributedStream.flatMap(DistributedFunction<? super T,? extends Stream<? extends R>> mapper) Serializable variant of java.util.stream.Stream#flatMap(Function).
<R> DistributedStream<R>	DistributedStream.flatMap(Function<? super T,? extends Stream<? extends R>> mapper)
static <K,V> DistributedStream<Map.Entry<K,V>>	DistributedStream.Cache.fromCache(ICacheJet<K,V> cache) Returns a DistributedStream with the supplied cache as its source.
static <T> DistributedStream<T>	DistributedStream.fromList(IListJet<T> list) Returns an ordered DistributedStream with this list as its source.
static <K,V> DistributedStream<Map.Entry<K,V>>	DistributedStream.fromMap(IMapJet<K,V> map) Returns a DistributedStream with this map as its source.
static <K,V,T> DistributedStream<T>	DistributedStream.fromMap(IMapJet<K,V> map, Predicate<K,V> predicate, DistributedFunction<Map.Entry<K,V>,T> projectionFn) Returns a DistributedStream with this map as its source.
static <T> DistributedStream<T>	DistributedStream.fromSource(JetInstance instance, BatchSource<T> source, boolean isOrdered) Returns a distributed Stream with the given BatchSource as the source.
DistributedStream<T>	DistributedStream.limit(long maxSize)
default <R> DistributedStream<R>	DistributedStream.map(DistributedFunction<? super T,? extends R> mapper) Serializable variant of java.util.stream.Stream#map(Function).
<R> DistributedStream<R>	DistributedStream.map(Function<? super T,? extends R> mapper)
default <U> DistributedStream<U>	DistributedDoubleStream.mapToObj(DistributedDoubleFunction<? extends U> mapper) Serializable variant of java.util.stream.DoubleStream#mapToObj(DoubleFunction).
default <U> DistributedStream<U>	DistributedIntStream.mapToObj(DistributedIntFunction<? extends U> mapper) Serializable variant of java.util.stream.IntStream#mapToObj(IntFunction).
default <U> DistributedStream<U>	DistributedLongStream.mapToObj(DistributedLongFunction<? extends U> mapper) Serializable variant of java.util.stream.LongStream#mapToObj(LongFunction).
<U> DistributedStream<U>	DistributedDoubleStream.mapToObj(DoubleFunction<? extends U> mapper)
<U> DistributedStream<U>	DistributedIntStream.mapToObj(IntFunction<? extends U> mapper)
<U> DistributedStream<U>	DistributedLongStream.mapToObj(LongFunction<? extends U> mapper)
DistributedStream<T>	DistributedStream.parallel()
DistributedStream<T>	DistributedStream.peek(Consumer<? super T> action)
default DistributedStream<T>	DistributedStream.peek(DistributedConsumer<? super T> action) Serializable variant of java.util.stream.Stream#peek(Consumer).
DistributedStream<T>	DistributedStream.sequential()
DistributedStream<T>	DistributedStream.skip(long n)
DistributedStream<T>	DistributedStream.sorted()
DistributedStream<T>	DistributedStream.sorted(Comparator<? super T> comparator)
default DistributedStream<T>	DistributedStream.sorted(DistributedComparator<? super T> comparator) Serializable variant of java.util.stream.Stream#sorted(Comparator).
DistributedStream<T>	DistributedStream.unordered()