Uses of Interface
com.hazelcast.jet.Traverser
Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of Traverser in com.hazelcast.jet
Methods in com.hazelcast.jet that return Traverser Modifier and Type Method Description default Traverser<T>
Traverser. append(T item)
Returns a traverser that will return all the items of this traverser, plus an additional item once this one returnsnull
.default Traverser<T>
Traverser. dropWhile(Predicate<? super T> predicate)
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
.default Traverser<T>
Traverser. filter(Predicate<? super T> filterFn)
Returns a traverser that will emit the same items as this traverser, but only those that pass the given predicate.default <R> Traverser<R>
Traverser. flatMap(Function<? super T,? extends Traverser<R>> flatMapFn)
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>
Traversers. lazy(Supplier<Traverser<T>> supplierOfTraverser)
Flattens a supplier of traverser into a lazy-initialized traverser.default <R> Traverser<R>
Traverser. map(Function<? super T,? extends R> mapFn)
Returns a traverser that will emit the results of applyingmapFn
to this traverser's items.default Traverser<T>
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
.default Traverser<T>
Traverser. peek(Consumer<? super T> action)
Returns a traverser that will emit the same items as this traverser, additionally passing each (non-null) item to the supplied consumer.default Traverser<T>
Traverser. prepend(T item)
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.default Traverser<T>
Traverser. takeWhile(Predicate<? super T> predicate)
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.Method parameters in com.hazelcast.jet with type arguments of type Traverser Modifier and Type Method Description default <R> Traverser<R>
Traverser. flatMap(Function<? super T,? extends Traverser<R>> flatMapFn)
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>
Traversers. lazy(Supplier<Traverser<T>> supplierOfTraverser)
Flattens a supplier of traverser into a lazy-initialized traverser. -
Uses of Traverser in com.hazelcast.jet.aggregate
Method parameters in com.hazelcast.jet.aggregate with type arguments of type Traverser Modifier and Type Method Description static <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
Classes in com.hazelcast.jet.core that implement Traverser Modifier and Type Class Description class
AppendableTraverser<T>
A traverser with an internalArrayDeque
.class
ResettableSingletonTraverser<T>
Traverses over a single item which can be set from the outside, by using this traverser as aConsumer<T>
.Methods in com.hazelcast.jet.core that return Traverser Modifier and Type Method Description Traverser<Object>
EventTimeMapper. flatMapEvent(T event, int partitionIndex, long nativeEventTime)
Flat-maps the givenevent
by (possibly) prepending it with a watermark.Traverser<Object>
EventTimeMapper. flatMapIdle()
Call this method when there is no event coming.Traverser<Object>
EventTimeMapper. removePartition(int partitionIndex)
Removes a partition that will no longer have events.Methods in com.hazelcast.jet.core with parameters of type Traverser Modifier and Type Method Description protected <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 <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 boolean
AbstractProcessor. emitFromTraverser(Traverser<?> traverser)
Convenience forAbstractProcessor.emitFromTraverser(int, Traverser)
which emits to all ordinals.protected <T extends Map.Entry<?, ?>>
booleanAbstractProcessor. emitFromTraverserToSnapshot(Traverser<T> traverser)
Obtains items from the traverser and offers them to the snapshot bucket of the outbox.Method parameters in com.hazelcast.jet.core with type arguments of type Traverser Modifier and Type Method Description protected <T, R> AbstractProcessor.FlatMapper<T,R>
AbstractProcessor. flatMapper(int[] ordinals, Function<? super T,? extends Traverser<? extends R>> mapper)
Factory ofAbstractProcessor.FlatMapper
.protected <T, R> AbstractProcessor.FlatMapper<T,R>
AbstractProcessor. flatMapper(int ordinal, Function<? super T,? extends Traverser<? extends R>> mapper)
Factory ofAbstractProcessor.FlatMapper
.protected <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
Method parameters in com.hazelcast.jet.core.processor with type arguments of type Traverser Modifier and Type Method Description static <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
Method parameters in com.hazelcast.jet.pipeline with type arguments of type Traverser Modifier and Type Method Description <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)
Attaches a flat-mapping stage which applies the supplied function to each input item independently and emits all the items from theTraverser
it returns as the output items.<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)