Package | Description |
---|---|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
DistributedStream<Integer> |
DistributedIntStream.boxed()
Returns a
Stream consisting of the elements of this stream,
each boxed to an Integer . |
DistributedStream<Long> |
DistributedLongStream.boxed()
Returns a
Stream consisting of the elements of this stream,
each boxed to a Long . |
DistributedStream<Double> |
DistributedDoubleStream.boxed()
Returns a
DistributedStream consisting of the elements of this stream,
boxed to Double . |
DistributedStream<T> |
DistributedStream.configure(JobConfig jobConfig) |
DistributedStream<T> |
DistributedStream.distinct() |
default DistributedStream<T> |
DistributedStream.filter(DistributedPredicate<? super T> predicate)
Returns a stream consisting of the elements of this stream that match
the given predicate.
|
DistributedStream<T> |
DistributedStream.filter(java.util.function.Predicate<? super T> predicate) |
default <R> DistributedStream<R> |
DistributedStream.flatMap(DistributedFunction<? super T,? extends java.util.stream.Stream<? extends R>> mapper)
Returns a stream consisting of the results of replacing each element of
this stream with the contents of a mapped stream produced by applying
the provided mapping function to each element.
|
<R> DistributedStream<R> |
DistributedStream.flatMap(java.util.function.Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper) |
static <T> DistributedStream<T> |
DistributedStream.fromSource(JetInstance instance,
ProcessorMetaSupplier metaSupplier)
Returns a distributed
Stream with given processors as its source. |
DistributedStream<T> |
DistributedStream.limit(long maxSize) |
default <R> DistributedStream<R> |
DistributedStream.map(DistributedFunction<? super T,? extends R> mapper)
Returns a stream consisting of the results of applying the given
function to the elements of this stream.
|
<R> DistributedStream<R> |
DistributedStream.map(java.util.function.Function<? super T,? extends R> mapper) |
default <U> DistributedStream<U> |
DistributedDoubleStream.mapToObj(DistributedDoubleFunction<? extends U> mapper)
Returns an object-valued
Stream consisting of the results of
applying the given function to the elements of this stream. |
default <U> DistributedStream<U> |
DistributedIntStream.mapToObj(DistributedIntFunction<? extends U> mapper)
Returns an object-valued
DistributedStream consisting of the results of
applying the given function to the elements of this stream. |
default <U> DistributedStream<U> |
DistributedLongStream.mapToObj(DistributedLongFunction<? extends U> mapper)
Returns an object-valued
Stream consisting of the results of
applying the given function to the elements of this stream. |
<U> DistributedStream<U> |
DistributedDoubleStream.mapToObj(java.util.function.DoubleFunction<? extends U> mapper) |
<U> DistributedStream<U> |
DistributedIntStream.mapToObj(java.util.function.IntFunction<? extends U> mapper) |
<U> DistributedStream<U> |
DistributedLongStream.mapToObj(java.util.function.LongFunction<? extends U> mapper) |
DistributedStream<T> |
DistributedStream.parallel() |
DistributedStream<E> |
IStreamList.parallelStream()
Returns a parallel
Stream with this list as its source. |
DistributedStream<T> |
DistributedStream.peek(java.util.function.Consumer<? super T> action) |
default DistributedStream<T> |
DistributedStream.peek(DistributedConsumer<? super T> action)
Returns a stream consisting of the elements of this stream, additionally
performing the provided action on each element as elements are consumed
from the resulting stream.
|
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)
Returns a stream consisting of the elements of this stream, sorted
according to the provided
Comparator . |
DistributedStream<Map.Entry<K,V>> |
IStreamMap.stream()
Returns a parallel and distributed
Stream with this map as its source. |
DistributedStream<Map.Entry<K,V>> |
IStreamCache.stream()
Returns a parallel and distributed
Stream with this list as its source. |
DistributedStream<E> |
IStreamList.stream()
Returns a sequential
Stream with this list as its source. |
<T> DistributedStream<T> |
IStreamMap.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. |
DistributedStream<T> |
DistributedStream.unordered() |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.