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 X Y 

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)
AccessLogAnalyzer - Class in com.hazelcast.jet.examples.files
Demonstrates the usage of the file sources and sinks in a job that reads a Web access log file and counts accesses to particular URL paths.
AccessLogAnalyzer() - Constructor for class com.hazelcast.jet.examples.files.AccessLogAnalyzer
 
AccessLogStreamAnalyzer - Class in com.hazelcast.jet.examples.files
Analyzes access log files from a HTTP server.
AccessLogStreamAnalyzer() - Constructor for class com.hazelcast.jet.examples.files.AccessLogStreamAnalyzer
 
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.
ActiveMQBroker - Class in com.hazelcast.jet.examples.jms
Utility class to start/stop an ActiveMQ Broker instance
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.
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
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.
ADDRESS - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Network address of the cluster member sourcing the metric.
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.
AddToCart - Class in com.hazelcast.jet.examples.cogroup.datamodel
 
AddToCart(long, int, int) - Constructor for class com.hazelcast.jet.examples.cogroup.datamodel.AddToCart
 
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().
amount() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.Payment
 
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
AnnotationBasedConfigurationSample - Class in com.hazelcast.jet.examples.spring
Example of integrating Hazelcast Jet with Spring annotation-based config.
AnnotationBasedConfigurationSample() - Constructor for class com.hazelcast.jet.examples.spring.AnnotationBasedConfigurationSample
 
