A B C D E F G H I J K L M N O P Q R S T U V W

A

AbstractProcessor - Class in com.hazelcast.jet.core

Base class to implement custom processors.

AbstractProcessor() - Constructor for class com.hazelcast.jet.core.AbstractProcessor

AbstractProcessor.FlatMapper<T,R> - Class in com.hazelcast.jet.core

A helper that simplifies the implementation of tryProcess(ordinal, item) for emitting collections.

accept(T) - Method in class com.hazelcast.jet.core.ResettableSingletonTraverser

Resets this traverser so that the following next() call will return the item supplied here.

accumulate(long, long) - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator

Accumulates a new sample.

accumulateByFrameP(DistributedFunction<? super T, K>, DistributedToLongFunction<? super T>, TimestampKind, WindowDefinition, AggregateOperation1<? super T, A, ?>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for the first-stage vertex in a two-stage sliding window aggregation setup (see the class Javadoc for an explanation of aggregation stages).

accumulateByKeyP(DistributedFunction<? super T, K>, AggregateOperation1<? super T, A, ?>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for the first-stage vertex in a two-stage group-and-aggregate setup.

accumulateFn(Tag<T>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation

A primitive that updates the accumulator state to account for a new item.

accumulateFn(int) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation

A primitive that updates the accumulator state to account for a new item.

accumulateFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation1

A primitive that updates the accumulator state to account for a new item.

accumulateFn0() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation2

A primitive that updates the accumulator state to account for a new item coming from stream-0.

accumulateFn0() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3

A primitive that updates the accumulator state to account for a new item coming from stream-0.

accumulateFn1() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation2

A primitive that updates the accumulator state to account for a new item coming from stream-1.

accumulateFn1() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3

A primitive that updates the accumulator state to account for a new item coming from stream-1.

accumulateFn2() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3

A primitive that updates the accumulator state to account for a new item coming from stream-2.

accumulateP(AggregateOperation1<T, A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that performs the provided aggregate operation on all the items it receives.

accumulator() - Method in interface com.hazelcast.jet.stream.DistributedCollector

A function that folds a value into a mutable result container.

add(double) - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator

Adds the value of to this objects' value.

add(DoubleAccumulator) - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator

Adds the value of the supplied accumulator to this one.

add(long) - Method in class com.hazelcast.jet.accumulator.LongAccumulator

Adds the supplied value to this accumulator.

add(LongAccumulator) - Method in class com.hazelcast.jet.accumulator.LongAccumulator

Adds the value of the supplied accumulator to this accumulator.

add(ComputeStage<E>, DistributedFunction<? super E, K>) - Method in class com.hazelcast.jet.CoGroupBuilder

Adds another contributing pipeline stage to the co-grouping operation.

add(ComputeStage<E1_IN>, JoinClause<K, E0, E1_IN, E1>) - Method in class com.hazelcast.jet.HashJoinBuilder

Adds another contributing pipeline stage to the hash-join operation.

addClass(Class...) - Method in class com.hazelcast.jet.config.JobConfig

Adds the supplied classes to the list of resources that will be available on the job's classpath while it's executing in the Jet cluster.

addExact(long) - Method in class com.hazelcast.jet.accumulator.LongAccumulator

Uses Math.addExact() to add the supplied value to this accumulator.

addExact(LongAccumulator) - Method in class com.hazelcast.jet.accumulator.LongAccumulator

Uses Math.addExact() to add the value of the supplied accumulator into this one.

addJar(URL) - Method in class com.hazelcast.jet.config.JobConfig

Adds the JAR identified by the supplied URL to the list of JARs that will be a part of the job's classpath while it's executing in the Jet cluster.

addJar(File) - Method in class com.hazelcast.jet.config.JobConfig

Adds the supplied JAR file to the list of JARs that will be a part of the job's classpath while it's executing in the Jet cluster.

addJar(String) - Method in class com.hazelcast.jet.config.JobConfig

Adds the JAR identified by the supplied pathname to the list of JARs that will be a part of the job's classpath while it's executing in the Jet cluster.

addResource(URL) - Method in class com.hazelcast.jet.config.JobConfig

Adds the resource identified by the supplied URL to the list of resources that will be on the job's classpath while it's executing in the Jet cluster.

addResource(URL, String) - Method in class com.hazelcast.jet.config.JobConfig

Adds the resource identified by the supplied URL to the list of resources that will be on the job's classpath while it's executing in the Jet cluster.

addResource(File) - Method in class com.hazelcast.jet.config.JobConfig

Adds the supplied file to the list of resources that will be on the job's classpath while it's executing in the Jet cluster.

addResource(File, String) - Method in class com.hazelcast.jet.config.JobConfig

Adds the supplied file to the list of resources that will be on the job's classpath while it's executing in the Jet cluster.

addResource(String) - Method in class com.hazelcast.jet.config.JobConfig

Adds the resource identified by the supplied pathname to the list of resources that will be on the job's classpath while it's executing in the Jet cluster.

addResource(String, String) - Method in class com.hazelcast.jet.config.JobConfig

Adds the resource identified by the supplied pathname to the list of resources that will be on the job's classpath while it's executing in the Jet cluster.

aggregateByKeyP(DistributedFunction<? super T, K>, AggregateOperation1<? super T, A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that groups items by key and performs the provided aggregate operation on each group.

AggregateOperation<A,R> - Interface in com.hazelcast.jet.aggregate

Contains primitives needed to compute an aggregated result of stream processing.

AggregateOperation1<T,A,R> - Interface in com.hazelcast.jet.aggregate

Specialization of AggregateOperation to the "arity-1" case with a single data stream being aggregated over.

AggregateOperation2<T0,T1,A,R> - Interface in com.hazelcast.jet.aggregate

Specialization of AggregateOperation to the "arity-2" case with two data stream being aggregated over.

AggregateOperation3<T0,T1,T2,A,R> - Interface in com.hazelcast.jet.aggregate

Specialization of AggregateOperation to the "arity-3" case with two data stream being aggregated over.

AggregateOperationBuilder<A> - Class in com.hazelcast.jet.aggregate

A builder object that can be used to construct the definition of an aggregate operation in a step-by-step manner.

AggregateOperationBuilder.Arity1<T0,A> - Class in com.hazelcast.jet.aggregate

The arity-1 variant of the aggregate operation builder.

AggregateOperationBuilder.Arity2<T0,T1,A> - Class in com.hazelcast.jet.aggregate

The arity-2 variant of the aggregate operation builder.

AggregateOperationBuilder.Arity3<T0,T1,T2,A> - Class in com.hazelcast.jet.aggregate

The arity-3 variant of the aggregate operation builder.

AggregateOperationBuilder.VarArity<A> - Class in com.hazelcast.jet.aggregate

The variable-arity variant of the aggregate operation builder.

AggregateOperations - Class in com.hazelcast.jet.aggregate

Utility class with factory methods for several useful windowing operations.

aggregateP(AggregateOperation1<T, A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that performs the provided aggregate operation on all the items it receives.

aggregateToSessionWindowP(long, DistributedToLongFunction<? super T>, DistributedFunction<? super T, K>, AggregateOperation1<? super T, A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that aggregates events into session windows.

aggregateToSlidingWindowP(DistributedFunction<? super T, K>, DistributedToLongFunction<? super T>, TimestampKind, WindowDefinition, AggregateOperation1<? super T, A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that aggregates events into a sliding window in a single stage (see the class Javadoc for an explanation of aggregation stages).

allMatch(DistributedDoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns whether all elements of this stream match the provided predicate.

allMatch(DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

allMatch(DistributedIntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns whether all elements of this stream match the provided predicate.

allMatch(IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

allMatch(DistributedLongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns whether all elements of this stream match the provided predicate.

allMatch(LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

allMatch(DistributedPredicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns whether all elements of this stream match the provided predicate.

allMatch(Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

allOf(AggregateOperation1<? super T, ?, ?>...) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation, that calculates multiple aggregations and returns their value in List<Object>.

allToOne() - Method in class com.hazelcast.jet.core.Edge

Activates a special-cased PARTITIONED routing policy where all items will be assigned the same, randomly chosen partition ID.

alwaysFalse() - Static method in class com.hazelcast.jet.function.DistributedFunctions

Return sa predicate that always evaluates to false.

alwaysTrue() - Static method in class com.hazelcast.jet.function.DistributedFunctions

Returns a predicate that always evaluates to true.

and(DistributedBiPredicate<? super T, ? super U>) - Method in interface com.hazelcast.jet.function.DistributedBiPredicate

Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.

and(DistributedDoublePredicate) - Method in interface com.hazelcast.jet.function.DistributedDoublePredicate

Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.

and(DistributedIntPredicate) - Method in interface com.hazelcast.jet.function.DistributedIntPredicate

Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.

and(DistributedLongPredicate) - Method in interface com.hazelcast.jet.function.DistributedLongPredicate

Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.

and(DistributedPredicate<? super T>) - Method in interface com.hazelcast.jet.function.DistributedPredicate

Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.

andAccumulate(DistributedBiConsumer<? super A, T>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder

Registers the supplied accumulate primitive.

andAccumulate(Tag<T>, DistributedBiConsumer<? super A, T>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder

Registers the supplied accumulate primitive for the stream tagged with the supplied tag.

andAccumulate(Tag<T>, DistributedBiConsumer<? super A, T>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity

Registers the supplied accumulate primitive for the stream tagged with the supplied tag.

andAccumulate0(DistributedBiConsumer<? super A, T0>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder

Registers the supplied accumulate primitive for stream-0.

andAccumulate1(DistributedBiConsumer<? super A, T1>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1

Registers the supplied accumulate primitive for stream-1, returning the arity-2 variant of the builder.

andAccumulate2(DistributedBiConsumer<? super A, T2>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2

Registers the supplied accumulate primitive for stream-2, returning the arity-3 variant of the builder.

andCombine(DistributedBiConsumer<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1

Registers the combine primitive.

andCombine(DistributedBiConsumer<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2

Registers the combine primitive.

andCombine(DistributedBiConsumer<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3

Registers the combine primitive.

andCombine(DistributedBiConsumer<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity

Registers the combine primitive.

andDeduct(DistributedBiConsumer<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1

Registers the deduct primitive.

andDeduct(DistributedBiConsumer<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2

Registers the deduct primitive.

andDeduct(DistributedBiConsumer<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3

Registers the deduct primitive.

andDeduct(DistributedBiConsumer<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity

Registers the deduct primitive.

andFinish(DistributedFunction<? super A, R>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1

Constructs and returns an AggregateOperation1 from the current state of the builder and the supplied finish primitive.

andFinish(DistributedFunction<? super A, R>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2

Constructs and returns an AggregateOperation2 from the current state of the builder and the supplied finish primitive.

andFinish(DistributedFunction<? super A, R>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3

Constructs and returns an AggregateOperation3 from the current state of the builder and the supplied finish primitive.

andFinish(DistributedFunction<? super A, R>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity

Constructs and returns an AggregateOperation from the current state of the builder and the supplied finish primitive.

andIdentityFinish() - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1

Constructs and returns an AggregateOperation1 from the current state of the builder, with the identity function as the finish primitive.

andIdentityFinish() - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2

Constructs and returns an AggregateOperation2 from the current state of the builder, with the identity function as the finish primitive.

andIdentityFinish() - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3

Constructs and returns an AggregateOperation3 from the current state of the builder, with the identity function as the finish primitive.

andIdentityFinish() - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity

Constructs and returns an AggregateOperation from the current state of the builder, with the identity function as the finish primitive.

andThen(DistributedBiConsumer<? super T, ? super U>) - Method in interface com.hazelcast.jet.function.DistributedBiConsumer

Returns a composed BiConsumer that performs, in sequence, this operation followed by the after operation.

andThen(DistributedFunction<? super R, ? extends V>) - Method in interface com.hazelcast.jet.function.DistributedBiFunction

Returns a composed function that first applies this function to its input, and then applies the after function to the result.

andThen(DistributedConsumer<? super T>) - Method in interface com.hazelcast.jet.function.DistributedConsumer

Returns a composed Consumer that performs, in sequence, this operation followed by the after operation.

andThen(DistributedDoubleConsumer) - Method in interface com.hazelcast.jet.function.DistributedDoubleConsumer

Returns a composed DoubleConsumer that performs, in sequence, this operation followed by the after operation.

andThen(DistributedDoubleUnaryOperator) - Method in interface com.hazelcast.jet.function.DistributedDoubleUnaryOperator

Returns a composed operator that first applies this operator to its input, and then applies the after operator to the result.

andThen(DistributedFunction<? super R, ? extends V>) - Method in interface com.hazelcast.jet.function.DistributedFunction

Returns a composed function that first applies this function to its input, and then applies the after function to the result.

andThen(DistributedIntConsumer) - Method in interface com.hazelcast.jet.function.DistributedIntConsumer

Returns a composed IntConsumer that performs, in sequence, this operation followed by the after operation.

andThen(DistributedIntUnaryOperator) - Method in interface com.hazelcast.jet.function.DistributedIntUnaryOperator

Returns a composed operator that first applies this operator to its input, and then applies the after operator to the result.

andThen(DistributedLongConsumer) - Method in interface com.hazelcast.jet.function.DistributedLongConsumer

Returns a composed LongConsumer that performs, in sequence, this operation followed by the after operation.

andThen(DistributedLongUnaryOperator) - Method in interface com.hazelcast.jet.function.DistributedLongUnaryOperator

Returns a composed operator that first applies this operator to its input, and then applies the after operator to the result.

anyMatch(DistributedDoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns whether any elements of this stream match the provided predicate.

anyMatch(DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

anyMatch(DistributedIntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns whether any elements of this stream match the provided predicate.

anyMatch(IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

anyMatch(DistributedLongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns whether any elements of this stream match the provided predicate.

anyMatch(LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

anyMatch(DistributedPredicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns whether any elements of this stream match the provided predicate.

anyMatch(Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

append(T) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser that will return all the items of this traverser, plus an additional item once this one returns null.

asDoubleStream() - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a DoubleStream consisting of the elements of this stream, converted to double.

asDoubleStream() - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a DoubleStream consisting of the elements of this stream, converted to double.

asLongStream() - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a LongStream consisting of the elements of this stream, converted to long.

averagingDouble(DistributedToDoubleFunction<T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation that calculates the arithmetic mean of double values returned by the getDoubleValueFn function.

averagingDouble(DistributedToDoubleFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that produces the arithmetic mean of a double-valued function applied to the input elements.

averagingInt(DistributedToIntFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that produces the arithmetic mean of an integer-valued function applied to the input elements.

averagingLong(DistributedToLongFunction<T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation that calculates the arithmetic mean of long values returned by the getLongValueFn function.

averagingLong(DistributedToLongFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that produces the arithmetic mean of a long-valued function applied to the input elements.

B

bag(Tag<E>) - Method in class com.hazelcast.jet.datamodel.BagsByTag

Retrieves the bag associated with the supplied tag.

bag0() - Method in class com.hazelcast.jet.datamodel.ThreeBags

Retrieves the bag at index 0.

bag0() - Method in class com.hazelcast.jet.datamodel.TwoBags

Retrieves the bag at index 0.

bag1() - Method in class com.hazelcast.jet.datamodel.ThreeBags

Retrieves the bag at index 1.

bag1() - Method in class com.hazelcast.jet.datamodel.TwoBags

Retrieves the bag at index 1.

bag2() - Method in class com.hazelcast.jet.datamodel.ThreeBags

Retrieves the bag at index 2.

BagsByTag - Class in com.hazelcast.jet.datamodel

A heterogeneous map from Tag<E> to Collection<E>, where E can be different for each tag.

BagsByTag() - Constructor for class com.hazelcast.jet.datamodel.BagsByTag

bagsByTag(Object...) - Static method in class com.hazelcast.jet.datamodel.BagsByTag

Accepts an argument list of alternating tags and collections, interprets them as a list of tag-bag pairs, and returns a BagsByTag populated with these pairs.

between(Vertex, Vertex) - Static method in class com.hazelcast.jet.core.Edge

Returns an edge between two vertices.

boxed() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns a DistributedStream consisting of the elements of this stream, boxed to Double.

boxed() - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a Stream consisting of the elements of this stream, each boxed to an Integer.

boxed() - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a Stream consisting of the elements of this stream, each boxed to a Long.

broadcast() - Method in class com.hazelcast.jet.core.Edge

Activates the BROADCAST routing policy.

BroadcastKey<K> - Interface in com.hazelcast.jet.core

Marker interface for a key in the snapshot state that indicates the corresponding entry should be broadcast to all processors when restoring the snapshot.

broadcastKey(K) - Static method in interface com.hazelcast.jet.core.BroadcastKey

Returns a given key as a broadcast key.

bucketCount() - Method in interface com.hazelcast.jet.core.Outbox

Returns the number of buckets in this outbox.

bucketCount() - Method in class com.hazelcast.jet.core.test.TestOutbox

build(AggregateOperation<A, R>) - Method in class com.hazelcast.jet.CoGroupBuilder

Builds a new pipeline stage that performs the co-grouping operation.

build() - Method in class com.hazelcast.jet.HashJoinBuilder

Builds a new pipeline stage that performs the hash-join operation.

C

cache(String) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that puts Map.Entrys it receives into a Hazelcast ICache with the specified name.

cache(String) - Static method in class com.hazelcast.jet.Sources

Returns a source that fetches entries from the Hazelcast ICache with the specified name and emits them as Map.Entry.

cacheJournal(String, DistributedPredicate<EventJournalCacheEvent<K, V>>, DistributedFunction<EventJournalCacheEvent<K, V>, T>, boolean) - Static method in class com.hazelcast.jet.Sources

Returns a source that will stream the EventJournalCacheEvent events of the Hazelcast ICache with the specified name.

cacheJournal(String, boolean) - Static method in class com.hazelcast.jet.Sources

Convenience for Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, boolean) with no projection or filtering.

cancel() - Method in interface com.hazelcast.jet.Job

Attempts to cancel execution of this job.

CloseableProcessorSupplier<E extends Processor & Closeable> - Class in com.hazelcast.jet.core

A ProcessorSupplier which closes created processor instances when the job is complete.

CloseableProcessorSupplier(DistributedSupplier<E>) - Constructor for class com.hazelcast.jet.core.CloseableProcessorSupplier

CloseableProcessorSupplier(DistributedIntFunction<Collection<E>>) - Constructor for class com.hazelcast.jet.core.CloseableProcessorSupplier

coAccumulateByKeyP(List<DistributedFunction<?, ? extends K>>, AggregateOperation<A, ?>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for the first-stage vertex in a two-stage group-and-aggregate setup.

coAggregateByKeyP(List<DistributedFunction<?, ? extends K>>, AggregateOperation<A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that groups items by key and performs the provided aggregate operation on each group.

coGroup(DistributedFunction<? super E, ? extends K>, ComputeStage<E1>, DistributedFunction<? super E1, ? extends K>, AggregateOperation2<? super E, ? super E1, A, R>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this and the supplied stage a stage that co-groups their items by a common key and applies the supplied aggregate operation to co-grouped items.

coGroup(DistributedFunction<? super E, ? extends K>, ComputeStage<E1>, DistributedFunction<? super E1, ? extends K>, ComputeStage<E2>, DistributedFunction<? super E2, ? extends K>, AggregateOperation3<? super E, ? super E1, ? super E2, A, R>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this and the supplied stages a stage that co-groups their items by a common key and applies the supplied aggregate operation to co-grouped items.

CoGroupBuilder<K,E0> - Class in com.hazelcast.jet

Offers a step-by-step fluent API to build a co-grouping pipeline stage by adding any number of contributing stages.

coGroupBuilder(DistributedFunction<? super E, K>) - Method in interface com.hazelcast.jet.ComputeStage

Returns a fluent API builder object to construct a co-group operation with any number of contributing stages.

collect(DistributedSupplier<R>, DistributedObjDoubleConsumer<R>, DistributedBiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Performs a mutable reduction operation on the elements of this stream.

collect(Supplier<R>, ObjDoubleConsumer<R>, BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

collect(DistributedSupplier<R>, DistributedObjIntConsumer<R>, DistributedBiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Performs a mutable reduction operation on the elements of this stream.

collect(Supplier<R>, ObjIntConsumer<R>, BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

collect(DistributedSupplier<R>, DistributedObjLongConsumer<R>, DistributedBiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Performs a mutable reduction operation on the elements of this stream.

collect(Supplier<R>, ObjLongConsumer<R>, BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

collect(DistributedSupplier<R>, DistributedBiConsumer<R, ? super T>, DistributedBiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Performs a mutable reduction operation on the elements of this stream.

collect(DistributedCollector<? super T, A, R>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Performs a mutable reduction operation on the elements of this stream using a DistributedCollector.

collect(DistributedCollector.Reducer<? super T, R>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Terminate the stream using a reduction performed by DistributedCollector.Reducer and return the resulting value.

collect(Supplier<R>, BiConsumer<R, ? super T>, BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedStream

collectingAndThen(DistributedCollector<T, A, R>, DistributedFunction<R, RR>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Adapts a DistributedCollector to perform an additional finishing transformation.

com.hazelcast.jet - package com.hazelcast.jet

The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

com.hazelcast.jet.accumulator - package com.hazelcast.jet.accumulator

Classes intended to be used for accumulator objects in Jet aggregation operations.

com.hazelcast.jet.aggregate - package com.hazelcast.jet.aggregate

Contains AggregateOperation and several its variants, as well as a builder object for the aggregate operations.

com.hazelcast.jet.config - package com.hazelcast.jet.config

Jet's configuration data objects.

com.hazelcast.jet.core - package com.hazelcast.jet.core

Jet's Core API.

com.hazelcast.jet.core.processor - package com.hazelcast.jet.core.processor

Apache Kafka reader/writer support for Hazelcast Jet.

com.hazelcast.jet.core.test - package com.hazelcast.jet.core.test

Utilities for writing tests of Core API Processors.

com.hazelcast.jet.datamodel - package com.hazelcast.jet.datamodel

Generic data containers used by the Pipeline API.

com.hazelcast.jet.function - package com.hazelcast.jet.function

Serializable variants of functional interfaces from java.util.function.

com.hazelcast.jet.server - package com.hazelcast.jet.server

Contains Java program entry points that will start a Jet server instance, submit jobs to a Jet cluster, etc.

com.hazelcast.jet.stream - package com.hazelcast.jet.stream

java.util.stream implementation using Hazelcast Jet

combine(LinTrendAccumulator) - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator

Combines this accumulator with the supplied one.

combineByKeyP(AggregateOperation<A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for the second-stage vertex in a two-stage group-and-aggregate setup.

combineFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation

A primitive that accepts two accumulators and updates the state of the left-hand one by combining it with the state of the right-hand one.

combineP(AggregateOperation1<T, A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that performs the provided aggregate operation on all the items it receives.

combiner() - Method in interface com.hazelcast.jet.stream.DistributedCollector

A function that accepts two partial results and merges them.

combineToSlidingWindowP(WindowDefinition, AggregateOperation1<?, A, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for the second-stage vertex in a two-stage sliding window aggregation setup (see the class Javadoc for an explanation of aggregation stages).

combineWith(BagsByTag) - Method in class com.hazelcast.jet.datamodel.BagsByTag

Merges the contents of the supplied bag container into this one.

combineWith(ThreeBags<E0, E1, E2>) - Method in class com.hazelcast.jet.datamodel.ThreeBags

Combines this and the supplied container by merging all the supplied container's data into this one.

combineWith(TwoBags<E0, E1>) - Method in class com.hazelcast.jet.datamodel.TwoBags

Combines this and the supplied container by merging all the supplied container's data into this one.

compareTo(Tag<?>) - Method in class com.hazelcast.jet.datamodel.Tag

comparing(Function<? super T, ? extends U>, Comparator<? super U>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparing(DistributedFunction<? super T, ? extends U>, DistributedComparator<? super U>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparing(Function<? super T, ? extends U>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparing(DistributedFunction<? super T, ? extends U>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparingDouble(ToDoubleFunction<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparingDouble(DistributedToDoubleFunction<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparingInt(ToIntFunction<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparingInt(DistributedToIntFunction<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparingLong(ToLongFunction<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

comparingLong(DistributedToLongFunction<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

complete(Throwable) - Method in class com.hazelcast.jet.core.CloseableProcessorSupplier

complete() - Method in interface com.hazelcast.jet.core.Processor

Called after all the inbound edges' streams are exhausted.

complete(Throwable) - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Called on coordinator member after execution has finished on all members, successfully or not.

complete(Throwable) - Method in interface com.hazelcast.jet.core.ProcessorSupplier

Called after the execution has finished on all members, successfully or not, or immediately, when the execution was aborted due to a member leaving the cluster.

completeEdge(int) - Method in interface com.hazelcast.jet.core.Processor

Called after the edge input with the supplied ordinal is exhausted.

compose(DistributedDoubleUnaryOperator) - Method in interface com.hazelcast.jet.function.DistributedDoubleUnaryOperator

Returns a composed operator that first applies the before operator to its input, and then applies this operator to the result.

compose(DistributedFunction<? super V, ? extends T>) - Method in interface com.hazelcast.jet.function.DistributedFunction

Returns a composed function that first applies the before function to its input, and then applies this function to the result.

compose(DistributedIntUnaryOperator) - Method in interface com.hazelcast.jet.function.DistributedIntUnaryOperator

Returns a composed operator that first applies the before operator to its input, and then applies this operator to the result.

compose(DistributedLongUnaryOperator) - Method in interface com.hazelcast.jet.function.DistributedLongUnaryOperator

Returns a composed operator that first applies the before operator to its input, and then applies this operator to the result.

ComputeStage<E> - Interface in com.hazelcast.jet

Represents a stage in a distributed computation pipeline.

configure(JobConfig) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

configure(JobConfig) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

configure(JobConfig) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

configure(JobConfig) - Method in interface com.hazelcast.jet.stream.DistributedStream

CONSTANT_KEY - Static variable in class com.hazelcast.jet.function.DistributedFunctions

The string key returned by DistributedFunctions.constantKey().

constantKey() - Static method in class com.hazelcast.jet.function.DistributedFunctions

Returns a function that always evaluates to the DistributedFunctions.CONSTANT_KEY.

cooperativeTimeout(long) - Method in class com.hazelcast.jet.core.test.TestSupport

If timeout > 0, the test will fail if any call to processing method in a cooperative processor exceeds this timeout.

copyTo(byte[], int) - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

counting() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation that tracks the count of items in the window.

counting() - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector accepting elements of type T that counts the number of input elements.

create() - Static method in interface com.hazelcast.jet.Pipeline

Creates a new, empty pipeline.

createFactory() - Method in class com.hazelcast.jet.core.JetDataSerializerHook

createFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation

A primitive that returns a new accumulator.

customTransform(String, DistributedSupplier<Processor>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this stage a stage with a custom transform based on the provided supplier of Core API Processors.

D

DAG - Class in com.hazelcast.jet.core

Describes a computation to be performed by the Jet computation engine.

DAG() - Constructor for class com.hazelcast.jet.core.DAG

dataSize() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

deduct(LinTrendAccumulator) - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator

Deducts the supplied accumulator from this one.

deductFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation

A primitive that accepts two accumulators and updates the state of the left-hand one by deducting the state of the right-hand one from it.

DEFAULT_BACKUP_COUNT - Static variable in class com.hazelcast.jet.config.InstanceConfig

The default value of the backup-count

DEFAULT_FLOW_CONTROL_PERIOD_MS - Static variable in class com.hazelcast.jet.config.InstanceConfig

The default value of the flow-control period.

DEFAULT_JET_MULTICAST_PORT - Static variable in class com.hazelcast.jet.config.JetConfig

The default port number for the cluster auto-discovery mechanism's multicast communication.

DEFAULT_PACKET_SIZE_LIMIT - Static variable in class com.hazelcast.jet.config.EdgeConfig

The default packet size limit.

DEFAULT_QUEUE_SIZE - Static variable in class com.hazelcast.jet.config.EdgeConfig

The default size of the concurrent queues connecting processors within a cluster member.

DEFAULT_RECEIVE_WINDOW_MULTIPLIER - Static variable in class com.hazelcast.jet.config.EdgeConfig

The default receive window multiplier.

defaultPartitioner() - Static method in interface com.hazelcast.jet.core.Partitioner

Returns a partitioner which applies the default Hazelcast partitioning.

DefaultPartitionStrategy - Interface in com.hazelcast.jet.core

A facade that hides the details of Hazelcast partitioning SPI and exposes just the partitioning strategy.

DiagnosticProcessors - Class in com.hazelcast.jet.core.processor

Static utility class with factories of sinks and wrappers that log the data flowing through the DAG.

disableCompleteCall() - Method in class com.hazelcast.jet.core.test.TestSupport

Disables calling complete() method during the test.

disableLogging() - Method in class com.hazelcast.jet.core.test.TestSupport

Disables logging of input and output objects.

disableProgressAssertion() - Method in class com.hazelcast.jet.core.test.TestSupport

Disables checking of progress of processing methods (see class javadoc for information on what is "progress").

disableRunUntilCompleted(long) - Method in class com.hazelcast.jet.core.test.TestSupport

If the timeout > 0, the complete() method is called repeatedly until the timeout elapses.

disableSnapshots() - Method in class com.hazelcast.jet.core.test.TestSupport

Disable snapshot save and restore before first item and after each process() and complete() call.

distinct() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns a stream consisting of the distinct elements of this stream.

distinct() - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a stream consisting of the distinct elements of this stream.

distinct() - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a stream consisting of the distinct elements of this stream.

distinct() - Method in interface com.hazelcast.jet.stream.DistributedStream

distributed() - Method in class com.hazelcast.jet.core.Edge

Declares that the edge is distributed.

DistributedBiConsumer<T,U> - Interface in com.hazelcast.jet.function

Represents an operation that accepts two input arguments and returns no result.

DistributedBiFunction<T,U,R> - Interface in com.hazelcast.jet.function

Represents a function that accepts two arguments and produces a result.

DistributedBinaryOperator<T> - Interface in com.hazelcast.jet.function

Represents an operation upon two operands of the same type, producing a result of the same type as the operands.

DistributedBiPredicate<T,U> - Interface in com.hazelcast.jet.function

Represents a predicate (boolean-valued function) of two arguments.

DistributedBooleanSupplier - Interface in com.hazelcast.jet.function

Represents a supplier of boolean-valued results.

DistributedCollector<T,A,R> - Interface in com.hazelcast.jet.stream

A mutable reduction operation that accumulates input elements into a mutable result container, optionally transforming the accumulated result into a final representation after all input elements have been processed.

DistributedCollector.Reducer<T,R> - Interface in com.hazelcast.jet.stream

Interface for Jet specific distributed reducers which execute the terminal reduce operation over the current DistributedStream by building and executing a DAG.

DistributedCollectors - Class in com.hazelcast.jet.stream

Implementations of DistributedCollector that implement various useful reduction operations, such as accumulating elements into collections, summarizing elements according to various criteria, etc.

DistributedCollectors() - Constructor for class com.hazelcast.jet.stream.DistributedCollectors

DistributedComparator<T> - Interface in com.hazelcast.jet.function

A comparison function, which imposes a total ordering on some collection of objects.

DistributedConsumer<T> - Interface in com.hazelcast.jet.function

Represents an operation that accepts a single input argument and returns no result.

DistributedDoubleBinaryOperator - Interface in com.hazelcast.jet.function

Represents an operation upon two double-valued operands and producing a double-valued result.

DistributedDoubleConsumer - Interface in com.hazelcast.jet.function

Represents an operation that accepts a single double-valued argument and returns no result.

DistributedDoubleFunction<R> - Interface in com.hazelcast.jet.function

Represents a function that accepts a double-valued argument and produces a result.

DistributedDoublePredicate - Interface in com.hazelcast.jet.function

Represents a predicate (boolean-valued function) of one double-valued argument.

DistributedDoubleStream - Interface in com.hazelcast.jet.stream

An extension of DoubleStream that supports distributed stream operations by replacing functional interfaces with their serializable equivalents.

DistributedDoubleSupplier - Interface in com.hazelcast.jet.function

Represents a supplier of double-valued results.

DistributedDoubleToIntFunction - Interface in com.hazelcast.jet.function

Represents a function that accepts a double-valued argument and produces an int-valued result.

DistributedDoubleToLongFunction - Interface in com.hazelcast.jet.function

Represents a function that accepts a double-valued argument and produces a long-valued result.

DistributedDoubleUnaryOperator - Interface in com.hazelcast.jet.function

Represents an operation on a single double-valued operand that produces a double-valued result.

DistributedFunction<T,R> - Interface in com.hazelcast.jet.function

Represents a function that accepts one argument and produces a result.

DistributedFunctions - Class in com.hazelcast.jet.function

Factory methods for several common distributed functions.

DistributedIntBinaryOperator - Interface in com.hazelcast.jet.function

Represents an operation upon two int-valued operands and producing an int-valued result.

DistributedIntConsumer - Interface in com.hazelcast.jet.function

Represents an operation that accepts a single int-valued argument and returns no result.

DistributedIntFunction<R> - Interface in com.hazelcast.jet.function

Represents a function that accepts an int-valued argument and produces a result.

DistributedIntPredicate - Interface in com.hazelcast.jet.function

Represents a predicate (boolean-valued function) of one int-valued argument.

DistributedIntStream - Interface in com.hazelcast.jet.stream

An extension of IntStream that supports distributed stream operations by replacing functional interfaces with their serializable equivalents.

DistributedIntSupplier - Interface in com.hazelcast.jet.function

Represents a supplier of int-valued results.

DistributedIntToDoubleFunction - Interface in com.hazelcast.jet.function

Represents a function that accepts an int-valued argument and produces a double-valued result.

DistributedIntToLongFunction - Interface in com.hazelcast.jet.function

Represents a function that accepts an int-valued argument and produces a long-valued result.

DistributedIntUnaryOperator - Interface in com.hazelcast.jet.function

Represents an operation on a single int-valued operand that produces an int-valued result.

DistributedLongBinaryOperator - Interface in com.hazelcast.jet.function

Represents an operation upon two long-valued operands and producing a long-valued result.

DistributedLongConsumer - Interface in com.hazelcast.jet.function

Represents an operation that accepts a single long-valued argument and returns no result.

DistributedLongFunction<R> - Interface in com.hazelcast.jet.function

Represents a function that accepts a long-valued argument and produces a result.

DistributedLongPredicate - Interface in com.hazelcast.jet.function

Represents a predicate (boolean-valued function) of one long-valued argument.

DistributedLongStream - Interface in com.hazelcast.jet.stream

An extension of LongStream that supports distributed stream operations by replacing functional interfaces with their serializable equivalents.

DistributedLongSupplier - Interface in com.hazelcast.jet.function

Represents a supplier of long-valued results.

DistributedLongToDoubleFunction - Interface in com.hazelcast.jet.function

Represents a function that accepts a long-valued argument and produces a double-valued result.

DistributedLongToIntFunction - Interface in com.hazelcast.jet.function

Represents a function that accepts a long-valued argument and produces an int-valued result.

DistributedLongUnaryOperator - Interface in com.hazelcast.jet.function

Represents an operation on a single long-valued operand that produces a long-valued result.

DistributedObjDoubleConsumer<T> - Interface in com.hazelcast.jet.function

Represents an operation that accepts an object-valued and a double-valued argument, and returns no result.

DistributedObjIntConsumer<T> - Interface in com.hazelcast.jet.function

Represents an operation that accepts an object-valued and a int-valued argument, and returns no result.

DistributedObjLongConsumer<T> - Interface in com.hazelcast.jet.function

Represents an operation that accepts an object-valued and a long-valued argument, and returns no result.

DistributedOptional<T> - Class in com.hazelcast.jet.function

A container object which may or may not contain a non-null value.

DistributedPredicate<T> - Interface in com.hazelcast.jet.function

Represents a predicate (boolean-valued function) of one argument.

DistributedStream<T> - Interface in com.hazelcast.jet.stream

An extension of Stream that supports distributed stream operations by replacing functional interfaces with their serializable equivalents.

DistributedSupplier<T> - Interface in com.hazelcast.jet.function

Represents a supplier of results.

DistributedToDoubleBiFunction<T,U> - Interface in com.hazelcast.jet.function

Represents a function that accepts two arguments and produces a double-valued result.

DistributedToDoubleFunction<T> - Interface in com.hazelcast.jet.function

Represents a function that produces a double-valued result.

DistributedToIntBiFunction<T,U> - Interface in com.hazelcast.jet.function

Represents a function that accepts two arguments and produces an int-valued result.

DistributedToIntFunction<T> - Interface in com.hazelcast.jet.function

Represents a function that produces an int-valued result.

DistributedToLongBiFunction<T,U> - Interface in com.hazelcast.jet.function

Represents a function that accepts two arguments and produces a long-valued result.

DistributedToLongFunction<T> - Interface in com.hazelcast.jet.function

Represents a function that produces a long-valued result.

DistributedUnaryOperator<T> - Interface in com.hazelcast.jet.function

Represents an operation on a single operand that produces a result of the same type as its operand.

dontParallelize(ProcessorSupplier) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Wraps the provided ProcessorSupplier into a meta-supplier that will always return it.

dontParallelize(DistributedSupplier<? extends Processor>) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Factory method that wraps the given Supplier<Processor> and uses it as the supplier of all Processor instances.

DoubleAccumulator - Class in com.hazelcast.jet.accumulator

Mutable container of a double value.

DoubleAccumulator() - Constructor for class com.hazelcast.jet.accumulator.DoubleAccumulator

Creates a new instance with value == 0.

DoubleAccumulator(double) - Constructor for class com.hazelcast.jet.accumulator.DoubleAccumulator

Creates a new instance with the specified value.

drain(Consumer<E>) - Method in interface com.hazelcast.jet.core.Inbox

Passes each of this object's items to the supplied consumer until it is empty.

drainOutbox(Queue<T>, Collection<? super T>, boolean) - Static method in class com.hazelcast.jet.core.test.TestSupport

Move all items from the outbox to the target list and make the outbox available to accept more items.

drainTo(Sink<? super E>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this stage a sink stage, one that accepts data but doesn't emit any.

drainTo(Collection<E>) - Method in interface com.hazelcast.jet.core.Inbox

Drains all elements into the provided Collection.

drawFrom(Source<E>) - Method in interface com.hazelcast.jet.Pipeline

Returns a new pipeline stage that has no upstream stages and produces some output for its downstream stages.

dropWhile(Predicate<? super T>) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser that will emit a suffix of the original traverser, starting from the item for which the predicate fails (inclusive).

E

edge(Edge) - Method in class com.hazelcast.jet.core.DAG

Adds an edge to this DAG.

Edge - Class in com.hazelcast.jet.core

Represents an edge between two vertices in a DAG.

Edge() - Constructor for class com.hazelcast.jet.core.Edge

Edge(Vertex, int, Vertex, int) - Constructor for class com.hazelcast.jet.core.Edge

Edge.RoutingPolicy - Enum in com.hazelcast.jet.core

An edge describes a connection from many upstream processors to many downstream processors.

EdgeConfig - Class in com.hazelcast.jet.config

A configuration object for a DAG Edge that holds fine-tuning parameters that influence its performance characteristics.

EdgeConfig() - Constructor for class com.hazelcast.jet.config.EdgeConfig

emitByFrame(WindowDefinition) - Static method in interface com.hazelcast.jet.core.WatermarkEmissionPolicy

Returns a watermark emission policy that ensures that the value of the emitted watermark belongs to a frame higher than the previous watermark's frame, as per the supplied WindowDefinition.

emitByMinStep(long) - Static method in interface com.hazelcast.jet.core.WatermarkEmissionPolicy

Returns a watermark emission policy that ensures that each emitted watermark's value is at least minStep more than the previous one.

emitFromTraverser(int[], Traverser<E>, Consumer<? super E>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Obtains items from the traverser and offers them to the outbox's buckets identified in the supplied array.

emitFromTraverser(int, Traverser<E>, Consumer<? super E>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Obtains items from the traverser and offers them to the outbox's buckets identified in the supplied array.

emitFromTraverser(Traverser<E>, Consumer<? super E>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Convenience for AbstractProcessor.emitFromTraverser(int, Traverser, Consumer) which emits to all ordinals.

emitFromTraverser(Traverser<?>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Convenience for AbstractProcessor.emitFromTraverser(int, Traverser, Consumer) which emits to all ordinals.

emitFromTraverser(int, Traverser<?>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Convenience for AbstractProcessor.emitFromTraverser(int, Traverser, Consumer) which emits to the specified ordinal.

emitFromTraverser(int[], Traverser<?>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Convenience for AbstractProcessor.emitFromTraverser(int[], Traverser, Consumer) which emits to the specified ordinals.

emitFromTraverserToSnapshot(Traverser<T>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Obtains items from the traverser and offers them to the snapshot bucket of the outbox.

empty() - Static method in class com.hazelcast.jet.function.DistributedOptional

Returns an empty Optional instance.

empty() - Static method in class com.hazelcast.jet.Traversers

Returns a traverser that always returns null.

ensureBag(Tag<E>) - Method in class com.hazelcast.jet.datamodel.BagsByTag

Ensures that there is a mapping from the supplied tag to a bag, creating an empty one if necessary.

entry(K, V) - Static method in class com.hazelcast.jet.Util

Returns a Map.Entry with the given key and value.

entryKey() - Static method in class com.hazelcast.jet.function.DistributedFunctions

Returns a function that extracts the key of a Map.Entry.

entryValue() - Static method in class com.hazelcast.jet.function.DistributedFunctions

Returns a function that extracts the value of a Map.Entry.

equals(Object) - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator

equals(Object) - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator

equals(Object) - Method in class com.hazelcast.jet.accumulator.LongAccumulator

equals(Object) - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator

equals(Object) - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator

equals(Object) - Method in class com.hazelcast.jet.accumulator.MutableReference

equals(Object) - Method in class com.hazelcast.jet.core.Edge

equals(Object) - Method in class com.hazelcast.jet.core.Watermark

equals(Object) - Method in class com.hazelcast.jet.datamodel.BagsByTag

equals(Object) - Method in class com.hazelcast.jet.datamodel.ItemsByTag

equals(Object) - Method in class com.hazelcast.jet.datamodel.Session

equals(Object) - Method in class com.hazelcast.jet.datamodel.Tag

equals(Object) - Method in class com.hazelcast.jet.datamodel.ThreeBags

equals(Object) - Method in class com.hazelcast.jet.datamodel.TimestampedEntry

equals(Object) - Method in class com.hazelcast.jet.datamodel.Tuple2

equals(Object) - Method in class com.hazelcast.jet.datamodel.Tuple3

equals(Object) - Method in class com.hazelcast.jet.datamodel.TwoBags

equals(Object) - Method in class com.hazelcast.jet.function.DistributedOptional

Indicates whether some other object is "equal to" this Optional.

execute() - Method in interface com.hazelcast.jet.Job

Deprecated.

Use Job.getFuture() instead. This method will be removed in the next release.

expectOutput(List<?>) - Method in class com.hazelcast.jet.core.test.TestSupport

Sets the expected output and runs the test.

F

f0() - Method in class com.hazelcast.jet.datamodel.Tuple2

Returns the value of the field 0.

f0() - Method in class com.hazelcast.jet.datamodel.Tuple3

Returns the value of the field 0.

f1() - Method in class com.hazelcast.jet.datamodel.Tuple2

Returns the value of the field 1.

f1() - Method in class com.hazelcast.jet.datamodel.Tuple3

Returns the value of the field 1.

f2() - Method in class com.hazelcast.jet.datamodel.Tuple3

Returns the value of the field 2.

files(String, DistributedFunction<E, String>, Charset, boolean) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that that writes the items it receives to files.

files(String, DistributedFunction<E, String>) - Static method in class com.hazelcast.jet.Sinks

Convenience for Sinks.files(String, DistributedFunction, Charset, boolean) with the UTF-8 charset and with overwriting of existing files.

files(String) - Static method in class com.hazelcast.jet.Sinks

Convenience for Sinks.files(String, DistributedFunction, Charset, boolean) with the UTF-8 charset and with overwriting of existing files.

files(String, Charset, String) - Static method in class com.hazelcast.jet.Sources

A source that emits lines from files in a directory (but not its subdirectories.

files(String) - Static method in class com.hazelcast.jet.Sources

Convenience for readFiles(directory, UTF_8, "*").

fileWatcher(String, Charset, String) - Static method in class com.hazelcast.jet.Sources

A source that emits a stream of lines of text coming from files in the watched directory (but not its subdirectories).

fileWatcher(String) - Static method in class com.hazelcast.jet.Sources

Convenience for streamFiles(watchedDirectory, UTF_8, "*").

filter(DistributedPredicate<E>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this stage a filtering stage, one which applies the provided predicate function to each input item to decide whether to pass the item to the output or to discard it.

filter(DistributedPredicate<? super T>) - Method in class com.hazelcast.jet.function.DistributedOptional

If a value is present, and the value matches the given predicate, return an Optional describing the value, otherwise return an empty Optional.

filter(DistributedDoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns a stream consisting of the elements of this stream that match the given predicate.

filter(DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

filter(DistributedIntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a stream consisting of the elements of this stream that match the given predicate.

filter(IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

filter(DistributedLongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a stream consisting of the elements of this stream that match the given predicate.

filter(LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

filter(DistributedPredicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns a stream consisting of the elements of this stream that match the given predicate.

filter(Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

filter(Predicate<? super T>) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser that will emit the same items as this traverser, but only those that pass the given predicate.

filterP(DistributedPredicate<T>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that emits the same items it receives, but only those that pass the given predicate.

finish() - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator

Computes the linear coefficient of the linear regression of the accumulated samples.

finisher() - Method in interface com.hazelcast.jet.stream.DistributedCollector

Perform the final transformation from the intermediate accumulation type A to the final result type R.

finishFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation

A primitive that finishes the accumulation process by transforming the accumulator object into the final result.

finishSnapshotRestore() - Method in interface com.hazelcast.jet.core.Processor

Called after a job was restarted from a snapshot and the processor has consumed all the snapshot data.

flatMap(DistributedFunction<? super E, Traverser<? extends R>>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this stage a flat-mapping stage, one which applies the supplied function to each input item independently and emits all items from the Traverser it returns as the output items.

flatMap(DistributedFunction<? super T, DistributedOptional<U>>) - Method in class com.hazelcast.jet.function.DistributedOptional

If a value is present, apply the provided Optional-bearing mapping function to it, return that result, otherwise return an empty Optional.

flatMap(DistributedDoubleFunction<? extends DoubleStream>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

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.

flatMap(DoubleFunction<? extends DoubleStream>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

flatMap(DistributedIntFunction<? extends IntStream>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

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.

flatMap(IntFunction<? extends IntStream>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

flatMap(DistributedLongFunction<? extends LongStream>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

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.

flatMap(LongFunction<? extends LongStream>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

flatMap(DistributedFunction<? super T, ? extends Stream<? extends R>>) - Method in interface com.hazelcast.jet.stream.DistributedStream

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.

flatMap(Function<? super T, ? extends Stream<? extends R>>) - Method in interface com.hazelcast.jet.stream.DistributedStream

flatMap(Function<? super T, ? extends Traverser<? extends R>>) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser traverser that will apply the given mapping function to each item retrieved from this traverser and emit all the items from the resulting traverser(s).

flatMapP(DistributedFunction<T, ? extends Traverser<? extends R>>) - Static method in class com.hazelcast.jet.core.processor.Processors

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.

flatMapper(int, Function<? super T, ? extends Traverser<? extends R>>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Factory of AbstractProcessor.FlatMapper.

flatMapper(Function<? super T, ? extends Traverser<? extends R>>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Factory of AbstractProcessor.FlatMapper.

flatMapper(int[], Function<? super T, ? extends Traverser<? extends R>>) - Method in class com.hazelcast.jet.core.AbstractProcessor

Factory of AbstractProcessor.FlatMapper.

flatMapToDouble(DistributedFunction<? super T, ? extends DoubleStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns an DoubleStream 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.

flatMapToDouble(Function<? super T, ? extends DoubleStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream

flatMapToInt(DistributedFunction<? super T, ? extends IntStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns an IntStream 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.

flatMapToInt(Function<? super T, ? extends IntStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream

flatMapToLong(DistributedFunction<? super T, ? extends LongStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns an LongStream 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.

flatMapToLong(Function<? super T, ? extends LongStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream

floorFrameTs(long) - Method in class com.hazelcast.jet.core.WindowDefinition

Returns the highest frame timestamp less than or equal to the given timestamp.

forEach(DistributedDoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Performs an action for each element of this stream.

forEach(DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

forEachOrdered(DistributedDoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Performs an action for each element of this stream, guaranteeing that each element is processed in encounter order for streams that have a defined encounter order.

forEachOrdered(DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

frameLength() - Method in class com.hazelcast.jet.core.WindowDefinition

Returns the length of the frame (equal to the sliding step).

frameOffset() - Method in class com.hazelcast.jet.core.WindowDefinition

Returns the frame offset.

from(Vertex) - Static method in class com.hazelcast.jet.core.Edge

Returns an edge with the given source vertex and no destination vertex.

from(Vertex, int) - Static method in class com.hazelcast.jet.core.Edge

Returns an edge with the given source vertex at the given ordinal and no destination vertex.

fromProcessor(String, ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.Sinks

Returns a sink constructed directly from the given Core API processor meta-supplier.

fromProcessor(String, ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.Sources

Returns a source constructed directly from the given Core API processor meta-supplier.

fromSource(JetInstance, ProcessorMetaSupplier) - Static method in interface com.hazelcast.jet.stream.DistributedStream

Returns a distributed Stream with given processors as its source.

G

get() - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator

Returns the current value.

get() - Method in class com.hazelcast.jet.accumulator.LongAccumulator

Returns the current value.

get() - Method in class com.hazelcast.jet.accumulator.MutableReference

Returns the current value.

get(int) - Method in class com.hazelcast.jet.core.CloseableProcessorSupplier

get(List<Address>) - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Called to create a mapping from member Address to the ProcessorSupplier that will be sent to that member.

get(int) - Method in interface com.hazelcast.jet.core.ProcessorSupplier

Called after ProcessorSupplier.init(Context) to retrieve instances of Processor that will be used during the execution of the Jet job.

get(Tag<E>) - Method in class com.hazelcast.jet.datamodel.ItemsByTag

Retrieves the value associated with the supplied tag and throws an exception if there is none.

get() - Method in class com.hazelcast.jet.function.DistributedOptional

If a value is present in this Optional, returns the value, otherwise throws NoSuchElementException.

getBackupCount() - Method in class com.hazelcast.jet.config.InstanceConfig

Returns the backup-count used for job metadata and snapshots

getCache(String) - Method in interface com.hazelcast.jet.stream.JetCacheManager

Returns the cache instance with the specified prefixed cache name.

getCacheManager() - Method in interface com.hazelcast.jet.JetInstance

Obtain the JetCacheManager that provides access to JSR-107 (JCache) caches configured on a Hazelcast Jet cluster.

getCluster() - Method in interface com.hazelcast.jet.JetInstance

Returns information about the cluster this Jet instance is part of.

getConfig() - Method in class com.hazelcast.jet.core.Edge

Returns the EdgeConfig instance associated with this edge.

getConfig() - Method in interface com.hazelcast.jet.JetInstance

Returns the configuration for this Jet member.

getCooperativeThreadCount() - Method in class com.hazelcast.jet.config.InstanceConfig

Returns the number of cooperative execution threads.

getCurrentWatermark() - Method in interface com.hazelcast.jet.core.WatermarkPolicy

Called to get the current watermark in the absence of an observed event.

getDefaultEdgeConfig() - Method in class com.hazelcast.jet.config.JetConfig

Returns the default DAG edge configuration.

getDestination() - Method in class com.hazelcast.jet.core.Edge

Returns this edge's destination vertex.

getDestName() - Method in class com.hazelcast.jet.core.Edge

Returns the name of the destination vertex.

getDestOrdinal() - Method in class com.hazelcast.jet.core.Edge

Returns the ordinal of the edge at the destination vertex.

getEnd() - Method in class com.hazelcast.jet.datamodel.Session

Returns the ending timestamp of the session.

getFactoryId() - Method in class com.hazelcast.jet.core.DAG

getFactoryId() - Method in class com.hazelcast.jet.core.Edge

getFactoryId() - Method in class com.hazelcast.jet.core.JetDataSerializerHook

getFactoryId() - Method in class com.hazelcast.jet.core.Vertex

getFlowControlPeriodMs() - Method in class com.hazelcast.jet.config.InstanceConfig

Returns the flow-control period in milliseconds.

getFuture() - Method in interface com.hazelcast.jet.Job

Gets the future associated with the job, used to control the job.

getHazelcastConfig() - Method in class com.hazelcast.jet.config.JetConfig

Returns the configuration object for the underlying Hazelcast instance.

getHazelcastInstance() - Method in interface com.hazelcast.jet.JetInstance

Returns the underlying Hazelcast IMDG instance used by Jet.

getHeapCost() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

getId() - Method in class com.hazelcast.jet.config.ResourceConfig

The ID of the resource, null for archives.

getId() - Method in class com.hazelcast.jet.core.DAG

getId() - Method in class com.hazelcast.jet.core.Edge

getId() - Method in class com.hazelcast.jet.core.Vertex

getInboundEdges(String) - Method in class com.hazelcast.jet.core.DAG

Returns the inbound edges connected to the vertex with the given name.

getInstance() - Static method in class com.hazelcast.jet.server.JetBootstrap

Returns the bootstrapped JetInstance.

getInstanceConfig() - Method in class com.hazelcast.jet.config.JetConfig

Returns the Jet instance config.

getJobId() - Method in interface com.hazelcast.jet.Job

Returns the ID of this job.

getJobs() - Method in interface com.hazelcast.jet.JetInstance

Returns all submitted jobs including running and completed ones

getJobStatus() - Method in interface com.hazelcast.jet.Job

Returns the status of this job.

getKey() - Method in class com.hazelcast.jet.datamodel.Session

Returns the session's key.

getKey() - Method in class com.hazelcast.jet.datamodel.TimestampedEntry

getKey() - Method in class com.hazelcast.jet.datamodel.Tuple2

getList(String) - Method in interface com.hazelcast.jet.JetInstance

Returns the distributed list instance with the specified name.

getLocalParallelism() - Method in class com.hazelcast.jet.core.Vertex

Returns the number of processors corresponding to this vertex that will be created on each member.

getLogger() - Method in class com.hazelcast.jet.core.AbstractProcessor

Returns the logger associated with this processor instance.

getManagedContext() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockSerializationService

getMap(String) - Method in interface com.hazelcast.jet.JetInstance

Returns the distributed map instance with the specified name.

getMetaSupplier() - Method in class com.hazelcast.jet.core.Vertex

Returns this vertex's meta-supplier of processors.

getName() - Method in class com.hazelcast.jet.core.Vertex

Returns the name of this vertex.

getName() - Method in interface com.hazelcast.jet.JetInstance

Returns the name of the Jet instance.

getObject() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

Javadoc pending

getOutboundEdges(String) - Method in class com.hazelcast.jet.core.DAG

Returns the outbound edges connected to the vertex with the given name.

getPacketSizeLimit() - Method in class com.hazelcast.jet.config.EdgeConfig

Returns the limit on the network packet size, in bytes

getPartition(Object) - Method in interface com.hazelcast.jet.core.DefaultPartitionStrategy

Returns the Hazelcast partition ID of the given object.

getPartition(Object, int) - Method in class com.hazelcast.jet.core.Partitioner.Default

getPartition(T, int) - Method in interface com.hazelcast.jet.core.Partitioner

Returns the partition ID of the given item.

getPartitioner() - Method in class com.hazelcast.jet.core.Edge

Returns the instance encapsulating the partitioning strategy in effect on this edge.

getPartitionHash() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

getPipeline() - Method in interface com.hazelcast.jet.Stage

Returns the Pipeline this stage belongs to.

getPriority() - Method in class com.hazelcast.jet.core.Edge

Returns the value of edge's priority, as explained on Edge.priority(int).

getProcessingGuarantee() - Method in class com.hazelcast.jet.config.JobConfig

Returns the configured processing guarantee.

getProperties() - Method in class com.hazelcast.jet.config.JetConfig

Returns the Jet-specific configuration properties.

getQueueSize() - Method in class com.hazelcast.jet.config.EdgeConfig

Returns the size of the SPSC queues used to implement this edge.

getReceiveWindowMultiplier() - Method in class com.hazelcast.jet.config.EdgeConfig

getResourceConfigs() - Method in class com.hazelcast.jet.config.JobConfig

Returns all the registered resource configurations.

getResult() - Method in class com.hazelcast.jet.datamodel.Session

Returns the aggregated result for the session.

getRoutingPolicy() - Method in class com.hazelcast.jet.core.Edge

Returns the Edge.RoutingPolicy in effect on the edge.

getSnapshotIntervalMillis() - Method in class com.hazelcast.jet.config.JobConfig

Returns the configured snapshot interval.

getSource() - Method in class com.hazelcast.jet.core.Edge

Returns this edge's source vertex.

getSourceName() - Method in class com.hazelcast.jet.core.Edge

Returns the name of the source vertex.

getSourceOrdinal() - Method in class com.hazelcast.jet.core.Edge

Returns the ordinal of the edge at the source vertex.

getStart() - Method in class com.hazelcast.jet.datamodel.Session

Returns the starting timestamp of the session.

getTempDir() - Method in class com.hazelcast.jet.config.InstanceConfig

Returns Jet's temp directory.

getTimestamp() - Method in class com.hazelcast.jet.datamodel.TimestampedEntry

Returns the timestamp of this entry.

getType() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

getUrl() - Method in class com.hazelcast.jet.config.ResourceConfig

Returns the URL at which the resource will be available.

getValue() - Method in class com.hazelcast.jet.datamodel.TimestampedEntry

getValue() - Method in class com.hazelcast.jet.datamodel.Tuple2

getValue1() - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator

Returns the current value1.

getValue1() - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator

Returns the current value1.

getValue2() - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator

Returns the current value2.

getValue2() - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator

Returns the current value2.

getVertex(String) - Method in class com.hazelcast.jet.core.DAG

Returns the vertex with the given name.

globalProcessorIndex() - Method in interface com.hazelcast.jet.core.Processor.Context

Returns the index of the processor among all the processors created for this vertex on all nodes: its unique cluster-wide index.

globalProcessorIndex() - Method in class com.hazelcast.jet.core.test.TestProcessorContext

groupBy(DistributedFunction<? super E, ? extends K>, AggregateOperation1<? super E, A, R>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this stage a group-by-key stage, one which will group all received items by the key returned from the provided key-extracting function.

groupingBy(DistributedFunction<? super T, ? extends K>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector implementing a "group by" operation on input elements of type T, grouping elements according to a classification function, and returning the results in a Map.

groupingBy(DistributedFunction<? super T, ? extends K>, DistributedCollector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream DistributedCollector.

groupingBy(DistributedFunction<? super T, ? extends K>, DistributedSupplier<M>, DistributedCollector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream DistributedCollector.

groupingByToICache(String, DistributedFunction<? super T, ? extends K>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer implementing a "group by" operation on input elements of type T, grouping elements according to a classification function, and returning the results in a new distributed Hazelcast ICache.

groupingByToICache(String, DistributedFunction<? super T, ? extends K>, DistributedCollector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream DistributedCollector.

groupingByToIMap(String, DistributedFunction<? super T, ? extends K>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer implementing a "group by" operation on input elements of type T, grouping elements according to a classification function, and returning the results in a new distributed Hazelcast IMap.

groupingByToIMap(String, DistributedFunction<? super T, ? extends K>, DistributedCollector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream DistributedCollector.

H

hash64() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

HASH_CODE - Static variable in interface com.hazelcast.jet.core.Partitioner

Partitioner which calls Object.hashCode() and coerces it with the modulo operation into the allowed range of partition IDs.

hashCode() - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator

hashCode() - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator

hashCode() - Method in class com.hazelcast.jet.accumulator.LongAccumulator

hashCode() - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator

hashCode() - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator

hashCode() - Method in class com.hazelcast.jet.accumulator.MutableReference

hashCode() - Method in class com.hazelcast.jet.core.Edge

hashCode() - Method in class com.hazelcast.jet.core.Watermark

hashCode() - Method in class com.hazelcast.jet.datamodel.BagsByTag

hashCode() - Method in class com.hazelcast.jet.datamodel.ItemsByTag

hashCode() - Method in class com.hazelcast.jet.datamodel.Session

hashCode() - Method in class com.hazelcast.jet.datamodel.Tag

hashCode() - Method in class com.hazelcast.jet.datamodel.ThreeBags

hashCode() - Method in class com.hazelcast.jet.datamodel.TimestampedEntry

hashCode() - Method in class com.hazelcast.jet.datamodel.Tuple2

hashCode() - Method in class com.hazelcast.jet.datamodel.Tuple3

hashCode() - Method in class com.hazelcast.jet.datamodel.TwoBags

hashCode() - Method in class com.hazelcast.jet.function.DistributedOptional

Returns the hash code value of the present value, if any, or 0 (zero) if no value is present.

hashJoin(ComputeStage<E1_IN>, JoinClause<K, E, E1_IN, E1>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to both this and the supplied stage a hash-joining stage and returns it.

hashJoin(ComputeStage<E1_IN>, JoinClause<K1, E, E1_IN, E1>, ComputeStage<E2_IN>, JoinClause<K2, E, E2_IN, E2>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this and the two supplied stages a hash-joining stage and returns it.

hashJoinBuilder() - Method in interface com.hazelcast.jet.ComputeStage

Returns a fluent API builder object to construct a hash join operation with any number of contributing stages.

HashJoinBuilder<E0> - Class in com.hazelcast.jet

Offers a step-by-step fluent API to build a hash-join pipeline stage.

hasPartitionHash() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

hdfs(JobConf, DistributedFunction<? super E, K>, DistributedFunction<? super E, V>) - Static method in class com.hazelcast.jet.HdfsSinks

Returns a sink that writes to Apache Hadoop HDFS.

hdfs(JobConf) - Static method in class com.hazelcast.jet.HdfsSinks

Convenience for HdfsSinks.hdfs(JobConf, DistributedFunction, DistributedFunction) which expects Map.Entry<K, V> as input and extracts its key and value parts to be written to HDFS.

hdfs(JobConf, DistributedBiFunction<K, V, E>) - Static method in class com.hazelcast.jet.HdfsSources

Returns a source that reads records from Apache Hadoop HDFS and emits the results of transforming each record (a key-value pair) with the supplied mapping function.

hdfs(JobConf) - Static method in class com.hazelcast.jet.HdfsSources

Convenience for HdfsSources.hdfs(JobConf, DistributedBiFunction) with Map.Entry as its output type.

HdfsProcessors - Class in com.hazelcast.jet.core.processor

Static utility class with factories of Apache Hadoop HDFS source and sink processors.

HdfsSinks - Class in com.hazelcast.jet

Factories of Apache Hadoop HDFS sinks.

HdfsSources - Class in com.hazelcast.jet

Contains factory methods for Apache Hadoop HDFS sources.

higherFrameTs(long) - Method in class com.hazelcast.jet.core.WindowDefinition

Returns the lowest frame timestamp greater than the given timestamp.

I

identity() - Static method in interface com.hazelcast.jet.function.DistributedDoubleUnaryOperator

Returns a unary operator that always returns its input argument.

identity() - Static method in interface com.hazelcast.jet.function.DistributedFunction

Returns a function that always returns its input argument.

identity() - Static method in interface com.hazelcast.jet.function.DistributedIntUnaryOperator

Returns a unary operator that always returns its input argument.

identity() - Static method in interface com.hazelcast.jet.function.DistributedLongUnaryOperator

Returns a unary operator that always returns its input argument.

identity() - Static method in interface com.hazelcast.jet.function.DistributedUnaryOperator

Returns a unary operator that always returns its input argument.

ifPresent(DistributedConsumer<? super T>) - Method in class com.hazelcast.jet.function.DistributedOptional

If a value is present, invoke the specified consumer with the value, otherwise do nothing.

Inbox - Interface in com.hazelcast.jet.core

A subset of Queue<Object> API restricted to the consumer side, with additional support for bulk draining operations.

index() - Method in class com.hazelcast.jet.datamodel.Tag

Returns the index associated with this tag.

init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.core.AbstractProcessor

init(Processor.Context) - Method in class com.hazelcast.jet.core.AbstractProcessor

Method that can be overridden to perform any necessary initialization for the processor.

init(ProcessorSupplier.Context) - Method in class com.hazelcast.jet.core.CloseableProcessorSupplier

init(DefaultPartitionStrategy) - Method in class com.hazelcast.jet.core.Partitioner.Default

init(DefaultPartitionStrategy) - Method in interface com.hazelcast.jet.core.Partitioner

Callback that injects the Hazelcast's default partitioning strategy into this partitioner so it can be consulted by the Partitioner.getPartition(Object, int) method.

init(Outbox, Processor.Context) - Method in interface com.hazelcast.jet.core.Processor

Initializes this processor with the outbox that the processing methods must use to deposit their output items.

init(ProcessorMetaSupplier.Context) - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Called on the cluster member that receives the client request, after deserializing the meta-supplier instance.

init(ProcessorSupplier.Context) - Method in interface com.hazelcast.jet.core.ProcessorSupplier

Called on each cluster member after deserialization.

input(List<?>) - Method in class com.hazelcast.jet.core.test.TestSupport

Sets the input objects for processor.

insertWatermarksP(DistributedToLongFunction<T>, DistributedSupplier<WatermarkPolicy>, WatermarkEmissionPolicy) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex that inserts watermark items into the stream.

InstanceConfig - Class in com.hazelcast.jet.config

General configuration options pertaining to a Jet instance.

InstanceConfig() - Constructor for class com.hazelcast.jet.config.InstanceConfig

isArchive() - Method in class com.hazelcast.jet.config.ResourceConfig

Whether this entry is an Jar archive or a single resource element.

isAutoRestartOnMemberFailureEnabled() - Method in class com.hazelcast.jet.config.JobConfig

Tells whether auto restart after member failure is enabled.

isCooperative() - Method in class com.hazelcast.jet.core.AbstractProcessor

isCooperative() - Method in interface com.hazelcast.jet.core.Processor

Tells whether this processor is able to participate in cooperative multithreading.

isDistributed() - Method in class com.hazelcast.jet.core.Edge

Says whether this edge is distributed.

isEmpty() - Method in interface com.hazelcast.jet.core.Inbox

Returns true if this inbox contains no elements, false otherwise.

isEqual(Object) - Static method in interface com.hazelcast.jet.function.DistributedPredicate

Returns a predicate that tests if two arguments are equal according to Objects.equals(Object, Object).

isolated() - Method in class com.hazelcast.jet.core.Edge

Activates the ISOLATED routing policy which establishes isolated paths from upstream to downstream processors.

isPortable() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

isPresent() - Method in class com.hazelcast.jet.function.DistributedOptional

Return true if there is a value present, otherwise false.

isSplitBrainProtectionEnabled() - Method in class com.hazelcast.jet.config.JobConfig

Tells whether split brain protection is enabled.

IStreamCache<K,V> - Interface in com.hazelcast.jet.stream

A decorator for ICache for supporting distributed Stream implementation.

IStreamList<E> - Interface in com.hazelcast.jet.stream

A decorator for IList for supporting distributed Stream implementation.

IStreamMap<K,V> - Interface in com.hazelcast.jet.stream

A decorator for IMap for supporting distributed Stream implementation.

isTumbling() - Method in class com.hazelcast.jet.core.WindowDefinition

Tells whether this definition describes a tumbling window.

isValidLocalParallelism(int) - Static method in class com.hazelcast.jet.core.Vertex

Says whether the given integer is valid as the value of localParallelism.

ItemsByTag - Class in com.hazelcast.jet.datamodel

A heterogeneous map from Tag<E> to E, where E can be different for each tag.

ItemsByTag() - Constructor for class com.hazelcast.jet.datamodel.ItemsByTag

itemsByTag(Object...) - Static method in class com.hazelcast.jet.datamodel.ItemsByTag

Accepts an argument list of alternating tags and values, interprets them as a list of tag-value pairs, and returns an ItemsByTag populated with these pairs.

iterator() - Method in class com.hazelcast.jet.core.DAG

Returns an iterator over the DAG's vertices in topological order.

J

Jet - Class in com.hazelcast.jet

Entry point to the Jet product.

JetBootstrap - Class in com.hazelcast.jet.server

A helper class that allows one to create a standalone runnable JAR which contains all the code needed to submit a job to a running Jet cluster.

JetCacheManager - Interface in com.hazelcast.jet.stream

JetCacheManager is the entry point to access JSR-107 (JCache) caches via JetInstance interface.

JetConfig - Class in com.hazelcast.jet.config

Configuration object for a Jet instance.

JetConfig() - Constructor for class com.hazelcast.jet.config.JetConfig

JetDataSerializerHook - Class in com.hazelcast.jet.core

A Java Service Provider hook for Hazelcast's Identified Data Serializable mechanism.

JetDataSerializerHook() - Constructor for class com.hazelcast.jet.core.JetDataSerializerHook

JetException - Exception in com.hazelcast.jet

Base Jet exception.

JetException() - Constructor for exception com.hazelcast.jet.JetException

JetException(String) - Constructor for exception com.hazelcast.jet.JetException

JetException(String, Throwable) - Constructor for exception com.hazelcast.jet.JetException

JetException(Throwable) - Constructor for exception com.hazelcast.jet.JetException

jetInstance() - Method in interface com.hazelcast.jet.core.Processor.Context

Returns the current Jet instance

jetInstance() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context

Returns the current Jet instance.

jetInstance() - Method in interface com.hazelcast.jet.core.ProcessorSupplier.Context

Returns the current Jet instance

jetInstance() - Method in class com.hazelcast.jet.core.test.TestProcessorContext

jetInstance() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

jetInstance() - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext

JetInstance - Interface in com.hazelcast.jet

Represents either an instance of a Jet server node or a Jet client instance that connects to a remote cluster.

Job - Interface in com.hazelcast.jet

A Jet computation job created from a DAG.

JobConfig - Class in com.hazelcast.jet.config

Contains the configuration specific to one Hazelcast Jet job.

JobConfig() - Constructor for class com.hazelcast.jet.config.JobConfig

JobNotFoundException - Exception in com.hazelcast.jet.core

Thrown when a job could not be found on the master node

JobNotFoundException(long) - Constructor for exception com.hazelcast.jet.core.JobNotFoundException

JobStatus - Enum in com.hazelcast.jet.core

Represents current status of the job from the perspective of the job coordinator.

join() - Method in interface com.hazelcast.jet.Job

Waits for the job to complete and throws exception if job is completed with an error.

JoinClause<K,E0,E1,E1_OUT> - Class in com.hazelcast.jet

Specifies how to join an enriching stream to the primary stream in a hash-join operation.

joining() - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that concatenates the input elements into a String, in encounter order.

joining(CharSequence) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that concatenates the input elements, separated by the specified delimiter, in encounter order.

joining(CharSequence, CharSequence, CharSequence) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that concatenates the input elements, separated by the specified delimiter, with the specified prefix and suffix, in encounter order.

joinMapEntries(DistributedFunction<E0, K>) - Static method in class com.hazelcast.jet.JoinClause

A shorthand factory for the common case of hash-joining with a stream of map entries.

K

kafka(Properties, DistributedFunction<? super E, ProducerRecord<K, V>>) - Static method in class com.hazelcast.jet.KafkaSinks

Returns a source that publishes messages to an Apache Kafka topic.

kafka(Properties, String, DistributedFunction<? super E, K>, DistributedFunction<? super E, V>) - Static method in class com.hazelcast.jet.KafkaSinks

Convenience for KafkaSinks.kafka(Properties, DistributedFunction) which creates a ProducerRecord using the given topic and the given key and value mapping functions

kafka(Properties, String) - Static method in class com.hazelcast.jet.KafkaSinks

Convenience for KafkaSinks.kafka(Properties, String, DistributedFunction, DistributedFunction) which expects Map.Entry<K, V> as input and extracts its key and value parts to be published to Kafka.

kafka(Properties, String...) - Static method in class com.hazelcast.jet.KafkaSources

Convenience for KafkaSources.kafka(Properties, DistributedBiFunction, String...) wrapping the output in Map.Entry.

kafka(Properties, DistributedBiFunction<K, V, T>, String...) - Static method in class com.hazelcast.jet.KafkaSources

Returns a source that consumes one or more Apache Kafka topics and emits items from them as Map.Entry instances.

KafkaProcessors - Class in com.hazelcast.jet.core.processor

Static utility class with factories of Apache Kafka source and sink processors.

KafkaSinks - Class in com.hazelcast.jet

Contains factory methods for Apache Kafka sinks.

KafkaSources - Class in com.hazelcast.jet

Contains factory methods for Apache Kafka sources.

key() - Method in interface com.hazelcast.jet.core.BroadcastKey

Returns the underlying key

L

lazy(Supplier<Traverser<T>>) - Static method in class com.hazelcast.jet.Traversers

Flattens a supplier of traverser into a lazy-initialized traverser.

leftKeyFn() - Method in class com.hazelcast.jet.JoinClause

Returns the left-hand key extractor function.

limit(long) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns a stream consisting of the elements of this stream, truncated to be no longer than maxSize in length.

limit(long) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a stream consisting of the elements of this stream, truncated to be no longer than maxSize in length.

limit(long) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a stream consisting of the elements of this stream, truncated to be no longer than maxSize in length.

limit(long) - Method in interface com.hazelcast.jet.stream.DistributedStream

limitingLagAndDelay(long, long) - Static method in class com.hazelcast.jet.core.WatermarkPolicies

Maintains watermark that lags behind the top observed timestamp by at most the given amount and is additionally guaranteed to reach the timestamp of any given event within maxDelayMs after observing it.

limitingLagAndLull(long, long) - Static method in class com.hazelcast.jet.core.WatermarkPolicies

Maintains watermark that lags behind the top timestamp by the amount specified with lag.

limitingTimestampAndWallClockLag(long, long) - Static method in class com.hazelcast.jet.core.WatermarkPolicies

Maintains watermark that lags behind the top timestamp by at most timestampLag and behind wall-clock time by at most wallClockLag.

linearTrend(DistributedToLongFunction<T>, DistributedToLongFunction<T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation that computes a linear trend on the items in the window.

LinTrendAccumulator - Class in com.hazelcast.jet.accumulator

Maintains the components needed to compute the linear regression on a set of (long, long) pairs.

LinTrendAccumulator() - Constructor for class com.hazelcast.jet.accumulator.LinTrendAccumulator

Constructs a new accumulator with all components at zero.

LinTrendAccumulator(long, BigInteger, BigInteger, BigInteger, BigInteger) - Constructor for class com.hazelcast.jet.accumulator.LinTrendAccumulator

Creates a new accumulator with the given components.

list(String) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that adds the items it receives to a Hazelcast IList with the specified name.

list(String) - Static method in class com.hazelcast.jet.Sources

Returns a source that emits items retrieved from a Hazelcast IList.

LOCAL_PARALLELISM_USE_DEFAULT - Static variable in class com.hazelcast.jet.core.Vertex

The value of Vertex.localParallelism(int) with the meaning "use the default local parallelism".

localParallelism() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context

Returns the number of processors that each ProcessorSupplier will be asked to create once deserialized on each member.

localParallelism() - Method in interface com.hazelcast.jet.core.ProcessorSupplier.Context

Returns the number of processors that the associated ProcessorSupplier will be asked to create.

localParallelism() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

localParallelism() - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext

localParallelism(int) - Method in class com.hazelcast.jet.core.Vertex

Sets the number of processors corresponding to this vertex that will be created on each member.

logger() - Method in interface com.hazelcast.jet.core.Processor.Context

Return a logger for the processor

logger() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context

Returns a logger for the associated ProcessorSupplier.

logger() - Method in interface com.hazelcast.jet.core.ProcessorSupplier.Context

Returns a logger for the associated ProcessorSupplier.

logger() - Method in class com.hazelcast.jet.core.test.TestProcessorContext

logger() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

logger() - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext

logger(DistributedFunction<E, String>) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that logs all the data items it receives, at the INFO level to the log category WriteLoggerP.

logger() - Static method in class com.hazelcast.jet.Sinks

Convenience for Sinks.logger(DistributedFunction) with Object.toString() as the toStringFn.

LongAccumulator - Class in com.hazelcast.jet.accumulator

Mutable container of a long value.

LongAccumulator() - Constructor for class com.hazelcast.jet.accumulator.LongAccumulator

Creates a new instance with value == 0.

LongAccumulator(long) - Constructor for class com.hazelcast.jet.accumulator.LongAccumulator

Creates a new instance with the specified value.

LongDoubleAccumulator - Class in com.hazelcast.jet.accumulator

Mutable container of a long and a double value.

LongDoubleAccumulator() - Constructor for class com.hazelcast.jet.accumulator.LongDoubleAccumulator

Creates a new instance with values equal to 0.

LongDoubleAccumulator(long, double) - Constructor for class com.hazelcast.jet.accumulator.LongDoubleAccumulator

Creates a new instance with the specified value.

LongLongAccumulator - Class in com.hazelcast.jet.accumulator

Mutable container of two long values.

LongLongAccumulator() - Constructor for class com.hazelcast.jet.accumulator.LongLongAccumulator

Creates a new instance with values equal to 0.

LongLongAccumulator(long, long) - Constructor for class com.hazelcast.jet.accumulator.LongLongAccumulator

Creates a new instance with the specified value.

M

main(String[]) - Static method in class com.hazelcast.jet.server.JetBootstrap

Runs the supplied JAR file and sets the static jar file name

main(String[]) - Static method in class com.hazelcast.jet.server.StartServer

Creates a server instance of Hazelcast Jet.

map(DistributedFunction<? super E, ? extends R>) - Method in interface com.hazelcast.jet.ComputeStage

Attaches to this stage a mapping stage, one which applies the supplied function to each input item independently and emits the function's result as the output item.

map(DistributedFunction<? super T, ? extends U>) - Method in class com.hazelcast.jet.function.DistributedOptional

If a value is present, apply the provided mapping function to it, and if the result is non-null, return an Optional describing the result.

map(String) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that puts Map.Entrys it receives into a Hazelcast IMap with the specified name.

map(String) - Static method in class com.hazelcast.jet.Sources

Returns a source that fetches entries from a local Hazelcast IMap with the specified name and emits them as Map.Entry.

map(String, Predicate<K, V>, Projection<Map.Entry<K, V>, T>) - Static method in class com.hazelcast.jet.Sources

Returns a source that fetches entries from a local Hazelcast IMap with the specified name.

map(String, Predicate<K, V>, DistributedFunction<Map.Entry<K, V>, T>) - Static method in class com.hazelcast.jet.Sources

Convenience for Sources.map(String, Predicate, Projection) which uses a DistributedFunction as the projection function.

map(DistributedDoubleUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns a stream consisting of the results of applying the given function to the elements of this stream.

map(DoubleUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

map(DistributedIntUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a stream consisting of the results of applying the given function to the elements of this stream.

map(IntUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

map(DistributedLongUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a stream consisting of the results of applying the given function to the elements of this stream.

map(LongUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

map(DistributedFunction<? super T, ? extends R>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns a stream consisting of the results of applying the given function to the elements of this stream.

map(Function<? super T, ? extends R>) - Method in interface com.hazelcast.jet.stream.DistributedStream

map(Function<? super T, ? extends R>) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser traverser that will emit the results of applying the mapping function to this traverser's items.

mapJournal(String, DistributedPredicate<EventJournalMapEvent<K, V>>, DistributedFunction<EventJournalMapEvent<K, V>, T>, boolean) - Static method in class com.hazelcast.jet.Sources

Returns a source that will stream the EventJournalMapEvent events of the Hazelcast IMap with the specified name.

mapJournal(String, boolean) - Static method in class com.hazelcast.jet.Sources

Convenience for Sources.mapJournal(String, DistributedPredicate, DistributedFunction, boolean) with no projection or filtering.

mapP(DistributedFunction<T, R>) - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processors for a vertex which, for each received item, emits the result of applying the given mapping function to it.

mapping(DistributedFunction<? super T, ? extends U>, AggregateOperation1<? super U, A, R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Adapts an AggregateOperation1 accepting elements of type U to one accepting elements of type T by applying a mapping function to each input element before accumulation.

mapping(DistributedFunction<? super T, ? extends U>, DistributedCollector<? super U, A, R>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Adapts a DistributedCollector accepting elements of type U to one accepting elements of type T by applying a mapping function to each input element before accumulation.

mapToDouble(DistributedIntToDoubleFunction) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a DistributedDoubleStream consisting of the results of applying the given function to the elements of this stream.

mapToDouble(IntToDoubleFunction) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

mapToDouble(DistributedLongToDoubleFunction) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a DoubleStream consisting of the results of applying the given function to the elements of this stream.

mapToDouble(LongToDoubleFunction) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

mapToDouble(DistributedToDoubleFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns a DistributedDoubleStream consisting of the results of applying the given function to the elements of this stream.

mapToDouble(ToDoubleFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

mapToInt(DistributedDoubleToIntFunction) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns an IntStream consisting of the results of applying the given function to the elements of this stream.

mapToInt(DoubleToIntFunction) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

mapToInt(DistributedLongToIntFunction) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns an IntStream consisting of the results of applying the given function to the elements of this stream.

mapToInt(LongToIntFunction) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

mapToInt(DistributedToIntFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns an DistributedIntStream consisting of the results of applying the given function to the elements of this stream.

mapToInt(ToIntFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

mapToLong(DistributedDoubleToLongFunction) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns a LongStream consisting of the results of applying the given function to the elements of this stream.

mapToLong(DoubleToLongFunction) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

mapToLong(DistributedIntToLongFunction) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a DistributedLongStream consisting of the results of applying the given function to the elements of this stream.

mapToLong(IntToLongFunction) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

mapToLong(DistributedToLongFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns a DistributedLongStream consisting of the results of applying the given function to the elements of this stream.

mapToLong(ToLongFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

mapToObj(DistributedDoubleFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.

mapToObj(DoubleFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

mapToObj(DistributedIntFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns an object-valued DistributedStream consisting of the results of applying the given function to the elements of this stream.

mapToObj(IntFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

mapToObj(DistributedLongFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.

mapToObj(LongFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

max(DistributedComparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns the maximum element of this stream according to the provided DistributedComparator.

max(Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

maxBy(DistributedComparator<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation that returns the maximum item, according the given comparator.

maxBy(Comparator<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedBinaryOperator

Returns a DistributedBinaryOperator which returns the greater of two elements according to the specified Comparator.

maxBy(DistributedComparator<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that produces the maximal element according to a given DistributedComparator, described as an Optional<T>.

min(DistributedComparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns the minimum element of this stream according to the provided DistributedComparator.

min(Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

minBy(DistributedComparator<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation that returns the minimum item, according the given comparator.

minBy(Comparator<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedBinaryOperator

Returns a DistributedBinaryOperator which returns the lesser of two elements according to the specified Comparator.

minBy(DistributedComparator<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that produces the minimal element according to a given DistributedComparator, described as an Optional<T>.

MockData(Object) - Constructor for class com.hazelcast.jet.core.test.TestOutbox.MockData

Javadoc pending

MockSerializationService() - Constructor for class com.hazelcast.jet.core.test.TestOutbox.MockSerializationService

MutableReference<T> - Class in com.hazelcast.jet.accumulator

Mutable container of an object reference.

MutableReference() - Constructor for class com.hazelcast.jet.accumulator.MutableReference

Creates a new instance with a null value.

MutableReference(T) - Constructor for class com.hazelcast.jet.accumulator.MutableReference

Creates a new instance with the specified value.

N

name() - Method in interface com.hazelcast.jet.Sink

Returns the name of this sink.

name() - Method in interface com.hazelcast.jet.Source

Returns the name of this source.

naturalOrder() - Static method in interface com.hazelcast.jet.function.DistributedComparator

Returns a comparator that compares Comparable objects in natural order.

negate() - Method in interface com.hazelcast.jet.function.DistributedBiPredicate

Returns a predicate that represents the logical negation of this predicate.

negate() - Method in interface com.hazelcast.jet.function.DistributedDoublePredicate

Returns a predicate that represents the logical negation of this predicate.

negate() - Method in interface com.hazelcast.jet.function.DistributedIntPredicate

Returns a predicate that represents the logical negation of this predicate.

negate() - Method in interface com.hazelcast.jet.function.DistributedLongPredicate

Returns a predicate that represents the logical negation of this predicate.

negate() - Method in interface com.hazelcast.jet.function.DistributedPredicate

Returns a predicate that represents the logical negation of this predicate.

newJetClient() - Static method in class com.hazelcast.jet.Jet

Creates a Jet client with the default configuration.

newJetClient(ClientConfig) - Static method in class com.hazelcast.jet.Jet

Creates a Jet client with the given Hazelcast client configuration.

newJetInstance(JetConfig) - Static method in class com.hazelcast.jet.Jet

Creates a member of the Jet cluster with the given configuration.

newJetInstance() - Static method in class com.hazelcast.jet.Jet

Creates a member of the Jet cluster with the default configuration.

newJob(DAG) - Method in interface com.hazelcast.jet.JetInstance

Creates and returns a Jet job based on the supplied DAG.

newJob(DAG, JobConfig) - Method in interface com.hazelcast.jet.JetInstance

Creates and returns a Jet job based on the supplied DAG and job configuration.

newJob(Pipeline) - Method in interface com.hazelcast.jet.JetInstance

Creates and returns an executable job based on the supplied pipeline.

newJob(Pipeline, JobConfig) - Method in interface com.hazelcast.jet.JetInstance

Creates and returns a Jet job based on the supplied pipeline and job configuration.

newVertex(String, DistributedSupplier<? extends Processor>) - Method in class com.hazelcast.jet.core.DAG

Creates a vertex from a Supplier<Processor> and adds it to this DAG.

newVertex(String, ProcessorSupplier) - Method in class com.hazelcast.jet.core.DAG

Creates a vertex from a ProcessorSupplier and adds it to this DAG.

newVertex(String, ProcessorMetaSupplier) - Method in class com.hazelcast.jet.core.DAG

Creates a vertex from a ProcessorMetaSupplier and adds it to this DAG.

next() - Method in class com.hazelcast.jet.core.ResettableSingletonTraverser

next() - Method in interface com.hazelcast.jet.Traverser

Returns the next item in the sequence, or null if there is no next item to return.

nonCooperativeP(ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.processor.Processors

Decorates a processor meta-supplier with one that will declare all its processors non-cooperative.

nonCooperativeP(ProcessorSupplier) - Static method in class com.hazelcast.jet.core.processor.Processors

Decorates a ProcessorSupplier with one that will declare all its processors non-cooperative.

nonCooperativeP(DistributedSupplier<Processor>) - Static method in class com.hazelcast.jet.core.processor.Processors

Decorates a Supplier<Processor> into one that will declare its processors non-cooperative.

noneMatch(DistributedDoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns whether no elements of this stream match the provided predicate.

noneMatch(DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

noneMatch(DistributedIntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns whether no elements of this stream match the provided predicate.

noneMatch(IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

noneMatch(DistributedLongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns whether no elements of this stream match the provided predicate.

noneMatch(LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

noneMatch(DistributedPredicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns whether no elements of this stream match the provided predicate.

noneMatch(Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

noopConsumer() - Static method in class com.hazelcast.jet.function.DistributedFunctions

Returns a consumer that does nothing with the argument.

noopP() - Static method in class com.hazelcast.jet.core.processor.Processors

Returns a supplier of processor that consumes all its input (if any) and does nothing with it.

nullsFirst(Comparator<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

nullsFirst(DistributedComparator<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

nullsLast(Comparator<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

nullsLast(DistributedComparator<? super T>) - Static method in interface com.hazelcast.jet.function.DistributedComparator

O

of(ProcessorSupplier, int) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Factory method that wraps the given ProcessorSupplier and returns the same instance for each given Address.

of(ProcessorSupplier) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Wraps the provided ProcessorSupplier into a meta-supplier that will always return it.

of(DistributedSupplier<? extends Processor>, int) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Factory method that wraps the given Supplier<Processor> and uses it as the supplier of all Processor instances.

of(DistributedSupplier<? extends Processor>) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Factory method that wraps the given Supplier<Processor> and uses it as the supplier of all Processor instances.

of(DistributedFunction<Address, ProcessorSupplier>, int) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Factory method that creates a ProcessorMetaSupplier from the supplied function that maps a cluster member address to a ProcessorSupplier.

of(DistributedFunction<Address, ProcessorSupplier>) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Factory method that creates a ProcessorMetaSupplier from the supplied function that maps a cluster member address to a ProcessorSupplier.

of(DistributedSupplier<? extends Processor>) - Static method in interface com.hazelcast.jet.core.ProcessorSupplier

Returns a ProcessorSupplier which will delegate to the given Supplier<Processor> to create all Processor instances.

of(T) - Static method in class com.hazelcast.jet.function.DistributedOptional

Returns an Optional with the specified present non-null value.

of(DistributedSupplier<R>, DistributedBiConsumer<R, T>, DistributedBinaryOperator<R>, Collector.Characteristics...) - Static method in interface com.hazelcast.jet.stream.DistributedCollector

Returns a new DistributedCollector described by the given supplier, accumulator, and combiner functions.

of(DistributedSupplier<A>, DistributedBiConsumer<A, T>, DistributedBinaryOperator<A>, DistributedFunction<A, R>, Collector.Characteristics...) - Static method in interface com.hazelcast.jet.stream.DistributedCollector

Returns a new DistributedCollector described by the given supplier, accumulator, combiner, and finisher functions.

offer(int, Object) - Method in interface com.hazelcast.jet.core.Outbox

Offers the supplied item to the bucket with the supplied ordinal.

offer(int[], Object) - Method in interface com.hazelcast.jet.core.Outbox

Offers the item to all supplied edge ordinals.

offer(Object) - Method in interface com.hazelcast.jet.core.Outbox

Offers the item to all edges.

offer(int, Object) - Method in class com.hazelcast.jet.core.test.TestOutbox

offer(int[], Object) - Method in class com.hazelcast.jet.core.test.TestOutbox

offer(Object) - Method in class com.hazelcast.jet.core.test.TestOutbox

offerToSnapshot(Object, Object) - Method in interface com.hazelcast.jet.core.Outbox

Offers the given key and value pair to the processor's snapshot storage.

offerToSnapshot(Object, Object) - Method in class com.hazelcast.jet.core.test.TestOutbox

ofNullable(T) - Static method in class com.hazelcast.jet.function.DistributedOptional

Returns an Optional describing the specified value, if non-null, otherwise returns an empty Optional.

onFirstNull(Runnable) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser that will emit the same items as this traverser and additionally run the supplied action the first time this traverser returns null.

onKeys(DistributedFunction<E0, K>, DistributedFunction<E1, K>) - Static method in class com.hazelcast.jet.JoinClause

Constructs and returns a join clause with the supplied left-hand and right-hand key extractor functions, and with an identity right-hand projection function.

or(DistributedBiPredicate<? super T, ? super U>) - Method in interface com.hazelcast.jet.function.DistributedBiPredicate

Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.

or(DistributedDoublePredicate) - Method in interface com.hazelcast.jet.function.DistributedDoublePredicate

Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.

or(DistributedIntPredicate) - Method in interface com.hazelcast.jet.function.DistributedIntPredicate

Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.

or(DistributedLongPredicate) - Method in interface com.hazelcast.jet.function.DistributedLongPredicate

Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.

or(DistributedPredicate<? super T>) - Method in interface com.hazelcast.jet.function.DistributedPredicate

Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.

orElse(T) - Method in class com.hazelcast.jet.function.DistributedOptional

Return the value if present, otherwise return other.

orElseGet(DistributedSupplier<? extends T>) - Method in class com.hazelcast.jet.function.DistributedOptional

Return the value if present, otherwise invoke other and return the result of that invocation.

orElseThrow(DistributedSupplier<? extends X>) - Method in class com.hazelcast.jet.function.DistributedOptional

Return the contained value, if present, otherwise throw an exception to be created by the provided supplier.

Outbox - Interface in com.hazelcast.jet.core

Data sink for a Processor.

outputChecker(BiPredicate<? super List<?>, ? super List<?>>) - Method in class com.hazelcast.jet.core.test.TestSupport

Predicate to compare expected and actual output.

over(T...) - Static method in interface com.hazelcast.jet.Traverser

Returns a traverser over the supplied arguments (or item array).

P

parallel() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns an equivalent stream that is parallel.

parallel() - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns an equivalent stream that is parallel.

parallel() - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns an equivalent stream that is parallel.

parallel() - Method in interface com.hazelcast.jet.stream.DistributedStream

parallelStream() - Method in interface com.hazelcast.jet.stream.IStreamList

Returns a parallel Stream with this list as its source.

partitioned(DistributedFunction<T, ?>) - Method in class com.hazelcast.jet.core.Edge

Activates the PARTITIONED routing policy and applies the default Hazelcast partitioning strategy.

partitioned(DistributedFunction<T, K>, Partitioner<? super K>) - Method in class com.hazelcast.jet.core.Edge

Activates the PARTITIONED routing policy and applies the provided partitioning strategy.

Partitioner<T> - Interface in com.hazelcast.jet.core

Encapsulates the logic associated with a DAG edge that decides on the partition ID of an item traveling over it.

Partitioner.Default - Class in com.hazelcast.jet.core

Partitioner which applies the default Hazelcast partitioning strategy.

partitioningBy(DistributedPredicate<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector which partitions the input elements according to a DistributedPredicate, and organizes them into a Map<Boolean, List<T>>.

partitioningBy(DistributedPredicate<? super T>, DistributedCollector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector which partitions the input elements according to a DistributedPredicate, reduces the values in each partition according to another DistributedCollector, and organizes them into a Map<Boolean, D> whose values are the result of the downstream reduction.

peek(DistributedPredicate<? super E>, DistributedFunction<? super E, String>) - Method in interface com.hazelcast.jet.ComputeStage

Adds a peeking layer to this compute stage which logs its output.

peek(DistributedFunction<? super E, String>) - Method in interface com.hazelcast.jet.ComputeStage

Adds a peeking layer to this compute stage which logs its output.

peek() - Method in interface com.hazelcast.jet.ComputeStage

Adds a peeking layer to this compute stage which logs its output.

peek() - Method in interface com.hazelcast.jet.core.Inbox

Retrieves, but does not remove, the head of this inbox, or returns null if it is empty.

peek(DistributedDoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

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.

peek(DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

peek(DistributedIntConsumer) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

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.

peek(IntConsumer) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

peek(DistributedLongConsumer) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

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.

peek(LongConsumer) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

peek(DistributedConsumer<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

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.

peek(Consumer<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

peek(Consumer<? super T>) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser that will emit the same items as this traverser, additionally passing each (non-null) item to the supplied consumer.

peekInputP(DistributedFunction<T, String>, DistributedPredicate<T>, ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates.

peekInputP(DistributedFunction<T, String>, DistributedPredicate<T>, ProcessorSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.

peekInputP(DistributedFunction<T, String>, DistributedPredicate<T>, DistributedSupplier<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a DistributedSupplier of processors instead of a meta-supplier.

peekInputP(ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekInput(toStringFn, shouldLogFn, metaSupplier) with a pass-through filter and Object#toString as the formatting function.

peekInputP(ProcessorSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekInput(toStringFn, shouldLogFn, metaSupplier) with a pass-through filter and Object#toString as the formatting function.

peekInputP(DistributedSupplier<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekInput(toStringFn, shouldLogFn, metaSupplier) with a pass-through filter and Object#toString as the formatting function.

peekOutputP(DistributedFunction<T, String>, DistributedPredicate<T>, ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates.

peekOutputP(DistributedFunction<T, String>, DistributedPredicate<T>, ProcessorSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.

peekOutputP(DistributedFunction<T, String>, DistributedPredicate<T>, DistributedSupplier<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a DistributedSupplier of processors instead of a meta-supplier.

peekOutputP(ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekOutput(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function.

peekOutputP(ProcessorSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekOutput(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function.

peekOutputP(DistributedSupplier<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekOutput(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function.

peekSnapshotP(DistributedFunction<Map.Entry<K, V>, String>, DistributedPredicate<Map.Entry<K, V>>, ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates.

peekSnapshotP(DistributedFunction<Map.Entry<K, V>, String>, DistributedPredicate<Map.Entry<K, V>>, ProcessorSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Same as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.

peekSnapshotP(DistributedFunction<Map.Entry<K, V>, String>, DistributedPredicate<Map.Entry<K, V>>, DistributedSupplier<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Same as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a DistributedSupplier of processors instead of a meta-supplier.

peekSnapshotP(DistributedSupplier<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekSnapshot(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function.

peekSnapshotP(ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekSnapshot(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function.

peekSnapshotP(ProcessorSupplier) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for peekSnapshot(toStringFn, shouldLogFn, metaSupplier with a pass-through filter and Object#toString as the formatting function.

Pipeline - Interface in com.hazelcast.jet

Models a distributed computation job using an analogy with a system of interconnected water pipes.

poll() - Method in interface com.hazelcast.jet.core.Inbox

Retrieves and removes the head of this inbox, or returns null if it is empty.

preferredLocalParallelism() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier

Returns the local parallelism the vertex should be configured with.

prepend(T) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser which prepends an additional item in front of all the items of this traverser.

priority(int) - Method in class com.hazelcast.jet.core.Edge

Sets the priority of the edge.

process(int, Inbox) - Method in class com.hazelcast.jet.core.AbstractProcessor

Implements the boilerplate of dispatching against the ordinal, taking items from the inbox one by one, and invoking the processing logic on each.

process(int, Inbox) - Method in interface com.hazelcast.jet.core.Processor

Called with a batch of items retrieved from an inbound edge's stream.

ProcessingGuarantee - Enum in com.hazelcast.jet.config

Defines what message processing guarantees are given under failure conditions.

processingGuarantee() - Method in interface com.hazelcast.jet.core.Processor.Context

Returns the guarantee for current job.

processingGuarantee() - Method in class com.hazelcast.jet.core.test.TestProcessorContext

Processor - Interface in com.hazelcast.jet.core

When Jet executes a DAG, it creates one or more instances of Processor on each cluster member to do the work of a given vertex.

Processor.Context - Interface in com.hazelcast.jet.core

Context passed to the processor in the init() call.

ProcessorMetaSupplier - Interface in com.hazelcast.jet.core

Factory of ProcessorSupplier instances.

ProcessorMetaSupplier.Context - Interface in com.hazelcast.jet.core

Context passed to the meta-supplier at init time on the member that received a job request from the client.

Processors - Class in com.hazelcast.jet.core.processor

Static utility class with factory methods for Jet processors.

ProcessorSupplier - Interface in com.hazelcast.jet.core

Factory of Processor instances.

ProcessorSupplier.Context - Interface in com.hazelcast.jet.core

Context passed to the supplier in the init() call.

projecting(DistributedFunction<E1, E1_NEW_OUT>) - Method in class com.hazelcast.jet.JoinClause

Returns a copy of this join clause, but with the right-hand projection function replaced with the supplied one.

put(Tag<E>, E) - Method in class com.hazelcast.jet.datamodel.ItemsByTag

Associates the supplied value with the supplied tag.

Q

queueWithOrdinal(int) - Method in class com.hazelcast.jet.core.test.TestOutbox

Exposes individual buckets to the testing code.

R

readCacheP(String) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.cache(String).

readData(ObjectDataInput) - Method in class com.hazelcast.jet.core.DAG

readData(ObjectDataInput) - Method in class com.hazelcast.jet.core.Edge

readData(ObjectDataInput) - Method in class com.hazelcast.jet.core.Vertex

readFilesP(String, Charset, String) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.files(String, Charset, String).

readHdfsP(JobConf, DistributedBiFunction<K, V, R>) - Static method in class com.hazelcast.jet.core.processor.HdfsProcessors

Returns a supplier of processors for HdfsSources.hdfs(JobConf, DistributedBiFunction).

readListP(String) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.list(String).

readMapP(String) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.map(String).

readMapP(String, Predicate<K, V>, Projection<Map.Entry<K, V>, T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.map(String, Predicate, Projection)}.

readMapP(String, Predicate<K, V>, DistributedFunction<Map.Entry<K, V>, T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.map(String, Predicate, DistributedFunction)}.

readRemoteCacheP(String, ClientConfig) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteCache(String, ClientConfig).

readRemoteListP(String, ClientConfig) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteList(String, ClientConfig).

readRemoteMapP(String, ClientConfig) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteMap(String, ClientConfig).

readRemoteMapP(String, ClientConfig, Predicate<K, V>, Projection<Map.Entry<K, V>, T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteMap(String, ClientConfig, Predicate, Projection).

readRemoteMapP(String, ClientConfig, Predicate<K, V>, DistributedFunction<Map.Entry<K, V>, T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteMap(String, ClientConfig, Predicate, DistributedFunction).

reduce(StreamContext, Pipe<? extends T>) - Method in interface com.hazelcast.jet.stream.DistributedCollector.Reducer

Executes the reducer with the given context and upstream pipeline.

reduce(double, DistributedDoubleBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Performs a reduction on the elements of this stream, using the provided identity value and an associative accumulation function, and returns the reduced value.

reduce(DistributedDoubleBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Performs a reduction on the elements of this stream, using an associative accumulation function, and returns an OptionalDouble describing the reduced value, if any.

reduce(double, DoubleBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

reduce(DoubleBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

reduce(int, DistributedIntBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Performs a reduction on the elements of this stream, using the provided identity value and an associative accumulation function, and returns the reduced value.

reduce(DistributedIntBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Performs a reduction on the elements of this stream, using an associative accumulation function, and returns an OptionalInt describing the reduced value, if any.

reduce(int, IntBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

reduce(IntBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

reduce(long, DistributedLongBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Performs a reduction on the elements of this stream, using the provided identity value and an associative accumulation function, and returns the reduced value.

reduce(DistributedLongBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Performs a reduction on the elements of this stream, using an associative accumulation function, and returns an OptionalLong describing the reduced value, if any.

reduce(long, LongBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

reduce(LongBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

reduce(T, DistributedBinaryOperator<T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Performs a reduction on the elements of this stream, using the provided identity value and an associative accumulation function, and returns the reduced value.

reduce(DistributedBinaryOperator<T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Performs a reduction on the elements of this stream, using an associative accumulation function, and returns an Optional describing the reduced value, if any.

reduce(U, DistributedBiFunction<U, ? super T, U>, DistributedBinaryOperator<U>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Performs a reduction on the elements of this stream, using the provided identity, accumulation and combining functions.

reduce(T, BinaryOperator<T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

reduce(BinaryOperator<T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

reduce(U, BiFunction<U, ? super T, U>, BinaryOperator<U>) - Method in interface com.hazelcast.jet.stream.DistributedStream

reducing(A, DistributedFunction<? super T, ? extends A>, DistributedBinaryOperator<A>, DistributedBinaryOperator<A>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

A reducing operation maintains an accumulated value that starts out as emptyAccValue and is being iteratively transformed by applying the combine primitive to it and each stream item's accumulated value, as returned from toAccValueFn.

reducing(T, DistributedBinaryOperator<T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector which performs a reduction of its input elements under a specified DistributedBinaryOperator using the provided identity.

reducing(DistributedBinaryOperator<T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector which performs a reduction of its input elements under a specified DistributedBinaryOperator.

reducing(U, DistributedFunction<? super T, ? extends U>, DistributedBinaryOperator<U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector which performs a reduction of its input elements under a specified mapping function and DistributedBinaryOperator.

remoteCache(String, ClientConfig) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that puts Map.Entrys it receives into a Hazelcast ICache with the specified name in a remote cluster identified by the supplied ClientConfig.

remoteCache(String, ClientConfig) - Static method in class com.hazelcast.jet.Sources

Returns a source that fetches entries from the Hazelcast ICache with the specified name in a remote cluster identified by the supplied ClientConfig and emits them as Map.Entry.

remoteCacheJournal(String, ClientConfig, DistributedPredicate<EventJournalCacheEvent<K, V>>, DistributedFunction<EventJournalCacheEvent<K, V>, T>, boolean) - Static method in class com.hazelcast.jet.Sources

Returns a source that will stream the EventJournalCacheEvent events of the Hazelcast ICache with the specified name from a remote cluster.

remoteCacheJournal(String, ClientConfig, boolean) - Static method in class com.hazelcast.jet.Sources

Convenience for Sources.remoteCacheJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, boolean) with no projection or filtering.

remoteList(String, ClientConfig) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that adds the items it receives to a Hazelcast IList with the specified name in a remote cluster identified by the supplied ClientConfig.

remoteList(String, ClientConfig) - Static method in class com.hazelcast.jet.Sources

Returns a source that emits items retrieved from a Hazelcast IList in a remote cluster identified by the supplied ClientConfig.

remoteMap(String, ClientConfig) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that puts Map.Entrys it receives into a Hazelcast IMap with the specified name in a remote cluster identified by the supplied ClientConfig.

remoteMap(String, ClientConfig) - Static method in class com.hazelcast.jet.Sources

Returns a source that fetches entries from the Hazelcast IMap with the specified name in a remote cluster identified by the supplied ClientConfig and emits them as Map.Entry.

remoteMap(String, ClientConfig, Predicate<K, V>, Projection<Map.Entry<K, V>, T>) - Static method in class com.hazelcast.jet.Sources

Returns a source that fetches entries from a remote Hazelcast IMap with the specified name in a remote cluster identified by the supplied ClientConfig.

remoteMap(String, ClientConfig, Predicate<K, V>, DistributedFunction<Map.Entry<K, V>, T>) - Static method in class com.hazelcast.jet.Sources

Convenience for Sources.remoteMap(String, ClientConfig, Predicate, Projection) which use a DistributedFunction as the projection function.

remoteMapJournal(String, ClientConfig, DistributedPredicate<EventJournalMapEvent<K, V>>, DistributedFunction<EventJournalMapEvent<K, V>, T>, boolean) - Static method in class com.hazelcast.jet.Sources

Returns a source that will stream the EventJournalMapEvent events of the Hazelcast IMap with the specified name from a remote cluster.

remoteMapJournal(String, ClientConfig, boolean) - Static method in class com.hazelcast.jet.Sources

Convenience for Sources.remoteMapJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, boolean) with no projection or filtering.

remove() - Method in interface com.hazelcast.jet.core.Inbox

Retrieves and removes the head of this inbox.

reportEvent(long) - Method in interface com.hazelcast.jet.core.WatermarkPolicy

Called to report the observation of an event with the given timestamp.

ResettableSingletonTraverser<T> - Class in com.hazelcast.jet.core

Traverses over a single item which can be set from the outside, by using this traverser as a Consumer<T>.

ResettableSingletonTraverser() - Constructor for class com.hazelcast.jet.core.ResettableSingletonTraverser

ResourceConfig - Class in com.hazelcast.jet.config

Describes a single resource to deploy to the Jet cluster.

restoreFromSnapshot(Inbox) - Method in class com.hazelcast.jet.core.AbstractProcessor

Implements the boilerplate of polling the inbox, casting the items to Map.Entry, and extracting the key and value.

restoreFromSnapshot(Object, Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Called to restore one key-value pair from the snapshot to processor's internal state.

restoreFromSnapshot(Inbox) - Method in interface com.hazelcast.jet.core.Processor

Called when a batch of items is received during the "restore from snapshot" operation.

reversed() - Method in interface com.hazelcast.jet.function.DistributedComparator

reverseOrder() - Static method in interface com.hazelcast.jet.function.DistributedComparator

Returns a comparator that imposes the reverse of the natural ordering.

rightKeyFn() - Method in class com.hazelcast.jet.JoinClause

Returns the right-hand key extractor function.

rightProjectFn() - Method in class com.hazelcast.jet.JoinClause

Returns the right-hand projection function.

S

saveToSnapshot() - Method in interface com.hazelcast.jet.core.Processor

Stores its snapshotted state by adding items to the outbox's snapshot bucket.

sequential() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns an equivalent stream that is sequential.

sequential() - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns an equivalent stream that is sequential.

sequential() - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns an equivalent stream that is sequential.

sequential() - Method in interface com.hazelcast.jet.stream.DistributedStream

Session<K,R> - Class in com.hazelcast.jet.datamodel

Holds the aggregated result of a session window.

Session(K, long, long, R) - Constructor for class com.hazelcast.jet.datamodel.Session

set(double) - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator

Sets the value as given.

set(long) - Method in class com.hazelcast.jet.accumulator.LongAccumulator

Sets the value as given.

set(T) - Method in class com.hazelcast.jet.accumulator.MutableReference

Sets the value as given.

setAutoRestartOnMemberFailure(boolean) - Method in class com.hazelcast.jet.config.JobConfig

Sets whether the job should automatically restart after a participating member leaves the cluster.

setBackupCount(int) - Method in class com.hazelcast.jet.config.InstanceConfig

Sets the number of synchronous backups for storing job metadata and snapshots.

setConfig(EdgeConfig) - Method in class com.hazelcast.jet.core.Edge

Assigns an EdgeConfig to this edge.

setCooperative(boolean) - Method in class com.hazelcast.jet.core.AbstractProcessor

Specifies what this processor's AbstractProcessor.isCooperative() method will return.

setCooperativeThreadCount(int) - Method in class com.hazelcast.jet.config.InstanceConfig

Sets the number of threads each cluster member will use to execute Jet jobs.

setDefaultEdgeConfig(EdgeConfig) - Method in class com.hazelcast.jet.config.JetConfig

Sets the configuration object that specifies the defaults to use for a DAG edge configuration.

setFlowControlPeriodMs(int) - Method in class com.hazelcast.jet.config.InstanceConfig

While executing a Jet job there is the issue of regulating the rate at which one member of the cluster sends data to another member.

setGlobalProcessorIndex(int) - Method in class com.hazelcast.jet.core.test.TestProcessorContext

Set the global processor index

setHazelcastConfig(Config) - Method in class com.hazelcast.jet.config.JetConfig

Sets the underlying IMDG instance's configuration object.

setInstanceConfig(InstanceConfig) - Method in class com.hazelcast.jet.config.JetConfig

Sets the Jet instance config.

setJetInstance(JetInstance) - Method in class com.hazelcast.jet.core.test.TestProcessorContext

Set the jet instance.

setJetInstance(JetInstance) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

Set the jet instance.

setJetInstance(JetInstance) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext

Set the jet instance.

setLocalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

Set local parallelism.

setLocalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext

Set local parallelism.

setLogger(ILogger) - Method in class com.hazelcast.jet.core.test.TestProcessorContext

Set the logger.

setPacketSizeLimit(int) - Method in class com.hazelcast.jet.config.EdgeConfig

For a distributed edge, data is sent to a remote member via Hazelcast network packets.

setProcessingGuarantee(ProcessingGuarantee) - Method in class com.hazelcast.jet.config.JobConfig

Set the processing guarantee for the job.

setProcessingGuarantee(ProcessingGuarantee) - Method in class com.hazelcast.jet.core.test.TestProcessorContext

Sets the processing guarantee.

setProperties(Properties) - Method in class com.hazelcast.jet.config.JetConfig

Sets the Jet-specific configuration properties.

setQueueSize(int) - Method in class com.hazelcast.jet.config.EdgeConfig

Sets the capacity of processor-to-processor concurrent queues.

setReceiveWindowMultiplier(int) - Method in class com.hazelcast.jet.config.EdgeConfig

Sets the scaling factor used by the adaptive receive window sizing function.

setSnapshotIntervalMillis(long) - Method in class com.hazelcast.jet.config.JobConfig

Sets the snapshot interval in milliseconds — the interval between the completion of the previous snapshot and the start of a new one.

setSplitBrainProtection(boolean) - Method in class com.hazelcast.jet.config.JobConfig

Configures the split brain protection feature.

setTempDir(String) - Method in class com.hazelcast.jet.config.InstanceConfig

Sets the directory where Jet can place its temporary working directories.

setTotalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

Set total parallelism.

setValue(V) - Method in class com.hazelcast.jet.datamodel.TimestampedEntry

setValue(E1) - Method in class com.hazelcast.jet.datamodel.Tuple2

setValue1(long) - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator

Sets the value1.

setValue1(long) - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator

Sets the value1.

setValue2(double) - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator

Sets the value2.

setValue2(long) - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator

Sets the value2.

setVertexName(String) - Method in class com.hazelcast.jet.core.test.TestProcessorContext

Set the vertex name.

shouldEmit(long, long) - Method in interface com.hazelcast.jet.core.WatermarkEmissionPolicy

Decides whether a watermark item with the supplied currentWm value should be emitted, given the last emitted value lastEmittedWm.

shutdown() - Method in interface com.hazelcast.jet.JetInstance

Shutdowns the current instance.

shutdownAll() - Static method in class com.hazelcast.jet.Jet

Shuts down all running Jet client and member instances.

Sink<E> - Interface in com.hazelcast.jet

A transform which accepts an input stream and produces no output streams.

SinkProcessors - Class in com.hazelcast.jet.core.processor

Static utility class with factories of sink processors (the terminators of the DAG data flow).

Sinks - Class in com.hazelcast.jet

Contains factory methods for various types of pipeline sinks.

SinkStage - Interface in com.hazelcast.jet

A pipeline stage that doesn't allow any downstream stages to be attached to it.

skip(long) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns a stream consisting of the remaining elements of this stream after discarding the first n elements of the stream.

skip(long) - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a stream consisting of the remaining elements of this stream after discarding the first n elements of the stream.

skip(long) - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a stream consisting of the remaining elements of this stream after discarding the first n elements of the stream.

skip(long) - Method in interface com.hazelcast.jet.stream.DistributedStream

slidingWindowDef(long, long) - Static method in class com.hazelcast.jet.core.WindowDefinition

Returns the definition of a sliding window of length windowLength that slides by slideBy.

snapshotQueue() - Method in class com.hazelcast.jet.core.test.TestOutbox

Returns the queue to which snapshot is written.

snapshottingEnabled() - Method in interface com.hazelcast.jet.core.Processor.Context

Returns true, if snapshots will be saved for this job.

socket(String, int, DistributedFunction<E, String>, Charset) - Static method in class com.hazelcast.jet.Sinks

Returns a sink that connects to the specified TCP socket and writes to it a string representation of the items it receives.

socket(String, int, DistributedFunction<E, String>) - Static method in class com.hazelcast.jet.Sinks

Convenience for Sinks.socket(String, int, DistributedFunction, Charset) with UTF-8 as the charset.

socket(String, int) - Static method in class com.hazelcast.jet.Sinks

Convenience for Sinks.socket(String, int, DistributedFunction, Charset) with Object.toString as the conversion function and UTF-8 as the charset.

socket(String, int, Charset) - Static method in class com.hazelcast.jet.Sources

Returns a source which connects to the specified socket and emits lines of text received from it.

sorted() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream

Returns a stream consisting of the elements of this stream in sorted order.

sorted() - Method in interface com.hazelcast.jet.stream.DistributedIntStream

Returns a stream consisting of the elements of this stream in sorted order.

sorted() - Method in interface com.hazelcast.jet.stream.DistributedLongStream

Returns a stream consisting of the elements of this stream in sorted order.

sorted() - Method in interface com.hazelcast.jet.stream.DistributedStream

sorted(DistributedComparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Returns a stream consisting of the elements of this stream, sorted according to the provided Comparator.

sorted(Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

Source<E> - Interface in com.hazelcast.jet

A transform that takes no input streams and produces an output stream.

SourceProcessors - Class in com.hazelcast.jet.core.processor

Static utility class with factories of source processors (the DAG entry points).

Sources - Class in com.hazelcast.jet

Contains factory methods for various types of pipeline sources.

Stage - Interface in com.hazelcast.jet

The basic element of a Jet pipeline.

StartServer - Class in com.hazelcast.jet.server

Main class that starts a Hazelcast Jet instance.

stream() - Method in interface com.hazelcast.jet.stream.IStreamCache

Returns a parallel and distributed Stream with this list as its source.

stream() - Method in interface com.hazelcast.jet.stream.IStreamList

Returns a sequential Stream with this list as its source.

stream() - Method in interface com.hazelcast.jet.stream.IStreamMap

Returns a parallel and distributed Stream with this map as its source.

stream(Predicate<K, V>, DistributedFunction<Map.Entry<K, V>, T>) - Method in interface com.hazelcast.jet.stream.IStreamMap

Returns a parallel and distributed Stream with this map as its source.

streamCacheP(String, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.cacheJournal(String, boolean).

streamCacheP(String, DistributedPredicate<EventJournalCacheEvent<K, V>>, DistributedFunction<EventJournalCacheEvent<K, V>, T>, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, boolean).

streamFilesP(String, Charset, String) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.fileWatcher(String, Charset, String).

streamKafkaP(Properties, DistributedBiFunction<K, V, T>, String...) - Static method in class com.hazelcast.jet.core.processor.KafkaProcessors

Returns a supplier of processors for KafkaSources.kafka(Properties, DistributedBiFunction, String...).

streamKafkaP(Properties, String...) - Static method in class com.hazelcast.jet.core.processor.KafkaProcessors

Returns a supplier of processors for KafkaSources.kafka(Properties, String...).

streamMapP(String, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.mapJournal(String, boolean).

streamMapP(String, DistributedPredicate<EventJournalMapEvent<K, V>>, DistributedFunction<EventJournalMapEvent<K, V>, T>, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.mapJournal(String, DistributedPredicate, DistributedFunction, boolean).

streamRemoteCacheP(String, ClientConfig, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteCacheJournal(String, ClientConfig, boolean).

streamRemoteCacheP(String, ClientConfig, DistributedPredicate<EventJournalCacheEvent<K, V>>, DistributedFunction<EventJournalCacheEvent<K, V>, T>, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteCacheJournal( String, ClientConfig, DistributedPredicate, DistributedFunction, boolean ).

streamRemoteMapP(String, ClientConfig, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteMapJournal(String, ClientConfig, boolean).

streamRemoteMapP(String, ClientConfig, DistributedPredicate<EventJournalMapEvent<K, V>>, DistributedFunction<EventJournalMapEvent<K, V>, T>, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.remoteMapJournal( String, ClientConfig, DistributedPredicate, DistributedFunction, boolean ).

streamSocketP(String, int, Charset) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors

Returns a supplier of processors for Sources.socket(String, int, Charset).

subtract(DoubleAccumulator) - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator

Subtracts the value of the supplied accumulator from this one.

subtract(LongAccumulator) - Method in class com.hazelcast.jet.accumulator.LongAccumulator

Subtracts the value of the supplied accumulator from this one.

subtractExact(LongAccumulator) - Method in class com.hazelcast.jet.accumulator.LongAccumulator

Uses Math.subtractExact() to subtract the value of the supplied accumulator from this one.

summarizingDouble(DistributedToDoubleFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector which applies an double-producing mapping function to each input element, and returns summary statistics for the resulting values.

summarizingInt(DistributedToIntFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector which applies an int-producing mapping function to each input element, and returns summary statistics for the resulting values.

summarizingLong(DistributedToLongFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector which applies an long-producing mapping function to each input element, and returns summary statistics for the resulting values.

summingDouble(DistributedToDoubleFunction<T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation that tracks the sum of the quantity returned by getDoubleValueFn applied to each item in the window.

summingDouble(DistributedToDoubleFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that produces the sum of a double-valued function applied to the input elements.

summingInt(DistributedToIntFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that produces the sum of a integer-valued function applied to the input elements.

summingLong(DistributedToLongFunction<T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an operation that tracks the sum of the quantity returned by getLongValueFn applied to each item in the window.

summingLong(DistributedToLongFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that produces the sum of a long-valued function applied to the input elements.

supplier() - Method in interface com.hazelcast.jet.stream.DistributedCollector

A function that creates and returns a new mutable result container.

supplierFrom(ProcessorSupplier) - Static method in class com.hazelcast.jet.core.test.TestSupport

Wraps the provided ProcessorSupplier with a Supplier<Processor> that returns processors obtained from it.

supplierFrom(ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.test.TestSupport

Wraps the provided ProcessorMetaSupplier with a Supplier<Processor> that returns processors obtained from it.

suppressDuplicates() - Static method in interface com.hazelcast.jet.core.WatermarkEmissionPolicy

Returns a policy that ensures that each emitted watermark has a higher timestamp than the last one.

T

Tag<T> - Class in com.hazelcast.jet.datamodel

A tag object useful as a key in heterogeneous maps.

tag(int) - Static method in class com.hazelcast.jet.datamodel.Tag

Returns a tag object associated with the specified index.

tag0() - Method in class com.hazelcast.jet.CoGroupBuilder

Returns the tag referring to the 0-indexed contributing pipeline stage, the one from which this builder was obtained.

tag0() - Static method in class com.hazelcast.jet.datamodel.Tag

Returns the tag constant Tag.TAG_0.

tag1() - Static method in class com.hazelcast.jet.datamodel.Tag

Returns the tag constant Tag.TAG_1.

tag2() - Static method in class com.hazelcast.jet.datamodel.Tag

Returns the tag constant Tag.TAG_2.

takeWhile(Predicate<? super T>) - Method in interface com.hazelcast.jet.Traverser

Returns a traverser that will emit a prefix of the original traverser, up to the item for which the predicate fails (exclusive).

TestInbox - Class in com.hazelcast.jet.core.test

Extends ArrayDeque to implement Inbox.

TestInbox() - Constructor for class com.hazelcast.jet.core.test.TestInbox

TestOutbox - Class in com.hazelcast.jet.core.test

Implements Outbox with an array of ArrayDeques.

TestOutbox(int...) - Constructor for class com.hazelcast.jet.core.test.TestOutbox

TestOutbox(int[], int) - Constructor for class com.hazelcast.jet.core.test.TestOutbox

TestOutbox.MockData - Class in com.hazelcast.jet.core.test

Javadoc pending

TestOutbox.MockSerializationService - Class in com.hazelcast.jet.core.test

Javadoc pending

TestProcessorContext - Class in com.hazelcast.jet.core.test

Simple implementation of Processor.Context.

TestProcessorContext() - Constructor for class com.hazelcast.jet.core.test.TestProcessorContext

Constructor with default values.

TestProcessorMetaSupplierContext - Class in com.hazelcast.jet.core.test

Simple implementation of ProcessorMetaSupplier.Context.

TestProcessorMetaSupplierContext() - Constructor for class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

TestProcessorSupplierContext - Class in com.hazelcast.jet.core.test

Simple implementation of ProcessorSupplier.Context.

TestProcessorSupplierContext() - Constructor for class com.hazelcast.jet.core.test.TestProcessorSupplierContext

TestSupport - Class in com.hazelcast.jet.core.test

A utility to test processors.

thenComparing(Comparator<? super T>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparing(DistributedComparator<? super T>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparing(Function<? super T, ? extends U>, Comparator<? super U>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparing(DistributedFunction<? super T, ? extends U>, DistributedComparator<? super U>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparing(Function<? super T, ? extends U>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparing(DistributedFunction<? super T, ? extends U>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparingDouble(ToDoubleFunction<? super T>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparingDouble(DistributedToDoubleFunction<? super T>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparingInt(ToIntFunction<? super T>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparingInt(DistributedToIntFunction<? super T>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparingLong(ToLongFunction<? super T>) - Method in interface com.hazelcast.jet.function.DistributedComparator

thenComparingLong(DistributedToLongFunction<? super T>) - Method in interface com.hazelcast.jet.function.DistributedComparator

ThreeBags<E0,E1,E2> - Class in com.hazelcast.jet.datamodel

A container of three bags (collections), each with its own element type.

threeBags() - Static method in class com.hazelcast.jet.datamodel.ThreeBags

Returns a new, empty ThreeBags container.

threeBags(Collection<E0>, Collection<E1>, Collection<E2>) - Static method in class com.hazelcast.jet.datamodel.ThreeBags

Returns a new ThreeBags container populated with the supplied collections.

timestamp() - Method in class com.hazelcast.jet.core.Watermark

Returns the timestamp of this watermark item.

TimestampedEntry<K,V> - Class in com.hazelcast.jet.datamodel

A Map.Entry extended with a long timestamp, used for event time-based data processing.

TimestampedEntry(long, K, V) - Constructor for class com.hazelcast.jet.datamodel.TimestampedEntry

Constructs a timestamped entry with the supplied field values.

TimestampKind - Enum in com.hazelcast.jet.core

Enumerates the two possible kinds of timestamp: event timestamp and frame timestamp.

to(Vertex) - Method in class com.hazelcast.jet.core.Edge

Sets the destination vertex of this edge, with ordinal 0.

to(Vertex, int) - Method in class com.hazelcast.jet.core.Edge

Sets the destination vertex and ordinal of this edge.

toByteArray() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

toCollection(DistributedSupplier<C>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an AggregateOperation1 that accumulates the input elements into a new Collection.

toCollection(DistributedSupplier<C>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that accumulates the input elements into a new Collection, in encounter order.

toDag() - Method in interface com.hazelcast.jet.Pipeline

Transforms the pipeline into a Jet DAG, which can be submitted for execution to a Jet instance.

toData(Object) - Method in class com.hazelcast.jet.core.test.TestOutbox.MockSerializationService

toData(Object, PartitioningStrategy) - Method in class com.hazelcast.jet.core.test.TestOutbox.MockSerializationService

toICache(String, DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer that accumulates elements into a new Hazelcast ICache whose keys and values are the result of applying the provided mapping functions to the input elements.

toICache(String) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer that accumulates elements into a new distributed Hazelcast ICache whose keys and values are the keys and values of the corresponding Cache.Entry.

toICache(String, DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>, DistributedBinaryOperator<U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer that accumulates elements into a new distributed Hazelcast ICache whose keys and values are the result of applying the provided mapping functions to the input elements.

toIList(String) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer that accumulates the input elements into a new Hazelcast IList.

toIMap(String, DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer that accumulates elements into a new Hazelcast IMap whose keys and values are the result of applying the provided mapping functions to the input elements.

toIMap(String) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer that accumulates elements into a new distributed Hazelcast IMap whose keys and values are the keys and values of the corresponding Map.Entry.

toIMap(String, DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>, DistributedBinaryOperator<U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a Reducer that accumulates elements into a new distributed Hazelcast IMap whose keys and values are the result of applying the provided mapping functions to the input elements.

toList() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an AggregateOperation1 that accumulates the input elements into a new ArrayList.

toList() - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that accumulates the input elements into a new List.

toMap(DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an AggregateOperation1 that accumulates elements into a HashMap whose keys and values are the result of applying the provided mapping functions to the input elements.

toMap(DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>, DistributedBinaryOperator<U>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an AggregateOperation1 that accumulates elements into a HashMap whose keys and values are the result of applying the provided mapping functions to the input elements.

toMap(DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>, DistributedBinaryOperator<U>, DistributedSupplier<M>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an AggregateOperation1 that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.

toMap(DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.

toMap(DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>, DistributedBinaryOperator<U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.

toMap(DistributedFunction<? super T, ? extends K>, DistributedFunction<? super T, ? extends U>, DistributedBinaryOperator<U>, DistributedSupplier<M>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.

toObject(Object) - Method in class com.hazelcast.jet.core.test.TestOutbox.MockSerializationService

toObject(Object, Class) - Method in class com.hazelcast.jet.core.test.TestOutbox.MockSerializationService

TopologyChangedException - Exception in com.hazelcast.jet.core

Thrown when a topology change causes a job to abort.

TopologyChangedException() - Constructor for exception com.hazelcast.jet.core.TopologyChangedException

Creates the exception

TopologyChangedException(String) - Constructor for exception com.hazelcast.jet.core.TopologyChangedException

Creates the exception with a message.

TopologyChangedException(String, Throwable) - Constructor for exception com.hazelcast.jet.core.TopologyChangedException

Creates the exception with a message and a cause.

toSet() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations

Returns an AggregateOperation1 that accumulates the input elements into a new HashSet.

toSet() - Static method in class com.hazelcast.jet.stream.DistributedCollectors

Returns a DistributedCollector that accumulates the input elements into a new Set.

toString() - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator

toString() - Method in class com.hazelcast.jet.accumulator.LongAccumulator

toString() - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator

toString() - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator

toString() - Method in class com.hazelcast.jet.accumulator.MutableReference

toString() - Method in class com.hazelcast.jet.config.ResourceConfig

toString() - Method in class com.hazelcast.jet.core.DAG

toString() - Method in class com.hazelcast.jet.core.Edge

toString() - Method in class com.hazelcast.jet.core.test.TestOutbox

toString() - Method in class com.hazelcast.jet.core.Vertex

toString() - Method in class com.hazelcast.jet.core.Watermark

toString() - Method in class com.hazelcast.jet.datamodel.BagsByTag

toString() - Method in class com.hazelcast.jet.datamodel.ItemsByTag

toString() - Method in class com.hazelcast.jet.datamodel.Session

toString() - Method in class com.hazelcast.jet.datamodel.Tag

toString() - Method in class com.hazelcast.jet.datamodel.ThreeBags

toString() - Method in class com.hazelcast.jet.datamodel.TimestampedEntry

toString() - Method in class com.hazelcast.jet.datamodel.Tuple2

toString() - Method in class com.hazelcast.jet.datamodel.Tuple3

toString() - Method in class com.hazelcast.jet.function.DistributedOptional

Returns a non-empty string representation of this Optional suitable for debugging.

totalParallelism() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context

Returns the total number of Processors that will be created across the cluster.

totalParallelism() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

totalSize() - Method in class com.hazelcast.jet.core.test.TestOutbox.MockData

toTumblingByFrame() - Method in class com.hazelcast.jet.core.WindowDefinition

Converts this definition to one defining a tumbling window of the same length as this definition's frame.

Transform - Interface in com.hazelcast.jet

Represents the data transformation performed by a pipeline Stage.

traverseArray(T[]) - Static method in class com.hazelcast.jet.Traversers

Returns a traverser over the given array.

traverseEnumeration(Enumeration<T>) - Static method in class com.hazelcast.jet.Traversers

Returns an adapter from Enumeration to Traverser.

traverseIterable(Iterable<? extends T>) - Static method in class com.hazelcast.jet.Traversers

Returns a traverser over the given iterable.

traverseIterator(Iterator<? extends T>) - Static method in class com.hazelcast.jet.Traversers

Returns an adapter from Iterator to Traverser.

Traverser<T> - Interface in com.hazelcast.jet

Traverses a potentially infinite sequence of non-null items.

Traversers - Class in com.hazelcast.jet

Utility class with several Traversers useful in Processor implementations.

traverseSpliterator(Spliterator<T>) - Static method in class com.hazelcast.jet.Traversers

Returns an adapter from Spliterator to Traverser.

traverseStream(Stream<T>) - Static method in class com.hazelcast.jet.Traversers

Returns a traverser over the given stream.

tryEmit(int, Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Offers the item to the outbox bucket at the supplied ordinal.

tryEmit(Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Offers the item to all the outbox buckets (except the snapshot outbox).

tryEmit(int[], Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Offers the item to the outbox buckets identified in the supplied array.

tryEmitToSnapshot(Object, Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Offers one key-value pair to the snapshot bucket.

tryProcess(T) - Method in class com.hazelcast.jet.core.AbstractProcessor.FlatMapper

Method designed to be called from one of AbstractProcessor#tryProcessX() methods.

tryProcess(int, Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Tries to process the supplied input item, which was received from the edge with the supplied ordinal.

tryProcess() - Method in interface com.hazelcast.jet.core.Processor

Called when there is no pending data in the inbox.

tryProcess0(Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Tries to process the supplied input item, which was received from the edge with ordinal 0.

tryProcess1(Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Tries to process the supplied input item, which was received from the edge with ordinal 1.

tryProcess2(Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Tries to process the supplied input item, which was received from the edge with ordinal 2.

tryProcess3(Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Tries to process the supplied input item, which was received from the edge with ordinal 3.

tryProcess4(Object) - Method in class com.hazelcast.jet.core.AbstractProcessor

Tries to process the supplied input item, which was received from the edge with ordinal 4.

tryProcessWm(int, Watermark) - Method in class com.hazelcast.jet.core.AbstractProcessor

Tries to process the supplied watermark, which was received from the edge with the supplied ordinal.

tryProcessWm0(Watermark) - Method in class com.hazelcast.jet.core.AbstractProcessor

tryProcessWm1(Watermark) - Method in class com.hazelcast.jet.core.AbstractProcessor

tryProcessWm2(Watermark) - Method in class com.hazelcast.jet.core.AbstractProcessor

tryProcessWm3(Watermark) - Method in class com.hazelcast.jet.core.AbstractProcessor

tryProcessWm4(Watermark) - Method in class com.hazelcast.jet.core.AbstractProcessor

tumblingWindowDef(long) - Static method in class com.hazelcast.jet.core.WindowDefinition

Returns the definition of a tumbling window of length windowLength.

Tuple2<E0,E1> - Class in com.hazelcast.jet.datamodel

A 2-tuple (pair) of statically typed fields.

tuple2(E0, E1) - Static method in class com.hazelcast.jet.datamodel.Tuple2

Returns a new 2-tuple with the supplied values.

Tuple3<E0,E1,E2> - Class in com.hazelcast.jet.datamodel

A 3-tuple (triple) of statically typed fields.

tuple3(E0, E1, E2) - Static method in class com.hazelcast.jet.datamodel.Tuple3

Returns a new 3-tuple with the supplied values.

TwoBags<E0,E1> - Class in com.hazelcast.jet.datamodel

A container of two bags (collections), each with its own element type.

twoBags() - Static method in class com.hazelcast.jet.datamodel.TwoBags

Returns a new, empty TwoBags container.

twoBags(Collection<E0>, Collection<E1>) - Static method in class com.hazelcast.jet.datamodel.TwoBags

Returns a new TwoBags container populated with the supplied collections.

U

unordered() - Method in interface com.hazelcast.jet.stream.DistributedStream

updateMetaSupplier(UnaryOperator<ProcessorMetaSupplier>) - Method in class com.hazelcast.jet.core.Vertex

Applies the provided operator function to the current processor meta-supplier and replaces it with the one it returns.

Util - Class in com.hazelcast.jet

Miscellaneous utility methods useful in DAG building logic.

V

valueOf(String) - Static method in enum com.hazelcast.jet.config.ProcessingGuarantee

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.hazelcast.jet.core.Edge.RoutingPolicy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.hazelcast.jet.core.JobStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.hazelcast.jet.core.TimestampKind

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.hazelcast.jet.config.ProcessingGuarantee

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.hazelcast.jet.core.Edge.RoutingPolicy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.hazelcast.jet.core.JobStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.hazelcast.jet.core.TimestampKind

Returns an array containing the constants of this enum type, in the order they are declared.

verifyProcessor(Processor) - Static method in class com.hazelcast.jet.core.test.TestSupport

verifyProcessor(Supplier<Processor>) - Static method in class com.hazelcast.jet.core.test.TestSupport

verifyProcessor(ProcessorSupplier) - Static method in class com.hazelcast.jet.core.test.TestSupport

verifyProcessor(ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.core.test.TestSupport

vertex(Vertex) - Method in class com.hazelcast.jet.core.DAG

Adds a vertex to this DAG.

Vertex - Class in com.hazelcast.jet.core

Represents a unit of data processing in a Jet computation job.

Vertex(String, DistributedSupplier<? extends Processor>) - Constructor for class com.hazelcast.jet.core.Vertex

Creates a vertex from a Supplier<Processor>.

Vertex(String, ProcessorSupplier) - Constructor for class com.hazelcast.jet.core.Vertex

Creates a vertex from a ProcessorSupplier.

Vertex(String, ProcessorMetaSupplier) - Constructor for class com.hazelcast.jet.core.Vertex

Creates a vertex from a ProcessorMetaSupplier.

vertexName() - Method in interface com.hazelcast.jet.core.Processor.Context

Returns the name of the vertex associated with this processor.

vertexName() - Method in class com.hazelcast.jet.core.test.TestProcessorContext

W

Watermark - Class in com.hazelcast.jet.core

Watermark is an item occasionally inserted into a disordered (sub)stream of timestamped items.

Watermark(long) - Constructor for class com.hazelcast.jet.core.Watermark

Constructs a new watermark item.

WatermarkEmissionPolicy - Interface in com.hazelcast.jet.core

A policy object that decides when when the watermark has advanced enough to emit a new watermark item.

WatermarkPolicies - Class in com.hazelcast.jet.core

Utility class with factories of several useful watermark policies.

WatermarkPolicy - Interface in com.hazelcast.jet.core

A policy object that decides on the watermark in a single data (sub)stream.

wholeItem() - Static method in class com.hazelcast.jet.function.DistributedFunctions

Synonym for DistributedFunction.identity(), to be used as a projection function (e.g., key extractor).

WindowDefinition - Class in com.hazelcast.jet.core

Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.

windowLength() - Method in class com.hazelcast.jet.core.WindowDefinition

Returns the length of the window (the size of the timestamp range it covers).

withCombiningAccumulateFn(DistributedFunction<T, A>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation

Returns a copy of this aggregate operation, but with the accumulate primitive replaced with one that expects to find accumulator objects in the input and will combine them all into a single accumulator of the same type.

withCreate(DistributedSupplier<A>) - Static method in interface com.hazelcast.jet.aggregate.AggregateOperation

Returns a builder object, initialized with the supplied create primitive, that can be used to construct the definition of an aggregate operation in a step-by-step manner.

withFinishFn(DistributedFunction<? super A, R_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation

Returns a copy of this aggregate operation, but with the finish primitive replaced with the supplied one.

withFinishFn(DistributedFunction<? super A, R_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation1

withFinishFn(DistributedFunction<? super A, R1>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation2

withFinishFn(DistributedFunction<? super A, R1>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3

withFixedLag(long) - Static method in class com.hazelcast.jet.core.WatermarkPolicies

Maintains watermark that lags behind the top observed timestamp by the given amount.

withOffset(long) - Method in class com.hazelcast.jet.core.WindowDefinition

Returns a new window definition where all the frames are shifted by the given offset.

writeBufferedP(DistributedIntFunction<B>, DistributedBiConsumer<B, T>, DistributedConsumer<B>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for a vertex that drains all the items from its inbox to an intermediate buffer and then flushes the buffer.

writeBufferedP(DistributedIntFunction<B>, DistributedBiConsumer<B, T>, DistributedConsumer<B>, DistributedConsumer<B>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for a vertex that drains all the items from the inbox to an intermediate buffer and then flushes the buffer.

writeCacheP(String) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.cache(String).

writeData(ObjectDataOutput) - Method in class com.hazelcast.jet.core.DAG

writeData(ObjectDataOutput) - Method in class com.hazelcast.jet.core.Edge

writeData(ObjectDataOutput) - Method in class com.hazelcast.jet.core.Vertex

writeFileP(String, DistributedFunction<T, String>, Charset, boolean) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.files(String, DistributedFunction, Charset, boolean).

writeFileP(String, DistributedFunction<T, String>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.files(String, DistributedFunction).

writeFileP(String) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.files(String).

writeHdfsP(JobConf, DistributedFunction<? super E, K>, DistributedFunction<? super E, V>) - Static method in class com.hazelcast.jet.core.processor.HdfsProcessors

Returns a supplier of processors for HdfsSinks.hdfs(JobConf, DistributedFunction, DistributedFunction).

writeKafkaP(Properties, String, DistributedFunction<? super T, K>, DistributedFunction<? super T, V>) - Static method in class com.hazelcast.jet.core.processor.KafkaProcessors

Returns a supplier of processors for KafkaSinks.kafka(Properties, String, DistributedFunction, DistributedFunction).

writeKafkaP(Properties, DistributedFunction<? super T, ProducerRecord<K, V>>) - Static method in class com.hazelcast.jet.core.processor.KafkaProcessors

Returns a supplier of processors for KafkaSinks.kafka(Properties, DistributedFunction).

writeListP(String) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.list(String).

writeLoggerP(DistributedFunction<T, String>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Returns a meta-supplier of processors for a sink vertex that logs all the data items it receives.

writeLoggerP() - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors

Convenience for DiagnosticProcessors.writeLoggerP(DistributedFunction) that uses toString() as toStringFn.

writeMapP(String) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.map(String).

writeObject(ObjectDataOutput) - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator

Serializes this accumulator.

writeRemoteCacheP(String, ClientConfig) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.remoteCache(String, ClientConfig).

writeRemoteListP(String, ClientConfig) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.remoteList(String, ClientConfig).

writeRemoteMapP(String, ClientConfig) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.remoteMap(String, ClientConfig).

writeSocketP(String, int, DistributedFunction<T, String>, Charset) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors

Returns a supplier of processors for Sinks.socket(String, int).

A B C D E F G H I J K L M N O P Q R S T U V W