Skip navigation links
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.
accept(T, U) - Method in interface com.hazelcast.jet.function.BiConsumerEx
 
accept(T) - Method in interface com.hazelcast.jet.function.ConsumerEx
 
acceptEx(T, U) - Method in interface com.hazelcast.jet.function.BiConsumerEx
Exception-declaring version of BiConsumer.accept(T, U).
acceptEx(T) - Method in interface com.hazelcast.jet.function.ConsumerEx
Exception-declaring version of Consumer.accept(T)
accumulate(double) - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator
Adds the value to this objects' value.
accumulate(long, long) - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator
Accumulates a new sample.
accumulateByFrameP(List<FunctionEx<?, ? extends K>>, List<ToLongFunctionEx<?>>, TimestampKind, SlidingWindowPolicy, 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 sliding window aggregation setup (see the class Javadoc for an explanation of aggregation stages).
accumulateByKeyP(List<FunctionEx<?, ? 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.
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(AggregateOperation<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.
add(long) - Method in class com.hazelcast.jet.accumulator.LongAccumulator
Adds the supplied value to this accumulator, throwing an exception in the case of integer overflow.
add(LongAccumulator) - Method in class com.hazelcast.jet.accumulator.LongAccumulator
Adds the value of the supplied accumulator to this accumulator, throwing an exception in the case of integer overflow.
add(AggregateOperation1<? super T, ?, R>) - Method in class com.hazelcast.jet.aggregate.AllOfAggregationBuilder
Adds the supplied aggregate operation to the composite.
add(Tag<T>, AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.aggregate.CoAggregateOperationBuilder
Registers the given aggregate operation with the tag corresponding to an input to the co-aggregating operation being built.
add(Object) - Method in class com.hazelcast.jet.core.test.TestInbox
Convenience for inbox.queue().add(o)
add(BatchStage<T>, AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.pipeline.AggregateBuilder
Adds another stage that will contribute its data to the aggregate operation to be performed.
add(BatchStage<T>) - Method in class com.hazelcast.jet.pipeline.AggregateBuilder1
Adds another stage that will contribute its data to the aggregate operation to be performed.
add(BatchStage<T1_IN>, JoinClause<K, T0, T1_IN, T1>) - Method in class com.hazelcast.jet.pipeline.GeneralHashJoinBuilder
Adds another contributing pipeline stage to the hash-join operation.
add(BatchStageWithKey<T, K>, AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.pipeline.GroupAggregateBuilder
Adds another stage that will contribute its data to the aggregate operation to be performed.
add(BatchStageWithKey<T, K>) - Method in class com.hazelcast.jet.pipeline.GroupAggregateBuilder1
Adds another stage that will contribute its data to the aggregate operation to be performed.
add(T) - Method in interface com.hazelcast.jet.pipeline.SourceBuilder.SourceBuffer
Adds an item to the buffer.
add(T, long) - Method in interface com.hazelcast.jet.pipeline.SourceBuilder.TimestampedSourceBuffer
Adds an item to the buffer, assigning a timestamp to it.
add(T) - Method in interface com.hazelcast.jet.pipeline.SourceBuilder.TimestampedSourceBuffer
Adds an item to the buffer, assigning System.currentTimeMillis() to it as the timestamp.
add(StreamStage<T>, AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.pipeline.WindowAggregateBuilder
Adds another stage that will contribute its data to the aggregate operation to be performed.
add(StreamStage<E>) - Method in class com.hazelcast.jet.pipeline.WindowAggregateBuilder1
Adds another stage that will contribute its data to the aggregate operation to be performed.
add(StreamStageWithKey<T, K>, AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.pipeline.WindowGroupAggregateBuilder
Adds another stage that will contribute its data to the windowed group-and-aggregate stage being constructed.
add(StreamStageWithKey<T, K>) - Method in class com.hazelcast.jet.pipeline.WindowGroupAggregateBuilder1
Adds another stage that will contribute its data to the windowed group-and-aggregate stage being constructed.
add1(long) - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator
Adds the supplied amount to the first value.
add2(long) - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator
Adds the supplied amount to the second value.
addAll(Collection<?>) - Method in class com.hazelcast.jet.core.test.TestInbox
Convenience for inbox.queue().addAll(collection)
addAllowingOverflow(long) - Method in class com.hazelcast.jet.accumulator.LongAccumulator
Adds the supplied value to this accumulator, allowing integer overflow.
addAllowingOverflow(LongAccumulator) - Method in class com.hazelcast.jet.accumulator.LongAccumulator
Adds the value of the supplied accumulator to this accumulator, allowing integer overflow.
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.
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.
addPartitions(int) - Method in class com.hazelcast.jet.core.EventTimeMapper
Adds addedCount partitions.
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.
addTimestamps(ToLongFunctionEx<? super T>, long) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Adds a timestamp to each item in the stream using the supplied function and specifies the allowed amount of disorder between them.
aggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Attaches a stage that performs the given aggregate operation over all the items it receives.
aggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
Attaches a stage that performs the given group-and-aggregate operation.
aggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Attaches a stage that performs the given group-and-aggregate operation.
aggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Attaches a stage that performs the given aggregate operation over all the items that belong to a given window.
aggregate2(BatchStage<T1>, AggregateOperation2<? super T, ? super T1, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Attaches a stage that performs the given aggregate operation over all the items it receives from both this stage and stage1 you supply.
aggregate2(AggregateOperation1<? super T, ?, ? extends R0>, BatchStage<T1>, AggregateOperation1<? super T1, ?, ? extends R1>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Attaches a stage that co-aggregates the data from this and the supplied stage by performing a separate aggregate operation on each and emitting a Tuple2 with their results.
aggregate2(BatchStageWithKey<T1, ? extends K>, AggregateOperation2<? super T, ? super T1, ?, R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
aggregate2(AggregateOperation1<? super T, ?, ? extends R0>, BatchStageWithKey<? extends T1, ? extends K>, AggregateOperation1<? super T1, ?, ? extends R1>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
Attaches a stage that performs the given cogroup-and-aggregate transformation of the items from both this stage and stage1 you supply.
aggregate2(StreamStageWithKey<T1, ? extends K>, AggregateOperation2<? super T, ? super T1, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
aggregate2(AggregateOperation1<? super T, ?, ? extends R0>, StreamStageWithKey<T1, ? extends K>, AggregateOperation1<? super T1, ?, ? extends R1>) - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
aggregate2(StreamStage<T1>, AggregateOperation2<? super T, ? super T1, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Attaches a stage that performs the given aggregate operation over all the items that belong to the same window.
aggregate2(AggregateOperation1<? super T, ?, ? extends R0>, StreamStage<T1>, AggregateOperation1<? super T1, ?, ? extends R1>) - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Attaches a stage that performs the given co-aggregate operations over the items from this stage and stage1 you supply.
aggregate3(BatchStage<T1>, BatchStage<T2>, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Attaches a stage that performs the given aggregate operation over all the items it receives from this stage as well as stage1 and stage2 you supply.
aggregate3(AggregateOperation1<? super T, ?, ? extends R0>, BatchStage<T1>, AggregateOperation1<? super T1, ?, ? extends R1>, BatchStage<T2>, AggregateOperation1<? super T2, ?, ? extends R2>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Attaches a stage that co-aggregates the data from this and the two supplied stages by performing a separate aggregate operation on each and emitting a Tuple3 with their results.
aggregate3(BatchStageWithKey<T1, ? extends K>, BatchStageWithKey<T2, ? extends K>, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
Attaches a stage that performs the given cogroup-and-aggregate operation over the items from this stage as well as stage1 and stage2 you supply.
aggregate3(AggregateOperation1<? super T, ?, ? extends R0>, BatchStageWithKey<T1, ? extends K>, AggregateOperation1<? super T1, ?, ? extends R1>, BatchStageWithKey<T2, ? extends K>, AggregateOperation1<? super T2, ?, ? extends R2>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
Attaches a stage that performs the given cogroup-and-aggregate transformation of the items from this stage as well as stage1 and stage2 you supply.
aggregate3(StreamStageWithKey<T1, ? extends K>, StreamStageWithKey<T2, ? extends K>, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Attaches a stage that performs the given cogroup-and-aggregate operation over the items from this stage as well as stage1 and stage2 you supply.
aggregate3(AggregateOperation1<? super T, ?, ? extends R0>, StreamStageWithKey<T1, ? extends K>, AggregateOperation1<? super T1, ?, ? extends R1>, StreamStageWithKey<T2, ? extends K>, AggregateOperation1<? super T2, ?, ? extends R2>) - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
aggregate3(StreamStage<T1>, StreamStage<T2>, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Attaches a stage that performs the given aggregate operation over the items it receives from this stage as well as stage1 and stage2 you supply.
aggregate3(AggregateOperation1<? super T, ?, ? extends R0>, StreamStage<T1>, AggregateOperation1<? super T1, ?, ? extends R1>, StreamStage<T2>, AggregateOperation1<? super T2, ?, ? extends R2>) - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Attaches a stage that performs the given aggregate operation over all the items that belong to the same window.
AggregateBuilder<R0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateBuilder(AggregateOperation1<? super T, ?, ? extends R0>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateBuilder() - Method in interface com.hazelcast.jet.pipeline.BatchStage
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateBuilder(AggregateOperation1<? super T, ?, ? extends R0>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateBuilder() - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateBuilder(AggregateOperation1<? super T, ?, ? extends R0>) - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateBuilder() - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateBuilder(AggregateOperation1<? super T, ?, ? extends R0>) - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateBuilder() - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
AggregateBuilder1<T0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages.
aggregateByKeyP(List<FunctionEx<?, ? extends K>>, AggregateOperation<A, R>, BiFunctionEx<? super K, ? super R, OUT>) - 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 data processing.
AggregateOperation1<T,A,R> - Interface in com.hazelcast.jet.aggregate
Specialization of AggregateOperation (refer to its extensive documentation) 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 (refer to its extensive documentation) to the "arity-2" case with two data streams being aggregated over.
aggregateOperation2(AggregateOperation1<? super T0, A0, ? extends R0>, AggregateOperation1<? super T1, A1, ? extends R1>, BiFunctionEx<? super R0, ? super R1, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that is a composite of two independent aggregate operations, each one accepting its own input.
aggregateOperation2(AggregateOperation1<? super T0, A0, ? extends R0>, AggregateOperation1<? super T1, A1, ? extends R1>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Convenience for aggregateOperation2(aggrOp0, aggrOp1, finishFn) that outputs a Tuple2(result0, result1).
AggregateOperation3<T0,T1,T2,A,R> - Interface in com.hazelcast.jet.aggregate
Specialization of AggregateOperation (refer to its extensive documentation) to the "arity-3" case with three data streams being aggregated over.
aggregateOperation3(AggregateOperation1<? super T0, A0, ? extends R0>, AggregateOperation1<? super T1, A1, ? extends R1>, AggregateOperation1<? super T2, A2, ? extends R2>, TriFunction<? super R0, ? super R1, ? super R2, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that is a composite of three independent aggregate operations, each one accepting its own input.
aggregateOperation3(AggregateOperation1<? super T0, A0, ? extends R0>, AggregateOperation1<? super T1, A1, ? extends R1>, AggregateOperation1<? super T2, A2, ? extends R2>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Convenience for aggregateOperation3(aggrOp0, aggrOp1, aggrOp2, finishFn) that outputs a Tuple3(result0, result1, result2).
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,R> - Class in com.hazelcast.jet.aggregate
The arity-1 variant of the aggregate operation builder.
AggregateOperationBuilder.Arity2<T0,T1,A,R> - Class in com.hazelcast.jet.aggregate
The arity-2 variant of the aggregate operation builder.
AggregateOperationBuilder.Arity3<T0,T1,T2,A,R> - Class in com.hazelcast.jet.aggregate
The arity-3 variant of the aggregate operation builder.
AggregateOperationBuilder.VarArity<A,R> - 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 aggregate operations.
aggregateP(AggregateOperation<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, long, List<ToLongFunctionEx<?>>, List<FunctionEx<?, ? extends K>>, AggregateOperation<A, ? extends R>, KeyedWindowResultFunction<? super K, ? super R, ? extends OUT>) - 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(List<FunctionEx<?, ? extends K>>, List<ToLongFunctionEx<?>>, TimestampKind, SlidingWindowPolicy, long, AggregateOperation<A, ? extends R>, KeyedWindowResultFunction<? super K, ? super R, ? extends OUT>) - 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).
allOf(AggregateOperation1<? super T, A0, ? extends R0>, AggregateOperation1<? super T, A1, ? extends R1>, BiFunctionEx<? super R0, ? super R1, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that is a composite of two aggregate operations.
allOf(AggregateOperation1<? super T, A0, R0>, AggregateOperation1<? super T, A1, R1>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
allOf(AggregateOperation1<? super T, A0, ? extends R0>, AggregateOperation1<? super T, A1, ? extends R1>, AggregateOperation1<? super T, A2, ? extends R2>, TriFunction<? super R0, ? super R1, ? super R2, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that is a composite of three aggregate operations.
allOf(AggregateOperation1<? super T, A0, ? extends R0>, AggregateOperation1<? super T, A1, ? extends R1>, AggregateOperation1<? super T, A2, ? extends R2>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
AllOfAggregationBuilder<T> - Class in com.hazelcast.jet.aggregate
Offers a step-by-step API to create a composite of multiple aggregate operations.
allOfBuilder() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns a builder object that helps you create a composite of multiple aggregate operations.
allToOne(Object) - Method in class com.hazelcast.jet.core.Edge
Activates a special-cased PARTITIONED routing policy where all items will be routed to the same partition ID, determined from the given key.
alwaysFalse() - Static method in interface com.hazelcast.jet.function.PredicateEx
Returns a predicate that always evaluates to false.
alwaysFalse() - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.alwaysFalse().
alwaysTrue() - Static method in interface com.hazelcast.jet.function.PredicateEx
Returns a predicate that always evaluates to true.
alwaysTrue() - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.alwaysTrue().
and(BiPredicateEx<? super T, ? super U>) - Method in interface com.hazelcast.jet.function.BiPredicateEx
and(PredicateEx<? super T>) - Method in interface com.hazelcast.jet.function.PredicateEx
and(TriPredicate<? super T, ? super U, ? super V>) - Method in interface com.hazelcast.jet.function.TriPredicate
Returns a composite predicate which evaluates the equivalent of this.test(t, u, v) && other.test(t, u, v).
and(Predicate<K, V>...) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.and(Predicate[]).
andAccumulate(BiConsumerEx<? super A, ? super T>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder
Registers the supplied accumulate primitive.
andAccumulate(Tag<T>, BiConsumerEx<? super A, ? super 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>, BiConsumerEx<? 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(BiConsumerEx<? super A, ? super T0>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder
Registers the supplied accumulate primitive for stream-0.
andAccumulate1(BiConsumerEx<? super A, ? super 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(BiConsumerEx<? super A, ? super 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(BiConsumerEx<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1
Registers the combine primitive.
andCombine(BiConsumerEx<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2
Registers the combine primitive.
andCombine(BiConsumerEx<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3
Registers the combine primitive.
andCombine(BiConsumerEx<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity
Registers the combine primitive.
andDeduct(BiConsumerEx<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1
Registers the deduct primitive.
andDeduct(BiConsumerEx<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2
Registers the deduct primitive.
andDeduct(BiConsumerEx<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3
Registers the deduct primitive.
andDeduct(BiConsumerEx<? super A, ? super A>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity
Registers the deduct primitive.
andExport(FunctionEx<? super A, ? extends R_NEW>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1
Registers the export primitive.
andExport(FunctionEx<? super A, ? extends R_NEW>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2
Registers the export primitive.
andExport(FunctionEx<? super A, ? extends R_NEW>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3
Registers the export primitive.
andExport(FunctionEx<? super A, ? extends R_NEW>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity
Registers the export primitive.
andExportFinish(FunctionEx<? super A, ? extends R_NEW>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1
Registers the supplied function as both the export and finish primitive.
andExportFinish(FunctionEx<? super A, ? extends R_NEW>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2
Registers the supplied function as both the export and finish primitive.
andExportFinish(FunctionEx<? super A, ? extends R_NEW>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3
Registers the supplied function as both the export and finish primitive.
andExportFinish(FunctionEx<? super A, ? extends R_NEW>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity
Registers the supplied function as both the export and finish primitive.
andFinish(FunctionEx<? super A, ? extends R>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1
Registers the supplied function as the finish primitive.
andFinish(FunctionEx<? super A, ? extends R>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2
Registers the supplied function as the finish primitive.
andFinish(FunctionEx<? super A, ? extends R>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3
Registers the supplied function as the finish primitive.
andFinish(FunctionEx<? super A, ? extends R>) - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity
Registers the supplied function as the finish primitive.
andThen(FunctionEx<? super R, ? extends R_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
Returns a copy of this aggregate operation, but with the export and finish primitives composed with the supplied thenFn.
andThen(FunctionEx<? super R, ? extends R_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation1
 
andThen(FunctionEx<? super R, ? extends R_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation2
 
andThen(FunctionEx<? super R, ? extends R_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3
 
andThen(BiConsumerEx<? super T, ? super U>) - Method in interface com.hazelcast.jet.function.BiConsumerEx
andThen(FunctionEx<? super R, ? extends V>) - Method in interface com.hazelcast.jet.function.BiFunctionEx
andThen(ConsumerEx<? super T>) - Method in interface com.hazelcast.jet.function.ConsumerEx
andThen(FunctionEx<? super R, ? extends V>) - Method in interface com.hazelcast.jet.function.FunctionEx
append(T) - Method in class com.hazelcast.jet.core.AppendableTraverser
Returns a traverser that will return all the items of this traverser, plus an additional item once this one returns null.
append(boolean) - Method in class com.hazelcast.jet.pipeline.FileSinkBuilder
Sets whether to append (true) or overwrite (false) an existing file.
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.
AppendableTraverser<T> - Class in com.hazelcast.jet.core
A traverser with an internal ArrayDeque.
AppendableTraverser(int) - Constructor for class com.hazelcast.jet.core.AppendableTraverser
Creates an appendable traverser.
apply(long, long, K, R, boolean) - Method in interface com.hazelcast.jet.core.function.KeyedWindowResultFunction
Applies the function to the given arguments
apply(T, long) - Method in interface com.hazelcast.jet.core.function.ObjLongBiFunction
Applies this function to the given arguments.
apply(T, U) - Method in interface com.hazelcast.jet.function.BiFunctionEx
 
apply(T, T) - Method in interface com.hazelcast.jet.function.BinaryOperatorEx
 
apply(T) - Method in interface com.hazelcast.jet.function.FunctionEx
 
apply(T0, T1, T2, T3) - Method in interface com.hazelcast.jet.function.QuadFunction
Applies this function to the given arguments.
apply(T0, T1, T2) - Method in interface com.hazelcast.jet.function.TriFunction
Applies this function to the given arguments.
apply(FunctionEx<? super BatchStage<T>, ? extends BatchStage<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Transforms this stage using the provided transformFn and returns the transformed stage.
apply(FunctionEx<? super StreamStage<T>, ? extends StreamStage<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
Transforms this stage using the provided transformFn and returns the transformed stage.
APPLY_FN_ENTRY_PROCESSOR - Static variable in class com.hazelcast.jet.core.JetDataSerializerHook
Serialization ID of the HazelcastWriters.ApplyFnEntryProcessor class.
applyAsDouble(T) - Method in interface com.hazelcast.jet.function.ToDoubleFunctionEx
 
applyAsDoubleEx(T) - Method in interface com.hazelcast.jet.function.ToDoubleFunctionEx
Exception-declaring version of ToDoubleFunction.applyAsDouble(T).
applyAsInt(T) - Method in interface com.hazelcast.jet.function.ToIntFunctionEx
 
applyAsIntEx(T) - Method in interface com.hazelcast.jet.function.ToIntFunctionEx
Exception-declaring version of ToIntFunction.applyAsInt(T).
applyAsLong(T) - Method in interface com.hazelcast.jet.function.ToLongFunctionEx
 
applyAsLongEx(T) - Method in interface com.hazelcast.jet.function.ToLongFunctionEx
Exception-declaring version of ToLongFunction.applyAsLong(T).
applyEx(T, long) - Method in interface com.hazelcast.jet.core.function.ObjLongBiFunction
Exception-declaring version of ObjLongBiFunction.apply(T, long).
applyEx(T, U) - Method in interface com.hazelcast.jet.function.BiFunctionEx
Exception-declaring version of BiFunction.apply(T, U).
applyEx(T, T) - Method in interface com.hazelcast.jet.function.BinaryOperatorEx
Exception-declaring version of BiFunction.apply(T, U).
applyEx(T) - Method in interface com.hazelcast.jet.function.FunctionEx
Exception-declaring version of Function.apply(T).
applyEx(T0, T1, T2, T3) - Method in interface com.hazelcast.jet.function.QuadFunction
Exception-declaring variant of QuadFunction.apply(T0, T1, T2, T3).
applyEx(T0, T1, T2) - Method in interface com.hazelcast.jet.function.TriFunction
Exception-declaring variant of TriFunction.apply(T0, T1, T2).
arity() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
Returns the number of contributing streams this operation is set up to handle.
averagingDouble(ToDoubleFunctionEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that finds the arithmetic mean (aka.
averagingLong(ToLongFunctionEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that finds the arithmetic mean (aka.
AvroProcessors - Class in com.hazelcast.jet.avro
Static utility class with factories of Apache Avro source and sink processors.
AvroSinks - Class in com.hazelcast.jet.avro
Contains factory methods for Apache Avro sinks.
AvroSourceBuilder<D> - Class in com.hazelcast.jet.avro
Builder for an Avro file source which reads records from Avro files in a directory (but not its subdirectories) and emits output object created by mapOutputFn.
AvroSources - Class in com.hazelcast.jet.avro
Contains factory methods for Apache Avro sources.

B

batch(String, FunctionEx<? super Processor.Context, ? extends C>) - Static method in class com.hazelcast.jet.pipeline.SourceBuilder
Returns a fluent-API builder with which you can create a batch source for a Jet pipeline.
batchFromProcessor(String, ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a bounded (batch) source constructed directly from the given Core API processor meta-supplier.
BatchSource<T> - Interface in com.hazelcast.jet.pipeline
A finite source of data for a Jet pipeline.
BatchStage<T> - Interface in com.hazelcast.jet.pipeline
A stage in a distributed computation pipeline that will observe a finite amount of data (a batch).
BatchStageWithKey<T,K> - Interface in com.hazelcast.jet.pipeline
An intermediate step while constructing a group-and-aggregate batch pipeline stage.
between(Vertex, Vertex) - Static method in class com.hazelcast.jet.core.Edge
Returns an edge between two vertices.
between(String, Comparable, Comparable) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.between(String, Comparable, Comparable).
BiConsumerEx<T,U> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.BiConsumer which declares checked exception.
BiFunctionEx<T,U,R> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.BiFunction which declares checked exception.
BinaryOperatorEx<T> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.BinaryOperator which declares checked exception.
BiPredicateEx<T,U> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.BiPredicate which declares checked exception.
block() - Method in class com.hazelcast.jet.core.test.TestOutbox
 
bottomN(int, ComparatorEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that finds the bottom n items according to the given comparator.
broadcast() - Method in class com.hazelcast.jet.core.Edge
Activates the BROADCAST routing policy.
BroadcastKey<K> - Class in com.hazelcast.jet.core
Marks a key in the snapshot state to indicate that the corresponding entry should be broadcast to all processors when restoring the snapshot.
broadcastKey(K) - Static method in class 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() - Method in class com.hazelcast.jet.aggregate.AllOfAggregationBuilder
Builds and returns the composite AggregateOperation1.
build(FunctionEx<ItemsByTag, R>) - Method in class com.hazelcast.jet.aggregate.AllOfAggregationBuilder
Builds and returns the composite AggregateOperation1.
build() - Method in class com.hazelcast.jet.aggregate.CoAggregateOperationBuilder
Builds and returns the AggregateOperation.
build(FunctionEx<? super ItemsByTag, ? extends R>) - Method in class com.hazelcast.jet.aggregate.CoAggregateOperationBuilder
Builds and returns the multi-input AggregateOperation.
build(BiFunctionEx<String, ? super D, T>) - Method in class com.hazelcast.jet.avro.AvroSourceBuilder
Builds a custom Avro file BatchSource with supplied components and the output function mapOutputFn.
build() - Method in class com.hazelcast.jet.avro.AvroSourceBuilder
build(FunctionEx<? super ItemsByTag, ? extends R>) - Method in class com.hazelcast.jet.pipeline.AggregateBuilder
Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object.
build() - Method in class com.hazelcast.jet.pipeline.AggregateBuilder
Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object.
build(AggregateOperation<?, R>) - Method in class com.hazelcast.jet.pipeline.AggregateBuilder1
Creates and returns a pipeline stage that performs the co-aggregation of pipeline stages registered with this builder object.
build() - Method in class com.hazelcast.jet.pipeline.FileSinkBuilder
Creates and returns the file Sink with the supplied components.
build() - Method in class com.hazelcast.jet.pipeline.FileSourceBuilder
build(BiFunctionEx<String, String, ? extends T>) - Method in class com.hazelcast.jet.pipeline.FileSourceBuilder
Builds a custom file BatchSource with supplied components and the output function mapOutputFn.
build() - Method in class com.hazelcast.jet.pipeline.GroupAggregateBuilder
Creates and returns a pipeline stage that performs the co-aggregation of the stages registered with this builder object and emits a Map.Entry(key, resultsByTag) for each distinct key.
build(AggregateOperation<?, R>, BiFunctionEx<? super K, ? super R, OUT>) - Method in class com.hazelcast.jet.pipeline.GroupAggregateBuilder1
Deprecated.
This is a leftover from an earlier development cycle of the Pipeline API. Use GroupAggregateBuilder1.build(AggregateOperation) instead and add a separate mapping stage with mapToOutputFn.
build(AggregateOperation<?, R>) - Method in class com.hazelcast.jet.pipeline.GroupAggregateBuilder1
Creates and returns a pipeline stage that performs the co-grouping and aggregation of pipeline stages registered with this builder object.
build(BiFunctionEx<T0, ItemsByTag, R>) - Method in class com.hazelcast.jet.pipeline.HashJoinBuilder
Builds a new pipeline stage that performs the hash-join operation.
build() - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Creates and returns the JMS Sink with the supplied components.
build(FunctionEx<? super Message, ? extends T>) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Creates and returns the JMS StreamSource with the supplied components and the projection function projectionFn.
build() - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
build() - Method in class com.hazelcast.jet.pipeline.SinkBuilder
Creates and returns the Sink with the components you supplied to this builder.
build() - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Batch
Builds and returns the batch source.
build() - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Stream
Builds and returns the unbounded stream source.
build() - Method in class com.hazelcast.jet.pipeline.SourceBuilder.TimestampedStream
Builds and returns the timestamped stream source.
build(BiFunctionEx<T0, ItemsByTag, R>) - Method in class com.hazelcast.jet.pipeline.StreamHashJoinBuilder
Builds a new pipeline stage that performs the hash-join operation.
build() - Method in class com.hazelcast.jet.pipeline.WindowAggregateBuilder
Creates and returns a pipeline stage that performs a windowed co-aggregation of the stages registered with this builder object.
build(AggregateOperation<A, R>) - Method in class com.hazelcast.jet.pipeline.WindowAggregateBuilder1
Creates and returns a pipeline stage that performs a windowed co-aggregation of the pipeline stages registered with this builder object.
build() - Method in class com.hazelcast.jet.pipeline.WindowGroupAggregateBuilder
Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate operation on the stages registered with this builder object.
build(AggregateOperation<?, ? extends R>) - Method in class com.hazelcast.jet.pipeline.WindowGroupAggregateBuilder1
Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate of the pipeline stages registered with this builder object.
buildWatcher() - Method in class com.hazelcast.jet.pipeline.FileSourceBuilder
buildWatcher(BiFunctionEx<String, String, ? extends T>) - Method in class com.hazelcast.jet.pipeline.FileSourceBuilder
Builds a source that emits a stream of lines of text coming from files in the watched directory (but not its subdirectories).

C

cache(String) - Static method in class com.hazelcast.jet.pipeline.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.pipeline.Sources
Returns a source that fetches entries from a Hazelcast ICache with the given name and emits them as Map.Entry.
cacheEventNewValue() - Static method in class com.hazelcast.jet.Util
Returns a projection that extracts the new value from an EventJournalCacheEvent.
cacheEventToEntry() - Static method in class com.hazelcast.jet.Util
Returns a projection that converts the EventJournalCacheEvent to a Map.Entry using the event's new value as a value.
cacheJournal(String, PredicateEx<? super EventJournalCacheEvent<K, V>>, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T>, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source that will stream the EventJournalCacheEvent events of a Hazelcast ICache with the specified name.
cacheJournal(String, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for Sources.cacheJournal(String, PredicateEx, FunctionEx, JournalInitialPosition) which will pass only CREATED and UPDATED events and will project the event's key and new value into a Map.Entry.
cachePutEvents() - Static method in class com.hazelcast.jet.Util
cancel() - Method in interface com.hazelcast.jet.Job
Makes a request to cancel this job and returns.
cancel(JetCommandLine.Verbosity, String) - Method in class com.hazelcast.jet.server.JetCommandLine
 
cancelAndExportSnapshot(String) - Method in interface com.hazelcast.jet.Job
Exports and saves a state snapshot with the given name, and then cancels the job without processing any more data after the barrier (graceful cancellation).
charset(Charset) - Method in class com.hazelcast.jet.pipeline.FileSinkBuilder
Sets the character set used to encode the files.
charset(Charset) - Method in class com.hazelcast.jet.pipeline.FileSourceBuilder
Sets the character set used to encode the files.
checkLocalParallelism(int) - Static method in class com.hazelcast.jet.core.Vertex
Says whether the given integer is valid as the value of localParallelism.
clear() - Method in class com.hazelcast.jet.core.test.TestInbox
Convenience for inbox.queue().clear()
close() - Method in interface com.hazelcast.jet.core.Processor
Called as the last method in the processor lifecycle.
close(Throwable) - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier
Called on coordinator member after execution has finished on all members, successfully or not.
close(Throwable) - Method in interface com.hazelcast.jet.core.ProcessorSupplier
Called after the execution has finished on all members - successfully or not.
close() - Method in interface com.hazelcast.jet.pipeline.SourceBuilder.SourceBuffer
Closes the buffer, signaling that all items have been emitted.
cluster(JetCommandLine.Verbosity) - Method in class com.hazelcast.jet.server.JetCommandLine
 
coAggregateOperationBuilder() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns a builder object that offers a step-by-step fluent API to create an aggregate operation that accepts multiple inputs.
CoAggregateOperationBuilder - Class in com.hazelcast.jet.aggregate
Offers a step-by-step API to create an aggregate operation that accepts multiple inputs.
com.hazelcast.jet - package com.hazelcast.jet
Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.
com.hazelcast.jet.accumulator - package com.hazelcast.jet.accumulator
Classes intended to be used for accumulator objects in an AggregateOperation.
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.avro - package com.hazelcast.jet.avro
Apache Avro file read/write support for Hazelcast Jet.
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.function - package com.hazelcast.jet.core.function
Functional interfaces used by Jet Core API
com.hazelcast.jet.core.processor - package com.hazelcast.jet.core.processor
Contains static utility classes with factories of Jet processors.
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 and exception-declaring variants of functional interfaces from java.util.function.
com.hazelcast.jet.hadoop - package com.hazelcast.jet.hadoop
Apache Hadoop HDFS read/write support for Hazelcast Jet.
com.hazelcast.jet.kafka - package com.hazelcast.jet.kafka
Apache Kafka reader/writer support for Hazelcast Jet.
com.hazelcast.jet.pipeline - package com.hazelcast.jet.pipeline
The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.
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.spring - package com.hazelcast.jet.spring
Spring integration for Hazelcast Jet
combine(DoubleAccumulator) - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator
Adds the value of the supplied accumulator to this one.
combine(LinTrendAccumulator) - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator
Combines this accumulator with the supplied one.
combineByKeyP(AggregateOperation<A, R>, BiFunctionEx<? super K, ? super R, OUT>) - 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(AggregateOperation<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.
combineToSlidingWindowP(SlidingWindowPolicy, AggregateOperation<A, ? extends R>, KeyedWindowResultFunction<? super K, ? super R, ? extends OUT>) - 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).
ComparatorEx<T> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.Comparator which declares checked exception.
compare(T, T) - Method in interface com.hazelcast.jet.function.ComparatorEx
 
compareEx(T, T) - Method in interface com.hazelcast.jet.function.ComparatorEx
Exception-declaring version of Comparator.compare(T, T).
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.ComparatorEx
comparing(FunctionEx<? super T, ? extends U>, ComparatorEx<? super U>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
comparing(Function<? super T, ? extends U>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
comparing(FunctionEx<? super T, ? extends U>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
comparingDouble(ToDoubleFunction<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
comparingDouble(ToDoubleFunctionEx<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
comparingInt(ToIntFunction<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
comparingInt(ToIntFunctionEx<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
comparingLong(ToLongFunction<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
comparingLong(ToLongFunctionEx<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
complete() - Method in interface com.hazelcast.jet.core.Processor
Called after all the inbound edges' streams are exhausted.
completeEdge(int) - Method in interface com.hazelcast.jet.core.Processor
Called after the edge input with the supplied ordinal is exhausted.
compose(FunctionEx<? super V, ? extends T>) - Method in interface com.hazelcast.jet.function.FunctionEx
concatenating() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that takes string items and concatenates them into a single string.
concatenating(CharSequence) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that takes string items and concatenates them, separated by the given delimiter, into a single string.
concatenating(CharSequence, CharSequence, CharSequence) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that takes string items and concatenates them, separated by the given delimiter, into a single string.
configureLogging() - Static method in class com.hazelcast.jet.server.StartServer
 
connectionFn(FunctionEx<ConnectionFactory, Connection>) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the function which creates the connection from connection factory.
connectionFn(FunctionEx<? super ConnectionFactory, ? extends Connection>) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the function which creates the connection from connection factory.
connectionParams(String, String) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the connection parameters.
connectionParams(String, String) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the connection parameters.
ConsumerEx<T> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.Consumer which declares checked exception.
consumerFn(FunctionEx<? super Session, ? extends MessageConsumer>) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the function which creates the message consumer from session.
ContextFactories - Class in com.hazelcast.jet.pipeline
Utility class with methods that create several useful context factories.
ContextFactory<C> - Class in com.hazelcast.jet.pipeline
A holder of functions needed to create and destroy a context object.
convenientSourceP(FunctionEx<? super Processor.Context, ? extends C>, BiConsumerEx<? super C, ? super SourceBuilder.SourceBuffer<T>>, FunctionEx<? super C, ? extends S>, BiConsumerEx<? super C, ? super List<S>>, ConsumerEx<? super C>, int, boolean) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
Returns a supplier of processors for a source that the user can create using the SourceBuilder.
convenientTimestampedSourceP(FunctionEx<? super Processor.Context, ? extends C>, BiConsumerEx<? super C, ? super SourceBuilder.TimestampedSourceBuffer<T>>, EventTimePolicy<? super T>, FunctionEx<? super C, ? extends S>, BiConsumerEx<? super C, ? super List<S>>, ConsumerEx<? super C>, int) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
Returns a supplier of processors for a source that the user can create using the SourceBuilder.
COOPERATIVE_DEFAULT - Static variable in class com.hazelcast.jet.pipeline.ContextFactory
Default value for ContextFactory.isCooperative.
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.
counting() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that counts the items it observes.
create() - Static method in interface com.hazelcast.jet.pipeline.Pipeline
Creates a new, empty pipeline.
createFactory() - Method in class com.hazelcast.jet.config.JetConfigDataSerializerHook
 
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.
createFn() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns the create-function.
createResultSet(Connection, int, int) - Method in interface com.hazelcast.jet.function.ToResultSetFunction
Creates a result set which returns a part of the rows pertaining to the given processor.
createSnapshotFn(FunctionEx<? super C, ? extends S>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Stream
 
createSnapshotFn(FunctionEx<? super C, ? extends S>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.TimestampedStream
 
creationTime() - Method in class com.hazelcast.jet.JobStateSnapshot
Returns the time the snapshot was created.
customTransform(String, SupplierEx<Processor>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
customTransform(String, ProcessorSupplier) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
customTransform(String, ProcessorMetaSupplier) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
customTransform(String, SupplierEx<Processor>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
customTransform(String, ProcessorSupplier) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
customTransform(String, ProcessorMetaSupplier) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
customTransform(String, SupplierEx<Processor>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a stage with a custom transform based on the provided supplier of Core API Processors.
customTransform(String, ProcessorSupplier) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a stage with a custom transform based on the provided supplier of Core API Processors.
customTransform(String, ProcessorMetaSupplier) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a stage with a custom transform based on the provided supplier of Core API Processors.
customTransform(String, SupplierEx<Processor>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a stage with a custom transform based on the provided supplier of Core API Processors.
customTransform(String, ProcessorSupplier) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a stage with a custom transform based on the provided supplier of Core API Processors.
customTransform(String, ProcessorMetaSupplier) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a stage with a custom transform based on the provided supplier of Core API Processors.
customTransform(String, SupplierEx<Processor>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
customTransform(String, ProcessorSupplier) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
customTransform(String, ProcessorMetaSupplier) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
customTransform(String, SupplierEx<Processor>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
customTransform(String, ProcessorSupplier) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
customTransform(String, ProcessorMetaSupplier) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 

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
 
DAG - Static variable in class com.hazelcast.jet.core.JetDataSerializerHook
Serialization ID of the DAG class.
dagJsonString() - Method in class com.hazelcast.jet.JobStateSnapshot
Returns the JSON representation of the DAG of the job this snapshot was created from.
deduct(DoubleAccumulator) - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator
Subtracts the value of the supplied accumulator from this one.
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_GROUP_NAME - Static variable in class com.hazelcast.jet.config.JetConfig
The default group name for a Jet cluster See GroupConfig
DEFAULT_IDLE_TIMEOUT - Static variable in class com.hazelcast.jet.core.EventTimePolicy
The default idle timeout in milliseconds.
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_METRICS_COLLECTION_SECONDS - Static variable in class com.hazelcast.jet.config.MetricsConfig
Default collection interval for metrics
DEFAULT_METRICS_RETENTION_SECONDS - Static variable in class com.hazelcast.jet.config.MetricsConfig
Default retention period for metrics.
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
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.
deleteSnapshot(JetCommandLine.Verbosity, String) - Method in class com.hazelcast.jet.server.JetCommandLine
 
destinationName(String) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the name of the destination.
destinationName(String) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the name of the destination.
destroy() - Method in class com.hazelcast.jet.JobStateSnapshot
Destroy the underlying distributed object.
destroyFn() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns the destroy-function.
destroyFn(ConsumerEx<? super W>) - Method in class com.hazelcast.jet.pipeline.SinkBuilder
Sets the function that will destroy the writer and perform any cleanup.
destroyFn(ConsumerEx<? super C>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Batch
 
destroyFn(ConsumerEx<? super C>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Stream
 
destroyFn(ConsumerEx<? super C>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.TimestampedStream
 
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").
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.pipeline.BatchStage
Attaches a stage that emits just the items that are distinct according to their definition of equality (equals and hashCode).
distinct() - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
Attaches a stage that emits just the items that are distinct according to the grouping key (no two items which map to the same key will be on the output).
distinct() - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Attaches a stage that passes through just the items that are distinct within their window according to the grouping key (no two items emitted for a window map to the same key).
distinct() - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Attaches a stage that passes through just the items that are distinct within their window (no two items emitted for a window are equal).
distributed() - Method in class com.hazelcast.jet.core.Edge
Declares that the edge is distributed.
distributed(int) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Batch
 
distributed(int) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Stream
 
distributed(int) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.TimestampedStream
 
DoubleAccumulator - Class in com.hazelcast.jet.accumulator
Accumulator 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.
drainQueueAndReset(int, Collection<T>, boolean) - Method in class com.hazelcast.jet.core.test.TestOutbox
Move all items from the queue to the target collection and make the outbox available to accept more items.
drainQueuesAndReset(List<? extends Collection<T>>, boolean) - Method in class com.hazelcast.jet.core.test.TestOutbox
Move all items from all queues (except the snapshot queue) to the target list of collections.
drainSnapshotQueueAndReset(Collection<? super Map.Entry<K, V>>, boolean) - Method in class com.hazelcast.jet.core.test.TestOutbox
Deserialize and move all items from the snapshot queue to the target collection and make the outbox available to accept more items.
drainTo(Collection<E>) - Method in interface com.hazelcast.jet.core.Inbox
Drains all elements into the provided Collection.
drainTo(Sink<? super T>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a sink stage, one that accepts data but doesn't emit any.
drainTo(Sink<? super T>, GeneralStage<? extends T>, GeneralStage<? extends T>, GeneralStage<? extends T>...) - Method in interface com.hazelcast.jet.pipeline.Pipeline
Attaches the supplied sink to two or more pipeline stages.
drawFrom(BatchSource<? extends T>) - Method in interface com.hazelcast.jet.pipeline.Pipeline
Returns a pipeline stage that represents a bounded (batch) data source.
drawFrom(StreamSource<? extends T>) - Method in interface com.hazelcast.jet.pipeline.Pipeline
Returns a pipeline stage that represents an unbounded data source (i.e., an event stream).
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

earlyResultsPeriod() - Method in class com.hazelcast.jet.pipeline.WindowDefinition
Returns the early results period for this window definition.
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 - Static variable in class com.hazelcast.jet.core.JetDataSerializerHook
Serialization ID of the Edge class.
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
 
emitFromTraverser(int[], Traverser<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>) - 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<?>) - Method in class com.hazelcast.jet.core.AbstractProcessor
Convenience for AbstractProcessor.emitFromTraverser(int, Traverser) which emits to all 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.Traversers
Returns a traverser that always returns null.
end() - Method in class com.hazelcast.jet.datamodel.WindowResult
Returns the ending timestamp of the window.
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.Functions
Returns a function that extracts the key of a Map.Entry.
entryValue() - Static method in class com.hazelcast.jet.function.Functions
Returns a function that extracts the value of a Map.Entry.
equal(String, Comparable) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.equal(String, Comparable).
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.config.JobConfig
 
equals(Object) - Method in class com.hazelcast.jet.config.ResourceConfig
 
equals(Object) - Method in class com.hazelcast.jet.core.BroadcastKey
 
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.ItemsByTag
 
equals(Object) - Method in class com.hazelcast.jet.datamodel.KeyedWindowResult
 
equals(Object) - Method in class com.hazelcast.jet.datamodel.Tag
 
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.Tuple4
 
equals(Object) - Method in class com.hazelcast.jet.datamodel.Tuple5
 
equals(Object) - Method in class com.hazelcast.jet.datamodel.WindowResult
 
EventTimeMapper<T> - Class in com.hazelcast.jet.core
A utility to that helps a source emit events according to a given EventTimePolicy.
EventTimeMapper(EventTimePolicy<? super T>) - Constructor for class com.hazelcast.jet.core.EventTimeMapper
The partition count is initially set to 0, call EventTimeMapper.addPartitions(int) to add partitions.
EventTimePolicy<T> - Class in com.hazelcast.jet.core
A holder of functions and parameters Jet needs to handle event time and the associated watermarks.
eventTimePolicy(ToLongFunctionEx<? super T>, ObjLongBiFunction<? super T, ?>, SupplierEx<? extends WatermarkPolicy>, long, long, long) - Static method in class com.hazelcast.jet.core.EventTimePolicy
Creates and returns a new event time policy.
eventTimePolicy(ToLongFunctionEx<? super T>, SupplierEx<? extends WatermarkPolicy>, long, long, long) - Static method in class com.hazelcast.jet.core.EventTimePolicy
Creates and returns a new event time policy.
executionId() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context
Returns the job execution ID.
executionId() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
expectOutput(List<?>) - Method in class com.hazelcast.jet.core.test.TestSupport
Sets the expected output and runs the test.
expectOutputs(List<List<?>>) - Method in class com.hazelcast.jet.core.test.TestSupport
Specifies the expected outputs and runs the test.
export() - Method in class com.hazelcast.jet.accumulator.DoubleAccumulator
Returns the current value.
export() - Method in class com.hazelcast.jet.accumulator.LinTrendAccumulator
Computes the linear coefficient of the linear regression of the accumulated samples.
exportFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
A primitive that transforms the accumulator into a result of the aggregation.
exportSnapshot(String) - Method in interface com.hazelcast.jet.Job
Exports a state snapshot and saves it under the given name.

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.
f0() - Method in class com.hazelcast.jet.datamodel.Tuple4
Returns the value of the field 0.
f0() - Method in class com.hazelcast.jet.datamodel.Tuple5
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.
f1() - Method in class com.hazelcast.jet.datamodel.Tuple4
Returns the value of the field 1.
f1() - Method in class com.hazelcast.jet.datamodel.Tuple5
Returns the value of the field 1.
f2() - Method in class com.hazelcast.jet.datamodel.Tuple3
Returns the value of the field 2.
f2() - Method in class com.hazelcast.jet.datamodel.Tuple4
Returns the value of the field 2.
f2() - Method in class com.hazelcast.jet.datamodel.Tuple5
Returns the value of the field 2.
f3() - Method in class com.hazelcast.jet.datamodel.Tuple4
Returns the value of the field 3.
f3() - Method in class com.hazelcast.jet.datamodel.Tuple5
Returns the value of the field 3.
f4() - Method in class com.hazelcast.jet.datamodel.Tuple5
Returns the value of the field 4.
FACTORY_ID - Static variable in class com.hazelcast.jet.config.JetConfigDataSerializerHook
 
FACTORY_ID - Static variable in class com.hazelcast.jet.core.JetDataSerializerHook
 
files(String, SupplierEx<Schema>, SupplierEx<DatumWriter<R>>) - Static method in class com.hazelcast.jet.avro.AvroSinks
Returns a sink that that writes the items it receives to Apache Avro files.
files(String, SupplierEx<Schema>, Class<R>) - Static method in class com.hazelcast.jet.avro.AvroSinks
Convenience for AvroSinks.files(String, SupplierEx, SupplierEx) which uses either SpecificDatumWriter or ReflectDatumWriter depending on the supplied recordClass.
files(String, SupplierEx<Schema>) - Static method in class com.hazelcast.jet.avro.AvroSinks
Convenience for AvroSinks.files(String, SupplierEx, SupplierEx) which uses GenericDatumWriter.
files(String, Class<D>) - Static method in class com.hazelcast.jet.avro.AvroSources
Convenience for AvroSources.filesBuilder(String, Class) which reads all the files in the supplied directory as specific records using supplied datumClass.
files(String, BiFunctionEx<String, GenericRecord, D>) - Static method in class com.hazelcast.jet.avro.AvroSources
Convenience for AvroSources.filesBuilder(String, SupplierEx) which reads all the files in the supplied directory as generic records and emits the results of transforming each generic record with the supplied mapping function.
files(String) - Static method in class com.hazelcast.jet.pipeline.Sinks
Convenience for Sinks.filesBuilder(java.lang.String) with the UTF-8 charset and with overwriting of existing files.
files(String) - Static method in class com.hazelcast.jet.pipeline.Sources
A source to read all files in a directory in a batch way.
filesBuilder(String, Class<D>) - Static method in class com.hazelcast.jet.avro.AvroSources
Returns a builder object that offers a step-by-step fluent API to build a custom Avro file source for the Pipeline API.
filesBuilder(String, SupplierEx<? extends DatumReader<D>>) - Static method in class com.hazelcast.jet.avro.AvroSources
Returns a builder object that offers a step-by-step fluent API to build a custom Avro file source for the Pipeline API.
filesBuilder(String) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a builder object that offers a step-by-step fluent API to build a custom file sink for the Pipeline API.
filesBuilder(String) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a builder object that offers a step-by-step fluent API to build a custom source to read files for the Pipeline API.
FileSinkBuilder<T> - Class in com.hazelcast.jet.pipeline
FileSourceBuilder - Class in com.hazelcast.jet.pipeline
Builder for a file source which reads lines from files in a directory (but not its subdirectories) and emits output object created by mapOutputFn
fileWatcher(String) - Static method in class com.hazelcast.jet.pipeline.Sources
A source to stream lines added to files in a directory.
fillBufferFn(BiConsumerEx<? super C, ? super SourceBuilder.SourceBuffer<T_NEW>>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Batch
Sets the function that Jet will call whenever it needs more data from your source.
fillBufferFn(BiConsumerEx<? super C, ? super SourceBuilder.SourceBuffer<T_NEW>>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.Stream
 
fillBufferFn(BiConsumerEx<? super C, ? super SourceBuilder.TimestampedSourceBuffer<T_NEW>>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.TimestampedStream
Sets the function that Jet will call whenever it needs more data from your source.
filter(PredicateEx<T>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
filter(PredicateEx<T>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a filtering stage 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(PredicateEx<T>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
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.
filtering(PredicateEx<? super T>, AggregateOperation1<? super T, A, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Adapts an aggregate operation so that it accumulates only the items passing the filterFn and ignores others.
filterP(PredicateEx<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.
filterUsingContext(ContextFactory<C>, BiPredicateEx<? super C, ? super T>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
filterUsingContext(ContextFactory<C>, TriPredicate<? super C, ? super K, ? super T>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
filterUsingContext(ContextFactory<C>, BiPredicateEx<? super C, ? super T>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a filtering stage which applies the provided predicate function to each input item to decide whether to pass the item to the output or to discard it.
filterUsingContext(ContextFactory<C>, TriPredicate<? super C, ? super K, ? super T>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a filtering stage which applies the provided predicate function to each input item to decide whether to pass the item to the output or to discard it.
filterUsingContext(ContextFactory<C>, BiPredicateEx<? super C, ? super T>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
filterUsingContext(ContextFactory<C>, TriPredicate<? super C, ? super K, ? super T>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
filterUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<Boolean>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
filterUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<Boolean>>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
filterUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<Boolean>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Asynchronous version of GeneralStage.filterUsingContext(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.BiPredicateEx<? super C, ? super T>): the filterAsyncFn returns a CompletableFuture<Boolean> instead of just a boolean.
filterUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<Boolean>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Asynchronous version of GeneralStageWithKey.filterUsingContext(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.TriPredicate<? super C, ? super K, ? super T>): the filterAsyncFn returns a CompletableFuture<Boolean> instead of just a boolean.
filterUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<Boolean>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
filterUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<Boolean>>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
filterUsingContextAsyncP(ContextFactory<C>, FunctionEx<T, K>, BiFunctionEx<? super C, ? super T, CompletableFuture<Boolean>>) - Static method in class com.hazelcast.jet.core.processor.Processors
Asynchronous version of Processors.filterUsingContextP(com.hazelcast.jet.pipeline.ContextFactory<C>, com.hazelcast.jet.function.BiPredicateEx<? super C, ? super T>): the filterAsyncFn returns a CompletableFuture<Boolean> instead of just a boolean.
filterUsingContextP(ContextFactory<C>, BiPredicateEx<? super C, ? super 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.
finishFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
A primitive that transforms the accumulator into a result of the aggregation.
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(FunctionEx<? super T, ? extends Traverser<? extends R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
flatMap(FunctionEx<? super T, ? extends Traverser<? extends R>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a flat-mapping stage which applies the supplied function to each input item independently and emits all the items from the Traverser it returns.
flatMap(FunctionEx<? super T, ? extends Traverser<? extends R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
flatMap(Function<? super T, ? extends Traverser<? extends R>>) - Method in interface com.hazelcast.jet.Traverser
Returns a traverser that will apply the given mapping function to each item retrieved from this traverser and emit all the items from the resulting traversers, which must be null-terminated.
flatMapEvent(T, int, long) - Method in class com.hazelcast.jet.core.EventTimeMapper
Flat-maps the given event by (possibly) prepending it with a watermark.
flatMapIdle() - Method in class com.hazelcast.jet.core.EventTimeMapper
Call this method when there is no event coming.
flatMapP(FunctionEx<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
flatMapper(Function<? super T, ? extends Traverser<? extends R>>) - Method in class com.hazelcast.jet.core.AbstractProcessor
flatMapper(int[], Function<? super T, ? extends Traverser<? extends R>>) - Method in class com.hazelcast.jet.core.AbstractProcessor
flatMapping(FunctionEx<? super T, ? extends Traverser<? extends U>>, AggregateOperation1<? super U, A, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Adapts an aggregate operation that takes items of type U to one that takes items of type T, by exploding each T into a sequence of Us and then accumulating all of them.
flatMapUsingContext(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
flatMapUsingContext(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, ? extends Traverser<? extends R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
flatMapUsingContext(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a flat-mapping stage which applies the supplied function to each input item independently and emits all items from the Traverser it returns as the output items.
flatMapUsingContext(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, ? extends Traverser<? extends R>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a flat-mapping stage which applies the supplied function to each input item independently and emits all the items from the Traverser it returns as the output items.
flatMapUsingContext(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
flatMapUsingContext(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, ? extends Traverser<? extends R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
flatMapUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<Traverser<R>>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
flatMapUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<Traverser<R>>>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
flatMapUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<Traverser<R>>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
flatMapUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<Traverser<R>>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
flatMapUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<Traverser<R>>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
flatMapUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<Traverser<R>>>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
flatMapUsingContextAsyncP(ContextFactory<C>, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super C, ? super T, CompletableFuture<Traverser<R>>>) - Static method in class com.hazelcast.jet.core.processor.Processors
flatMapUsingContextP(ContextFactory<C>, BiFunctionEx<? super C, ? super 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.
floorFrameTs(long) - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the highest frame timestamp less than or equal to the given timestamp.
flushFn(ConsumerEx<Session>) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the function which flushes the session after a batch of messages is sent.
flushFn(ConsumerEx<? super Session>) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the function which commits the session after consuming each message.
flushFn(ConsumerEx<? super W>) - Method in class com.hazelcast.jet.pipeline.SinkBuilder
Sets the function that implements the sink's flushing behavior.
forceTotalParallelismOne(ProcessorSupplier) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier
Variant of ProcessorMetaSupplier.forceTotalParallelismOne(ProcessorSupplier, String) where the node for the supplier will be chosen randomly.
forceTotalParallelismOne(ProcessorSupplier, String) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier
Wraps the provided ProcessorSupplier into a meta-supplier that will only use the given ProcessorSupplier on a single node.
frameOffset() - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the frame offset.
frameSize() - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the length of the frame (equal to the sliding step).
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.pipeline.Sinks
Returns a sink constructed directly from the given Core API processor meta-supplier.
FunctionEx<T,R> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.Function which declares checked exception.
Functions - Class in com.hazelcast.jet.function
Factory methods for several common functions.

G

GeneralHashJoinBuilder<T0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step fluent API to build a hash-join pipeline stage.
GeneralStage<T> - Interface in com.hazelcast.jet.pipeline
The common aspect of batch and stream pipeline stages, defining those operations that apply to both.
GeneralStageWithKey<T,K> - Interface in com.hazelcast.jet.pipeline
An intermediate step when constructing a group-and-aggregate pipeline stage.
generate(JetConfig) - Static method in class com.hazelcast.jet.config.JetConfigXmlGenerator
Convenience for JetConfigXmlGenerator.generate(JetConfig, int) without any indentation
generate(JetConfig, int) - Static method in class com.hazelcast.jet.config.JetConfigXmlGenerator
Generates Hazelcast Jet XML string for given JetConfig using the indent value.
GenericPredicates - Class in com.hazelcast.jet.pipeline
Generic wrappers for methods in Predicates.
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(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 interface com.hazelcast.jet.function.SupplierEx
 
get1() - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator
Returns the first value.
get2() - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator
Returns the second value.
getBackupCount() - Method in class com.hazelcast.jet.config.InstanceConfig
Returns the number of backups used for job metadata and snapshots.
getCache(String) - Method in interface com.hazelcast.jet.JetCacheManager
Returns the cache instance with the specified, optionally 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.
getClassLoaderFactory() - Method in class com.hazelcast.jet.config.JobConfig
Returns the configured JobClassLoaderFactory.
getCluster() - Method in interface com.hazelcast.jet.JetInstance
Returns information about the cluster this Jet instance is part of.
getCollectionIntervalSeconds() - Method in class com.hazelcast.jet.config.MetricsConfig
Returns the metrics collection interval.
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.
getConfig() - Method in interface com.hazelcast.jet.Job
Returns the configuration this job was submitted with.
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.
getDouble() - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator
Returns the double value.
getEx() - Method in interface com.hazelcast.jet.function.SupplierEx
Exception-declaring version of Supplier.get().
getFactoryId() - Method in class com.hazelcast.jet.config.JetConfigDataSerializerHook
 
getFactoryId() - Method in class com.hazelcast.jet.config.JobConfig
 
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.
getHazelcastConfig() - Method in class com.hazelcast.jet.config.JetConfig
Returns the configuration object for the underlying Hazelcast IMDG instance.
getHazelcastInstance() - Method in interface com.hazelcast.jet.JetInstance
Returns the underlying Hazelcast IMDG instance used by Jet.
getId() - Method in class com.hazelcast.jet.config.JobConfig
 
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
 
getId() - Method in interface com.hazelcast.jet.Job
Returns the ID of this job.
getIdString() - Method in interface com.hazelcast.jet.Job
Returns the string representation of this job's ID.
getInboundEdges(String) - Method in class com.hazelcast.jet.core.DAG
Returns the inbound edges connected to the vertex with the given name.
getInitialSnapshotName() - Method in class com.hazelcast.jet.config.JobConfig
Returns the configured initial snapshot name or null if no initial snapshot is configured.
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.
getJob(long) - Method in interface com.hazelcast.jet.JetInstance
Returns the job with the given id or null if no such job could be found.
getJob(String) - Method in interface com.hazelcast.jet.JetInstance
Returns the active or last submitted job with the given name or null if no such job could be found.
getJobClassLoader() - Method in interface com.hazelcast.jet.config.JobClassLoaderFactory
Return the class loader instance.
getJobs() - Method in interface com.hazelcast.jet.JetInstance
Returns all submitted jobs including running and completed ones.
getJobs(String) - Method in interface com.hazelcast.jet.JetInstance
Returns all jobs submitted with the given name, ordered in descending order by submission time.
getJobStateSnapshot(String) - Method in interface com.hazelcast.jet.JetInstance
Returns the JobStateSnapshot object representing an exported snapshot with the given name.
getJobStateSnapshots() - Method in interface com.hazelcast.jet.JetInstance
Returns the collection of exported job state snapshots stored in the cluster.
getKey() - Method in class com.hazelcast.jet.datamodel.KeyedWindowResult
Alias for KeyedWindowResult.key, implements Map.Entry.
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.
getLong() - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator
Returns the long value.
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.
getMetricsConfig() - Method in class com.hazelcast.jet.config.JetConfig
Returns the metrics collection config.
getName() - Method in class com.hazelcast.jet.config.JobConfig
Returns the name of the job or null if no name was given.
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.
getName() - Method in interface com.hazelcast.jet.Job
Returns the name of this job or null if no name was supplied.
getOutboundEdges(String) - Method in class com.hazelcast.jet.core.DAG
Returns the outbound edges connected to the vertex with the given name.
getOutbox() - Method in class com.hazelcast.jet.core.AbstractProcessor
 
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.
getPipeline() - Method in interface com.hazelcast.jet.pipeline.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
 
getReplicatedMap(String) - Method in interface com.hazelcast.jet.JetInstance
Returns the replicated map instance with the specified name.
getResourceConfigs() - Method in class com.hazelcast.jet.config.JobConfig
Returns all the registered resource configurations.
getRetentionSeconds() - Method in class com.hazelcast.jet.config.MetricsConfig
Returns the number of seconds the metrics will be retained on the instance.
getRoutingPolicy() - Method in class com.hazelcast.jet.core.Edge
Returns the Edge.RoutingPolicy in effect on the edge.
getScaleUpDelayMillis() - Method in class com.hazelcast.jet.config.InstanceConfig
Returns the scale-up delay, see InstanceConfig.setScaleUpDelayMillis(long).
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.
getStatus() - Method in interface com.hazelcast.jet.Job
Returns the current status of this job.
getSubmissionTime() - Method in interface com.hazelcast.jet.Job
Returns the time when the job was submitted to the cluster.
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.KeyedWindowResult
Alias for WindowResult.result(), implements Map.Entry.
getValue() - Method in class com.hazelcast.jet.datamodel.Tuple2
 
getVersion() - Method in class com.hazelcast.jet.server.JetCommandLine.JetVersionProvider
 
getVertex(String) - Method in class com.hazelcast.jet.core.DAG
Returns the vertex with the given name.
getWatermark(int) - Method in class com.hazelcast.jet.core.EventTimeMapper
Watermark value to be saved to state snapshot for the given source partition index.
glob(String) - Method in class com.hazelcast.jet.avro.AvroSourceBuilder
Sets the globbing mask, see getPathMatcher().
glob(String) - Method in class com.hazelcast.jet.pipeline.FileSourceBuilder
Sets the globbing mask, see getPathMatcher().
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: it's a unique cluster-wide index.
globalProcessorIndex() - Method in class com.hazelcast.jet.core.test.TestProcessorContext
 
greaterEqual(String, Comparable) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.greaterEqual(String, Comparable).
greaterThan(String, Comparable) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.greaterThan(String, Comparable).
GroupAggregateBuilder<K,R0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step API to build a pipeline stage that co-groups and aggregates the data from several input stages.
GroupAggregateBuilder1<T0,K> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step API to build a pipeline stage that co-groups and aggregates the data from several input stages.
groupingBy(FunctionEx<? super T, ? extends K>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates the items into a HashMap where the key is the result of applying keyFn and the value is a list of the items with that key.
groupingBy(FunctionEx<? super T, ? extends K>, AggregateOperation1<? super T, A, R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates the items into a HashMap where the key is the result of applying keyFn and the value is the result of applying the downstream aggregate operation to the items with that key.
groupingBy(FunctionEx<? super T, ? extends K>, SupplierEx<M>, AggregateOperation1<? super T, A, R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an AggregateOperation1 that accumulates the items into a Map (as obtained from createMapFn) where the key is the result of applying keyFn and the value is the result of applying the downstream aggregate operation to the items with that key.
groupingKey(FunctionEx<? super T, ? extends K>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Specifies the function that will extract a key from the items in the associated pipeline stage.
groupingKey(FunctionEx<? super T, ? extends K>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Specifies the function that will extract a key from the items in the associated pipeline stage.
groupingKey(FunctionEx<? super T, ? extends K>) - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Specifies the function that will extract the grouping key from the items in the associated pipeline stage and moves on to the step in which you'll complete the construction of a windowed group-and-aggregate stage.
groupingKey(FunctionEx<? super T, ? extends K>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 

H

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.config.JobConfig
 
hashCode() - Method in class com.hazelcast.jet.config.ResourceConfig
 
hashCode() - Method in class com.hazelcast.jet.core.BroadcastKey
 
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.ItemsByTag
 
hashCode() - Method in class com.hazelcast.jet.datamodel.KeyedWindowResult
 
hashCode() - Method in class com.hazelcast.jet.datamodel.Tag
 
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.Tuple4
 
hashCode() - Method in class com.hazelcast.jet.datamodel.Tuple5
 
hashCode() - Method in class com.hazelcast.jet.datamodel.WindowResult
 
hashJoin(BatchStage<T1_IN>, JoinClause<K, ? super T, ? super T1_IN, ? extends T1>, BiFunctionEx<T, T1, R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
hashJoin(BatchStage<T1_IN>, JoinClause<K, ? super T, ? super T1_IN, ? extends T1>, BiFunctionEx<T, T1, R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches to both this and the supplied stage a hash-joining stage and returns it.
hashJoin(BatchStage<T1_IN>, JoinClause<K, ? super T, ? super T1_IN, ? extends T1>, BiFunctionEx<T, T1, R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
hashJoin2(BatchStage<T1_IN>, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1>, BatchStage<T2_IN>, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2>, TriFunction<T, T1, T2, R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
hashJoin2(BatchStage<T1_IN>, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1>, BatchStage<T2_IN>, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2>, TriFunction<T, T1, T2, R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches to this and the two supplied stages a hash-joining stage and returns it.
hashJoin2(BatchStage<T1_IN>, JoinClause<K1, ? super T, ? super T1_IN, ? extends T1>, BatchStage<T2_IN>, JoinClause<K2, ? super T, ? super T2_IN, ? extends T2>, TriFunction<T, T1, T2, R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
hashJoinBuilder() - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
hashJoinBuilder() - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Returns a fluent API builder object to construct a hash join operation with any number of contributing stages.
HashJoinBuilder<T0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step fluent API to build a hash-join pipeline stage.
hashJoinBuilder() - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
hasLocalSharing() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns the hasLocalSharing flag.
hasOrderedAsyncResponses() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Tells whether the async responses are ordered, see ContextFactory.withUnorderedAsyncResponses().
hasUnfinishedItem() - Method in interface com.hazelcast.jet.core.Outbox
Returns true if this outbox has an unfinished item and the same item must be offered again.
hasUnfinishedItem() - Method in class com.hazelcast.jet.core.test.TestOutbox
 
hdfs(JobConf, FunctionEx<? super E, K>, FunctionEx<? super E, V>) - Static method in class com.hazelcast.jet.hadoop.HdfsSinks
Returns a sink that writes to Apache Hadoop HDFS.
hdfs(JobConf) - Static method in class com.hazelcast.jet.hadoop.HdfsSinks
Convenience for HdfsSinks.hdfs(JobConf, FunctionEx, FunctionEx) which expects Map.Entry<K, V> as input and extracts its key and value parts to be written to HDFS.
hdfs(JobConf, BiFunctionEx<K, V, E>) - Static method in class com.hazelcast.jet.hadoop.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.hadoop.HdfsSources
Convenience for HdfsSources.hdfs(JobConf, BiFunctionEx) with Map.Entry as its output type.
HdfsProcessors - Class in com.hazelcast.jet.hadoop
Static utility class with factories of Apache Hadoop HDFS source and sink processors.
HdfsSinks - Class in com.hazelcast.jet.hadoop
Factories of Apache Hadoop HDFS sinks.
HdfsSources - Class in com.hazelcast.jet.hadoop
Contains factory methods for Apache Hadoop HDFS sources.
higherFrameTs(long) - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the lowest frame timestamp greater than the given timestamp.

I

ICacheJet<K,V> - Interface in com.hazelcast.jet
A distributed, in-memory implementation of JCache specification.
identity() - Static method in interface com.hazelcast.jet.function.FunctionEx
idFromString(String) - Static method in class com.hazelcast.jet.Util
Parses the jobId formatted with Util.idToString(long).
idleTimeoutMillis() - Method in class com.hazelcast.jet.core.EventTimePolicy
Returns the amount of time allowed to pass without receiving any events from a partition before marking it as "idle".
idToString(long) - Static method in class com.hazelcast.jet.Util
Converts a long job or execution ID to a string representation.
ilike(String, String) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.ilike(String, String).
IListJet<E> - Interface in com.hazelcast.jet
A concurrent, in-memory concurrent list implementation.
iMapContext(String) - Static method in class com.hazelcast.jet.pipeline.ContextFactories
Returns a factory that provides an IMapJet as the context.
IMapJet<K,V> - Interface in com.hazelcast.jet
A distributed, in-memory concurrent map implementation.
in(String, Comparable...) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.in(String, Comparable[]).
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(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.
init() - Method in class com.hazelcast.jet.spring.JetNamespaceHandler
 
input(List<?>) - Method in class com.hazelcast.jet.core.test.TestSupport
Sets the input objects for processor.
inputs(List<List<?>>) - Method in class com.hazelcast.jet.core.test.TestSupport
Sets the input objects for the processor on multiple input ordinals.
inputs(List<List<?>>, int[]) - Method in class com.hazelcast.jet.core.test.TestSupport
Sets the input objects for the processor on multiple input ordinals.
insertWatermarksP(EventTimePolicy<? super T>) - 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
 
instanceOf(Class<? extends V>) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.instanceOf(Class).
isArchive() - Method in class com.hazelcast.jet.config.ResourceConfig
Whether this entry is an Jar archive or a single resource element.
isAutoScaling() - Method in class com.hazelcast.jet.config.JobConfig
Returns whether auto scaling is enabled, see JobConfig.setAutoScaling(boolean).
isCooperative() - Method in interface com.hazelcast.jet.core.Processor
Tells whether this processor is able to participate in cooperative multithreading.
isCooperative() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns the isCooperative flag.
isDistributed() - Method in class com.hazelcast.jet.core.Edge
Says whether this edge is distributed.
isEarly() - Method in class com.hazelcast.jet.datamodel.WindowResult
Returns whether this is an early window result, to be followed by the final one.
isEmpty() - Method in class com.hazelcast.jet.core.AppendableTraverser
Returns true, if the next call to AppendableTraverser.next() will return null.
isEmpty() - Method in interface com.hazelcast.jet.core.Inbox
Returns true if this inbox contains no elements, false otherwise.
isEmpty() - Method in class com.hazelcast.jet.core.test.TestInbox
 
isEnabled() - Method in class com.hazelcast.jet.config.MetricsConfig
Returns if metrics collection is enabled.
isEqual(Object) - Static method in interface com.hazelcast.jet.function.PredicateEx
isJmxEnabled() - Method in class com.hazelcast.jet.config.MetricsConfig
Returns whether metrics will be exposed through JMX MBeans.
isLosslessRestartEnabled() - Method in class com.hazelcast.jet.config.InstanceConfig
Returns if lossless restart is enabled, see InstanceConfig.setLosslessRestartEnabled(boolean).
isMetricsForDataStructuresEnabled() - Method in class com.hazelcast.jet.config.MetricsConfig
Returns if statistics for data structures are added to metrics.
isNull() - Method in class com.hazelcast.jet.accumulator.MutableReference
Tells whether the current value is null.
isolated() - Method in class com.hazelcast.jet.core.Edge
Activates the ISOLATED routing policy which establishes isolated paths from upstream to downstream processors.
isSplitBrainProtectionEnabled() - Method in class com.hazelcast.jet.config.JobConfig
Tells whether split brain protection is enabled.
isTumbling() - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Tells whether this definition describes a tumbling window.
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

jdbc(String, SupplierEx<Connection>, BiConsumerEx<PreparedStatement, T>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that connects to the specified database using the given connectionSupplier, prepares a statement using the given updateQuery and inserts/updates the items.
jdbc(String, String, BiConsumerEx<PreparedStatement, T>) - Static method in class com.hazelcast.jet.pipeline.Sinks
jdbc(SupplierEx<? extends Connection>, ToResultSetFunction, FunctionEx<? super ResultSet, ? extends T>) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source which connects to the specified database using the given connectionSupplier, queries the database and creates a result set using the the given resultSetFn.
jdbc(String, String, FunctionEx<? super ResultSet, ? extends T>) - Static method in class com.hazelcast.jet.pipeline.Sources
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
JetCacheManager is the entry point to access JSR-107 (JCache) caches via JetInstance interface.
JetClientBeanDefinitionParser - Class in com.hazelcast.jet.spring
BeanDefinitionParser for Hazelcast Jet Client Configuration.
JetClientBeanDefinitionParser() - Constructor for class com.hazelcast.jet.spring.JetClientBeanDefinitionParser
 
JetClientConfig - Class in com.hazelcast.jet.config
A config object which is used for configuring the Jet client to connect to the Jet cluster.
JetClientConfig() - Constructor for class com.hazelcast.jet.config.JetClientConfig
Creates a new config instance with default group name for Jet
JetCommandLine - Class in com.hazelcast.jet.server
 
JetCommandLine(Function<ClientConfig, JetInstance>, PrintStream, PrintStream) - Constructor for class com.hazelcast.jet.server.JetCommandLine
 
JetCommandLine.JetVersionProvider - Class in com.hazelcast.jet.server
 
JetCommandLine.Verbosity - Class in com.hazelcast.jet.server
 
JetConfig - Class in com.hazelcast.jet.config
Configuration object for a Jet instance.
JetConfig() - Constructor for class com.hazelcast.jet.config.JetConfig
Creates a new, empty JetConfig with the default configuration.
JetConfigDataSerializerHook - Class in com.hazelcast.jet.config
Hazelcast serializer hooks for the classes in the com.hazelcast.jet.config package.
JetConfigDataSerializerHook() - Constructor for class com.hazelcast.jet.config.JetConfigDataSerializerHook
 
JetConfigXmlGenerator - Class in com.hazelcast.jet.config
The JetConfigXmlGenerator is responsible for transforming a JetConfig to a Hazelcast Jet XML string.
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
 
JetHazelcastBeanDefinitionParser - Class in com.hazelcast.jet.spring
BeanDefinitionParser for Hazelcast Instance created via Jet Instance.
JetHazelcastBeanDefinitionParser() - Constructor for class com.hazelcast.jet.spring.JetHazelcastBeanDefinitionParser
 
jetInstance() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context
Returns the current Jet instance.
jetInstance() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
jetInstance(JetInstance) - Method in class com.hazelcast.jet.core.test.TestSupport
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.
JetInstanceBeanDefinitionParser - Class in com.hazelcast.jet.spring
BeanDefinitionParser for Hazelcast Jet Instance Configuration.
JetInstanceBeanDefinitionParser() - Constructor for class com.hazelcast.jet.spring.JetInstanceBeanDefinitionParser
 
JetNamespaceHandler - Class in com.hazelcast.jet.spring
Hazelcast Jet Custom Namespace Definitions.
JetNamespaceHandler() - Constructor for class com.hazelcast.jet.spring.JetNamespaceHandler
 
JetVersionProvider() - Constructor for class com.hazelcast.jet.server.JetCommandLine.JetVersionProvider
 
jmsQueue(SupplierEx<ConnectionFactory>, String) - Static method in class com.hazelcast.jet.pipeline.Sinks
jmsQueue(SupplierEx<? extends ConnectionFactory>, String) - Static method in class com.hazelcast.jet.pipeline.Sources
jmsQueueBuilder(SupplierEx<ConnectionFactory>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a builder object that offers a step-by-step fluent API to build a custom JMS queue sink for the Pipeline API.
jmsQueueBuilder(SupplierEx<? extends ConnectionFactory>) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a builder object that offers a step-by-step fluent API to build a custom JMS StreamSource for the Pipeline API.
JmsSinkBuilder<T> - Class in com.hazelcast.jet.pipeline
JmsSourceBuilder - Class in com.hazelcast.jet.pipeline
jmsTopic(SupplierEx<ConnectionFactory>, String) - Static method in class com.hazelcast.jet.pipeline.Sinks
jmsTopic(SupplierEx<? extends ConnectionFactory>, String) - Static method in class com.hazelcast.jet.pipeline.Sources
jmsTopicBuilder(SupplierEx<ConnectionFactory>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a builder object that offers a step-by-step fluent API to build a custom JMS topic sink for the Pipeline API.
jmsTopicBuilder(SupplierEx<? extends ConnectionFactory>) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a builder object that offers a step-by-step fluent API to build a custom JMS StreamSource for the Pipeline API.
Job - Interface in com.hazelcast.jet
A Jet computation job created by submitting a DAG or Pipeline.
JOB_CONFIG - Static variable in class com.hazelcast.jet.config.JetConfigDataSerializerHook
Serialization ID of the JobConfig class.
JobAlreadyExistsException - Exception in com.hazelcast.jet
Thrown when a named job is submitted while there is an active job with the same name.
JobAlreadyExistsException() - Constructor for exception com.hazelcast.jet.JobAlreadyExistsException
Creates the exception
JobAlreadyExistsException(String) - Constructor for exception com.hazelcast.jet.JobAlreadyExistsException
Creates the exception with a message.
JobAlreadyExistsException(String, Throwable) - Constructor for exception com.hazelcast.jet.JobAlreadyExistsException
Creates the exception with a message and a cause.
JobClassLoaderFactory - Interface in com.hazelcast.jet.config
An interface that can be implemented to provide custom class loader for Jet job.
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
 
jobConfig() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context
Returns the JobConfig.
jobConfig() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
jobId() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context
Returns the job ID.
jobId() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
jobId() - Method in class com.hazelcast.jet.JobStateSnapshot
Returns the job ID of the job the snapshot was originally exported from.
jobName() - Method in class com.hazelcast.jet.JobStateSnapshot
Returns the job name of the job the snapshot was originally exported from.
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
 
JobNotFoundException(String) - Constructor for exception com.hazelcast.jet.core.JobNotFoundException
 
JobNotFoundException(String, Throwable) - Constructor for exception com.hazelcast.jet.core.JobNotFoundException
 
JobStateSnapshot - Class in com.hazelcast.jet
A handle to an exported state snapshot created using Job.exportSnapshot(String).
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 an exception if the job completes with an error.
JoinClause<K,T0,T1,T1_OUT> - Class in com.hazelcast.jet.pipeline
Specifies how to join an enriching stream to the primary stream in a hash-join operation.
joinMapEntries(FunctionEx<? super T0, ? extends K>) - Static method in class com.hazelcast.jet.pipeline.JoinClause
A shorthand factory for the common case of hash-joining with a stream of map entries.
JournalInitialPosition - Enum in com.hazelcast.jet.pipeline
When passed to an IMap/ICache Event Journal source, specifies which event to start from.

K

kafka(Properties, FunctionEx<? super E, ProducerRecord<K, V>>) - Static method in class com.hazelcast.jet.kafka.KafkaSinks
Returns a source that publishes messages to an Apache Kafka topic.
kafka(Properties, String, FunctionEx<? super E, K>, FunctionEx<? super E, V>) - Static method in class com.hazelcast.jet.kafka.KafkaSinks
Convenience for KafkaSinks.kafka(Properties, FunctionEx) 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.kafka.KafkaSinks
Convenience for KafkaSinks.kafka(Properties, String, FunctionEx, FunctionEx) 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.kafka.KafkaSources
Convenience for KafkaSources.kafka(Properties, FunctionEx, String...) wrapping the output in Map.Entry.
kafka(Properties, FunctionEx<ConsumerRecord<K, V>, T>, String...) - Static method in class com.hazelcast.jet.kafka.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.kafka
Static utility class with factories of Apache Kafka source and sink processors.
KafkaSinks - Class in com.hazelcast.jet.kafka
Contains factory methods for Apache Kafka sinks.
KafkaSources - Class in com.hazelcast.jet.kafka
Contains factory methods for Apache Kafka sources.
key() - Method in class com.hazelcast.jet.core.BroadcastKey
Returns the underlying key
key() - Method in class com.hazelcast.jet.datamodel.KeyedWindowResult
Returns the grouping key.
KeyedWindowResult<K,R> - Class in com.hazelcast.jet.datamodel
Holds the result of a group-and-aggregate operation performed over a time window.
KeyedWindowResult(long, long, K, R, boolean) - Constructor for class com.hazelcast.jet.datamodel.KeyedWindowResult
 
KeyedWindowResult(long, long, K, R) - Constructor for class com.hazelcast.jet.datamodel.KeyedWindowResult
Constructs a keyed window result that is not early.
KeyedWindowResultFunction<K,R,OUT> - Interface in com.hazelcast.jet.core.function
Represents the function you pass to windowing processors such as aggregateToSlidingWindowP() and aggregateToSessionWindowP() as mapToOutputFn.
keyFn() - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Returns the function that extracts the key from stream items.
keyFn() - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Returns the function that extracts the grouping key from stream items.

L

lastForwardedWm() - Method in class com.hazelcast.jet.core.test.TestOutbox
 
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.pipeline.JoinClause
Returns the left-hand key extractor function.
lessEqual(String, Comparable) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.lessEqual(String, Comparable).
lessThan(String, Comparable) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.lessThan(String, Comparable).
like(String, String) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.like(String, String).
limitingLag(long) - Static method in interface com.hazelcast.jet.core.WatermarkPolicy
Maintains a watermark that lags behind the top observed timestamp by the given amount.
linearTrend(ToLongFunctionEx<T>, ToLongFunctionEx<T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that computes a linear trend over the items.
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.pipeline.Sinks
Returns a sink that adds the items it receives to a Hazelcast IList with the specified name.
list(IList<? super T>) - Static method in class com.hazelcast.jet.pipeline.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.pipeline.Sources
Returns a source that emits items retrieved from a Hazelcast IList.
list(IList<? extends T>) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source that emits items retrieved from a Hazelcast IList.
listJobs(JetCommandLine.Verbosity, boolean) - Method in class com.hazelcast.jet.server.JetCommandLine
 
listSnapshots(JetCommandLine.Verbosity) - Method in class com.hazelcast.jet.server.JetCommandLine
 
loadDefault() - Static method in class com.hazelcast.jet.config.JetConfig
Loads JetConfig using the default lookup mechanism to locate the configuration file.
loadDefault(Properties) - Static method in class com.hazelcast.jet.config.JetConfig
Loads JetConfig using the built-in lookup mechanism to locate the configuration file.
loadFromClasspath(ClassLoader, String) - Static method in class com.hazelcast.jet.config.JetConfig
Creates a JetConfig which is loaded from a classpath resource.
loadFromClasspath(ClassLoader, String, Properties) - Static method in class com.hazelcast.jet.config.JetConfig
Creates a JetConfig which is loaded from a classpath resource.
loadFromClasspath(String) - Static method in class com.hazelcast.jet.config.JetConfig
loadFromClasspath(String, Properties) - Static method in class com.hazelcast.jet.config.JetConfig
loadFromFile(File) - Static method in class com.hazelcast.jet.config.JetConfig
Creates a JetConfig based on a Hazelcast Jet configuration file (XML or YAML) and uses the System.properties to resolve variables in the file.
loadFromFile(File, Properties) - Static method in class com.hazelcast.jet.config.JetConfig
Creates a JetConfig based on a Hazelcast Jet configuration file (XML or YAML).
loadFromStream(InputStream) - Static method in class com.hazelcast.jet.config.JetConfig
loadFromStream(InputStream, Properties) - Static method in class com.hazelcast.jet.config.JetConfig
loadXmlFromStream(InputStream) - Static method in class com.hazelcast.jet.config.JetConfig
Loads JetConfig from the supplied input stream.
loadXmlFromStream(InputStream, Properties) - Static method in class com.hazelcast.jet.config.JetConfig
Loads JetConfig from the supplied input stream.
loadXmlFromString(String) - Static method in class com.hazelcast.jet.config.JetConfig
Creates a JetConfig from the provided XML string and uses the System.properties to resolve variables in the XML.
loadXmlFromString(String, Properties) - Static method in class com.hazelcast.jet.config.JetConfig
Creates a JetConfig from the provided XML string and properties to resolve the variables in the XML.
loadYamlFromStream(InputStream) - Static method in class com.hazelcast.jet.config.JetConfig
Loads JetConfig from the supplied input stream.
loadYamlFromStream(InputStream, Properties) - Static method in class com.hazelcast.jet.config.JetConfig
Loads JetConfig from the supplied input stream.
loadYamlFromString(String) - Static method in class com.hazelcast.jet.config.JetConfig
Creates a JetConfig from the provided YAML string and uses the System.properties to resolve variables in the YAML.
loadYamlFromString(String, Properties) - Static method in class com.hazelcast.jet.config.JetConfig
Creates a JetConfig from the provided YAML string and properties to resolve the variables in the YAML.
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 class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
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.
localProcessorIndex() - Method in interface com.hazelcast.jet.core.Processor.Context
Returns the index of the processor among all the processors created for this vertex on a single node: it's a unique node-wide index.
localProcessorIndex() - Method in class com.hazelcast.jet.core.test.TestProcessorContext
 
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 ProcessorMetaSupplier.
logger() - Method in interface com.hazelcast.jet.core.ProcessorSupplier.Context
Returns a logger for the associated ProcessorSupplier.
logger - Variable in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
logger() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
logger(FunctionEx<? super T, String>) - Static method in class com.hazelcast.jet.pipeline.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.pipeline.Sinks
Convenience for Sinks.logger(FunctionEx) with Object.toString() as the toStringFn.
loggerName() - Method in class com.hazelcast.jet.core.test.TestProcessorContext
 
loggerName() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
loggerName() - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
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 values.
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 values.

M

main(String[]) - Static method in class com.hazelcast.jet.server.JetCommandLine
 
main(String[]) - Static method in class com.hazelcast.jet.server.StartServer
Creates a server instance of Hazelcast Jet.
map(FunctionEx<? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
map(FunctionEx<? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a mapping stage which applies the given function to each input item independently and emits the function's result as the output item.
map(String) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that puts Map.Entrys it receives into a Hazelcast IMap with the specified name.
map(IMap<? super K, ? super V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that puts Map.Entrys it receives into the given Hazelcast IMap.
map(String) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source that fetches entries from a local Hazelcast IMap with the specified name and emits them as Map.Entry.
map(IMap<? extends K, ? extends V>) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source that fetches entries from the given Hazelcast IMap and emits them as Map.Entry.
map(String, Predicate<? super K, ? super V>, Projection<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source that fetches entries from a local Hazelcast IMap with the specified name.
map(IMap<? extends K, ? extends V>, Predicate<? super K, ? super V>, Projection<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source that fetches entries from the given Hazelcast IMap.
map(String, Predicate<? super K, ? super V>, FunctionEx<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for Sources.map(String, Predicate, Projection) which uses a FunctionEx as the projection function.
map(IMap<? extends K, ? extends V>, Predicate<? super K, ? super V>, FunctionEx<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for Sources.map(IMap, Predicate, Projection) which uses a FunctionEx as the projection function.
map(FunctionEx<? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
map(Function<? super T, ? extends R>) - Method in interface com.hazelcast.jet.Traverser
Returns a traverser that will emit the results of applying mapFn to this traverser's items.
mapEventNewValue() - Static method in class com.hazelcast.jet.Util
Returns a projection that extracts the new value from an EventJournalMapEvent.
mapEventToEntry() - Static method in class com.hazelcast.jet.Util
Returns a projection that converts the EventJournalMapEvent to a Map.Entry using the event's new value as a value.
mapJournal(String, PredicateEx<? super EventJournalMapEvent<K, V>>, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T>, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source that will stream EventJournalMapEvents of the Hazelcast IMap with the specified name.
mapJournal(IMap<? extends K, ? extends V>, PredicateEx<? super EventJournalMapEvent<K, V>>, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T>, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns a source that will stream EventJournalMapEvents of the given Hazelcast IMap.
mapJournal(String, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for Sources.mapJournal(String, PredicateEx, FunctionEx, JournalInitialPosition) which will pass only ADDED and UPDATED events and will project the event's key and new value into a Map.Entry.
mapJournal(IMap<? extends K, ? extends V>, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for Sources.mapJournal(IMap, PredicateEx, FunctionEx, JournalInitialPosition) which will pass only ADDED and UPDATED events and will project the event's key and new value into a Map.Entry.
mapP(FunctionEx<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(FunctionEx<? super T, ? extends U>, AggregateOperation1<? super U, A, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Adapts an aggregate operation that takes items of type U to one that takes items of type T, by applying the given mapping function to each item.
mapPutEvents() - Static method in class com.hazelcast.jet.Util
mapUsingContext(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
mapUsingContext(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
mapUsingContext(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a mapping stage which applies the supplied function to each input item independently and emits the function's result as the output item.
mapUsingContext(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a mapping stage which applies the given function to each input item independently and emits the function's result as the output item.
mapUsingContext(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
mapUsingContext(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
mapUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
mapUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
mapUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<R>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
mapUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<R>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
mapUsingContextAsync(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends CompletableFuture<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
mapUsingContextAsync(ContextFactory<C>, TriFunction<? super C, ? super K, ? super T, CompletableFuture<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
mapUsingContextAsyncP(ContextFactory<C>, FunctionEx<T, K>, BiFunctionEx<? super C, ? super T, CompletableFuture<R>>) - Static method in class com.hazelcast.jet.core.processor.Processors
mapUsingContextP(ContextFactory<C>, BiFunctionEx<? super C, ? super T, ? extends 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.
mapUsingIMap(String, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
mapUsingIMap(IMap<K, V>, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
mapUsingIMap(String, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
mapUsingIMap(IMap<K, V>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
mapUsingIMap(String, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a mapping stage where for each item a lookup in the IMap with the supplied name is performed and the result of the lookup is merged with the item and emitted.
mapUsingIMap(IMap<K, V>, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a mapping stage where for each item a lookup in the supplied IMap is performed and the result of the lookup is merged with the item and emitted.
mapUsingIMap(String, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a mapping stage where for each item a lookup in the IMap with the supplied name using the grouping key is performed and the result of the lookup is merged with the item and emitted.
mapUsingIMap(IMap<K, V>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a mapping stage where for each item a lookup in the supplied IMap using the grouping key is performed and the result of the lookup is merged with the item and emitted.
mapUsingIMap(String, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
mapUsingIMap(IMap<K, V>, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
mapUsingIMap(String, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
mapUsingIMap(IMap<K, V>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
mapUsingReplicatedMap(String, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
mapUsingReplicatedMap(ReplicatedMap<K, V>, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
mapUsingReplicatedMap(String, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a mapping stage where for each item a lookup in the ReplicatedMap with the supplied name is performed and the result of the lookup is merged with the item and emitted.
mapUsingReplicatedMap(ReplicatedMap<K, V>, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a mapping stage where for each item a lookup in the supplied ReplicatedMap is performed and the result of the lookup is merged with the item and emitted.
mapUsingReplicatedMap(String, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
mapUsingReplicatedMap(ReplicatedMap<K, V>, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super T, ? super V, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
mapWithEntryProcessor(String, FunctionEx<? super E, ? extends K>, FunctionEx<? super E, ? extends EntryProcessor<K, V>>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that uses the items it receives to create EntryProcessors it submits to a Hazelcast IMap with the specified name.
mapWithEntryProcessor(IMap<? super K, ? super V>, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends EntryProcessor<K, V>>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that uses the items it receives to create EntryProcessors it submits to a Hazelcast IMap with the specified name.
mapWithMerging(String, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends V>, BinaryOperatorEx<V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that uses the supplied functions to extract the key and value with which to update a Hazelcast IMap.
mapWithMerging(IMap<? super K, ? super V>, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends V>, BinaryOperatorEx<V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that uses the supplied functions to extract the key and value with which to update a Hazelcast IMap.
mapWithMerging(String, BinaryOperatorEx<? super V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
mapWithMerging(IMap<? super K, V>, BinaryOperatorEx<V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
mapWithUpdating(String, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super V, ? super T, ? extends V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that uses the supplied key-extracting and value-updating functions to update a Hazelcast IMap.
mapWithUpdating(IMap<? super K, ? super V>, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super V, ? super T, ? extends V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink that uses the supplied key-extracting and value-updating functions to update a Hazelcast IMap.
mapWithUpdating(String, BiFunctionEx<? super V, ? super E, ? extends V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
mapWithUpdating(IMap<? super K, ? super V>, BiFunctionEx<? super V, ? super E, ? extends V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
MAX_PENDING_CALLS_DEFAULT - Static variable in class com.hazelcast.jet.pipeline.ContextFactory
maxBy(ComparatorEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that computes the greatest item according to the given comparator.
maxBy(Comparator<? super T>) - Static method in interface com.hazelcast.jet.function.BinaryOperatorEx
maxPendingCallsPerProcessor() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns the maximum pending calls per processor, see ContextFactory.withMaxPendingCallsPerProcessor(int).
memberCount() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context
Returns the number of members running this job.
memberCount() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
memberIndex() - Method in interface com.hazelcast.jet.core.ProcessorSupplier.Context
Returns the index of the member among all the members that run this job: it's a unique cluster-wide index.
memberIndex() - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
merge(BatchStage<? extends T>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
Attaches a stage that emits all the items from this stage as well as all the items from the supplied stage.
merge(StreamStage<? extends T>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
Attaches a stage that emits all the items from this stage as well as all the items from the supplied stage.
mergeMapP(String, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends V>, BinaryOperatorEx<V>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
mergeRemoteMapP(String, ClientConfig, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends V>, BinaryOperatorEx<V>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
messageFn(BiFunctionEx<Session, T, Message>) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the function which creates the message from the item.
MetricsConfig - Class in com.hazelcast.jet.config
Configuration options specific to metrics collection.
MetricsConfig() - Constructor for class com.hazelcast.jet.config.MetricsConfig
 
minBy(ComparatorEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that computes the least item according to the given comparator.
minBy(Comparator<? super T>) - Static method in interface com.hazelcast.jet.function.BinaryOperatorEx
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 class com.hazelcast.jet.JobStateSnapshot
Returns the snapshot name.
name() - Method in interface com.hazelcast.jet.pipeline.BatchSource
Returns a descriptive name of this source.
name() - Method in interface com.hazelcast.jet.pipeline.Sink
Returns a descriptive name for this sink.
name() - Method in interface com.hazelcast.jet.pipeline.Stage
Returns the name of this stage.
name() - Method in interface com.hazelcast.jet.pipeline.StreamSource
Returns a descriptive name of this source.
naturalOrder() - Static method in interface com.hazelcast.jet.function.ComparatorEx
Serializable variant of java.util.Comparator#naturalOrder().
negate() - Method in interface com.hazelcast.jet.function.BiPredicateEx
negate() - Method in interface com.hazelcast.jet.function.PredicateEx
Serializable variant of Predicate.negate().
negate() - Method in interface com.hazelcast.jet.function.TriPredicate
Returns a composite predicate which evaluates the equivalent of !this.test(t, u, v).
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() - Static method in class com.hazelcast.jet.Jet
Creates a member of the Jet cluster with the configuration loaded from default location.
newJetInstance(JetConfig) - Static method in class com.hazelcast.jet.Jet
Creates a member of the Jet cluster with the given configuration.
newJob(DAG) - Method in interface com.hazelcast.jet.JetInstance
Creates and returns a Jet job based on the supplied DAG.
newJob(Pipeline) - Method in interface com.hazelcast.jet.JetInstance
Creates and returns an executable job based on the supplied pipeline.
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, JobConfig) - Method in interface com.hazelcast.jet.JetInstance
Creates and returns a Jet job based on the supplied pipeline and job configuration.
newJobIfAbsent(DAG, JobConfig) - Method in interface com.hazelcast.jet.JetInstance
Creates and returns a Jet job based on the supplied DAG and job configuration.
newJobIfAbsent(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, SupplierEx<? 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.
newWmPolicyFn() - Method in class com.hazelcast.jet.core.EventTimePolicy
Returns the factory of the watermark policy objects.
next() - Method in class com.hazelcast.jet.core.AppendableTraverser
 
next() - Method in class com.hazelcast.jet.core.ResettableSingletonTraverser
 
next() - Method in interface com.hazelcast.jet.Traverser
Returns the next item, removing it from this traverser.
NO_NATIVE_TIME - Static variable in class com.hazelcast.jet.core.EventTimeMapper
Value to use as the nativeEventTime argument when calling EventTimeMapper.flatMapEvent(Object, int, long) when there's no native event time to supply.
noEventTime() - Static method in class com.hazelcast.jet.core.EventTimePolicy
Returns an event time policy that results in no timestamping.
noop() - Static method in interface com.hazelcast.jet.function.ConsumerEx
Returns a consumer that does nothing.
noop() - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink which discards all received items.
noopP() - Static method in class com.hazelcast.jet.core.processor.Processors
Returns a supplier of a processor that swallows all its normal input (if any), does nothing with it, forwards the watermarks, produces no output and completes immediately.
not(Predicate<K, V>) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.not(Predicate).
notEqual(String, Comparable) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.notEqual(String, Comparable).
nullsFirst(Comparator<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
nullsFirst(ComparatorEx<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
nullsLast(Comparator<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx
nullsLast(ComparatorEx<? super T>) - Static method in interface com.hazelcast.jet.function.ComparatorEx

O

ObjLongBiFunction<T,R> - Interface in com.hazelcast.jet.core.function
Represents a specialization of BiFunction where the second argument is a long.
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(SupplierEx<? 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(SupplierEx<? 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(FunctionEx<? super Address, ? extends 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(FunctionEx<? super Address, ? extends 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(SupplierEx<? 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.
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(Object) - Method in class com.hazelcast.jet.core.test.TestOutbox
 
offer(int[], 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
 
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(FunctionEx<? super T0, ? extends K>, FunctionEx<? super T1, ? extends K>) - Static method in class com.hazelcast.jet.pipeline.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(BiPredicateEx<? super T, ? super U>) - Method in interface com.hazelcast.jet.function.BiPredicateEx
or(PredicateEx<? super T>) - Method in interface com.hazelcast.jet.function.PredicateEx
or(TriPredicate<? super T, ? super U, ? super V>) - Method in interface com.hazelcast.jet.function.TriPredicate
Returns a composite predicate which evaluates the equivalent of this.test(t, u, v) || other.test(t, u, v).
or(Predicate<K, V>...) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.or(Predicate[]).
ORDERED_ASYNC_RESPONSES_DEFAULT - Static variable in class com.hazelcast.jet.pipeline.ContextFactory
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.

P

parseInternal(Element, ParserContext) - Method in class com.hazelcast.jet.spring.JetClientBeanDefinitionParser
 
parseInternal(Element, ParserContext) - Method in class com.hazelcast.jet.spring.JetHazelcastBeanDefinitionParser
 
parseInternal(Element, ParserContext) - Method in class com.hazelcast.jet.spring.JetInstanceBeanDefinitionParser
 
partitionCount() - Method in class com.hazelcast.jet.core.EventTimeMapper
Returns the current partition count.
partitioned(FunctionEx<T, ?>) - Method in class com.hazelcast.jet.core.Edge
Activates the PARTITIONED routing policy and applies the default Hazelcast partitioning strategy.
partitioned(FunctionEx<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.
partitionIdleTimeout() - Method in interface com.hazelcast.jet.pipeline.StreamSource
payloadSize() - Method in class com.hazelcast.jet.JobStateSnapshot
Returns the size in bytes of the payload data of the state snapshot.
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() - Method in class com.hazelcast.jet.core.test.TestInbox
 
peek() - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
peek(PredicateEx<? super T>, FunctionEx<? super T, ? extends CharSequence>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
peek(FunctionEx<? super T, ? extends CharSequence>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
peek(PredicateEx<? super T>, FunctionEx<? super T, ? extends CharSequence>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a peeking stage which logs this stage's output and passes it through without transformation.
peek(FunctionEx<? super T, ? extends CharSequence>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Adds a peeking layer to this compute stage which logs its output.
peek() - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Adds a peeking layer to this compute stage which logs its output.
peek() - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
peek(PredicateEx<? super T>, FunctionEx<? super T, ? extends CharSequence>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
peek(FunctionEx<? super T, ? extends CharSequence>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
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(FunctionEx<T, ? extends CharSequence>, PredicateEx<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(FunctionEx<T, ? extends CharSequence>, PredicateEx<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(FunctionEx<T, ? extends CharSequence>, PredicateEx<T>, SupplierEx<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors
Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a SupplierEx 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(SupplierEx<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(FunctionEx<? super T, ? extends CharSequence>, PredicateEx<? super 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(FunctionEx<? super T, ? extends CharSequence>, PredicateEx<? super 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(FunctionEx<? super T, ? extends CharSequence>, PredicateEx<? super T>, SupplierEx<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors
Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a SupplierEx 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(SupplierEx<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(FunctionEx<? super Map.Entry<K, V>, ? extends CharSequence>, PredicateEx<? super 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(FunctionEx<? super Map.Entry<K, V>, ? extends CharSequence>, PredicateEx<? super 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(FunctionEx<? super Map.Entry<K, V>, ? extends CharSequence>, PredicateEx<? super Map.Entry<K, V>>, SupplierEx<Processor>) - Static method in class com.hazelcast.jet.core.processor.DiagnosticProcessors
Same as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a SupplierEx of processors instead of a meta-supplier.
peekSnapshotP(SupplierEx<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.
pickAny() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation whose result is an arbitrary item it observed, or null if it observed no items.
Pipeline - Interface in com.hazelcast.jet.pipeline
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.
poll() - Method in class com.hazelcast.jet.core.test.TestInbox
 
PredicateEx<T> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.Predicate which declares checked exception.
preferLocalParallelismOne(ProcessorSupplier) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier
Wraps the provided ProcessorSupplier into a meta-supplier that will always return it.
preferLocalParallelismOne(SupplierEx<? extends Processor>) - Static method in interface com.hazelcast.jet.core.ProcessorMetaSupplier
Variant of ProcessorMetaSupplier.preferLocalParallelismOne(ProcessorSupplier) where the supplied SupplierEx<Processor> will be wrapped into a ProcessorSupplier.
preferredLocalParallelism() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier
Returns the local parallelism the vertex should be configured with.
preferredLocalParallelism(int) - Method in class com.hazelcast.jet.pipeline.SinkBuilder
Sets the local parallelism of the sink.
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.ProcessorMetaSupplier.Context
Returns the guarantee for current job.
processingGuarantee() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
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(FunctionEx<? super T1, ? extends T1_NEW_OUT>) - Method in class com.hazelcast.jet.pipeline.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

QuadFunction<T0,T1,T2,T3,R> - Interface in com.hazelcast.jet.function
Represents a four-arity function that accepts four arguments and produces a result.
queue() - Method in class com.hazelcast.jet.core.test.TestInbox
Retrieves the queue backing the inbox.
queue(int) - Method in class com.hazelcast.jet.core.test.TestOutbox
Exposes individual output queues 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.config.JobConfig
 
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, String, boolean, SupplierEx<? extends DatumReader<D>>, BiFunctionEx<String, ? super D, T>) - Static method in class com.hazelcast.jet.avro.AvroProcessors
readFilesP(String, Charset, String, boolean, BiFunctionEx<? super String, ? super String, ? extends R>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
Returns a supplier of processors for Sources.filesBuilder(java.lang.String).
readHdfsP(JobConf, BiFunctionEx<K, V, R>) - Static method in class com.hazelcast.jet.hadoop.HdfsProcessors
Returns a supplier of processors for HdfsSources.hdfs(JobConf, BiFunctionEx).
readJdbcP(SupplierEx<? extends Connection>, ToResultSetFunction, FunctionEx<? super ResultSet, ? extends T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
readJdbcP(String, String, FunctionEx<? super ResultSet, ? extends T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
Returns a supplier of processors for Sources.jdbc(String, String, FunctionEx).
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<? super K, ? super V>, Projection<? super Map.Entry<K, V>, ? extends 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<? super K, ? super V>, FunctionEx<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
Returns a supplier of processors for Sources.map(String, Predicate, FunctionEx).
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<? super K, ? super V>, Projection<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
readRemoteMapP(String, ClientConfig, Predicate<? super K, ? super V>, FunctionEx<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
receiveFn(BiConsumerEx<? super W, ? super T_NEW>) - Method in class com.hazelcast.jet.pipeline.SinkBuilder
Sets the function Jet will call upon receiving an item.
reducing(A, FunctionEx<? super T, ? extends A>, BinaryOperatorEx<A>, BinaryOperatorEx<A>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that constructs the result through the process of immutable reduction: The initial accumulated value is emptyAccValue.
regex(String, String) - Static method in class com.hazelcast.jet.pipeline.GenericPredicates
See Predicates.regex(String, String).
remoteCache(String, ClientConfig) - Static method in class com.hazelcast.jet.pipeline.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.pipeline.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, PredicateEx<? super EventJournalCacheEvent<K, V>>, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T>, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.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, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for Sources.remoteCacheJournal(String, ClientConfig, PredicateEx, FunctionEx, JournalInitialPosition) which will pass only CREATED and UPDATED events and will project the event's key and new value into a Map.Entry.
remoteList(String, ClientConfig) - Static method in class com.hazelcast.jet.pipeline.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.pipeline.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.pipeline.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.pipeline.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<? super K, ? super V>, Projection<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.pipeline.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<? super K, ? super V>, FunctionEx<? super Map.Entry<K, V>, ? extends T>) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for Sources.remoteMap(String, ClientConfig, Predicate, Projection) which use a FunctionEx as the projection function.
remoteMapJournal(String, ClientConfig, PredicateEx<? super EventJournalMapEvent<K, V>>, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T>, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.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, JournalInitialPosition) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for Sources.remoteMapJournal(String, ClientConfig, PredicateEx, FunctionEx, JournalInitialPosition) which will pass only ADDED and UPDATED events and will project the event's key and new value into a Map.Entry.
remoteMapWithEntryProcessor(String, ClientConfig, FunctionEx<? super E, ? extends K>, FunctionEx<? super E, ? extends EntryProcessor<K, V>>) - Static method in class com.hazelcast.jet.pipeline.Sinks
remoteMapWithMerging(String, ClientConfig, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends V>, BinaryOperatorEx<V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a sink equivalent to Sinks.mapWithMerging(String, BinaryOperatorEx), but for a map in a remote Hazelcast cluster identified by the supplied ClientConfig.
remoteMapWithMerging(String, ClientConfig, BinaryOperatorEx<V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
remoteMapWithUpdating(String, ClientConfig, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super V, ? super T, ? extends V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
remoteMapWithUpdating(String, ClientConfig, BiFunctionEx<? super V, ? super E, ? extends V>) - Static method in class com.hazelcast.jet.pipeline.Sinks
remove() - Method in interface com.hazelcast.jet.core.Inbox
Removes the head of this inbox.
remove() - Method in class com.hazelcast.jet.core.test.TestInbox
 
removePartition(int) - Method in class com.hazelcast.jet.core.EventTimeMapper
Removes a partition that will no longer have events.
replicatedMapContext(String) - Static method in class com.hazelcast.jet.pipeline.ContextFactories
Returns a factory that provides a ReplicatedMap as the context object.
reportEvent(long) - Method in interface com.hazelcast.jet.core.WatermarkPolicy
Called to report the observation of an event with the given timestamp.
reset() - Method in class com.hazelcast.jet.core.test.TestOutbox
 
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.
restart() - Method in interface com.hazelcast.jet.Job
Gracefully stops the current execution and schedules a new execution with the current member list of the Jet cluster.
restart(JetCommandLine.Verbosity, String) - Method in class com.hazelcast.jet.server.JetCommandLine
 
RestartableException - Exception in com.hazelcast.jet
Exception to throw from job-executing methods to indicate a failure that can be resolved by restarting the job.
RestartableException() - Constructor for exception com.hazelcast.jet.RestartableException
 
RestartableException(String) - Constructor for exception com.hazelcast.jet.RestartableException
 
RestartableException(String, Throwable) - Constructor for exception com.hazelcast.jet.RestartableException
 
RestartableException(Throwable) - Constructor for exception com.hazelcast.jet.RestartableException
 
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.
restoreSnapshotFn(BiConsumerEx<? super C, ? super List<S>>) - Method in class com.hazelcast.jet.pipeline.SourceBuilder.FaultTolerant
Sets the function that restores the source's state from a snapshot.
restoreWatermark(int, long) - Method in class com.hazelcast.jet.core.EventTimeMapper
Restore watermark value from state snapshot.
result() - Method in class com.hazelcast.jet.datamodel.WindowResult
Returns the aggregated result.
resume() - Method in interface com.hazelcast.jet.Job
Resumes a suspended job.
resume(JetCommandLine.Verbosity, String) - Method in class com.hazelcast.jet.server.JetCommandLine
 
reversed() - Method in interface com.hazelcast.jet.function.ComparatorEx
Serializable variant of java.util.Comparator#reversed()
reverseOrder() - Static method in interface com.hazelcast.jet.function.ComparatorEx
Serializable variant of java.util.Comparator#reverseOrder().
rightKeyFn() - Method in class com.hazelcast.jet.pipeline.JoinClause
Returns the right-hand key extractor function.
rightProjectFn() - Method in class com.hazelcast.jet.pipeline.JoinClause
Returns the right-hand projection function.
rollingAggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
rollingAggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
rollingAggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a rolling aggregation stage.
rollingAggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a rolling aggregation stage.
rollingAggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
rollingAggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
rollingAggregateP(FunctionEx<? super T, ? extends K>, AggregateOperation1<? super T, A, ? extends R>, TriFunction<? super T, ? super K, ? super R, ? extends OUT>) - Static method in class com.hazelcast.jet.core.processor.Processors
Returns a supplier of processors for a vertex that performs a rolling aggregation.
run() - Method in class com.hazelcast.jet.server.JetCommandLine
 
runUntilOutputMatches(long, long) - Method in class com.hazelcast.jet.core.test.TestSupport
Normally, the complete() method is run repeatedly until it returns true.

S

SAME_ITEMS_ANY_ORDER - Static variable in class com.hazelcast.jet.core.test.TestSupport
An output checker that will claim actual and expected object lists as equal if they both contain the same items, in any order.
saveSnapshot(JetCommandLine.Verbosity, String, String, boolean) - Method in class com.hazelcast.jet.server.JetCommandLine
 
saveToSnapshot() - Method in interface com.hazelcast.jet.core.Processor
Stores its snapshotted state by adding items to the outbox's snapshot bucket.
sendFn(BiConsumerEx<MessageProducer, Message>) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the function which sends the message via message producer.
session(long) - Static method in class com.hazelcast.jet.pipeline.WindowDefinition
Returns a window definition that aggregates events into session windows.
sessionFn(FunctionEx<Connection, Session>) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the function which creates a session from a connection.
sessionFn(FunctionEx<? super Connection, ? extends Session>) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the function which creates the session from connection.
sessionParams(boolean, int) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the session parameters.
sessionParams(boolean, int) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the session parameters.
sessionTimeout() - Method in class com.hazelcast.jet.pipeline.SessionWindowDefinition
Returns the session timeout, which is the largest difference in the timestamps of any two consecutive events in the session window.
SessionWindowDefinition - Class in com.hazelcast.jet.pipeline
Represents the definition of a session window.
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.
set1(long) - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator
Sets the first value.
set2(long) - Method in class com.hazelcast.jet.accumulator.LongLongAccumulator
Sets the second value.
setAutoScaling(boolean) - Method in class com.hazelcast.jet.config.JobConfig
Sets whether Jet will scale the job up or down when a member is added or removed from the cluster.
setBackupCount(int) - Method in class com.hazelcast.jet.config.InstanceConfig
Sets the number of backups that Jet will maintain for the job metadata and snapshots.
setClassLoaderFactory(JobClassLoaderFactory) - Method in class com.hazelcast.jet.config.JobConfig
Sets a custom JobClassLoaderFactory that will be used to load job classes and resources on Jet members.
setCollectionIntervalSeconds(int) - Method in class com.hazelcast.jet.config.MetricsConfig
Sets the metrics collection interval in seconds.
setConfig(EdgeConfig) - Method in class com.hazelcast.jet.core.Edge
Assigns an EdgeConfig to this edge.
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.
setDouble(double) - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator
Sets the double value.
setEarlyResultsPeriod(long) - Method in class com.hazelcast.jet.pipeline.SessionWindowDefinition
 
setEarlyResultsPeriod(long) - Method in class com.hazelcast.jet.pipeline.SlidingWindowDefinition
 
setEarlyResultsPeriod(long) - Method in class com.hazelcast.jet.pipeline.WindowDefinition
Sets the period in milliseconds at which the windowed aggregation stage will emit partial results of all the windows that contain some data, but the watermark hasn't yet advanced enough to close them and emit the final results.
setEnabled(boolean) - Method in class com.hazelcast.jet.config.MetricsConfig
Sets whether metrics collection should be enabled for the node.
setExecutionId(long) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets the execution ID.
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 Hazelcast IMDG instance's configuration object.
setInitialSnapshotName(String) - Method in class com.hazelcast.jet.config.JobConfig
Sets the exported state snapshot name to restore the initial job state from.
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
 
setJetInstance(JetInstance) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets the jet instance.
setJetInstance(JetInstance) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
setJmxEnabled(boolean) - Method in class com.hazelcast.jet.config.MetricsConfig
Enables metrics exposure through JMX.
setJobConfig(JobConfig) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets the job name.
setJobId(long) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets the job ID.
setLocalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorContext
 
setLocalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets local parallelism.
setLocalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
setLocalParallelism(int) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
setLocalParallelism(int) - Method in interface com.hazelcast.jet.pipeline.SinkStage
 
setLocalParallelism(int) - Method in interface com.hazelcast.jet.pipeline.Stage
Sets the preferred local parallelism (number of processors per Jet cluster member) this stage will configure its DAG vertices with.
setLocalParallelism(int) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
setLocalProcessorIndex(int) - Method in class com.hazelcast.jet.core.test.TestProcessorContext
Set the local processor index
setLogger(ILogger) - Method in class com.hazelcast.jet.core.test.TestProcessorContext
 
setLogger(ILogger) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets the logger.
setLogger(ILogger) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
setLong(long) - Method in class com.hazelcast.jet.accumulator.LongDoubleAccumulator
Sets the long value.
setLosslessRestartEnabled(boolean) - Method in class com.hazelcast.jet.config.InstanceConfig
Sets whether lossless job restart is enabled for the node.
setMemberIndex(int) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
Set the member index.
setMetricsConfig(MetricsConfig) - Method in class com.hazelcast.jet.config.JetConfig
Sets the metrics collection config.
setMetricsForDataStructuresEnabled(boolean) - Method in class com.hazelcast.jet.config.MetricsConfig
Sets whether statistics for data structures are added to metrics.
setName(String) - Method in class com.hazelcast.jet.config.JobConfig
Sets the name of the job.
setName(String) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
setName(String) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
 
setName(String) - Method in interface com.hazelcast.jet.pipeline.SinkStage
 
setName(String) - Method in interface com.hazelcast.jet.pipeline.Stage
Overrides the default name of the stage with the name you choose and returns the stage.
setName(String) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
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.
setPartitionIdleTimeout(long) - Method in interface com.hazelcast.jet.pipeline.StreamSource
Sets a timeout after which idle partitions will be excluded from watermark coalescing.
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
 
setProcessingGuarantee(ProcessingGuarantee) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets the processing guarantee.
setProcessingGuarantee(ProcessingGuarantee) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
setProperties(Properties) - Method in class com.hazelcast.jet.config.JetConfig
Sets the Jet-specific configuration properties.
setProperty(String, String) - Method in class com.hazelcast.jet.config.JetConfig
Sets the value of the specified property.
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.
setRetentionSeconds(int) - Method in class com.hazelcast.jet.config.MetricsConfig
Returns the number of seconds the metrics will be retained on the instance.
setScaleUpDelayMillis(long) - Method in class com.hazelcast.jet.config.InstanceConfig
Sets the delay after which auto-scaled jobs will restart if a new member is added to the cluster.
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.
setTotalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorContext
 
setTotalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets the total parallelism.
setTotalParallelism(int) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
setValue(R) - Method in class com.hazelcast.jet.datamodel.KeyedWindowResult
Implements Map.Entry, throws UnsupportedOperationException.
setValue(E1) - Method in class com.hazelcast.jet.datamodel.Tuple2
 
setVertexName(String) - Method in class com.hazelcast.jet.core.test.TestProcessorContext
 
setVertexName(String) - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
Sets the vertex name.
setVertexName(String) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
SHARE_LOCALLY_DEFAULT - Static variable in class com.hazelcast.jet.pipeline.ContextFactory
sharedFileSystem(boolean) - Method in class com.hazelcast.jet.avro.AvroSourceBuilder
Sets if files are in a shared storage visible to all members.
sharedFileSystem(boolean) - Method in class com.hazelcast.jet.pipeline.FileSourceBuilder
Sets if files are in a shared storage visible to all members.
shutdown() - Method in interface com.hazelcast.jet.JetInstance
Shuts down the current instance.
shutdownAll() - Static method in class com.hazelcast.jet.Jet
Shuts down all running Jet client and member instances.
singleton(T) - Static method in class com.hazelcast.jet.Traversers
Returns a traverser over the given single item.
Sink<T> - Interface in com.hazelcast.jet.pipeline
A data sink in a Jet pipeline.
SinkBuilder<W,T> - Class in com.hazelcast.jet.pipeline
sinkBuilder(String, FunctionEx<Processor.Context, ? extends W>) - Static method in class com.hazelcast.jet.pipeline.SinkBuilder
Returns a builder object that offers a step-by-step fluent API to build a custom Sink for the Pipeline API.
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.pipeline
Contains factory methods for various types of pipeline sinks.
SinkStage - Interface in com.hazelcast.jet.pipeline
A pipeline stage that doesn't allow any downstream stages to be attached to it.
size() - Method in class com.hazelcast.jet.core.test.TestInbox
Convenience for inbox.queue().size()
size() - Method in interface com.hazelcast.jet.pipeline.SourceBuilder.SourceBuffer
Returns the number of items the buffer holds.
slideBy() - Method in class com.hazelcast.jet.pipeline.SlidingWindowDefinition
Returns the size of the sliding step.
sliding(long, long) - Static method in class com.hazelcast.jet.pipeline.WindowDefinition
Returns a sliding window definition with the given parameters.
SlidingWindowDefinition - Class in com.hazelcast.jet.pipeline
Represents the definition of a sliding window.
SlidingWindowPolicy - Class in com.hazelcast.jet.core
Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.
slidingWinPolicy(long, long) - Static method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the definition of a sliding window of length windowSize 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.ProcessorMetaSupplier.Context
Returns true, if snapshots will be saved for this job.
socket(String, int, FunctionEx<? super T, ? extends String>, Charset) - Static method in class com.hazelcast.jet.pipeline.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, FunctionEx<? super T, ? extends String>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Convenience for Sinks.socket(String, int, FunctionEx, Charset) with UTF-8 as the charset.
socket(String, int) - Static method in class com.hazelcast.jet.pipeline.Sinks
Convenience for Sinks.socket(String, int, FunctionEx, 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.pipeline.Sources
Returns a source which connects to the specified socket and emits lines of text received from it.
socket(String, int) - Static method in class com.hazelcast.jet.pipeline.Sources
Convenience for socket(host, port, charset) with UTF-8 as the charset.
sorting(ComparatorEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates all input items into an ArrayList and sorts it with the given comparator.
SourceBuilder<C> - Class in com.hazelcast.jet.pipeline
Top-level class for Jet custom source builders.
SourceBuilder.Batch<T> - Class in com.hazelcast.jet.pipeline
SourceBuilder.FaultTolerant<B,S> - Class in com.hazelcast.jet.pipeline
Represents a step in building a custom source where you add a SourceBuilder.FaultTolerant.restoreSnapshotFn(com.hazelcast.jet.function.BiConsumerEx<? super C, ? super java.util.List<S>>) after adding a createSnapshotFn.
SourceBuilder.SourceBuffer<T> - Interface in com.hazelcast.jet.pipeline
The buffer object that the fillBufferFn gets on each call.
SourceBuilder.Stream<T> - Class in com.hazelcast.jet.pipeline
SourceBuilder.TimestampedSourceBuffer<T> - Interface in com.hazelcast.jet.pipeline
The buffer object that the fillBufferFn gets on each call.
SourceBuilder.TimestampedStream<T> - Class in com.hazelcast.jet.pipeline
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.pipeline
Contains factory methods for various types of pipeline sources.
Stage - Interface in com.hazelcast.jet.pipeline
The basic element of a Jet pipeline, represents a computation step.
StageWithKeyAndWindow<T,K> - Interface in com.hazelcast.jet.pipeline
Represents an intermediate step in the construction of a pipeline stage that performs a windowed group-and-aggregate operation.
StageWithWindow<T> - Interface in com.hazelcast.jet.pipeline
Represents an intermediate step in the construction of a pipeline stage that performs a windowed aggregate operation.
start() - Method in class com.hazelcast.jet.datamodel.WindowResult
Returns the starting timestamp of the window.
StartServer - Class in com.hazelcast.jet.server
Main class that starts a Hazelcast Jet instance.
stream(String, FunctionEx<? super Processor.Context, ? extends C>) - Static method in class com.hazelcast.jet.pipeline.SourceBuilder
Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.
streamCacheP(String, JournalInitialPosition, EventTimePolicy<? super Map.Entry<K, V>>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
Returns a supplier of processors for Sources.cacheJournal(String, JournalInitialPosition).
streamCacheP(String, PredicateEx<? super EventJournalCacheEvent<K, V>>, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T>, JournalInitialPosition, EventTimePolicy<? super T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
streamFilesP(String, Charset, String, boolean, BiFunctionEx<? super String, ? super String, ?>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
Returns a supplier of processors for Sources.filesBuilder(java.lang.String).
streamFromProcessor(String, ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns an unbounded (event stream) source constructed directly from the given Core API processor meta-supplier.
streamFromProcessorWithWatermarks(String, Function<EventTimePolicy<? super T>, ProcessorMetaSupplier>, boolean) - Static method in class com.hazelcast.jet.pipeline.Sources
Returns an unbounded (event stream) source that will use the supplied function to create processor meta-suppliers as required by the Core API.
StreamHashJoinBuilder<T0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step fluent API to build a hash-join pipeline stage.
streamJmsQueueP(SupplierEx<? extends Connection>, FunctionEx<? super Connection, ? extends Session>, FunctionEx<? super Session, ? extends MessageConsumer>, ConsumerEx<? super Session>, FunctionEx<? super Message, ? extends T>, EventTimePolicy<? super T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
streamJmsTopicP(SupplierEx<? extends Connection>, FunctionEx<? super Connection, ? extends Session>, FunctionEx<? super Session, ? extends MessageConsumer>, ConsumerEx<? super Session>, FunctionEx<? super Message, ? extends T>, EventTimePolicy<? super T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
streamKafkaP(Properties, FunctionEx<? super ConsumerRecord<K, V>, ? extends T>, EventTimePolicy<? super T>, String...) - Static method in class com.hazelcast.jet.kafka.KafkaProcessors
Returns a supplier of processors for KafkaSources.kafka(Properties, FunctionEx, String...).
streamMapP(String, JournalInitialPosition, EventTimePolicy<? super Map.Entry<K, V>>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
Returns a supplier of processors for Sources.mapJournal(String, JournalInitialPosition) )}.
streamMapP(String, PredicateEx<? super EventJournalMapEvent<K, V>>, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T>, JournalInitialPosition, EventTimePolicy<? super T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
streamRemoteCacheP(String, ClientConfig, JournalInitialPosition, EventTimePolicy<? super Map.Entry<K, V>>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
streamRemoteCacheP(String, ClientConfig, PredicateEx<? super EventJournalCacheEvent<K, V>>, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T>, JournalInitialPosition, EventTimePolicy<? super T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
streamRemoteMapP(String, ClientConfig, JournalInitialPosition, EventTimePolicy<? super Map.Entry<K, V>>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
streamRemoteMapP(String, ClientConfig, PredicateEx<? super EventJournalMapEvent<K, V>>, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T>, JournalInitialPosition, EventTimePolicy<? super T>) - Static method in class com.hazelcast.jet.core.processor.SourceProcessors
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).
StreamSource<T> - Interface in com.hazelcast.jet.pipeline
An infinite source of data for a Jet pipeline.
StreamSourceStage<T> - Interface in com.hazelcast.jet.pipeline
A source stage in a distributed computation pipeline that will observe an unbounded amount of data (i.e., an event stream).
streamStage() - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Returns the pipeline stage associated with this object.
StreamStage<T> - Interface in com.hazelcast.jet.pipeline
A stage in a distributed computation pipeline that will observe an unbounded amount of data (i.e., an event stream).
StreamStageWithKey<T,K> - Interface in com.hazelcast.jet.pipeline
An intermediate step while constructing a windowed group-and-aggregate pipeline stage.
submit(JetCommandLine.Verbosity, String, String, File, List<String>) - Method in class com.hazelcast.jet.server.JetCommandLine
 
subtract(long) - Method in class com.hazelcast.jet.accumulator.LongAccumulator
Subtracts the supplied value from this accumulator, throwing an exception in the case of integer overflow.
subtract(LongAccumulator) - Method in class com.hazelcast.jet.accumulator.LongAccumulator
Subtracts the value of the supplied accumulator from this one, throwing an exception in the case of integer overflow.
subtractAllowingOverflow(long) - Method in class com.hazelcast.jet.accumulator.LongAccumulator
Subtracts the supplied value from this accumulator, allowing integer overflow.
subtractAllowingOverflow(LongAccumulator) - Method in class com.hazelcast.jet.accumulator.LongAccumulator
Subtracts the value of the supplied accumulator from this one, allowing integer overflow.
summingDouble(ToDoubleFunctionEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that computes the sum of the double values it obtains by applying getDoubleValueFn to each item.
summingLong(ToLongFunctionEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that computes the sum of the long values it obtains by applying getLongValueFn to each item.
SupplierEx<T> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.Supplier which declares checked exception.
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(ProcessorSupplier, ProcessorSupplier.Context) - 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.
supplierFrom(ProcessorMetaSupplier, ProcessorSupplier.Context) - Static method in class com.hazelcast.jet.core.test.TestSupport
Wraps the provided ProcessorMetaSupplier with a Supplier<Processor> that returns processors obtained from it.
supportsNativeTimestamps() - Method in interface com.hazelcast.jet.pipeline.StreamSource
Returns true if this source supports native timestamps.
suspend() - Method in interface com.hazelcast.jet.Job
Gracefully suspends the current execution of the job.
suspend(JetCommandLine.Verbosity, String) - Method in class com.hazelcast.jet.server.JetCommandLine
 

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() - Static method in class com.hazelcast.jet.datamodel.Tag
Returns the tag constant Tag.TAG_0.
tag0() - Method in class com.hazelcast.jet.pipeline.AggregateBuilder
Returns the tag corresponding to the pipeline stage this builder was obtained from.
tag0() - Method in class com.hazelcast.jet.pipeline.AggregateBuilder1
Returns the tag corresponding to the pipeline stage this builder was obtained from.
tag0() - Method in class com.hazelcast.jet.pipeline.GroupAggregateBuilder
Returns the tag corresponding to the pipeline stage this builder was obtained from.
tag0() - Method in class com.hazelcast.jet.pipeline.GroupAggregateBuilder1
Returns the tag corresponding to the pipeline stage this builder was obtained from.
tag0() - Method in class com.hazelcast.jet.pipeline.WindowAggregateBuilder
Returns the tag corresponding to the pipeline stage this builder was obtained from.
tag0() - Method in class com.hazelcast.jet.pipeline.WindowAggregateBuilder1
Returns the tag corresponding to the pipeline stage this builder was obtained from.
tag0() - Method in class com.hazelcast.jet.pipeline.WindowGroupAggregateBuilder
Returns the tag corresponding to the pipeline stage this builder was obtained from.
tag0() - Method in class com.hazelcast.jet.pipeline.WindowGroupAggregateBuilder1
Returns the tag corresponding to the pipeline stage this builder was obtained from.
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).
test(T, U) - Method in interface com.hazelcast.jet.function.BiPredicateEx
 
test(T) - Method in interface com.hazelcast.jet.function.PredicateEx
 
test(T, U, V) - Method in interface com.hazelcast.jet.function.TriPredicate
Evaluates this predicate with the given arguments.
testEx(T, U) - Method in interface com.hazelcast.jet.function.BiPredicateEx
Exception-declaring version of BiPredicate.test(T, U).
testEx(T) - Method in interface com.hazelcast.jet.function.PredicateEx
Exception-declaring version of Predicate.test(T).
testEx(T, U, V) - Method in interface com.hazelcast.jet.function.TriPredicate
Exception-declaring version of TriPredicate.test(T, U, V).
TestInbox - Class in com.hazelcast.jet.core.test
Inbox implementation suitable to be used in tests.
TestInbox() - Constructor for class com.hazelcast.jet.core.test.TestInbox
 
TestOutbox - Class in com.hazelcast.jet.core.test
Outbox implementation suitable to be used in tests.
TestOutbox(int...) - Constructor for class com.hazelcast.jet.core.test.TestOutbox
 
TestOutbox(int[], int) - Constructor for class com.hazelcast.jet.core.test.TestOutbox
 
TestProcessorContext - Class in com.hazelcast.jet.core.test
Processor.Context implementation suitable to be used in tests.
TestProcessorContext() - Constructor for class com.hazelcast.jet.core.test.TestProcessorContext
Constructor with default values.
TestProcessorMetaSupplierContext - Class in com.hazelcast.jet.core.test
ProcessorMetaSupplier.Context implementation suitable to be used in tests.
TestProcessorMetaSupplierContext() - Constructor for class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
TestProcessorSupplierContext - Class in com.hazelcast.jet.core.test
ProcessorSupplier.Context implementation suitable to be used in tests.
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.ComparatorEx
thenComparing(ComparatorEx<? super T>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparing(Function<? super T, ? extends U>, Comparator<? super U>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparing(FunctionEx<? super T, ? extends U>, ComparatorEx<? super U>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparing(Function<? super T, ? extends U>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparing(FunctionEx<? super T, ? extends U>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparingDouble(ToDoubleFunction<? super T>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparingDouble(ToDoubleFunctionEx<? super T>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparingInt(ToIntFunction<? super T>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparingInt(ToIntFunctionEx<? super T>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparingLong(ToLongFunction<? super T>) - Method in interface com.hazelcast.jet.function.ComparatorEx
thenComparingLong(ToLongFunctionEx<? super T>) - Method in interface com.hazelcast.jet.function.ComparatorEx
timestamp() - Method in class com.hazelcast.jet.core.Watermark
Returns the timestamp of this watermark item.
timestampedStream(String, FunctionEx<? super Processor.Context, ? extends C>) - Static method in class com.hazelcast.jet.pipeline.SourceBuilder
Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.
timestampFn() - Method in class com.hazelcast.jet.core.EventTimePolicy
Returns the function that extracts the timestamp from the event.
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.
toCollection(SupplierEx<C>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates the items into a Collection.
toCollector() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation1
Adapts this aggregate operation to a collector which can be passed to Stream.collect(Collector).
toCompletableFuture(ICompletableFuture<T>) - Static method in class com.hazelcast.jet.Util
Wraps Hazelcast IMDG's ICompletableFuture into Java's standard CompletableFuture.
toDag() - Method in interface com.hazelcast.jet.pipeline.Pipeline
Transforms the pipeline into a Jet DAG, which can be submitted for execution to a Jet instance.
toDotString() - Method in class com.hazelcast.jet.core.DAG
Returns a DOT format (graphviz) representation of the DAG.
toDotString() - Method in interface com.hazelcast.jet.pipeline.Pipeline
Returns a DOT format (graphviz) representation of the Pipeline.
ToDoubleFunctionEx<T> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.ToDoubleFunction which declares checked exception.
ToIntFunctionEx<T> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.ToIntFunction which declares checked exception.
toJson(int) - Method in class com.hazelcast.jet.core.DAG
Returns a JSON representation of the DAG.
toList() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates the items into an ArrayList.
ToLongFunctionEx<T> - Interface in com.hazelcast.jet.function
Serializable variant of java.util.function.ToLongFunction which declares checked exception.
toMap(FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends U>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates the items into a HashMap whose keys and values are the result of applying the provided mapping functions.
toMap(FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends U>, BinaryOperatorEx<U>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates the items into a HashMap whose keys and values are the result of applying the provided mapping functions.
toMap(FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends U>, BinaryOperatorEx<U>, SupplierEx<M>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates elements into a user-supplied Map instance.
toNonCooperative() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns a copy of this ContextFactory with the isCooperative flag set to false.
topN(int, ComparatorEx<? super T>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that finds the top n items according to the given comparator.
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.
ToResultSetFunction - Interface in com.hazelcast.jet.function
A function that accepts a JDBC connection to the database, the total parallelism and processor index as arguments and produces a result set.
toSet() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that accumulates the items into a HashSet.
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.BroadcastKey
 
toString() - Method in class com.hazelcast.jet.core.DAG
 
toString(int) - Method in class com.hazelcast.jet.core.DAG
Returns a string representation of the DAG.
toString() - Method in class com.hazelcast.jet.core.Edge
 
toString() - Method in class com.hazelcast.jet.core.test.TestInbox
 
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.ItemsByTag
 
toString() - Method in class com.hazelcast.jet.datamodel.KeyedWindowResult
 
toString() - Method in class com.hazelcast.jet.datamodel.Tag
 
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.datamodel.Tuple4
 
toString() - Method in class com.hazelcast.jet.datamodel.Tuple5
 
toString() - Method in class com.hazelcast.jet.datamodel.WindowResult
 
toStringFn(FunctionEx<? super T, String>) - Method in class com.hazelcast.jet.pipeline.FileSinkBuilder
Sets the function which converts the item to its string representation.
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
 
toTumblingByFrame() - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Converts this definition to one defining a tumbling window of the same length as this definition's frame.
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.
traverseItems(T...) - Static method in class com.hazelcast.jet.Traversers
Returns a traverser over the supplied arguments (or item array).
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.
traverseIterator(Iterator<? extends T>, boolean) - 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.
TriFunction<T0,T1,T2,R> - Interface in com.hazelcast.jet.function
Represents a three-arity function that accepts three arguments and produces a result.
TriPredicate<T,U,V> - Interface in com.hazelcast.jet.function
Represents a predicate which accepts three arguments.
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
This method will be called periodically and only when the current batch of items in the inbox has been exhausted.
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.
tryProcessWatermark(Watermark) - Method in class com.hazelcast.jet.core.AbstractProcessor
This basic implementation only forwards the passed watermark.
tryProcessWatermark(Watermark) - Method in interface com.hazelcast.jet.core.Processor
Tries to process the supplied watermark.
tumbling(long) - Static method in class com.hazelcast.jet.pipeline.WindowDefinition
Returns a tumbling window definition with the given parameters.
tumblingWinPolicy(long) - Static method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the definition of a tumbling window of length windowSize.
Tuple2<E0,E1> - Class in com.hazelcast.jet.datamodel
An immutable 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
An immutable 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.
Tuple4<E0,E1,E2,E3> - Class in com.hazelcast.jet.datamodel
An immutable 4-tuple of statically typed fields.
tuple4(E0, E1, E2, E3) - Static method in class com.hazelcast.jet.datamodel.Tuple4
Returns a new 5-tuple with the supplied values.
Tuple5<E0,E1,E2,E3,E4> - Class in com.hazelcast.jet.datamodel
An immutable 5-tuple of statically typed fields.
tuple5(E0, E1, E2, E3, E4) - Static method in class com.hazelcast.jet.datamodel.Tuple5
Returns a new 5-tuple with the supplied values.

U

unblock() - Method in class com.hazelcast.jet.core.test.TestOutbox
 
updateMapP(String, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super V, ? super T, ? extends V>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
updateMapP(String, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends EntryProcessor<K, V>>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
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.
updateRemoteMapP(String, ClientConfig, FunctionEx<? super T, ? extends K>, BiFunctionEx<? super V, ? super T, ? extends V>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
updateRemoteMapP(String, ClientConfig, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends EntryProcessor<K, V>>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
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.
valueOf(String) - Static method in enum com.hazelcast.jet.pipeline.JournalInitialPosition
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.
values() - Static method in enum com.hazelcast.jet.pipeline.JournalInitialPosition
Returns an array containing the constants of this enum type, in the order they are declared.
varArity() - Method in class com.hazelcast.jet.aggregate.AggregateOperationBuilder
Selects the variable-arity variant for this aggregate operation builder.
Verbosity() - Constructor for class com.hazelcast.jet.server.JetCommandLine.Verbosity
 
verifyProcessor(SupplierEx<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 - Static variable in class com.hazelcast.jet.core.JetDataSerializerHook
Serialization ID of the Vertex class.
Vertex - Class in com.hazelcast.jet.core
Represents a unit of data processing in a Jet computation job.
Vertex(String, SupplierEx<? 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.ProcessorMetaSupplier.Context
Returns the name of the associated vertex.
vertexName() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 

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.
WatermarkPolicy - Interface in com.hazelcast.jet.core
This object tracks and determines the current Watermark given the event timestamps as they occur for a single input stream.
watermarkThrottlingFrameOffset() - Method in class com.hazelcast.jet.core.EventTimePolicy
watermarkThrottlingFrameSize() - Method in class com.hazelcast.jet.core.EventTimePolicy
This value together with EventTimePolicy.watermarkThrottlingFrameOffset() specify the frame size the watermarks are throttled to.
wholeItem() - Static method in class com.hazelcast.jet.function.Functions
Synonym for FunctionEx.identity(), to be used as a projection function (e.g., key extractor).
window(WindowDefinition) - Method in interface com.hazelcast.jet.pipeline.StreamStage
Adds the given window definition to this stage, as the first step in the construction of a pipeline stage that performs windowed aggregation.
window(WindowDefinition) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
Adds the definition of the window to use in the group-and-aggregate pipeline stage being constructed.
WindowAggregateBuilder<R0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step fluent API to build a pipeline stage that performs a windowed co-aggregation of the data from several input stages.
WindowAggregateBuilder1<T0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step fluent API to build a pipeline stage that performs a windowed co-aggregation of the data from several input stages.
windowDefinition() - Method in interface com.hazelcast.jet.pipeline.StageWithKeyAndWindow
Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.
windowDefinition() - Method in interface com.hazelcast.jet.pipeline.StageWithWindow
Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.
WindowDefinition - Class in com.hazelcast.jet.pipeline
The definition of the window for a windowed aggregation operation.
WindowDefinition() - Constructor for class com.hazelcast.jet.pipeline.WindowDefinition
 
WindowGroupAggregateBuilder<K,R0> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step API to build a pipeline stage that performs a windowed co-grouping and aggregation of the data from several input stages.
WindowGroupAggregateBuilder1<T0,K> - Class in com.hazelcast.jet.pipeline
Offers a step-by-step API to build a pipeline stage that performs a windowed co-grouping and aggregation of the data from several input stages.
WindowResult<R> - Class in com.hazelcast.jet.datamodel
Holds the result of an aggregate operation performed over a time window.
WindowResult(long, long, R, boolean) - Constructor for class com.hazelcast.jet.datamodel.WindowResult
 
WindowResult(long, long, R) - Constructor for class com.hazelcast.jet.datamodel.WindowResult
Constructs a window result that is not early.
windowSize() - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the length of the window (the size of the timestamp range it covers).
windowSize() - Method in class com.hazelcast.jet.pipeline.SlidingWindowDefinition
Returns the length of the window (the size of the timestamp range it covers).
withAccumulateFn(BiConsumerEx<? super A, ? super NEW_T>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation1
Returns a copy of this aggregate operation, but with the accumulate primitive replaced with the one supplied here.
withAccumulateFn0(BiConsumerEx<? super A, ? super T0_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation2
Returns a copy of this aggregate operation, but with the accumulate primitive at index 0 replaced with the one supplied here.
withAccumulateFn0(BiConsumerEx<? super A, ? super T0_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3
Returns a copy of this aggregate operation, but with the accumulate primitive at index 0 replaced with the one supplied here.
withAccumulateFn1(BiConsumerEx<? super A, ? super T1_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation2
Returns a copy of this aggregate operation, but with the accumulate primitive at index 1 replaced with the one supplied here.
withAccumulateFn1(BiConsumerEx<? super A, ? super T1_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3
Returns a copy of this aggregate operation, but with the accumulate primitive at index 1 replaced with the one supplied here.
withAccumulateFn2(BiConsumerEx<? super A, ? super T2_NEW>) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3
Returns a copy of this aggregate operation, but with the accumulate primitive at index 2 replaced with the one supplied here.
withAccumulateFns(BiConsumerEx...) - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
Returns a copy of this aggregate operation, but with all the accumulate primitives replaced with the ones supplied here.
withCombiningAccumulateFn(FunctionEx<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 items and combines them all into a single accumulator of the same type.
withCreate(SupplierEx<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.
withCreateFn(FunctionEx<JetInstance, ? extends C>) - Static method in class com.hazelcast.jet.pipeline.ContextFactory
Creates a new ContextFactory with the given create-function.
withDestroyFn(ConsumerEx<? super C>) - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns a copy of this ContextFactory with the destroy-function replaced with the given function.
withIdentityFinish() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
Returns a copy of this aggregate operation, but with the finish primitive replaced with the identity function.
withIdentityFinish() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation1
 
withIdentityFinish() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation2
 
withIdentityFinish() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation3
 
withIngestionTimestamps() - Method in interface com.hazelcast.jet.pipeline.StreamSourceStage
Declares that the source will assign the time of ingestion as the event timestamp.
withLocalSharing() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns a copy of this ContextFactory with the localSharing flag set.
withMaxPendingCallsPerProcessor(int) - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns a copy of this ContextFactory with the maxPendingCallsPerProcessor property set to the given value.
withNativeTimestamps(long) - Method in interface com.hazelcast.jet.pipeline.StreamSourceStage
Declares that the stream will use the source's native timestamps.
withOffset(long) - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns a new window definition where all the frames are shifted by the given offset.
withoutTimestamps() - Method in interface com.hazelcast.jet.pipeline.StreamSourceStage
Declares that the source will not assign any timestamp to the events it emits.
withTimestamps(ToLongFunctionEx<? super T>, long) - Method in interface com.hazelcast.jet.pipeline.StreamSourceStage
Declares that the source will extract timestamps from the stream items.
withUnorderedAsyncResponses() - Method in class com.hazelcast.jet.pipeline.ContextFactory
Returns a copy of this ContextFactory with the unorderedAsyncResponses flag set to true.
wrapFn() - Method in class com.hazelcast.jet.core.EventTimePolicy
Returns the function that transforms the received item and its timestamp into the emitted item.
writeBufferedP(FunctionEx<? super Processor.Context, ? extends W>, BiConsumerEx<? super W, ? super T>, ConsumerEx<? super W>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
writeBufferedP(FunctionEx<? super Processor.Context, ? extends W>, BiConsumerEx<? super W, ? super T>, ConsumerEx<? super W>, ConsumerEx<? super W>) - 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 internal writer object and then does a flush.
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.config.JobConfig
 
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, FunctionEx<? super T, ? extends String>, Charset, boolean) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
Returns a supplier of processors for Sinks.filesBuilder(java.lang.String).
writeFilesP(String, SupplierEx<Schema>, SupplierEx<DatumWriter<D>>) - Static method in class com.hazelcast.jet.avro.AvroProcessors
writeHdfsP(JobConf, FunctionEx<? super E, K>, FunctionEx<? super E, V>) - Static method in class com.hazelcast.jet.hadoop.HdfsProcessors
Returns a supplier of processors for HdfsSinks.hdfs(JobConf, FunctionEx, FunctionEx).
writeJdbcP(String, SupplierEx<? extends Connection>, BiConsumerEx<? super PreparedStatement, ? super T>) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
Returns a supplier of processors for Sinks.jdbc(String, SupplierEx, BiConsumerEx).
writeJmsQueueP(SupplierEx<? extends Connection>, FunctionEx<? super Connection, ? extends Session>, BiFunctionEx<? super Session, ? super T, ? extends Message>, BiConsumerEx<? super MessageProducer, ? super Message>, ConsumerEx<? super Session>, String) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
writeJmsTopicP(SupplierEx<? extends Connection>, FunctionEx<? super Connection, ? extends Session>, BiFunctionEx<? super Session, ? super T, ? extends Message>, BiConsumerEx<? super MessageProducer, ? super Message>, ConsumerEx<? super Session>, String) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
writeKafkaP(Properties, String, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends V>) - Static method in class com.hazelcast.jet.kafka.KafkaProcessors
writeKafkaP(Properties, FunctionEx<? super T, ? extends ProducerRecord<K, V>>) - Static method in class com.hazelcast.jet.kafka.KafkaProcessors
Returns a supplier of processors for KafkaSinks.kafka(Properties, FunctionEx).
writeListP(String) - Static method in class com.hazelcast.jet.core.processor.SinkProcessors
Returns a supplier of processors for Sinks.list(String).
writeLoggerP(FunctionEx<T, ? extends CharSequence>) - 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(FunctionEx) 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, FunctionEx<? super T, ? extends 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 
Skip navigation links

Copyright © 2019 Hazelcast, Inc.. All rights reserved.