AppConfig - Class in com.hazelcast.jet.examples.spring.config
Spring Context annotation-based configuration class
AppConfig() - Constructor for class com.hazelcast.jet.examples.spring.config.AppConfig
 
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 UpdateMapP.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.
assertAnyOrder(String, Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.Assertions
Asserts that the previous stage emitted the expected items in any order, but nothing else.
assertAnyOrder(Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.Assertions
Asserts that the previous stage emitted the expected items in any order, but nothing else.
assertAnyOrder(String, Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.AssertionSinks
Asserts that the previous stage emitted the expected items in any order, but nothing else.
assertAnyOrder(Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.AssertionSinks
Asserts that the previous stage emitted the expected items in any order, but nothing else.
assertCollected(ConsumerEx<? super List<T>>) - Static method in class com.hazelcast.jet.pipeline.test.Assertions
Collects all the received items in a list and once the upstream stage is completed it executes the assertion supplied by assertFn.
assertCollected(ConsumerEx<? super List<T>>) - Static method in class com.hazelcast.jet.pipeline.test.AssertionSinks
Collects all the received items in a list and once the upstream stage is completed it executes the assertion supplied by assertFn.
assertCollectedEventually(int, ConsumerEx<? super List<T>>) - Static method in class com.hazelcast.jet.pipeline.test.Assertions
Collects all the received items into a list and runs the assertFn every time a new item is received.
assertCollectedEventually(int, ConsumerEx<? super List<T>>) - Static method in class com.hazelcast.jet.pipeline.test.AssertionSinks
Collects all the received items into a list and runs the assertFn every time a new item is received.
assertContains(String, Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.Assertions
Asserts that the previous stage emitted all of the given items in any order.
assertContains(Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.Assertions
Asserts that the previous stage emitted all of the given items in any order.
assertContains(String, Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.AssertionSinks
Asserts that the previous stage emitted all of the given items in any order.
assertEquals(String, Object, Object) - Static method in class com.hazelcast.jet.core.test.JetAssert
Asserts that the two given objects are equal, when compared using Object.equals(Object).
assertFalse(String, boolean) - Static method in class com.hazelcast.jet.core.test.JetAssert
Asserts that the given condition is false.
AssertionCompletedException - Exception in com.hazelcast.jet.pipeline.test
An exception which indicates that an assertion passed successfully.
AssertionCompletedException() - Constructor for exception com.hazelcast.jet.pipeline.test.AssertionCompletedException
Creates the exception
AssertionCompletedException(String) - Constructor for exception com.hazelcast.jet.pipeline.test.AssertionCompletedException
Creates the exception with the given message
AssertionCompletedException(String, Throwable) - Constructor for exception com.hazelcast.jet.pipeline.test.AssertionCompletedException
Creates the exception with the given message and cause
Assertions - Class in com.hazelcast.jet.pipeline.test
Various assertions which can be used to assert items passing through the pipeline for correctness.
assertionSink(String, SupplierEx<? extends S>) - Static method in class com.hazelcast.jet.pipeline.test.AssertionSinkBuilder
Returns a builder object that offers a step-by-step fluent API to build an assertion Sink for the Pipeline API.
AssertionSinkBuilder<S,T> - Class in com.hazelcast.jet.pipeline.test
AssertionSinks - Class in com.hazelcast.jet.pipeline.test
Various assertions which can be used to assert items on the output of a pipeline.
assertOrdered(String, Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.Assertions
Asserts that the previous stage emitted the exact sequence of expected items and nothing else.
assertOrdered(Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.Assertions
Asserts that the previous stage emitted the exact sequence of expected items and nothing else.
assertOrdered(String, Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.AssertionSinks
Asserts that the previous stage emitted the exact sequence of expected items and nothing else.
assertOrdered(Collection<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.AssertionSinks
Asserts that the previous stage emitted the exact sequence of expected items and nothing else.
assertOutput(int, BiConsumer<TestSupport.TestMode, List<List<Object>>>) - Method in class com.hazelcast.jet.core.test.TestSupport
Runs the test with the specified custom assertion.
assertSame(String, Object, Object) - Static method in class com.hazelcast.jet.core.test.JetAssert
Asserts that the two given objects are the same, when compared using the == operator and if not, an AssertionError is thrown with the given message.
assertTrue(String, boolean) - Static method in class com.hazelcast.jet.core.test.JetAssert
Asserts that the given condition is true.
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.
AvroSink - Class in com.hazelcast.jet.examples.files.avro
Demonstrates dumping a map's values to an Apache Avro file.
AvroSink() - Constructor for class com.hazelcast.jet.examples.files.avro.AvroSink
 
AvroSinks - Class in com.hazelcast.jet.avro
Contains factory methods for Apache Avro sinks.
AvroSource - Class in com.hazelcast.jet.examples.files.avro
Demonstrates reading Apache Avro files from a directory and populating IMap Run AvroSink first to create necessary Apache Avro files directory.
AvroSource() - Constructor for class com.hazelcast.jet.examples.files.avro.AvroSource
 
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.
BatchCoGroup - Class in com.hazelcast.jet.examples.cogroup
Demonstrates the usage of Pipeline API's co-group transformation, which joins two or more streams on a common key and performs a user-specified aggregate operation on the co-grouped items.
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.
bindService() - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceImplBase
 
bindService() - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceImplBase
 
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.
Broker - Class in com.hazelcast.jet.examples.enrichment.datamodel
 
Broker(int, String) - Constructor for class com.hazelcast.jet.examples.enrichment.datamodel.Broker
 
Broker - Class in com.hazelcast.jet.examples.grpc.datamodel
 
Broker(int, String) - Constructor for class com.hazelcast.jet.examples.grpc.datamodel.Broker
 
BROKER_URL - Static variable in class com.hazelcast.jet.examples.jms.ActiveMQBroker
 
brokerId() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Trade
 
brokerId() - Method in class com.hazelcast.jet.examples.grpc.datamodel.Trade
 
brokerInfo(BrokerInfoRequest) - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceBlockingStub
 
brokerInfo(BrokerInfoRequest) - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceFutureStub
 
brokerInfo(BrokerInfoRequest, StreamObserver<BrokerInfoReply>) - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceImplBase
 
brokerInfo(BrokerInfoRequest, StreamObserver<BrokerInfoReply>) - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceStub
 
brokerInfo(BrokerInfoRequest, StreamObserver<BrokerInfoReply>) - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceImpl
 
BrokerInfoReply - Class in com.hazelcast.jet.examples.grpc
Protobuf type helloworld.BrokerInfoReply
BrokerInfoReply.Builder - Class in com.hazelcast.jet.examples.grpc
Protobuf type helloworld.BrokerInfoReply
BrokerInfoReplyOrBuilder - Interface in com.hazelcast.jet.examples.grpc
 
BrokerInfoRequest - Class in com.hazelcast.jet.examples.grpc
Protobuf type helloworld.BrokerInfoRequest
BrokerInfoRequest.Builder - Class in com.hazelcast.jet.examples.grpc
Protobuf type helloworld.BrokerInfoRequest
BrokerInfoRequestOrBuilder - Interface in com.hazelcast.jet.examples.grpc
 
BROKERNAME_FIELD_NUMBER - Static variable in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
BrokerServiceGrpc - Class in com.hazelcast.jet.examples.grpc
 
BrokerServiceGrpc.BrokerServiceBlockingStub - Class in com.hazelcast.jet.examples.grpc
 
BrokerServiceGrpc.BrokerServiceFutureStub - Class in com.hazelcast.jet.examples.grpc
 
BrokerServiceGrpc.BrokerServiceImplBase - Class in com.hazelcast.jet.examples.grpc
 
BrokerServiceGrpc.BrokerServiceStub - Class in com.hazelcast.jet.examples.grpc
 
BrokerServiceImpl - Class in com.hazelcast.jet.examples.grpc
Server-side implementation of a gRPC service.
BrokerServiceImpl(Map<Integer, Broker>) - Constructor for class com.hazelcast.jet.examples.grpc.BrokerServiceImpl
 
BrokerServiceImplBase() - Constructor for class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceImplBase
 
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() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
build() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceBlockingStub
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceFutureStub
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceStub
 
build() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
build() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceBlockingStub
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceFutureStub
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceStub
 
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.test.AssertionSinkBuilder
Creates and returns the Sink with the components you supplied to this builder.
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.
buildPartial() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
buildPartial() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
buildPartial() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
buildPartial() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
BuildStopwords - Class in com.hazelcast.jet.examples.tfidf
A utility that rebuilds the stopwords file, only needed when the list of books in the books module changes.
BuildStopwords() - Constructor for class com.hazelcast.jet.examples.tfidf.BuildStopwords
 
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.
CacheJournalSource - Class in com.hazelcast.jet.examples.eventjournal
A pipeline which streams events from an ICache.
CacheJournalSource() - Constructor for class com.hazelcast.jet.examples.eventjournal.CacheJournalSource
 
cachePutEvents() - Static method in class com.hazelcast.jet.Util
CacheSourceAndSink - Class in com.hazelcast.jet.examples.imdg
Demonstrates the usage of Hazelcast ICache as source and sink with the Pipeline API.
CacheSourceAndSink() - Constructor for class com.hazelcast.jet.examples.imdg.CacheSourceAndSink
 
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()
clear() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
clear() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
clear() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
clear() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
clearBrokerName() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
string brokerName = 1;
clearField(Descriptors.FieldDescriptor) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
clearId() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
int32 id = 1;
clearId() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
int32 id = 1;
clearOneof(Descriptors.OneofDescriptor) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
clearProductName() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
string productName = 1;
clone() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
clone() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
clone() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
clone() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
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.
COALESCED_WM - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the highest watermark observed on all the input queues of a particular incoming Edge of a certain Vertex.
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.metrics - package com.hazelcast.jet.core.metrics
Jet's Job Metric 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.examples.cogroup - package com.hazelcast.jet.examples.cogroup
 
com.hazelcast.jet.examples.cogroup.datamodel - package com.hazelcast.jet.examples.cogroup.datamodel
 
com.hazelcast.jet.examples.configuration.logging - package com.hazelcast.jet.examples.configuration.logging
 
com.hazelcast.jet.examples.configuration.xml - package com.hazelcast.jet.examples.configuration.xml
 
com.hazelcast.jet.examples.configuration.yaml - package com.hazelcast.jet.examples.configuration.yaml
 
com.hazelcast.jet.examples.earlyresults - package com.hazelcast.jet.examples.earlyresults
 
com.hazelcast.jet.examples.earlyresults.support - package com.hazelcast.jet.examples.earlyresults.support
 
com.hazelcast.jet.examples.enrichment - package com.hazelcast.jet.examples.enrichment
 
com.hazelcast.jet.examples.enrichment.datamodel - package com.hazelcast.jet.examples.enrichment.datamodel
 
com.hazelcast.jet.examples.eventjournal - package com.hazelcast.jet.examples.eventjournal
 
com.hazelcast.jet.examples.faulttolerance - package com.hazelcast.jet.examples.faulttolerance
 
com.hazelcast.jet.examples.files - package com.hazelcast.jet.examples.files
 
com.hazelcast.jet.examples.files.avro - package com.hazelcast.jet.examples.files.avro
 
com.hazelcast.jet.examples.files.s3 - package com.hazelcast.jet.examples.files.s3
 
com.hazelcast.jet.examples.grpc - package com.hazelcast.jet.examples.grpc
 
com.hazelcast.jet.examples.grpc.datamodel - package com.hazelcast.jet.examples.grpc.datamodel
 
com.hazelcast.jet.examples.hadoop - package com.hazelcast.jet.examples.hadoop
 
com.hazelcast.jet.examples.hadoop.avro - package com.hazelcast.jet.examples.hadoop.avro
 
com.hazelcast.jet.examples.imdg - package com.hazelcast.jet.examples.imdg
 
com.hazelcast.jet.examples.jdbc - package com.hazelcast.jet.examples.jdbc
 
com.hazelcast.jet.examples.jms - package com.hazelcast.jet.examples.jms
 
com.hazelcast.jet.examples.jobmanagement - package com.hazelcast.jet.examples.jobmanagement
 
com.hazelcast.jet.examples.kafka - package com.hazelcast.jet.examples.kafka
 
com.hazelcast.jet.examples.kafka.avro - package com.hazelcast.jet.examples.kafka.avro
 
com.hazelcast.jet.examples.kafka.json - package com.hazelcast.jet.examples.kafka.json
 
com.hazelcast.jet.examples.patternmatching - package com.hazelcast.jet.examples.patternmatching
 
com.hazelcast.jet.examples.patternmatching.support - package com.hazelcast.jet.examples.patternmatching.support
 
com.hazelcast.jet.examples.rollingaggregation - package com.hazelcast.jet.examples.rollingaggregation
 
com.hazelcast.jet.examples.sessionwindow - package com.hazelcast.jet.examples.sessionwindow
 
com.hazelcast.jet.examples.sinkbuilder - package com.hazelcast.jet.examples.sinkbuilder
 
com.hazelcast.jet.examples.slidingwindow - package com.hazelcast.jet.examples.slidingwindow
 
com.hazelcast.jet.examples.sockets - package com.hazelcast.jet.examples.sockets
 
com.hazelcast.jet.examples.sourcebuilder - package com.hazelcast.jet.examples.sourcebuilder
 
com.hazelcast.jet.examples.sourcebuilder.support - package com.hazelcast.jet.examples.sourcebuilder.support
 
com.hazelcast.jet.examples.spring - package com.hazelcast.jet.examples.spring
 
com.hazelcast.jet.examples.spring.config - package com.hazelcast.jet.examples.spring.config
 
com.hazelcast.jet.examples.spring.dao - package com.hazelcast.jet.examples.spring.dao
 
com.hazelcast.jet.examples.spring.model - package com.hazelcast.jet.examples.spring.model
 
com.hazelcast.jet.examples.spring.source - package com.hazelcast.jet.examples.spring.source
 
com.hazelcast.jet.examples.tfidf - package com.hazelcast.jet.examples.tfidf
 
com.hazelcast.jet.examples.wordcount - package com.hazelcast.jet.examples.wordcount
 
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.pipeline.test - package com.hazelcast.jet.pipeline.test
This package contains various mock sources to help with pipeline testing and development.
com.hazelcast.jet.s3 - package com.hazelcast.jet.s3
AWS S3 read/write support for Hazelcast Jet.
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.
complete() - Method in class com.hazelcast.jet.examples.spring.source.CustomSourceP
 
completeEdge(int) - Method in interface com.hazelcast.jet.core.Processor
Called after the edge input with the supplied ordinal is exhausted.
completeFn(ConsumerEx<? super S>) - Method in class com.hazelcast.jet.pipeline.test.AssertionSinkBuilder
Sets the function that will be called after all the upstream stages have completed and all the items were received.
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.
ConfigLookup - Class in com.hazelcast.jet.examples.configuration.xml
 
ConfigLookup() - Constructor for class com.hazelcast.jet.examples.configuration.xml.ConfigLookup
 
ConfigLookup - Class in com.hazelcast.jet.examples.configuration.yaml
 
ConfigLookup() - Constructor for class com.hazelcast.jet.examples.configuration.yaml.ConfigLookup
 
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.
containsTag(String) - Static method in class com.hazelcast.jet.core.metrics.MeasurementPredicates
Matches a Measurement which contain the specified tag.
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.
COOPERATIVE_WORKER - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Index of the cooperative worker in a fixed worker pool sourcing the metric.
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
 
createFactory() - Method in class com.hazelcast.jet.core.metrics.MetricsDataSerializerHook
 
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.
customSource() - Static method in class com.hazelcast.jet.examples.spring.source.CustomSourceP
 
CustomSourceP - Class in com.hazelcast.jet.examples.spring.source
A processor which uses an auto-wired DAO to find all users and emit them to downstream.
CustomSourceP() - Constructor for class com.hazelcast.jet.examples.spring.source.CustomSourceP
 
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.
dataSource() - Method in class com.hazelcast.jet.examples.spring.config.AppConfig
DataSource bean for embedded database HSQL
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
 
determineLocalParallelism(int) - Method in class com.hazelcast.jet.core.Vertex
Determines the local parallelism value for the vertex by looking its local parallelism and meta supplier's preferred local parallelism.
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.
DIRECTORY_NAME - Static variable in class com.hazelcast.jet.examples.files.avro.AvroSink
 
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
 
DISTRIBUTED_BYTES_IN - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the data volume (bytes) coming in over the network for DISTRIBUTED input Edges of particular Vertex instances running on various Processors.
DISTRIBUTED_BYTES_OUT - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the data volume (bytes) going out over the network for DISTRIBUTED output Edges of particular Vertex instances running on various Processors.
DISTRIBUTED_ITEMS_IN - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Counts data items coming in over the network for DISTRIBUTED input Edges of particular Vertex instances running on various Processors.
DISTRIBUTED_ITEMS_OUT - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Counts data items going out over the network for DISTRIBUTED output Edges of particular Vertex instances running on various Processors.
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.
EMITTED_COUNT - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Counts the data items emitted on outgoing Edges of particular Vertex instances running on various Processors.
empty() - Static method in class com.hazelcast.jet.core.metrics.JobMetrics
Returns an empty JobMetrics object.
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.
Enrichment - Class in com.hazelcast.jet.examples.enrichment
Demonstrates the usage of the Pipeline API to enrich a data stream.
EnrichmentProto - Class in com.hazelcast.jet.examples.grpc
 
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.metrics.JobMetrics
 
equals(Object) - Method in class com.hazelcast.jet.core.metrics.Measurement
 
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.TimestampedItem
 
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
 
equals(Object) - Method in class com.hazelcast.jet.examples.cogroup.datamodel.AddToCart
 
equals(Object) - Method in class com.hazelcast.jet.examples.cogroup.datamodel.PageVisit
 
equals(Object) - Method in class com.hazelcast.jet.examples.cogroup.datamodel.Payment
 
equals(Object) - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Trade
 
equals(Object) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
equals(Object) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
equals(Object) - Method in class com.hazelcast.jet.examples.grpc.datamodel.Trade
 
equals(Object) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
equals(Object) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
equals(Object) - Method in class com.hazelcast.jet.examples.jdbc.User
 
equals(Object) - Method in class com.hazelcast.jet.pipeline.test.SimpleEvent
 
Event - Class in com.hazelcast.jet.examples.cogroup.datamodel
 
EventGenerator - Class in com.hazelcast.jet.examples.enrichment
 
EventGenerator - Class in com.hazelcast.jet.examples.grpc
 
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.
ExclusiveJobExecution - Class in com.hazelcast.jet.examples.jobmanagement
We demonstrate how just one running instance of a named job can be created in the cluster with multiple submissions.
ExclusiveJobExecution() - Constructor for class com.hazelcast.jet.examples.jobmanagement.ExclusiveJobExecution
 
EXECUTION - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Unique ID of a particular execution of a job (sourcing the metric), example value would be a numerical (long) ID encoded in a human readable form, like "2f7f-d88a-4669-6195", see Util.idToString(long) for details.
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
 
FACTORY_ID - Static variable in class com.hazelcast.jet.core.metrics.MetricsDataSerializerHook
 
fail(String) - Static method in class com.hazelcast.jet.core.test.JetAssert
Throws an AssertionError with the given message.
FaultTolerance - Class in com.hazelcast.jet.examples.faulttolerance
A simple application which uses Jet with the event journal reader for IMap to perform rolling average calculations and illustrates the differences in processing guarantees.
FaultTolerance() - Constructor for class com.hazelcast.jet.examples.faulttolerance.FaultTolerance
 
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(String, String) - Method in class com.hazelcast.jet.core.metrics.JobMetrics
Convenience method for #filter(Predicate), returns a new JobMetrics instance containing only those Measurements which have the specified tag set to the specified value.
filter(Predicate<Measurement>) - Method in class com.hazelcast.jet.core.metrics.JobMetrics
Returns a new JobMetrics instance containing a subset of the Measurements found in the current one.
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<? 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.
filterStateful(SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
filterStateful(SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
filterStateful(SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a stage that performs a stateful filtering operation.
filterStateful(SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a stage that performs a stateful filtering operation.
filterStateful(SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
filterStateful(long, SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
Attaches a stage that performs a stateful filtering operation.
filterStateful(SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
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.
findAll() - Method in interface com.hazelcast.jet.examples.spring.dao.UserDao
 
findAll() - Method in class com.hazelcast.jet.examples.spring.dao.UserDaoImpl
 
findByName(String) - Method in interface com.hazelcast.jet.examples.spring.dao.UserDao
 
findByName(String) - Method in class com.hazelcast.jet.examples.spring.dao.UserDaoImpl
 
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<? 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.
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.
flatMapStateful(SupplierEx<? extends S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
flatMapStateful(SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
flatMapStateful(SupplierEx<? extends S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a stage that performs a stateful flat-mapping operation.
flatMapStateful(SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a stage that performs a stateful flat-mapping operation.
flatMapStateful(SupplierEx<? extends S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
flatMapStateful(long, SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>, TriFunction<? super S, ? super K, ? super Long, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
Attaches a stage that performs a stateful flat-mapping operation.
flatMapStateful(SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
flatMapStatefulP(long, FunctionEx<? super T, ? extends K>, ToLongFunctionEx<? super T>, Supplier<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>, TriFunction<? super S, ? super K, ? super Long, ? extends Traverser<R>>) - Static method in class com.hazelcast.jet.core.processor.Processors
Returns a supplier of processors for a vertex that performs a stateful flat-mapping of its input.
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.
generate(long, long) - Method in interface com.hazelcast.jet.pipeline.test.GeneratorFunction
Applies the function to the given timestamp and sequence.
GeneratorFunction<R> - Interface in com.hazelcast.jet.pipeline.test
A function which takes a timestamp and a sequence number as the input.
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(String) - Method in class com.hazelcast.jet.core.metrics.JobMetrics
Returns all Measurements associated with a given metric name.
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(int) - Method in class com.hazelcast.jet.examples.hadoop.avro.User
 
get(int) - Method in class com.hazelcast.jet.examples.kafka.avro.User
 
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.
getAge() - Method in class com.hazelcast.jet.examples.files.avro.User
 
getAge() - Method in class com.hazelcast.jet.examples.kafka.json.User
 
getBackupCount() - Method in class com.hazelcast.jet.config.InstanceConfig
Returns the number of backups used for job metadata and snapshots.
getBrokerInfoMethod() - Static method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc
 
getBrokerName() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
string brokerName = 1;
getBrokerName() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
string brokerName = 1;
getBrokerName() - Method in interface com.hazelcast.jet.examples.grpc.BrokerInfoReplyOrBuilder
string brokerName = 1;
getBrokerNameBytes() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
string brokerName = 1;
getBrokerNameBytes() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
string brokerName = 1;
getBrokerNameBytes() - Method in interface com.hazelcast.jet.examples.grpc.BrokerInfoReplyOrBuilder
string brokerName = 1;
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.
getDefaultInstance() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
getDefaultInstance() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
getDefaultInstance() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
getDefaultInstance() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.EnrichmentProto
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
getDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
getDescriptorForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
getDescriptorForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
getDescriptorForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
getDescriptorForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
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.metrics.JobMetrics
 
getFactoryId() - Method in class com.hazelcast.jet.core.metrics.Measurement
 
getFactoryId() - Method in class com.hazelcast.jet.core.metrics.MetricsDataSerializerHook
 
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.metrics.JobMetrics
 
getId() - Method in class com.hazelcast.jet.core.metrics.Measurement
 
getId() - Method in class com.hazelcast.jet.core.Vertex
 
getId() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
int32 id = 1;
getId() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
int32 id = 1;
getId() - Method in interface com.hazelcast.jet.examples.grpc.BrokerInfoRequestOrBuilder
int32 id = 1;
getId() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
int32 id = 1;
getId() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
int32 id = 1;
getId() - Method in interface com.hazelcast.jet.examples.grpc.ProductInfoRequestOrBuilder
int32 id = 1;
getId() - Method in class com.hazelcast.jet.examples.jdbc.User
 
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.
getMetrics() - Method in interface com.hazelcast.jet.Job
Returns a snapshot of the current values of all job-specific metrics.
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 class com.hazelcast.jet.examples.jdbc.User
 
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.
getNamedParameterJdbcTemplate() - Method in class com.hazelcast.jet.examples.spring.config.AppConfig
Jdbc template bean to query DataSource
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
getParserForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
getParserForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
getParserForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
getParserForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
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.
getPassword() - Method in class com.hazelcast.jet.examples.files.avro.User
 
getPassword() - Method in class com.hazelcast.jet.examples.kafka.json.User
 
getPipeline() - Method in interface com.hazelcast.jet.pipeline.Stage
Returns the Pipeline this stage belongs to.
getPrice() - Method in class com.hazelcast.jet.examples.earlyresults.support.Trade
 
getPrice() - Method in class com.hazelcast.jet.examples.rollingaggregation.Trade
 
getPrice() - Method in class com.hazelcast.jet.examples.slidingwindow.Trade
 
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.
getProductEventType() - Method in class com.hazelcast.jet.examples.sessionwindow.ProductEvent
 
getProductId() - Method in class com.hazelcast.jet.examples.sessionwindow.ProductEvent
 
getProductInfoMethod() - Static method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc
 
getProductName() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
string productName = 1;
getProductName() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
string productName = 1;
getProductName() - Method in interface com.hazelcast.jet.examples.grpc.ProductInfoReplyOrBuilder
string productName = 1;
getProductNameBytes() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
string productName = 1;
getProductNameBytes() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
string productName = 1;
getProductNameBytes() - Method in interface com.hazelcast.jet.examples.grpc.ProductInfoReplyOrBuilder
string productName = 1;
getProperties() - Method in class com.hazelcast.jet.config.JetConfig
Returns the Jet-specific configuration properties.
getQuantity() - Method in class com.hazelcast.jet.examples.earlyresults.support.Trade
 
getQuantity() - Method in class com.hazelcast.jet.examples.rollingaggregation.Trade
 
getQuantity() - Method in class com.hazelcast.jet.examples.slidingwindow.Trade
 
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).
getSchema() - Method in class com.hazelcast.jet.examples.hadoop.avro.User
 
getSchema() - Method in class com.hazelcast.jet.examples.kafka.avro.User
 
getSerializedSize() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
getSerializedSize() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
getSerializedSize() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
getSerializedSize() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
getServiceDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc
 
getServiceDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc
 
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.
getTag(String) - Method in class com.hazelcast.jet.core.metrics.Measurement
Returns the value associated with a specific tag, based on the metric description of this particular Measurement.
getTicker() - Method in class com.hazelcast.jet.examples.earlyresults.support.Trade
 
getTicker() - Method in class com.hazelcast.jet.examples.rollingaggregation.Trade
 
getTicker() - Method in class com.hazelcast.jet.examples.slidingwindow.Trade
 
getTime() - Method in class com.hazelcast.jet.examples.earlyresults.support.Trade
 
getTime() - Method in class com.hazelcast.jet.examples.rollingaggregation.Trade
 
getTime() - Method in class com.hazelcast.jet.examples.slidingwindow.Trade
 
getTimestamp() - Method in class com.hazelcast.jet.core.metrics.Measurement
Returns the timestamps associated with this Measurement, the moment when the value was gathered.
getTimestamp() - Method in class com.hazelcast.jet.examples.sessionwindow.ProductEvent
 
getUnknownFields() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
getUnknownFields() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
getUnknownFields() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
getUnknownFields() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
getUrl() - Method in class com.hazelcast.jet.config.ResourceConfig
Returns the URL at which the resource will be available.
getUserId() - Method in class com.hazelcast.jet.examples.sessionwindow.ProductEvent
 
getUsername() - Method in class com.hazelcast.jet.examples.files.avro.User
 
getUsername() - Method in class com.hazelcast.jet.examples.kafka.json.User
 
getValue() - Method in class com.hazelcast.jet.core.metrics.Measurement
Returns the value associated with this Measurement.
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
 
GRPCEnrichment - Class in com.hazelcast.jet.examples.grpc
Demonstrates the usage of the Pipeline API to enrich a data stream.

H

HadoopAvro - Class in com.hazelcast.jet.examples.hadoop.avro
A sample which reads records from HDFS using Apache Avro input format, filters and writes back to HDFS using Apache Avro output format
HadoopAvro() - Constructor for class com.hazelcast.jet.examples.hadoop.avro.HadoopAvro
 
HadoopWordCount - Class in com.hazelcast.jet.examples.hadoop
Word count example adapted to read from and write to HDFS instead of Jet in-memory maps.
HadoopWordCount() - Constructor for class com.hazelcast.jet.examples.hadoop.HadoopWordCount
 
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.metrics.JobMetrics
 
hashCode() - Method in class com.hazelcast.jet.core.metrics.Measurement
 
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.TimestampedItem
 
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
 
hashCode() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.AddToCart
 
hashCode() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.PageVisit
 
hashCode() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.Payment
 
hashCode() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Trade
 
hashCode() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
hashCode() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
hashCode() - Method in class com.hazelcast.jet.examples.grpc.datamodel.Trade
 
hashCode() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
hashCode() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
hashCode() - Method in class com.hazelcast.jet.examples.jdbc.User
 
hashCode() - Method in class com.hazelcast.jet.pipeline.test.SimpleEvent
 
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.
httpServer() - Method in class com.hazelcast.jet.examples.sourcebuilder.support.SystemMonitorHttpService
 
HttpSource - Class in com.hazelcast.jet.examples.sourcebuilder
Shows how to use the SourceBuilder to build a source connector for the Jet pipeline.
HttpSource() - Constructor for class com.hazelcast.jet.examples.sourcebuilder.HttpSource
 

I

ICacheJet<K,V> - Interface in com.hazelcast.jet
A distributed, in-memory implementation of JCache specification.
id() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Broker
 
id() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Product
 
id() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Trade
 
id() - Method in class com.hazelcast.jet.examples.grpc.datamodel.Broker
 
id() - Method in class com.hazelcast.jet.examples.grpc.datamodel.Product
 
id() - Method in class com.hazelcast.jet.examples.grpc.datamodel.Trade
 
ID_FIELD_NUMBER - Static variable in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
ID_FIELD_NUMBER - Static variable in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
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.
inboxSize() - Method in class com.hazelcast.jet.core.test.TestSupport.TestMode
Size limit of the inbox.
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(Processor.Context) - Method in class com.hazelcast.jet.examples.spring.source.CustomSourceP
 
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.
instance() - Method in class com.hazelcast.jet.examples.spring.config.AppConfig
JetInstance bean which configured programmatically with SpringManagedContext
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).
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
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.examples.spring.source.CustomSourceP
 
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
isInitialized() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
isInitialized() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
isInitialized() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
isInitialized() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
isInitialized() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
isInitialized() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
isInitialized() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
isInitialized() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
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).
isMetricsEnabled() - Method in class com.hazelcast.jet.config.JobConfig
Returns if metrics collection is enabled for the job.
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.
isSnapshotsEnabled() - Method in class com.hazelcast.jet.core.test.TestSupport.TestMode
Are snapshots enabled.
isSplitBrainProtectionEnabled() - Method in class com.hazelcast.jet.config.JobConfig
Tells whether split brain protection is enabled.
isStatus() - Method in class com.hazelcast.jet.examples.files.avro.User
 
isStatus() - Method in class com.hazelcast.jet.examples.kafka.json.User
 
isStoreMetricsAfterJobCompletion() - Method in class com.hazelcast.jet.config.JobConfig
Returns whether metrics should be stored in the cluster after the job completes.
isTumbling() - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Tells whether this definition describes a tumbling window.
item() - Method in class com.hazelcast.jet.datamodel.TimestampedItem
Returns the item.
items(Iterable<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.TestSources
Returns a batch source which iterates through the supplied iterable and then terminates.
items(T...) - Static method in class com.hazelcast.jet.pipeline.test.TestSources
Returns a batch source which iterates through the supplied items and then terminates.
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.
itemStream(int) - Static method in class com.hazelcast.jet.pipeline.test.TestSources
Returns a streaming source which generates events of type SimpleEvent at the specified rate infinitely.
itemStream(int, GeneratorFunction<? extends T>) - Static method in class com.hazelcast.jet.pipeline.test.TestSources
Returns a streaming source which generates events created by the generatorFn at the specified rate infinitely.
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 newConnectionFn, 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 newConnectionFn, 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
JdbcSink - Class in com.hazelcast.jet.examples.jdbc
Demonstrates dumping values from an IMap to a table in a relational database using the JDBC connector.
JdbcSink() - Constructor for class com.hazelcast.jet.examples.jdbc.JdbcSink
 
JdbcSource - Class in com.hazelcast.jet.examples.jdbc
Demonstrates dumping values from a table in a relational database to an IMap using the JDBC connector.
JdbcSource() - Constructor for class com.hazelcast.jet.examples.jdbc.JdbcSource
 
Jet - Class in com.hazelcast.jet
Entry point to the Jet product.
JET_HOME - Static variable in class com.hazelcast.jet.core.JetProperties
Root of Jet installation.
JET_IDLE_COOPERATIVE_MAX_MICROSECONDS - Static variable in class com.hazelcast.jet.core.JetProperties
The maximum time in microseconds the cooperative worker threads will sleep if none of the tasklets made any progress.
JET_IDLE_COOPERATIVE_MIN_MICROSECONDS - Static variable in class com.hazelcast.jet.core.JetProperties
The minimum time in microseconds the cooperative worker threads will sleep if none of the tasklets made any progress.
JET_IDLE_NONCOOPERATIVE_MAX_MICROSECONDS - Static variable in class com.hazelcast.jet.core.JetProperties
The maximum time in microseconds the non-cooperative worker threads will sleep if none of the tasklets made any progress.
JET_IDLE_NONCOOPERATIVE_MIN_MICROSECONDS - Static variable in class com.hazelcast.jet.core.JetProperties
The minimum time in microseconds the non-cooperative worker threads will sleep if none of the tasklets made any progress.
JET_SHUTDOWNHOOK_ENABLED - Static variable in class com.hazelcast.jet.core.JetProperties
Whether a JVM shutdown hook is registered to shutdown the node gracefully when the process is terminated.
JetAssert - Class in com.hazelcast.jet.core.test
Assert methods that throw exceptions similar to those thrown by JUnit.
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 - Class in com.hazelcast.jet.examples.configuration.logging
 
JetInstance() - Constructor for class com.hazelcast.jet.examples.configuration.logging.JetInstance
 
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
 
JetProperties - Class in com.hazelcast.jet.core
Defines the names and default values for internal Hazelcast Jet properties.
JetVersionProvider() - Constructor for class com.hazelcast.jet.server.JetCommandLine.JetVersionProvider
 
JmsMessageProducer - Class in com.hazelcast.jet.examples.jms
Utility class to produce messages to the given destination
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.
JmsQueueSample - Class in com.hazelcast.jet.examples.jms
A pipeline which streams messages from a JMS queue, filters them according to the priority and writes a new message with modified properties to another JMS queue.
JmsQueueSample() - Constructor for class com.hazelcast.jet.examples.jms.JmsQueueSample
 
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.
JmsTopicSample - Class in com.hazelcast.jet.examples.jms
A pipeline which streams messages from a JMS topic, filters them according to the priority and writes a new message with modified properties to another JMS topic.
JmsTopicSample() - Constructor for class com.hazelcast.jet.examples.jms.JmsTopicSample
 
JOB - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Unique ID of the job (sourcing the metric), example value would be a numerical (long) ID encoded in a human readable form, like "2f7f-d88a-4669-6195", see Util.idToString(long))} for details.
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.
JOB_METRICS - Static variable in class com.hazelcast.jet.core.metrics.MetricsDataSerializerHook
Serialization ID of the JobMetrics class.
JOB_RESULTS_MAX_SIZE - Static variable in class com.hazelcast.jet.core.JetProperties
Maximum number of job results to keep in the cluster, the oldest results will be automatically deleted after this size is reached.
JOB_RESULTS_TTL_SECONDS - Static variable in class com.hazelcast.jet.core.JetProperties
Maximum number of time in seconds the job results will be kept in the cluster.
JOB_SCAN_PERIOD - Static variable in class com.hazelcast.jet.core.JetProperties
Jet will periodically check for new jobs to start and perform cleanup of unused resources.
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.
JobManualRestart - Class in com.hazelcast.jet.examples.jobmanagement
We demonstrate how a job can be manually scaled out after adding new nodes to the Jet cluster.
JobManualRestart() - Constructor for class com.hazelcast.jet.examples.jobmanagement.JobManualRestart
 
JobMetrics - Class in com.hazelcast.jet.core.metrics
An immutable collection of job-specific metrics, pairs of metric names and sets of associated Measurements.
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.
JobSuspendResume - Class in com.hazelcast.jet.examples.jobmanagement
We demonstrate how a job can be submitted to Jet and further managed via the Job interface.
JobSuspendResume() - Constructor for class com.hazelcast.jet.examples.jobmanagement.JobSuspendResume
 
JobTracking - Class in com.hazelcast.jet.examples.jobmanagement
We demonstrate how submitted jobs can be fetched and tracked via any Jet instance.
JobTracking() - Constructor for class com.hazelcast.jet.examples.jobmanagement.JobTracking
 
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.
KafkaAvroSource - Class in com.hazelcast.jet.examples.kafka.avro
A sample which demonstrates how to consume items using Apache Avro serialization.
KafkaAvroSource() - Constructor for class com.hazelcast.jet.examples.kafka.avro.KafkaAvroSource
 
KafkaJsonSource - Class in com.hazelcast.jet.examples.kafka.json
A sample which demonstrates how to consume items using custom JSON serialization.
KafkaJsonSource() - Constructor for class com.hazelcast.jet.examples.kafka.json.KafkaJsonSource
 
KafkaProcessors - Class in com.hazelcast.jet.kafka
Static utility class with factories of Apache Kafka source and sink processors.
KafkaSink - Class in com.hazelcast.jet.examples.kafka
A sample which consumes an IMap and writes the received items to a Kafka Topic.
KafkaSink() - Constructor for class com.hazelcast.jet.examples.kafka.KafkaSink
 
KafkaSinks - Class in com.hazelcast.jet.kafka
Contains factory methods for Apache Kafka sinks.
KafkaSource - Class in com.hazelcast.jet.examples.kafka
A sample which consumes two Kafka topics and writes the received items to an IMap.
KafkaSource() - Constructor for class com.hazelcast.jet.examples.kafka.KafkaSource
 
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

LAST_FORWARDED_WM - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the last watermark emitted by a particular Processor, which can be identified based on the MetricTags.PROCESSOR tag.
LAST_FORWARDED_WM_LATENCY - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the difference between the last emitted watermark and the system time of a particular Processor.
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, boolean) - Method in class com.hazelcast.jet.server.JetCommandLine
 
ListSourceAndSink - Class in com.hazelcast.jet.examples.imdg
Demonstrates the usage of Hazelcast IList as source and sink with the Pipeline API.
ListSourceAndSink() - Constructor for class com.hazelcast.jet.examples.imdg.ListSourceAndSink
 
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
loadTime() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.PageVisit
 
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.examples.cogroup.BatchCoGroup
 
main(String[]) - Static method in class com.hazelcast.jet.examples.cogroup.WindowedCoGroup
 
main(String[]) - Static method in class com.hazelcast.jet.examples.configuration.logging.JetInstance
 
main(String[]) - Static method in class com.hazelcast.jet.examples.configuration.xml.ConfigLookup
 
main(String[]) - Static method in class com.hazelcast.jet.examples.configuration.xml.XmlJetConfigClasspath
 
main(String[]) - Static method in class com.hazelcast.jet.examples.configuration.yaml.ConfigLookup
 
main(String[]) - Static method in class com.hazelcast.jet.examples.configuration.yaml.YamlJetConfigClasspath
 
main(String[]) - Static method in class com.hazelcast.jet.examples.earlyresults.TradingVolumeOverTime
 
main(String[]) - Static method in class com.hazelcast.jet.examples.enrichment.Enrichment
 
main(String[]) - Static method in class com.hazelcast.jet.examples.eventjournal.CacheJournalSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.eventjournal.MapJournalSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.eventjournal.RemoteCacheJournalSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.eventjournal.RemoteMapJournalSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.faulttolerance.FaultTolerance
 
main(String[]) - Static method in class com.hazelcast.jet.examples.files.AccessLogAnalyzer
 
main(String[]) - Static method in class com.hazelcast.jet.examples.files.AccessLogStreamAnalyzer
 
main(String[]) - Static method in class com.hazelcast.jet.examples.files.avro.AvroSink
 
main(String[]) - Static method in class com.hazelcast.jet.examples.files.avro.AvroSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.files.s3.S3WordCount
 
main(String[]) - Static method in class com.hazelcast.jet.examples.grpc.GRPCEnrichment
 
main(String[]) - Static method in class com.hazelcast.jet.examples.hadoop.avro.HadoopAvro
 
main(String[]) - Static method in class com.hazelcast.jet.examples.hadoop.HadoopWordCount
 
main(String[]) - Static method in class com.hazelcast.jet.examples.imdg.CacheSourceAndSink
 
main(String[]) - Static method in class com.hazelcast.jet.examples.imdg.ListSourceAndSink
 
main(String[]) - Static method in class com.hazelcast.jet.examples.imdg.MapPredicateAndProjection
 
main(String[]) - Static method in class com.hazelcast.jet.examples.imdg.MapSourceAndSinks
 
main(String[]) - Static method in class com.hazelcast.jet.examples.imdg.RemoteListSourceAndSink
 
main(String[]) - Static method in class com.hazelcast.jet.examples.imdg.RemoteMapSourceAndSink
 
main(String[]) - Static method in class com.hazelcast.jet.examples.jdbc.JdbcSink
 
main(String[]) - Static method in class com.hazelcast.jet.examples.jdbc.JdbcSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.jms.JmsQueueSample
 
main(String[]) - Static method in class com.hazelcast.jet.examples.jms.JmsTopicSample
 
main(String[]) - Static method in class com.hazelcast.jet.examples.jobmanagement.ExclusiveJobExecution
 
main(String[]) - Static method in class com.hazelcast.jet.examples.jobmanagement.JobManualRestart
 
main(String[]) - Static method in class com.hazelcast.jet.examples.jobmanagement.JobSuspendResume
 
main(String[]) - Static method in class com.hazelcast.jet.examples.jobmanagement.JobTracking
 
main(String[]) - Static method in class com.hazelcast.jet.examples.kafka.avro.KafkaAvroSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.kafka.json.KafkaJsonSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.kafka.KafkaSink
 
main(String[]) - Static method in class com.hazelcast.jet.examples.kafka.KafkaSource
 
main(String[]) - Static method in class com.hazelcast.jet.examples.patternmatching.TransactionTracking
 
main(String[]) - Static method in class com.hazelcast.jet.examples.rollingaggregation.TradingVolume
 
main(String[]) - Static method in class com.hazelcast.jet.examples.sessionwindow.SessionWindow
 
main(String[]) - Static method in class com.hazelcast.jet.examples.sinkbuilder.TopicSink
Creates a Hazelcast Jet cluster, attaches a topic listener and runs the pipeline
main(String[]) - Static method in class com.hazelcast.jet.examples.slidingwindow.StockExchange
 
main(String[]) - Static method in class com.hazelcast.jet.examples.slidingwindow.TopNStocks
 
main(String[]) - Static method in class com.hazelcast.jet.examples.sockets.StreamTextSocket
 
main(String[]) - Static method in class com.hazelcast.jet.examples.sockets.WriteTextSocket
 
main(String[]) - Static method in class com.hazelcast.jet.examples.sourcebuilder.HttpSource
Starts the system-monitoring HTTP service, the GUI screen and Hazelcast Jet, and runs the stream job on it.
main(String[]) - Static method in class com.hazelcast.jet.examples.spring.AnnotationBasedConfigurationSample
 
main(String[]) - Static method in class com.hazelcast.jet.examples.spring.SpringBootSample
 
main(String[]) - Static method in class com.hazelcast.jet.examples.spring.XmlConfigurationSample
 
main(String[]) - Static method in class com.hazelcast.jet.examples.spring.XmlConfigurationWithSchemaSample
 
main(String[]) - Static method in class com.hazelcast.jet.examples.tfidf.BuildStopwords
 
main(String[]) - Static method in class com.hazelcast.jet.examples.tfidf.TfIdf
 
main(String[]) - Static method in class com.hazelcast.jet.examples.tfidf.TfIdfJdkStreams
 
main(String[]) - Static method in class com.hazelcast.jet.examples.wordcount.WordCount
 
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.
managedContext() - Method in class com.hazelcast.jet.examples.spring.config.AppConfig
A ManagedContext implementation bean which enables @SpringAware annotation for de-serialized objects.
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.
MAP_NAME - Static variable in class com.hazelcast.jet.examples.files.avro.AvroSink
 
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.
MapJournalSource - Class in com.hazelcast.jet.examples.eventjournal
A pipeline which streams events from an IMap.
MapJournalSource() - Constructor for class com.hazelcast.jet.examples.eventjournal.MapJournalSource
 
mapP(FunctionEx<? 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.
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.
MapPredicateAndProjection - Class in com.hazelcast.jet.examples.imdg
Demonstrates the usage of Hazelcast IMap as source and using Hazelcast predicates and projections on Hazelcast portable types.
MapPredicateAndProjection() - Constructor for class com.hazelcast.jet.examples.imdg.MapPredicateAndProjection
 
mapPutEvents() - Static method in class com.hazelcast.jet.Util
MapSourceAndSinks - Class in com.hazelcast.jet.examples.imdg
Demonstrates the usage of Hazelcast IMap as source and sink with the Pipeline API.
MapSourceAndSinks(JetInstance) - Constructor for class com.hazelcast.jet.examples.imdg.MapSourceAndSinks
 
mapStateful(SupplierEx<? extends S>, BiFunctionEx<? super S, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
mapStateful(SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
mapStateful(SupplierEx<? extends S>, BiFunctionEx<? super S, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a stage that performs a stateful mapping operation.
mapStateful(SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a stage that performs a stateful mapping operation.
mapStateful(SupplierEx<? extends S>, BiFunctionEx<? super S, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
mapStateful(long, SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends R>, TriFunction<? super S, ? super K, ? super Long, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
Attaches a stage that performs a stateful mapping operation.
mapStateful(SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
mapStatefulP(long, FunctionEx<? super T, ? extends K>, ToLongFunctionEx<? super T>, Supplier<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends R>, TriFunction<? super S, ? super K, ? super Long, ? extends R>) - Static method in class com.hazelcast.jet.core.processor.Processors
Returns a supplier of processors for a vertex that performs a stateful mapping of its input.
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<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_LAG - Static variable in class com.hazelcast.jet.examples.earlyresults.support.TradeGenerator
 
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).
Measurement - Class in com.hazelcast.jet.core.metrics
Immutable data class containing information about one metric measurement, consisting of: metric value metric timestamp, generated when the metric was gathered metric descriptor (set of tag name-value pairs)
MEASUREMENT - Static variable in class com.hazelcast.jet.core.metrics.MetricsDataSerializerHook
Serialization ID of the Measurement class.
MeasurementPredicates - Class in com.hazelcast.jet.core.metrics
Static utility class for creating various Measurement filtering predicates.
MEMBER - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Unique ID of the cluster member sourcing the metric.
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
 
memoryUsage() - Method in class com.hazelcast.jet.examples.sourcebuilder.support.MemoryUsageMetric
 
MemoryUsageMetric - Class in com.hazelcast.jet.examples.sourcebuilder.support
Represents a single measurement of JVM heap memory usage taken at the given timestamp.
MemoryUsageMetric(long, long) - Constructor for class com.hazelcast.jet.examples.sourcebuilder.support.MemoryUsageMetric
 
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.
mergeFrom(Message) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
mergeFrom(BrokerInfoReply) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
mergeFrom(Message) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
mergeFrom(BrokerInfoRequest) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
mergeFrom(Message) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
mergeFrom(ProductInfoReply) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
mergeFrom(Message) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
mergeFrom(ProductInfoRequest) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
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
mergeUnknownFields(UnknownFieldSet) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
messageFn(BiFunctionEx<Session, T, Message>) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the function which creates the message from the item.
METRIC - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
The name of the metric.
MetricNames - Class in com.hazelcast.jet.core.metrics
Each metric provided by Jet has a specific name which conceptually identifies what it's being used to measure.
metrics() - Method in class com.hazelcast.jet.core.metrics.JobMetrics
Returns all metrics present.
MetricsConfig - Class in com.hazelcast.jet.config
Configuration options specific to metrics collection.
MetricsConfig() - Constructor for class com.hazelcast.jet.config.MetricsConfig
 
MetricsDataSerializerHook - Class in com.hazelcast.jet.core.metrics
A Java Service Provider hook for Hazelcast's Identified Data Serializable mechanism.
MetricsDataSerializerHook() - Constructor for class com.hazelcast.jet.core.metrics.MetricsDataSerializerHook
 
MetricTags - Class in com.hazelcast.jet.core.metrics
Metric descriptors are formed from a comma separated list of tag_name=tag_value pairs.
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
MODULE - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Source system or module, value is always "jet".
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.examples.enrichment.datamodel.Broker
 
name() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Product
 
name() - Method in class com.hazelcast.jet.examples.grpc.datamodel.Broker
 
name() - Method in class com.hazelcast.jet.examples.grpc.datamodel.Product
 
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).
newBlockingStub(Channel) - Static method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc
Creates a new blocking-style stub that supports unary and streaming output calls on the service
newBlockingStub(Channel) - Static method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc
Creates a new blocking-style stub that supports unary and streaming output calls on the service
newBuilder() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
newBuilder(BrokerInfoReply) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
newBuilder() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
newBuilder(BrokerInfoRequest) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
newBuilder() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
newBuilder(ProductInfoReply) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
newBuilder() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
newBuilder(ProductInfoRequest) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
newBuilderForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
newBuilderForType() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
newBuilderForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
newBuilderForType() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
newFutureStub(Channel) - Static method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc
Creates a new ListenableFuture-style stub that supports unary calls on the service
newFutureStub(Channel) - Static method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc
Creates a new ListenableFuture-style stub that supports unary calls on the service
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.
newJetFailoverClient(ClientFailoverConfig) - Static method in class com.hazelcast.jet.Jet
Creates a Jet client with cluster failover capability.
newJetFailoverClient() - Static method in class com.hazelcast.jet.Jet
Creates a Jet client with cluster failover capability.
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.
newStub(Channel) - Static method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc
Creates a new async stub that supports all call types for the service
newStub(Channel) - Static method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc
Creates a new async stub that supports all call types for the service
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(Stream<Measurement>) - Static method in class com.hazelcast.jet.core.metrics.JobMetrics
Builds a JobMetrics object based on a stream of Measurements.
of(long, long, Map<String, String>) - Static method in class com.hazelcast.jet.core.metrics.Measurement
Builds a Measurement instance based on timestamp, value and the metric descriptor in map form.
of(int, ProcessorSupplier) - 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
ORDINAL - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Index of the vertex input or output edges sourcing the metric.
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

PageVisit - Class in com.hazelcast.jet.examples.cogroup.datamodel
 
PageVisit(long, int, int) - Constructor for class com.hazelcast.jet.examples.cogroup.datamodel.PageVisit
 
parseDelimitedFrom(InputStream) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseDelimitedFrom(InputStream) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseDelimitedFrom(InputStream) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseDelimitedFrom(InputStream) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(ByteBuffer) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(ByteString) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(byte[]) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(InputStream) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(CodedInputStream) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parseFrom(ByteBuffer) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(ByteString) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(byte[]) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(InputStream) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(CodedInputStream) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parseFrom(ByteBuffer) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(ByteString) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(byte[]) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(InputStream) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(CodedInputStream) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parseFrom(ByteBuffer) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(ByteString) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(byte[]) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(InputStream) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(CodedInputStream) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
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
 
parser() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
parser() - Static method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
parser() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
parser() - Static method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
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.
Payment - Class in com.hazelcast.jet.examples.cogroup.datamodel
 
Payment(long, int, int) - Constructor for class com.hazelcast.jet.examples.cogroup.datamodel.Payment
 
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.
PENDING_CODE - Static variable in class com.hazelcast.jet.examples.patternmatching.support.TransactionStatusGui
 
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.
price() - Method in class com.hazelcast.jet.examples.faulttolerance.PriceUpdateEvent
 
PriceUpdateEvent - Class in com.hazelcast.jet.examples.faulttolerance
Represents a single price update event
PriceUpdateEvent(String, Integer, Long) - Constructor for class com.hazelcast.jet.examples.faulttolerance.PriceUpdateEvent
 
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 - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Global index of the Processor sourcing the metric.
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.
PROCESSOR_TYPE - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Class name without package name of the Processor sourcing the metric (only for processor-specific metrics).
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.
Product - Class in com.hazelcast.jet.examples.enrichment.datamodel
 
Product(int, String) - Constructor for class com.hazelcast.jet.examples.enrichment.datamodel.Product
 
Product - Class in com.hazelcast.jet.examples.grpc.datamodel
 
Product(int, String) - Constructor for class com.hazelcast.jet.examples.grpc.datamodel.Product
 
ProductEvent - Class in com.hazelcast.jet.examples.sessionwindow
DTO for product event.
ProductEvent(long, String, String, ProductEventType) - Constructor for class com.hazelcast.jet.examples.sessionwindow.ProductEvent
 
ProductEventType - Enum in com.hazelcast.jet.examples.sessionwindow
 
productId() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Trade
 
productId() - Method in class com.hazelcast.jet.examples.grpc.datamodel.Trade
 
productInfo(ProductInfoRequest) - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceBlockingStub
 
productInfo(ProductInfoRequest) - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceFutureStub
 
productInfo(ProductInfoRequest, StreamObserver<ProductInfoReply>) - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceImplBase
 
productInfo(ProductInfoRequest, StreamObserver<ProductInfoReply>) - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceStub
 
productInfo(ProductInfoRequest, StreamObserver<ProductInfoReply>) - Method in class com.hazelcast.jet.examples.grpc.ProductServiceImpl
 
ProductInfoReply - Class in com.hazelcast.jet.examples.grpc
Protobuf type helloworld.ProductInfoReply
ProductInfoReply.Builder - Class in com.hazelcast.jet.examples.grpc
Protobuf type helloworld.ProductInfoReply
ProductInfoReplyOrBuilder - Interface in com.hazelcast.jet.examples.grpc
 
ProductInfoRequest - Class in com.hazelcast.jet.examples.grpc
Protobuf type helloworld.ProductInfoRequest
ProductInfoRequest.Builder - Class in com.hazelcast.jet.examples.grpc
Protobuf type helloworld.ProductInfoRequest
ProductInfoRequestOrBuilder - Interface in com.hazelcast.jet.examples.grpc
 
PRODUCTNAME_FIELD_NUMBER - Static variable in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
ProductServiceGrpc - Class in com.hazelcast.jet.examples.grpc
 
ProductServiceGrpc.ProductServiceBlockingStub - Class in com.hazelcast.jet.examples.grpc
 
ProductServiceGrpc.ProductServiceFutureStub - Class in com.hazelcast.jet.examples.grpc
 
ProductServiceGrpc.ProductServiceImplBase - Class in com.hazelcast.jet.examples.grpc
 
ProductServiceGrpc.ProductServiceStub - Class in com.hazelcast.jet.examples.grpc
 
ProductServiceImpl - Class in com.hazelcast.jet.examples.grpc
Server-side implementation of a gRPC service.
ProductServiceImpl(Map<Integer, Product>) - Constructor for class com.hazelcast.jet.examples.grpc.ProductServiceImpl
 
ProductServiceImplBase() - Constructor for class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceImplBase
 
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.
put(int, Object) - Method in class com.hazelcast.jet.examples.hadoop.avro.User
 
put(int, Object) - Method in class com.hazelcast.jet.examples.kafka.avro.User
 

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.
quantity() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.AddToCart
 
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.
QUEUE_CAPACITY - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the total capacity of all input queues of a particular Vertex on a particular Processor.
QUEUE_SIZES - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the total size of all input queues of a particular Vertex on a particular Processor.

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.metrics.JobMetrics
 
readData(ObjectDataInput) - Method in class com.hazelcast.jet.core.metrics.Measurement
 
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
RECEIVED_BATCHES - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Counts incoming data item batches on input Edges of particular Vertex instances running on various Processors.
RECEIVED_COUNT - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Counts incoming data items on input Edges of particular Vertex instances running on various Processors.
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.
receiveFn(BiConsumerEx<? super S, ? super T_NEW>) - Method in class com.hazelcast.jet.pipeline.test.AssertionSinkBuilder
Sets the function Jet will call upon receiving every 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).
registerAllExtensions(ExtensionRegistryLite) - Static method in class com.hazelcast.jet.examples.grpc.EnrichmentProto
 
registerAllExtensions(ExtensionRegistry) - Static method in class com.hazelcast.jet.examples.grpc.EnrichmentProto
 
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.
RemoteCacheJournalSource - Class in com.hazelcast.jet.examples.eventjournal
A pipeline which streams events from an ICache on a remote Hazelcast cluster.
RemoteCacheJournalSource() - Constructor for class com.hazelcast.jet.examples.eventjournal.RemoteCacheJournalSource
 
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.
RemoteListSourceAndSink - Class in com.hazelcast.jet.examples.imdg
Demonstrates the usage of a Hazelcast IList in an external cluster as source and sink with the Pipeline API.
RemoteListSourceAndSink() - Constructor for class com.hazelcast.jet.examples.imdg.RemoteListSourceAndSink
 
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.
RemoteMapJournalSource - Class in com.hazelcast.jet.examples.eventjournal
A pipeline which streams events from an IMap on a remote Hazelcast cluster.
RemoteMapJournalSource() - Constructor for class com.hazelcast.jet.examples.eventjournal.RemoteMapJournalSource
 
RemoteMapSourceAndSink - Class in com.hazelcast.jet.examples.imdg
Demonstrates the usage of Hazelcast IMap as source and sink from/to a remote Hazelcast cluster.
RemoteMapSourceAndSink() - Constructor for class com.hazelcast.jet.examples.imdg.RemoteMapSourceAndSink
 
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, A, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
rollingAggregate(AggregateOperation1<? super T, A, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
rollingAggregate(AggregateOperation1<? super T, A, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStage
Attaches a rolling aggregation stage.
rollingAggregate(AggregateOperation1<? super T, A, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.GeneralStageWithKey
Attaches a rolling aggregation stage.
rollingAggregate(AggregateOperation1<? super T, A, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
rollingAggregate(AggregateOperation1<? super T, A, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
rollingAggregate(long, AggregateOperation1<? super T, A, ? extends R>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
Attaches a rolling aggregation stage.
run() - Method in class com.hazelcast.jet.examples.enrichment.EventGenerator
 
run() - Method in class com.hazelcast.jet.examples.grpc.EventGenerator
 
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

s3(String, SupplierEx<? extends S3Client>) - Static method in class com.hazelcast.jet.s3.S3Sinks
Convenience for S3Sinks.s3(String, String, Charset, SupplierEx, FunctionEx) Uses Object.toString() to convert the items to lines.
s3(String, String, Charset, SupplierEx<? extends S3Client>, FunctionEx<? super T, String>) - Static method in class com.hazelcast.jet.s3.S3Sinks
Creates an AWS S3 Sink which writes items to files into the given bucket.
s3(List<String>, String, SupplierEx<? extends S3Client>) - Static method in class com.hazelcast.jet.s3.S3Sources
s3(List<String>, String, Charset, SupplierEx<? extends S3Client>, BiFunctionEx<String, String, ? extends T>) - Static method in class com.hazelcast.jet.s3.S3Sources
Creates an AWS S3 BatchSource which lists all the objects in the bucket-list using given prefix, reads them line by line, transforms each line to the desired output object using given mapFn and emits them to downstream.
S3Sinks - Class in com.hazelcast.jet.s3
Contains factory methods for creating AWS S3 sinks.
S3Sources - Class in com.hazelcast.jet.s3
Contains factory methods for creating AWS S3 sources.
S3WordCount - Class in com.hazelcast.jet.examples.files.s3
Word count example adapted to read from and write to S3 bucket.
S3WordCount() - Constructor for class com.hazelcast.jet.examples.files.s3.S3WordCount
 
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.
SCHEMA - Static variable in class com.hazelcast.jet.examples.hadoop.avro.User
 
sendFn(BiConsumerEx<MessageProducer, Message>) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the function which sends the message via message producer.
sequence() - Method in class com.hazelcast.jet.pipeline.test.SimpleEvent
Sequence number of the event
SERVICE_NAME - Static variable in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc
 
SERVICE_NAME - Static variable in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc
 
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.
SessionWindow - Class in com.hazelcast.jet.examples.sessionwindow
Demonstrates the usage of a session window to track the behavior of the users in an online shop.
SessionWindow() - Constructor for class com.hazelcast.jet.examples.sessionwindow.SessionWindow
 
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.
setAge(int) - Method in class com.hazelcast.jet.examples.files.avro.User
 
setAge(int) - Method in class com.hazelcast.jet.examples.kafka.json.User
 
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.
setBrokerName(String) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
string brokerName = 1;
setBrokerNameBytes(ByteString) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
string brokerName = 1;
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.
setEmail(String) - Method in class com.hazelcast.jet.examples.spring.model.User
 
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.
setField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
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.
setId(int) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
int32 id = 1;
setId(int) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
int32 id = 1;
setId(int) - Method in class com.hazelcast.jet.examples.jdbc.User
 
setId(Integer) - Method in class com.hazelcast.jet.examples.spring.model.User
 
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.
setItem(T) - Method in class com.hazelcast.jet.datamodel.TimestampedItem
Sets the item.
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.
setMetricsEnabled(boolean) - Method in class com.hazelcast.jet.config.JobConfig
Sets whether metrics collection should be enabled for the job.
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 class com.hazelcast.jet.examples.jdbc.User
 
setName(String) - Method in class com.hazelcast.jet.examples.spring.model.User
 
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.
setPassword(String) - Method in class com.hazelcast.jet.examples.files.avro.User
 
setPassword(String) - Method in class com.hazelcast.jet.examples.kafka.json.User
 
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
 
setProductName(String) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
string productName = 1;
setProductNameBytes(ByteString) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
string productName = 1;
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.
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
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.
setStatus(boolean) - Method in class com.hazelcast.jet.examples.files.avro.User
 
setStatus(boolean) - Method in class com.hazelcast.jet.examples.kafka.json.User
 
setStoreMetricsAfterJobCompletion(boolean) - Method in class com.hazelcast.jet.config.JobConfig
Sets whether metrics should be stored in the cluster after the job completes.
setTimestamp(long) - Method in class com.hazelcast.jet.datamodel.TimestampedItem
Sets the timestamp.
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
 
setUnknownFields(UnknownFieldSet) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest.Builder
 
setUsername(String) - Method in class com.hazelcast.jet.examples.files.avro.User
 
setUsername(String) - Method in class com.hazelcast.jet.examples.kafka.json.User
 
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.
SimpleEvent - Class in com.hazelcast.jet.pipeline.test
A simple event with a timestamp and a sequence number.
SimpleEvent(long, long) - Constructor for class com.hazelcast.jet.pipeline.test.SimpleEvent
Create an event with the given timestamp and sequence number
singleton(T) - Static method in class com.hazelcast.jet.Traversers
Returns a traverser over the given single item.
SINK - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Boolean flag which is true if the Processor sourcing the metric is a DAG sink.
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 interface com.hazelcast.jet.core.Inbox
Returns the number of objects in the inbox.
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.
snapshotRestoreInterval() - Method in class com.hazelcast.jet.core.test.TestSupport.TestMode
How often the snapshot is restored.
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.
SOURCE - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Boolean flag which is true if the Processor sourcing the metric is a DAG source.
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.
SpringBootSample - Class in com.hazelcast.jet.examples.spring
Example of integrating Hazelcast Jet with Spring Boot.
SpringBootSample() - Constructor for class com.hazelcast.jet.examples.spring.SpringBootSample
 
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.
start() - Method in class com.hazelcast.jet.examples.jms.ActiveMQBroker
 
start() - Method in class com.hazelcast.jet.examples.jms.JmsMessageProducer
 
StartServer - Class in com.hazelcast.jet.server
Main class that starts a Hazelcast Jet instance.
StockExchange - Class in com.hazelcast.jet.examples.slidingwindow
Showcases the Sliding Window Aggregation operator of the Pipeline API.
StockExchange() - Constructor for class com.hazelcast.jet.examples.slidingwindow.StockExchange
 
stop() - Method in class com.hazelcast.jet.examples.jms.ActiveMQBroker
 
stop() - Method in class com.hazelcast.jet.examples.jms.JmsMessageProducer
 
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 pieline transform that involves a grouping key, such as windowed group-and-aggregate.
StreamTextSocket - Class in com.hazelcast.jet.examples.sockets
A Pipeline which connects to a server and writes the received lines to an IList.
StreamTextSocket() - Constructor for class com.hazelcast.jet.examples.sockets.StreamTextSocket
 
submit(JetCommandLine.Verbosity, String, String, File, List<String>) - Method in class com.hazelcast.jet.server.JetCommandLine
 
submitJob() - Method in class com.hazelcast.jet.examples.spring.SpringBootSample
 
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
 
SystemMonitorGui - Class in com.hazelcast.jet.examples.sourcebuilder.support
Displays a live time graph based on the data it gets from a Hazelcast map listener.
SystemMonitorGui(IMap<Long, Double>) - Constructor for class com.hazelcast.jet.examples.sourcebuilder.support.SystemMonitorGui
 
SystemMonitorHttpService - Class in com.hazelcast.jet.examples.sourcebuilder.support
Starts a thread that records a time series of used JVM heap memory.
SystemMonitorHttpService() - Constructor for class com.hazelcast.jet.examples.sourcebuilder.support.SystemMonitorHttpService
 

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.
tagValueEquals(String, String) - Static method in class com.hazelcast.jet.core.metrics.MeasurementPredicates
Matches a Measurement which contains the specified tag and the tag has the specified value.
tagValueMatches(String, String) - Static method in class com.hazelcast.jet.core.metrics.MeasurementPredicates
Matches a Measurement which has this exact tag with a value matching the provided regular expression.
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
 
TestSources - Class in com.hazelcast.jet.pipeline.test
Contains factory methods for various mock sources which can be used for pipeline testing and development.
TestSupport - Class in com.hazelcast.jet.core.test
A utility to test processors.
TestSupport.TestMode - Class in com.hazelcast.jet.core.test
Describes the current test mode.
TfIdf - Class in com.hazelcast.jet.examples.tfidf
Builds, for a given set of text documents, an inverted index that maps each word to the set of documents that contain it.
TfIdf() - Constructor for class com.hazelcast.jet.examples.tfidf.TfIdf
 
TfIdfJdkStreams - Class in com.hazelcast.jet.examples.tfidf
Implementation of TF-IDF without Jet, with just the JDK code.
TfIdfJdkStreams() - Constructor for class com.hazelcast.jet.examples.tfidf.TfIdfJdkStreams
 
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
ticker() - Method in class com.hazelcast.jet.examples.faulttolerance.PriceUpdateEvent
 
TIMED_OUT_CODE - Static variable in class com.hazelcast.jet.examples.patternmatching.support.TransactionStatusGui
 
timerFn(ConsumerEx<? super S>) - Method in class com.hazelcast.jet.pipeline.test.AssertionSinkBuilder
Sets the function that will be called periodically.
timestamp() - Method in class com.hazelcast.jet.core.Watermark
Returns the timestamp of this watermark item.
timestamp() - Method in class com.hazelcast.jet.datamodel.TimestampedItem
Returns the timestamp.
timestamp() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.Event
 
timestamp() - Method in class com.hazelcast.jet.examples.faulttolerance.PriceUpdateEvent
 
timestamp() - Method in class com.hazelcast.jet.examples.patternmatching.support.TransactionEvent
 
timestamp() - Method in class com.hazelcast.jet.examples.sourcebuilder.support.MemoryUsageMetric
 
timestamp() - Method in class com.hazelcast.jet.pipeline.test.SimpleEvent
Timestamp of the event in milliseconds
TimestampedItem<T> - Class in com.hazelcast.jet.datamodel
Mutable wrapper around an item that adds a timestamp.
TimestampedItem(long, T) - Constructor for class com.hazelcast.jet.datamodel.TimestampedItem
Creates a new timestamped 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.
toAggregator(AggregateOperation1<? super T, A, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Adapts this aggregate operation to be used for IMap.aggregate(Aggregator) calls.
toBuilder() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoReply
 
toBuilder() - Method in class com.hazelcast.jet.examples.grpc.BrokerInfoRequest
 
toBuilder() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply
 
toBuilder() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoRequest
 
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
toCollector(AggregateOperation1<? super T, A, ? extends R>) - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
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(int) - Method in class com.hazelcast.jet.core.DAG
Returns a DOT format (graphviz) representation of the DAG and annotates the vertices using default parallelism with the supplied value.
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.
TOP_OBSERVED_WM - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the highest coalesced watermark observed on all input Edges of a particular Vertex (ie.
TopicSink - Class in com.hazelcast.jet.examples.sinkbuilder
Shows how to use the SinkBuilder to build a sink for the Jet pipeline.
TopicSink() - Constructor for class com.hazelcast.jet.examples.sinkbuilder.TopicSink
 
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.
TopNStocks - Class in com.hazelcast.jet.examples.slidingwindow
Shows how perform nested aggregation.
TopNStocks() - Constructor for class com.hazelcast.jet.examples.slidingwindow.TopNStocks
 
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.metrics.JobMetrics
 
toString() - Method in class com.hazelcast.jet.core.metrics.Measurement
 
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.test.TestSupport.TestMode
 
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.TimestampedItem
 
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
 
toString() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.AddToCart
 
toString() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.PageVisit
 
toString() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.Payment
 
toString() - Method in class com.hazelcast.jet.examples.earlyresults.support.Trade
 
toString() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Broker
 
toString() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Product
 
toString() - Method in class com.hazelcast.jet.examples.enrichment.datamodel.Trade