Uses of Interface
com.hazelcast.jet.Traverser
Package
Description
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Contains
AggregateOperation
and its several variants, as well
as a builder object for the aggregate operations.Jet's Core API.
Contains static utility classes with factories of Jet processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of Traverser in com.hazelcast.jet
Modifier and TypeMethodDescriptionReturns a traverser that will return all the items of this traverser, plus an additional item once this one returnsnull
.Returns a traverser that will emit a suffix of the original traverser, starting from the item for which the predicate fails (inclusive).static <T> Traverser<T>
Traversers.empty()
Returns a traverser that always returnsnull
.Returns a traverser that will emit the same items as this traverser, but only those that pass the given predicate.default <R> Traverser<R>
Returns a traverser that will apply the given mapping function to each item retrieved from this traverser and emit all the items from the resulting traversers, which must be null-terminated.static <T> Traverser<T>
Flattens a supplier of traverser into a lazy-initialized traverser.default <R> Traverser<R>
Returns a traverser that will emit the results of applyingmapFn
to this traverser's items.Traverser.onFirstNull
(Runnable action) Returns a traverser that will emit the same items as this traverser and additionally run the supplied action the first time this traverser returnsnull
.Returns a traverser that will emit the same items as this traverser, additionally passing each (non-null) item to the supplied consumer.Returns a traverser which prepends an additional item in front of all the items of this traverser.static <T> Traverser<T>
Traversers.singleton
(T item) Returns a traverser over the given single item.Returns a traverser that will emit a prefix of the original traverser, up to the item for which the predicate fails (exclusive).static <T> Traverser<T>
Traversers.traverseArray
(T[] array) Returns a traverser over the given array.static <T> Traverser<T>
Traversers.traverseEnumeration
(Enumeration<T> enumeration) Returns an adapter fromEnumeration
toTraverser
.static <T> Traverser<T>
Traversers.traverseItems
(T... items) Returns a traverser over the supplied arguments (or item array).static <T> Traverser<T>
Traversers.traverseIterable
(Iterable<? extends T> iterable) Returns a traverser over the given iterable.static <T> Traverser<T>
Traversers.traverseIterator
(Iterator<? extends T> iterator) Returns an adapter fromIterator
toTraverser
.static <T> Traverser<T>
Traversers.traverseIterator
(Iterator<? extends T> iterator, boolean ignoreNulls) Returns an adapter fromIterator
toTraverser
.static <T> Traverser<T>
Traversers.traverseSpliterator
(Spliterator<T> spliterator) Returns an adapter fromSpliterator
toTraverser
.static <T> Traverser<T>
Traversers.traverseStream
(Stream<T> stream) Returns a traverser over the given stream.Modifier and TypeMethodDescriptiondefault <R> Traverser<R>
Returns a traverser that will apply the given mapping function to each item retrieved from this traverser and emit all the items from the resulting traversers, which must be null-terminated.static <T> Traverser<T>
Flattens a supplier of traverser into a lazy-initialized traverser. -
Uses of Traverser in com.hazelcast.jet.aggregate
Modifier and TypeMethodDescriptionstatic <T,
U, A, R> AggregateOperation1<T, A, R> AggregateOperations.flatMapping
(FunctionEx<? super T, ? extends Traverser<? extends U>> flatMapFn, AggregateOperation1<? super U, A, ? extends R> downstream) Adapts an aggregate operation that takes items of typeU
to one that takes items of typeT
, by exploding eachT
into a sequence ofU
s and then accumulating all of them. -
Uses of Traverser in com.hazelcast.jet.core
Modifier and TypeClassDescriptionclass
A traverser with an internalArrayDeque
.class
Traverses over a single item which can be set from the outside, by using this traverser as aConsumer<T>
.Modifier and TypeMethodDescriptionEventTimeMapper.flatMapEvent
(long now, T event, int partitionIndex, long nativeEventTime) A lower-level variant offlatMapEvent(T, int, long)
that accepts an explicit result of aSystem.nanoTime()
call.EventTimeMapper.flatMapEvent
(T event, int partitionIndex, long nativeEventTime) Flat-maps the givenevent
by (possibly) prepending it with a watermark.EventTimeMapper.flatMapIdle()
Call this method when there is no event to emit.EventTimeMapper.removePartition
(int partitionIndex) Removes a partition that will no longer have events.Modifier and TypeMethodDescriptionprotected final <E> boolean
AbstractProcessor.emitFromTraverser
(int[] ordinals, Traverser<E> traverser) Obtains items from the traverser and offers them to the outbox's buckets identified in the supplied array.protected final <E> boolean
AbstractProcessor.emitFromTraverser
(int ordinal, Traverser<E> traverser) Obtains items from the traverser and offers them to the outbox's buckets identified in the supplied array.protected final boolean
AbstractProcessor.emitFromTraverser
(Traverser<?> traverser) Convenience forAbstractProcessor.emitFromTraverser(int, Traverser)
which emits to all ordinals.protected final <T extends Map.Entry<?,
?>>
booleanAbstractProcessor.emitFromTraverserToSnapshot
(Traverser<T> traverser) Obtains items from the traverser and offers them to the snapshot bucket of the outbox.Modifier and TypeMethodDescriptionprotected final <T,
R> AbstractProcessor.FlatMapper<T, R> AbstractProcessor.flatMapper
(int[] ordinals, Function<? super T, ? extends Traverser<? extends R>> mapper) Factory ofAbstractProcessor.FlatMapper
.protected final <T,
R> AbstractProcessor.FlatMapper<T, R> AbstractProcessor.flatMapper
(int ordinal, Function<? super T, ? extends Traverser<? extends R>> mapper) Factory ofAbstractProcessor.FlatMapper
.protected final <T,
R> AbstractProcessor.FlatMapper<T, R> AbstractProcessor.flatMapper
(Function<? super T, ? extends Traverser<? extends R>> mapper) Factory ofAbstractProcessor.FlatMapper
. -
Uses of Traverser in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <T,
R> SupplierEx<Processor> Processors.flatMapP
(FunctionEx<? super T, ? extends Traverser<? extends R>> flatMapFn) Returns a supplier of processors for a vertex that applies the provided item-to-traverser mapping function to each received item and emits all the items from the resulting traverser.static <T,
K, S, R> SupplierEx<Processor> Processors.flatMapStatefulP
(long ttl, FunctionEx<? super T, ? extends K> keyFn, ToLongFunctionEx<? super T> timestampFn, Supplier<? extends S> createFn, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> statefulFlatMapFn, TriFunction<? super S, ? super K, ? super Long, ? extends Traverser<R>> onEvictFn) Returns a supplier of processors for a vertex that performs a stateful flat-mapping of its input.static <C,
S, T, R> ProcessorSupplier Processors.flatMapUsingServiceP
(ServiceFactory<C, S> serviceFactory, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) Returns a supplier of processors for a vertex that applies the provided item-to-traverser mapping function to each received item and emits all the items from the resulting traverser. -
Uses of Traverser in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescription<R> BatchStage<R>
BatchStage.flatMap
(FunctionEx<? super T, ? extends Traverser<R>> flatMapFn) <R> GeneralStage<R>
GeneralStage.flatMap
(FunctionEx<? super T, ? extends Traverser<R>> flatMapFn) Attaches a flat-mapping stage which applies the supplied function to each input item independently and emits all the items from theTraverser
it returns.<R> StreamStage<R>
StreamStage.flatMap
(FunctionEx<? super T, ? extends Traverser<R>> flatMapFn) <S,
R> BatchStage<R> BatchStage.flatMapStateful
(SupplierEx<? extends S> createFn, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> BatchStage<R> BatchStageWithKey.flatMapStateful
(SupplierEx<? extends S> createFn, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> GeneralStage<R> GeneralStage.flatMapStateful
(SupplierEx<? extends S> createFn, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) Attaches a stage that performs a stateful flat-mapping operation.<S,
R> GeneralStage<R> GeneralStageWithKey.flatMapStateful
(SupplierEx<? extends S> createFn, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn) Attaches a stage that performs a stateful flat-mapping operation.<S,
R> StreamStage<R> StreamStage.flatMapStateful
(SupplierEx<? extends S> createFn, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> StreamStage<R> StreamStageWithKey.flatMapStateful
(long ttl, SupplierEx<? extends S> createFn, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn, TriFunction<? super S, ? super K, ? super Long, ? extends Traverser<R>> onEvictFn) Attaches a stage that performs a stateful flat-mapping operation.<S,
R> StreamStage<R> StreamStageWithKey.flatMapStateful
(SupplierEx<? extends S> createFn, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> BatchStage<R> BatchStage.flatMapUsingService
(ServiceFactory<?, S> serviceFactory, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> BatchStage<R> BatchStageWithKey.flatMapUsingService
(ServiceFactory<?, S> serviceFactory, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> GeneralStage<R> GeneralStage.flatMapUsingService
(ServiceFactory<?, S> serviceFactory, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) Attaches a flat-mapping stage which applies the supplied function to each input item independently and emits all items from theTraverser
it returns as the output items.<S,
R> GeneralStage<R> GeneralStageWithKey.flatMapUsingService
(ServiceFactory<?, S> serviceFactory, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn) Deprecated.<S,
R> StreamStage<R> StreamStage.flatMapUsingService
(ServiceFactory<?, S> serviceFactory, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn) <S,
R> StreamStage<R> StreamStageWithKey.flatMapUsingService
(ServiceFactory<?, S> serviceFactory, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn)
GeneralStage.rebalance()
andGeneralStage.rebalance(FunctionEx)
.