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

AbstractAsyncTransformUsingServiceP<C,S> - Class in com.hazelcast.jet.impl.processor
 
AbstractAsyncTransformUsingServiceP(ServiceFactory<C, S>, C, int, boolean) - Constructor for class com.hazelcast.jet.impl.processor.AbstractAsyncTransformUsingServiceP
 
AbstractHazelcastConnectorSupplier - Class in com.hazelcast.jet.impl.connector
 
AbstractJobOperation - Class in com.hazelcast.jet.impl.operation
Base class for GetJobStatusOperation and others.
AbstractJobOperation() - Constructor for class com.hazelcast.jet.impl.operation.AbstractJobOperation
 
AbstractJobOperation(long) - Constructor for class com.hazelcast.jet.impl.operation.AbstractJobOperation
 
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.
AbstractStage - Class in com.hazelcast.jet.impl.pipeline
 
AbstractTransform - Class in com.hazelcast.jet.impl.pipeline.transform
 
AbstractTransform(String, List<Transform>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.AbstractTransform
 
AbstractTransform(String, Transform) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.AbstractTransform
 
AbstractTransform.Optimization - Enum in com.hazelcast.jet.impl.pipeline.transform
 
AbstractTransformUsingServiceP<C,S> - Class in com.hazelcast.jet.impl.processor
 
AbstractTransformUsingServiceP(ServiceFactory<C, S>, C) - Constructor for class com.hazelcast.jet.impl.processor.AbstractTransformUsingServiceP
 
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.
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.
accumulate(T) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOpAggregator
 
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.
accumulateFn() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation1Impl
 
accumulateFn(Tag<T>) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation1Impl
 
accumulateFn(Tag<T>) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation2Impl
 
accumulateFn(Tag<T>) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation3Impl
 
accumulateFn(int) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
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.
accumulateFn0() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation2Impl
 
accumulateFn0() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation3Impl
 
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.
accumulateFn1() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation2Impl
 
accumulateFn1() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation3Impl
 
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.
accumulateFn2() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation3Impl
 
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
activeTransaction() - Method in class com.hazelcast.jet.impl.processor.TransactionPoolSnapshotUtility
 
activeTransaction() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility
Returns the active transaction that can be used to store an item or query the source.
activeTransaction() - Method in class com.hazelcast.jet.impl.processor.UnboundedTransactionsProcessorUtility
 
ADAPT_TO_JET_EVENT - Static variable in class com.hazelcast.jet.impl.pipeline.ComputeStageImplBase
 
adaptHashJoinOutputFn(BiFunctionEx<? super T, ? super T1, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.FunctionAdapter
 
adaptingMetaSupplier(ProcessorMetaSupplier, int[]) - Static method in class com.hazelcast.jet.impl.pipeline.FunctionAdapter
 
adaptJoinClause(JoinClause<? extends K, ? super T0, ? super T1, ? extends T1_OUT>) - Method in class com.hazelcast.jet.impl.pipeline.FunctionAdapter
 
adaptKeyFn(FunctionEx<? super T, ? extends K>) - Method in class com.hazelcast.jet.impl.pipeline.FunctionAdapter
 
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(GeneralStage<E>) - Method in class com.hazelcast.jet.impl.pipeline.AggBuilder
 
add(StreamStageWithKey<T, K>) - Method in class com.hazelcast.jet.impl.pipeline.GrAggBuilder
 
add(BatchStageWithKey<E, K>) - Method in class com.hazelcast.jet.impl.pipeline.GrAggBuilder
 
add(T) - Method in class com.hazelcast.jet.impl.pipeline.SourceBufferImpl.Plain
 
add(T, long) - Method in class com.hazelcast.jet.impl.pipeline.SourceBufferImpl.Timestamped
 
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)
addAllInputValue(Iterable<String>) - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
repeated string inputValue = 1;
addAllOutputValue(Iterable<String>) - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
repeated string outputValue = 1;
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.
addClamped(long, long) - Static method in class com.hazelcast.jet.impl.util.Util
 
addClass(Class...) - Method in class com.hazelcast.jet.config.JobConfig
Adds the given classes and recursively all their nested (inner & anonymous) classes to the Jet job's classpath.
addClasspathResource(URL) - Method in class com.hazelcast.jet.config.JobConfig
Adds a resource that will be available on the Jet job's classpath.
addClasspathResource(URL, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds a resource that will be available on the Jet job's classpath.
addClasspathResource(File) - Method in class com.hazelcast.jet.config.JobConfig
Adds a file that will be available as a resource on the Jet job's classpath.
addClasspathResource(File, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds a file that will be available as a resource on the Jet job's classpath.
addClasspathResource(String) - Method in class com.hazelcast.jet.config.JobConfig
Adds a file that will be available as a resource on the Jet job's classpath.
addClasspathResource(String, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds a file that will be available as a resource on the Jet job's classpath.
addEdges(Transform, Vertex, ObjIntConsumer<Edge>) - Method in class com.hazelcast.jet.impl.pipeline.Planner
 
addEdges(Transform, Vertex, Consumer<Edge>) - Method in class com.hazelcast.jet.impl.pipeline.Planner
 
addEdges(Transform, Vertex) - Method in class com.hazelcast.jet.impl.pipeline.Planner
 
addFile(String, File) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
Add an attached file or folder.
addInputValue(String) - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
repeated string inputValue = 1;
addInputValueBytes(ByteString) - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
repeated string inputValue = 1;
addJar(URL) - Method in class com.hazelcast.jet.config.JobConfig
Adds a JAR whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.
addJar(File) - Method in class com.hazelcast.jet.config.JobConfig
Adds a JAR whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.
addJar(String) - Method in class com.hazelcast.jet.config.JobConfig
Adds a JAR whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.
addJarsInZip(URL) - Method in class com.hazelcast.jet.config.JobConfig
Adds a ZIP file with JARs whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.
addJarsInZip(File) - Method in class com.hazelcast.jet.config.JobConfig
Adds a ZIP file with JARs whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.
addJarsInZip(String) - Method in class com.hazelcast.jet.config.JobConfig
Adds a ZIP file with JARs whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code.
addObserver(Observer<T>) - Method in class com.hazelcast.jet.impl.observer.ObservableImpl
 
addObserver(Observer<T>) - Method in interface com.hazelcast.jet.Observable
Registers an Observer to this Observable.
addOrIncrementIndexInName(String) - Static method in class com.hazelcast.jet.impl.util.Util
If the name ends with "-N", returns a new name where "-N" is replaced with "-M" where M = N + 1.
addOutputValue(String) - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
repeated string outputValue = 1;
addOutputValueBytes(ByteString) - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
repeated string outputValue = 1;
addPackage(String...) - Method in class com.hazelcast.jet.config.JobConfig
Adds recursively all the classes and resources in given packages to the Jet job's classpath.
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
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
 
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 class com.hazelcast.jet.impl.pipeline.ComputeStageImplBase
 
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
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.AggregateTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.BatchSourceTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.DistinctTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.FlatMapStatefulTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.FlatMapTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.GlobalFlatMapStatefulTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.GlobalMapStatefulTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.GroupTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.HashJoinTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.MapStatefulTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.MapTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.MergeTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.PartitionedProcessorTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.PeekTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.ProcessorTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.SinkTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.StreamSourceTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.TimestampTransform
 
addToDag(Planner) - Method in interface com.hazelcast.jet.impl.pipeline.transform.Transform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.WindowAggregateTransform
 
addToDag(Planner) - Method in class com.hazelcast.jet.impl.pipeline.transform.WindowGroupTransform
 
addVertex(Transform, String, int, SupplierEx<Processor>) - Method in class com.hazelcast.jet.impl.pipeline.Planner
 
addVertex(Transform, String, int, ProcessorSupplier) - Method in class com.hazelcast.jet.impl.pipeline.Planner
 
addVertex(Transform, String, int, ProcessorMetaSupplier) - Method in class com.hazelcast.jet.impl.pipeline.Planner
 
advance() - Method in class com.hazelcast.jet.impl.util.CircularListCursor
Advances to the next list element.
afterCompleted() - Method in class com.hazelcast.jet.impl.processor.TransactionPoolSnapshotUtility
 
afterCompleted() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility
For sinks and inner vertices, call from Processor.complete().
afterCompleted() - Method in class com.hazelcast.jet.impl.processor.UnboundedTransactionsProcessorUtility
 
age - Variable in class com.hazelcast.jet.examples.hadoop.generated.User
Deprecated.
AggBuilder - Class in com.hazelcast.jet.impl.pipeline
 
AggBuilder(GeneralStage<T0>, WindowDefinition) - Constructor for class com.hazelcast.jet.impl.pipeline.AggBuilder
 
AggBuilder.CreateOutStageFn<OUT,OUT_STAGE extends GeneralStage<OUT>> - Interface in com.hazelcast.jet.impl.pipeline
 
aggregate() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOpAggregator
 
aggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
aggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
aggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.StageWithKeyAndWindowImpl
 
aggregate(AggregateOperation1<? super T, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.StageWithWindowImpl
 
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 class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
aggregate2(BatchStageWithKey<T1, ? extends K>, AggregateOperation2<? super T, ? super T1, ?, R>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
aggregate2(StreamStageWithKey<T1, ? extends K>, AggregateOperation2<? super T, ? super T1, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.StageWithKeyAndWindowImpl
 
aggregate2(StreamStage<T1>, AggregateOperation2<? super T, ? super T1, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.StageWithWindowImpl
 
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 class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
aggregate3(BatchStageWithKey<T1, ? extends K>, BatchStageWithKey<T2, ? extends K>, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
aggregate3(StreamStageWithKey<T1, ? extends K>, StreamStageWithKey<T2, ? extends K>, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.StageWithKeyAndWindowImpl
 
aggregate3(StreamStage<T1>, StreamStage<T2>, AggregateOperation3<? super T, ? super T1, ? super T2, ?, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.StageWithWindowImpl
 
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.
AGGREGATE_OP_AGGREGATOR - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
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.
AggregateOpAggregator<T,A,R> - Class in com.hazelcast.jet.impl.aggregate
 
AggregateOpAggregator() - Constructor for class com.hazelcast.jet.impl.aggregate.AggregateOpAggregator
 
AggregateOpAggregator(AggregateOperation1<? super T, A, ? extends R>) - Constructor for class com.hazelcast.jet.impl.aggregate.AggregateOpAggregator
 
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.
AggregateOperation1Impl<T0,A,R> - Class in com.hazelcast.jet.impl.aggregate
 
AggregateOperation1Impl(SupplierEx<A>, BiConsumerEx<? super A, ? super T0>, BiConsumerEx<? super A, ? super A>, BiConsumerEx<? super A, ? super A>, FunctionEx<? super A, ? extends R>, FunctionEx<? super A, ? extends R>) - Constructor for class com.hazelcast.jet.impl.aggregate.AggregateOperation1Impl
 
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).
AggregateOperation2Impl<T0,T1,A,R> - Class in com.hazelcast.jet.impl.aggregate
 
AggregateOperation2Impl(SupplierEx<A>, BiConsumerEx<? super A, ? super T0>, BiConsumerEx<? super A, ? super T1>, BiConsumerEx<? super A, ? super A>, BiConsumerEx<? super A, ? super A>, FunctionEx<? super A, ? extends R>, FunctionEx<? super A, ? extends R>) - Constructor for class com.hazelcast.jet.impl.aggregate.AggregateOperation2Impl
 
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).
AggregateOperation3Impl<T0,T1,T2,A,R> - Class in com.hazelcast.jet.impl.aggregate
 
AggregateOperation3Impl(SupplierEx<A>, BiConsumerEx<? super A, ? super T0>, BiConsumerEx<? super A, ? super T1>, BiConsumerEx<? super A, ? super T2>, BiConsumerEx<? super A, ? super A>, BiConsumerEx<? super A, ? super A>, FunctionEx<? super A, ? extends R>, FunctionEx<? super A, ? extends R>) - Constructor for class com.hazelcast.jet.impl.aggregate.AggregateOperation3Impl
 
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.
AggregateOperationImpl<A,R> - Class in com.hazelcast.jet.impl.aggregate
 
AggregateOperationImpl(SupplierEx<A>, BiConsumerEx<? super A, ?>[], BiConsumerEx<? super A, ? super A>, BiConsumerEx<? super A, ? super A>, FunctionEx<? super A, ? extends R>, FunctionEx<? super A, ? extends R>) - Constructor for class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
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).
AggregateTransform<A,R> - Class in com.hazelcast.jet.impl.pipeline.transform
 
AggregateTransform(List<Transform>, AggregateOperation<A, ? extends R>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.AggregateTransform
 
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.
AmazonS3 - Class in com.hazelcast.jet.examples.hadoop.cloud
Word count example adapted to read from and write to Amazon S3 object storage using HDFS source and sink.
AmazonS3() - Constructor for class com.hazelcast.jet.examples.hadoop.cloud.AmazonS3
 
amount() - Method in class com.hazelcast.jet.examples.cogroup.datamodel.Payment
 
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).
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(FunctionEx<? super R, ? extends R_NEW>) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation1Impl
 
andThen(FunctionEx<? super R, ? extends R_NEW>) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation2Impl
 
andThen(FunctionEx<? super R, ? extends R_NEW>) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperation3Impl
 
andThen(FunctionEx<? super R, ? extends R_NEW>) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
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
 
ANSI_BLACK - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
ANSI_BLUE - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
ANSI_CYAN - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
ANSI_GREEN - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
ANSI_PURPLE - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
ANSI_RED - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
ANSI_RESET - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
ANSI_WHITE - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
ANSI_YELLOW - Static variable in class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
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(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(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.
applyEx(T, long) - Method in interface com.hazelcast.jet.core.function.ObjLongBiFunction
Exception-declaring version of ObjLongBiFunction.apply(T, long).
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).
applyEx(T) - Method in class com.hazelcast.jet.impl.util.ConstantFunctionEx
 
ApplyFnEntryProcessor() - Constructor for class com.hazelcast.jet.impl.connector.UpdateMapP.ApplyFnEntryProcessor
 
arity() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
Returns the number of contributing streams this operation is set up to handle.
arity() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
ArrayDequeInbox - Class in com.hazelcast.jet.impl.util
An Inbox implementation backed by an ArrayDeque.
ArrayDequeInbox(ProgressTracker) - Constructor for class com.hazelcast.jet.impl.util.ArrayDequeInbox
Constructs the inbox with the provided progress tracker.
arrayIndexOf(int, int[]) - Static method in class com.hazelcast.jet.impl.util.Util
Sequentially search through an array, return the index of first needle element in haystack or -1, if not found.
asClientConfig(String) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
Converts client-config xml string to ClientConfig using XmlClientConfigBuilder.
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
AssertionP<S,T> - Class in com.hazelcast.jet.impl.pipeline.test
 
assertionP(String, SupplierEx<? extends A>, BiConsumerEx<? super A, ? super T>, ConsumerEx<? super A>, ConsumerEx<? super A>) - Static method in class com.hazelcast.jet.impl.pipeline.test.AssertionP
 
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.
asXmlString(ClientConfig) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
Converts ClientConfig to xml representation using ClientConfigXmlGenerator.
ASYNC_SNAPSHOT_WRITER_SNAPSHOT_DATA_KEY - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
ASYNC_SNAPSHOT_WRITER_SNAPSHOT_DATA_VALUE_TERMINATOR - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
AsyncHazelcastWriterP - Class in com.hazelcast.jet.impl.connector
 
AsyncJobOperation - Class in com.hazelcast.jet.impl.operation
 
AsyncJobOperation() - Constructor for class com.hazelcast.jet.impl.operation.AsyncJobOperation
 
AsyncJobOperation(long) - Constructor for class com.hazelcast.jet.impl.operation.AsyncJobOperation
 
AsyncOperation - Class in com.hazelcast.jet.impl.operation
Base class for async operations.
AsyncOperation() - Constructor for class com.hazelcast.jet.impl.operation.AsyncOperation
 
AsyncSnapshotWriter - Interface in com.hazelcast.jet.impl.util
 
AsyncSnapshotWriterImpl - Class in com.hazelcast.jet.impl.util
 
AsyncSnapshotWriterImpl(NodeEngine, SnapshotContext, String, int, int, SerializationService) - Constructor for class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
 
AsyncSnapshotWriterImpl.SnapshotDataKey - Class in com.hazelcast.jet.impl.util
 
AsyncSnapshotWriterImpl.SnapshotDataValueTerminator - Class in com.hazelcast.jet.impl.util
 
AsyncTransformUsingServiceBatchedP<C,S,T,R> - Class in com.hazelcast.jet.impl.processor
Processor which, for each received item, emits all the items from the traverser returned by the given async item-to-traverser function, using a service.
AsyncTransformUsingServiceOrderedP<C,S,T,R> - Class in com.hazelcast.jet.impl.processor
Processor which, for each received item, emits all the items from the traverser returned by the given async item-to-traverser function, using a service.
AsyncTransformUsingServiceUnorderedP<C,S,T,K,R> - Class in com.hazelcast.jet.impl.processor
Processor which, for each received item, emits all the items from the traverser returned by the given async item-to-traverser function, using a service.
attachAll(Map<String, File>) - Method in class com.hazelcast.jet.config.JobConfig
Attaches all the files/directories in the supplied map, as if by calling attachDirectory(dir, id) for every entry that resolves to a directory and attachFile(file, id) for every entry that resolves to a regular file.
attachDirectory(URL) - Method in class com.hazelcast.jet.config.JobConfig
Adds the directory identified by the supplied URL to the list of directories that will be available to the job while it's executing in the Jet cluster.
attachDirectory(URL, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds the directory identified by the supplied URL to the list of directories that will be available to the job while it's executing in the Jet cluster.
attachDirectory(String) - Method in class com.hazelcast.jet.config.JobConfig
Adds the directory identified by the supplied pathname to the list of files that will be available to the job while it's executing in the Jet cluster.
attachDirectory(String, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds the directory identified by the supplied pathname to the list of files that will be available to the job while it's executing in the Jet cluster.
attachDirectory(File) - Method in class com.hazelcast.jet.config.JobConfig
Adds the supplied directory to the list of files that will be available to the job while it's executing in the Jet cluster.
attachDirectory(File, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds the supplied directory to the list of files that will be available to the job while it's executing in the Jet cluster.
attachedDirectory(String) - Method in interface com.hazelcast.jet.core.ProcessorSupplier.Context
Uses the supplied ID to look up a directory you attached to the current Jet job.
attachedDirectory(String) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
attachedDirectory(String) - Method in class com.hazelcast.jet.impl.execution.init.Contexts.ProcSupplierCtx
 
attachedFile(String) - Method in interface com.hazelcast.jet.core.ProcessorSupplier.Context
Uses the supplied ID to look up a file you attached to the current Jet job.
attachedFile(String) - Method in class com.hazelcast.jet.core.test.TestProcessorSupplierContext
 
attachedFile(String) - Method in class com.hazelcast.jet.impl.execution.init.Contexts.ProcSupplierCtx
 
attachedFiles() - Method in class com.hazelcast.jet.impl.pipeline.PipelineImpl
 
attachedFiles() - Method in class com.hazelcast.jet.pipeline.ServiceFactory
Returns the files and directories attached to this service factory.
attachFile(URL) - Method in class com.hazelcast.jet.config.JobConfig
Adds the file identified by the supplied URL as a resource that will be available to the job while it's executing in the Jet cluster.
attachFile(URL, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds the file identified by the supplied URL to the list of resources that will be available to the job while it's executing in the Jet cluster.
attachFile(File) - Method in class com.hazelcast.jet.config.JobConfig
Adds the supplied file to the list of resources that will be available to the job while it's executing in the Jet cluster.
attachFile(File, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds the supplied file to the list of files that will be available to the job while it's executing in the Jet cluster.
attachFile(String) - Method in class com.hazelcast.jet.config.JobConfig
Adds the file identified by the supplied pathname to the list of files that will be available to the job while it's executing in the Jet cluster.
attachFile(String, String) - Method in class com.hazelcast.jet.config.JobConfig
Adds the file identified by the supplied pathname to the list of files that will be available to the job while it's executing in the Jet cluster.
attachFiles(Map<String, File>) - Method in class com.hazelcast.jet.impl.pipeline.PipelineImpl
 
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.
awaitWorkerTermination() - Method in class com.hazelcast.jet.impl.execution.TaskletExecutionService
Blocks until all workers terminate (cooperative & blocking).
AzureCloudStorage - Class in com.hazelcast.jet.examples.hadoop.cloud
Word count example adapted to read from and write to Azure Cloud Storage using HDFS source and sink.
AzureCloudStorage() - Constructor for class com.hazelcast.jet.examples.hadoop.cloud.AzureCloudStorage
 
AzureDataLake - Class in com.hazelcast.jet.examples.hadoop.cloud
Word count example adapted to read from and write to Azure Data Lake Storage using HDFS source and sink.
AzureDataLake() - Constructor for class com.hazelcast.jet.examples.hadoop.cloud.AzureDataLake
 

B

baseDir() - Method in class com.hazelcast.jet.python.PythonServiceConfig
Returns the Python base directory.
BasicObservable - Class in com.hazelcast.jet.examples.returnresults
Demonstrates the usage of observable results on client side in most basic form (similar to Reactive Java Observers & Observables).
BasicObservable() - Constructor for class com.hazelcast.jet.examples.returnresults.BasicObservable
 
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.
BatchSourceTransform<T> - Class in com.hazelcast.jet.impl.pipeline.transform
 
BatchSourceTransform(String, ProcessorMetaSupplier) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.BatchSourceTransform
 
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).
BatchStageImpl<T> - Class in com.hazelcast.jet.impl.pipeline
 
BatchStageImpl(Transform, FunctionAdapter, PipelineImpl) - Constructor for class com.hazelcast.jet.impl.pipeline.BatchStageImpl
This constructor exists just to match the shape of the functional interface GeneralHashJoinBuilder.CreateOutStageFn
BatchStageWithKey<T,K> - Interface in com.hazelcast.jet.pipeline
An intermediate step while constructing a group-and-aggregate batch pipeline stage.
BatchStageWithKeyImpl<T,K> - Class in com.hazelcast.jet.impl.pipeline
 
bean(String, Class<T>) - Static method in class com.hazelcast.jet.spring.JetSpringServiceFactories
Returns a Spring Bean ServiceFactory.
bean(Class<T>) - Static method in class com.hazelcast.jet.spring.JetSpringServiceFactories
Returns a Spring Bean ServiceFactory.
bean(String) - Static method in class com.hazelcast.jet.spring.JetSpringServiceFactories
Returns a Spring Bean ServiceFactory.
BeanAsAServiceSample - Class in com.hazelcast.jet.examples.spring
Example of using Spring beans as a service for ServiceFactory.
BeanAsAServiceSample() - Constructor for class com.hazelcast.jet.examples.spring.BeanAsAServiceSample
 
beforeRun() - Method in class com.hazelcast.jet.impl.operation.AsyncOperation
 
begin() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.LoggingNonThrowingResource
 
begin() - Method in interface com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.TransactionalResource
Begins the transaction.
beginExecution() - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
Starts local execution of job by submitting tasklets to execution service.
beginSnapshotPhase1(long, String, int) - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
Starts the phase 1 of a new snapshot.
beginSnapshotPhase2(long, boolean) - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
Starts the phase 2 of the current snapshot.
between(Vertex, Vertex) - Static method in class com.hazelcast.jet.core.Edge
Returns an edge between two vertices.
bindFn(BiConsumerEx<PreparedStatement, T>) - Method in class com.hazelcast.jet.pipeline.JdbcSinkBuilder
Set the function to bind values to a PreparedStatement created with the query set with JdbcSinkBuilder.updateQuery(String).
bindService() - Method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc.BrokerServiceImplBase
 
bindService() - Method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc.ProductServiceImplBase
 
bindService() - Method in class com.hazelcast.jet.python.grpc.JetToPythonGrpc.JetToPythonImplBase
 
block() - Method in class com.hazelcast.jet.core.test.TestOutbox
 
block() - Method in class com.hazelcast.jet.impl.execution.OutboxImpl
 
block() - Method in interface com.hazelcast.jet.impl.execution.OutboxInternal
Blocks the outbox so it allows the caller only to offer the current unfinished item.
BlockingIteratorObserver<T> - Class in com.hazelcast.jet.impl.observer
 
BlockingIteratorObserver() - Constructor for class com.hazelcast.jet.impl.observer.BlockingIteratorObserver
 
bootstrappedInstance() - Static method in class com.hazelcast.jet.Jet
Returns either a local Jet instance or a "bootstrapped" Jet client for a remote Jet cluster, depending on the context.
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.
bottomObservedWm() - Method in class com.hazelcast.jet.impl.util.SkewReductionPolicy
 
broadcast() - Method in class com.hazelcast.jet.core.Edge
Activates the BROADCAST routing policy.
BROADCAST_ENTRY - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
BROADCAST_KEY - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
BroadcastEntry<K,V> - Class in com.hazelcast.jet.impl.execution
A Map.Entry implementation which implements BroadcastItem.
BroadcastEntry(K, V) - Constructor for class com.hazelcast.jet.impl.execution.BroadcastEntry
 
BroadcastEntry(Map.Entry<? extends K, ? extends V>) - Constructor for class com.hazelcast.jet.impl.execution.BroadcastEntry
 
BroadcastItem - Interface in com.hazelcast.jet.impl.execution
Marker interface for items which are always broadcast along an edge, regardless of the configured Edge.RoutingPolicy.
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.
broadcastTracker - Variable in class com.hazelcast.jet.impl.execution.OutboundCollector.Composite
 
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
 
bucketCount() - Method in class com.hazelcast.jet.impl.execution.OutboxImpl
 
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() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
 
build() - Method in class com.hazelcast.jet.impl.config.XmlJetConfigBuilder
 
build(JetConfig) - Method in class com.hazelcast.jet.impl.config.XmlJetConfigBuilder
 
build() - Method in class com.hazelcast.jet.impl.config.YamlJetConfigBuilder
 
build(JetConfig) - Method in class com.hazelcast.jet.impl.config.YamlJetConfigBuilder
 
build(AggregateOperation<A, R>, AggBuilder.CreateOutStageFn<OUT, OUT_STAGE>) - Method in class com.hazelcast.jet.impl.pipeline.AggBuilder
 
build() - Method in class com.hazelcast.jet.kafka.KafkaSinks.Builder
Builds the Sink object that you pass to the GeneralStage.writeTo(Sink) method.
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(FunctionEx<? super Path, ? extends Stream<T>>) - Method in class com.hazelcast.jet.pipeline.FileSourceBuilder
Builds a custom file BatchSource with supplied components.
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.JdbcSinkBuilder
Creates and returns the JDBC Sink with the supplied components.
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.
build() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.python.grpc.JetToPythonGrpc.JetToPythonBlockingStub
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.python.grpc.JetToPythonGrpc.JetToPythonFutureStub
 
build(Channel, CallOptions) - Method in class com.hazelcast.jet.python.grpc.JetToPythonGrpc.JetToPythonStub
 
build() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
 
buildBatch(AggregateOperation<A, ? extends R>, BiFunctionEx<? super K, ? super R, OUT>) - Method in class com.hazelcast.jet.impl.pipeline.GrAggBuilder
 
buildConfig(Node) - Method in class com.hazelcast.jet.impl.config.JetDomConfigProcessor
 
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
 
buildPartial() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
buildPartial() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.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
 
buildStream(AggregateOperation<A, ? extends R>) - Method in class com.hazelcast.jet.impl.pipeline.GrAggBuilder
 
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, JournalInitialPosition, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T>, PredicateEx<? super EventJournalCacheEvent<K, V>>) - 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, JournalInitialPosition, FunctionEx, PredicateEx) 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
 
call() - Method in class com.hazelcast.jet.impl.execution.ProcessorTasklet
 
call() - Method in class com.hazelcast.jet.impl.execution.ReceiverTasklet
 
call() - Method in class com.hazelcast.jet.impl.execution.SenderTasklet
 
call() - Method in class com.hazelcast.jet.impl.execution.StoreSnapshotTasklet
 
call() - Method in interface com.hazelcast.jet.impl.execution.Tasklet
 
cancel(boolean) - Method in class com.hazelcast.jet.impl.util.NonCompletableFuture
 
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).
cancelJob - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetExportSnapshotCodec.RequestParameters
 
capacities() - Method in class com.hazelcast.jet.impl.execution.ConcurrentInboundEdgeStream
 
capacities() - Method in interface com.hazelcast.jet.impl.execution.InboundEdgeStream
Returns the total capacity of input queues.
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.
checkSerializable(Object, String) - Static method in class com.hazelcast.jet.impl.util.Util
Checks that the object implements Serializable and is correctly serializable by actually trying to serialize it.
checkWmHistory() - Method in class com.hazelcast.jet.impl.execution.WatermarkCoalescer
Checks if there is a watermark to emit now based on the passage of system time or if all input queues are idle and we should forward the idle marker.
CircularListCursor<E> - Class in com.hazelcast.jet.impl.util
Cursor that repeatedly traverses a list.
CircularListCursor(List<E>) - Constructor for class com.hazelcast.jet.impl.util.CircularListCursor
 
classes() - Method in class com.hazelcast.jet.impl.util.ReflectionUtils.Resources
 
ClassResource(String, URL) - Constructor for class com.hazelcast.jet.impl.util.ReflectionUtils.ClassResource
 
clear() - Method in interface com.hazelcast.jet.core.Inbox
Removes all items from the inbox.
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
 
clear() - Method in class com.hazelcast.jet.impl.util.ArrayDequeInbox
 
clear() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
clear() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
 
clearAge() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Clears the value of the 'age' field.
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
 
clearField(Descriptors.FieldDescriptor) - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class com.hazelcast.jet.python.grpc.OutputMessage.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;
clearInputValue() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
repeated string inputValue = 1;
clearName() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Clears the value of the 'name' field.
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
 
clearOneof(Descriptors.OneofDescriptor) - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
 
clearOutputValue() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
repeated string outputValue = 1;
clearPassword() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Clears the value of the 'password' field.
clearProductName() - Method in class com.hazelcast.jet.examples.grpc.ProductInfoReply.Builder
string productName = 1;
clearStatus() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Clears the value of the 'status' field.
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
 
clone() - Method in class com.hazelcast.jet.pipeline.ServiceFactory
 
clone() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
clone() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.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(Throwable) - Method in class com.hazelcast.jet.impl.connector.AbstractHazelcastConnectorSupplier
 
close() - Method in class com.hazelcast.jet.impl.connector.ConvenientSourceP
 
close() - Method in class com.hazelcast.jet.impl.connector.ReadFilesP
 
close() - Method in class com.hazelcast.jet.impl.connector.ReadIListP
 
close() - Method in class com.hazelcast.jet.impl.connector.ReadJdbcP
 
close() - Method in class com.hazelcast.jet.impl.connector.StreamFilesP
 
close() - Method in class com.hazelcast.jet.impl.connector.StreamJmsP
 
close(Throwable) - Method in class com.hazelcast.jet.impl.connector.StreamJmsP.Supplier
 
close() - Method in class com.hazelcast.jet.impl.connector.StreamSocketP
 
close() - Method in class com.hazelcast.jet.impl.connector.WriteBufferedP
 
close() - Method in class com.hazelcast.jet.impl.connector.WriteFileP
 
close() - Method in class com.hazelcast.jet.impl.connector.WriteJdbcP
 
close() - Method in class com.hazelcast.jet.impl.connector.XaSinkProcessorBase
 
close() - Method in class com.hazelcast.jet.impl.deployment.IMapInputStream
 
close() - Method in class com.hazelcast.jet.impl.deployment.IMapOutputStream
 
close() - Method in class com.hazelcast.jet.impl.execution.ProcessorTasklet
 
close() - Method in interface com.hazelcast.jet.impl.execution.Tasklet
 
close() - Method in class com.hazelcast.jet.impl.pipeline.SourceBufferImpl
 
close() - Method in class com.hazelcast.jet.impl.processor.AbstractTransformUsingServiceP
 
close(Throwable) - Method in class com.hazelcast.jet.impl.processor.ProcessorSupplierWithService
 
close() - Method in class com.hazelcast.jet.impl.processor.ProcessorWrapper
 
close() - Method in class com.hazelcast.jet.impl.processor.TransactionPoolSnapshotUtility
 
close() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility
close() - Method in class com.hazelcast.jet.impl.processor.UnboundedTransactionsProcessorUtility
 
close(Throwable) - Method in class com.hazelcast.jet.impl.util.WrappingProcessorMetaSupplier
 
close(Throwable) - Method in class com.hazelcast.jet.impl.util.WrappingProcessorSupplier
 
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.
coalescedWm() - Method in class com.hazelcast.jet.impl.execution.ConcurrentInboundEdgeStream
 
coalescedWm() - Method in interface com.hazelcast.jet.impl.execution.InboundEdgeStream
Returns the last coalesced WM that was forwarded from the edge.
coalescedWm() - Method in class com.hazelcast.jet.impl.execution.WatermarkCoalescer
Returns the last emitted watermark.
collectors - Variable in class com.hazelcast.jet.impl.execution.OutboundCollector.Composite
 
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.annotation - package com.hazelcast.jet.annotation
Annotations used for describing public API stability.
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.earlyresults - package com.hazelcast.jet.examples.earlyresults
 
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.hadoop.cloud - package com.hazelcast.jet.examples.hadoop.cloud
 
com.hazelcast.jet.examples.hadoop.generated - package com.hazelcast.jet.examples.hadoop.generated
 
com.hazelcast.jet.examples.hadoop.parquet - package com.hazelcast.jet.examples.hadoop.parquet
 
com.hazelcast.jet.examples.helloworld - package com.hazelcast.jet.examples.helloworld
 
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.python - package com.hazelcast.jet.examples.python
 
com.hazelcast.jet.examples.returnresults - package com.hazelcast.jet.examples.returnresults
 
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.tradesource - package com.hazelcast.jet.examples.tradesource
 
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 read/write support for Hazelcast Jet.
com.hazelcast.jet.impl.aggregate - package com.hazelcast.jet.impl.aggregate
 
com.hazelcast.jet.impl.client.protocol.codec - package com.hazelcast.jet.impl.client.protocol.codec
 
com.hazelcast.jet.impl.client.protocol.task - package com.hazelcast.jet.impl.client.protocol.task
 
com.hazelcast.jet.impl.config - package com.hazelcast.jet.impl.config
 
com.hazelcast.jet.impl.connector - package com.hazelcast.jet.impl.connector
 
com.hazelcast.jet.impl.deployment - package com.hazelcast.jet.impl.deployment
 
com.hazelcast.jet.impl.exception - package com.hazelcast.jet.impl.exception
 
com.hazelcast.jet.impl.execution - package com.hazelcast.jet.impl.execution
 
com.hazelcast.jet.impl.execution.init - package com.hazelcast.jet.impl.execution.init
 
com.hazelcast.jet.impl.metrics - package com.hazelcast.jet.impl.metrics
 
com.hazelcast.jet.impl.observer - package com.hazelcast.jet.impl.observer
 
com.hazelcast.jet.impl.operation - package com.hazelcast.jet.impl.operation
 
com.hazelcast.jet.impl.pipeline - package com.hazelcast.jet.impl.pipeline
 
com.hazelcast.jet.impl.pipeline.test - package com.hazelcast.jet.impl.pipeline.test
 
com.hazelcast.jet.impl.pipeline.transform - package com.hazelcast.jet.impl.pipeline.transform
 
com.hazelcast.jet.impl.processor - package com.hazelcast.jet.impl.processor
 
com.hazelcast.jet.impl.serialization - package com.hazelcast.jet.impl.serialization
 
com.hazelcast.jet.impl.util - package com.hazelcast.jet.impl.util
 
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.protobuf - package com.hazelcast.jet.protobuf
Protocol Buffers v3 support for Hazelcast Jet.
com.hazelcast.jet.python - package com.hazelcast.jet.python
Contributes a PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig) transform that allows you to transform Jet pipeline data using a Python function.
com.hazelcast.jet.python.grpc - package com.hazelcast.jet.python.grpc
 
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.
combine(Aggregator) - Method in class com.hazelcast.jet.impl.aggregate.AggregateOpAggregator
 
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.
combineFn() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
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).
commit() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.LoggingNonThrowingResource
 
commit() - Method in interface com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.TransactionalResource
Makes the changes visible to others and acknowledges consumed items.
compareTo(Tag<?>) - Method in class com.hazelcast.jet.datamodel.Tag
 
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
 
complete() - Method in class com.hazelcast.jet.impl.connector.AsyncHazelcastWriterP
 
complete() - Method in class com.hazelcast.jet.impl.connector.ConvenientSourceP
 
complete() - Method in class com.hazelcast.jet.impl.connector.ReadFilesP
 
complete() - Method in class com.hazelcast.jet.impl.connector.ReadIListP
 
complete() - Method in class com.hazelcast.jet.impl.connector.ReadJdbcP
 
complete() - Method in class com.hazelcast.jet.impl.connector.ReadMapOrCacheP
 
complete() - Method in class com.hazelcast.jet.impl.connector.StreamEventJournalP
 
complete() - Method in class com.hazelcast.jet.impl.connector.StreamFilesP
 
complete() - Method in class com.hazelcast.jet.impl.connector.StreamJmsP
 
complete() - Method in class com.hazelcast.jet.impl.connector.StreamSocketP
 
complete() - Method in class com.hazelcast.jet.impl.connector.WriteFileP
 
complete() - Method in class com.hazelcast.jet.impl.connector.XaSinkProcessorBase
 
complete() - Method in class com.hazelcast.jet.impl.pipeline.test.AssertionP
 
complete() - Method in class com.hazelcast.jet.impl.processor.AsyncTransformUsingServiceOrderedP
 
complete() - Method in class com.hazelcast.jet.impl.processor.AsyncTransformUsingServiceUnorderedP
 
complete() - Method in class com.hazelcast.jet.impl.processor.GroupP
 
complete() - Method in class com.hazelcast.jet.impl.processor.HashJoinCollectP
 
complete() - Method in class com.hazelcast.jet.impl.processor.ProcessorWrapper
 
complete() - Method in class com.hazelcast.jet.impl.processor.SessionWindowP
 
complete() - Method in class com.hazelcast.jet.impl.processor.SlidingWindowP
 
complete() - Method in class com.hazelcast.jet.impl.processor.TransformStatefulP
 
complete(Void) - Method in class com.hazelcast.jet.impl.util.NonCompletableFuture
 
COMPLETE_EXECUTION_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
completeEdge(int) - Method in interface com.hazelcast.jet.core.Processor
Called after the edge input with the supplied ordinal is exhausted.
completeEdge(int) - Method in class com.hazelcast.jet.impl.processor.ProcessorWrapper
 
completeExceptionally(Throwable) - Method in class com.hazelcast.jet.impl.util.NonCompletableFuture
 
completeExecution(Throwable) - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
Complete local execution.
CompleteExecutionOperation - Class in com.hazelcast.jet.impl.operation
 
CompleteExecutionOperation() - Constructor for class com.hazelcast.jet.impl.operation.CompleteExecutionOperation
 
CompleteExecutionOperation(long, boolean, Throwable) - Constructor for class com.hazelcast.jet.impl.operation.CompleteExecutionOperation
 
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.
compositeCollector(OutboundCollector[], EdgeDef, int) - Static method in interface com.hazelcast.jet.impl.execution.OutboundCollector
 
ComputeStageImplBase<T> - Class in com.hazelcast.jet.impl.pipeline
 
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.
ConcurrentInboundEdgeStream - Class in com.hazelcast.jet.impl.execution
InboundEdgeStream implemented in terms of a ConcurrentConveyor.
ConcurrentInboundEdgeStream(ConcurrentConveyor<Object>, int, int, boolean, String) - Constructor for class com.hazelcast.jet.impl.execution.ConcurrentInboundEdgeStream
 
ConcurrentMemoizingSupplier<T> - Class in com.hazelcast.jet.impl.util
Wraps a Supplier and returns a thread-safe memoizing supplier which calls it only on the first invocation of get() and afterwards returns the remembered instance.
ConcurrentMemoizingSupplier(Supplier<T>) - Constructor for class com.hazelcast.jet.impl.util.ConcurrentMemoizingSupplier
 
config - Variable in class com.hazelcast.jet.impl.config.JetDomConfigProcessor
 
ConfigProvider - Class in com.hazelcast.jet.impl.config
Locates and loads Jet or Jet Client configurations from various locations.
configureCapacity(int) - Method in class com.hazelcast.jet.impl.observer.ObservableImpl
 
configureCapacity(int) - Method in interface com.hazelcast.jet.Observable
Set the capacity of the underlying Ringbuffer, which defaults to .
configureHazelcast(Consumer<Config>) - Method in class com.hazelcast.jet.config.JetConfig
Convenience method for for configuring underlying Hazelcast IMDG instance.
connect(Transform, Transform) - Method in class com.hazelcast.jet.impl.pipeline.PipelineImpl
 
connect(List<Transform>, Transform) - Method in class com.hazelcast.jet.impl.pipeline.PipelineImpl
 
connectionFn(FunctionEx<ConnectionFactory, Connection>) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Sets the function which creates a connection given a connection factory.
connectionFn(FunctionEx<? super ConnectionFactory, ? extends Connection>) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the function which creates the connection using the 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.
ConstantFunctionEx<T,R> - Class in com.hazelcast.jet.impl.util
A function returning a constant.
ConstantFunctionEx(R) - Constructor for class com.hazelcast.jet.impl.util.ConstantFunctionEx
 
consumerFn(FunctionEx<? super Session, ? extends MessageConsumer>) - Method in class com.hazelcast.jet.pipeline.JmsSourceBuilder
Sets the function which creates the message consumer from session.
container() - Static method in class com.hazelcast.jet.impl.metrics.MetricsImpl
 
containsTag(String) - Static method in class com.hazelcast.jet.core.metrics.MeasurementPredicates
Matches a Measurement which contain the specified tag.
Contexts - Class in com.hazelcast.jet.impl.execution.init
 
Contexts.ProcCtx - Class in com.hazelcast.jet.impl.execution.init
 
Contexts.ProcSupplierCtx - Class in com.hazelcast.jet.impl.execution.init
 
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.
ConvenientSourceP<C,T,S> - Class in com.hazelcast.jet.impl.connector
Implements a data source the user created using the Source Builder API.
ConvenientSourceP(Function<? super Processor.Context, ? extends C>, BiConsumer<? super C, ? super ConvenientSourceP.SourceBufferConsumerSide<?>>, FunctionEx<? super C, ? extends S>, BiConsumerEx<? super C, ? super List<S>>, Consumer<? super C>, ConvenientSourceP.SourceBufferConsumerSide<?>, EventTimePolicy<? super T>) - Constructor for class com.hazelcast.jet.impl.connector.ConvenientSourceP
 
ConvenientSourceP.SourceBufferConsumerSide<T> - Interface in com.hazelcast.jet.impl.connector
This processor's view of the buffer accessible to the user.
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.
convertData(Data, DataType) - Method in class com.hazelcast.jet.impl.serialization.DelegatingSerializationService
 
ConveyorCollector - Class in com.hazelcast.jet.impl.execution
 
ConveyorCollector(ConcurrentConveyor<Object>, int, int[]) - Constructor for class com.hazelcast.jet.impl.execution.ConveyorCollector
 
ConveyorCollectorWithPartition - Class in com.hazelcast.jet.impl.execution
 
ConveyorCollectorWithPartition(ConcurrentConveyor<Object>, int, int[]) - Constructor for class com.hazelcast.jet.impl.execution.ConveyorCollectorWithPartition
 
COOPERATIVE_DEFAULT - Static variable in class com.hazelcast.jet.pipeline.ServiceFactory
Default value for ServiceFactory.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.
coordinator() - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
COPY_ON_READ - Static variable in class com.hazelcast.jet.hadoop.HadoopSources
With the new HDFS API, some of the RecordReaders return the same key/value instances for each record, for example LineRecordReader.
copyMapUsingJob(JetInstance, int, String, String) - Static method in class com.hazelcast.jet.impl.util.Util
 
copyStream(InputStream, OutputStream) - Static method in class com.hazelcast.jet.impl.util.IOUtil
 
counting() - Static method in class com.hazelcast.jet.aggregate.AggregateOperations
Returns an aggregate operation that counts the items it observes.
create(boolean, boolean) - Static method in class com.hazelcast.jet.impl.execution.SnapshotFlags
 
create(int) - Static method in class com.hazelcast.jet.impl.execution.WatermarkCoalescer
Factory method.
create(ByteOrder) - Static method in interface com.hazelcast.jet.impl.serialization.MemoryReader
 
create() - Static method in interface com.hazelcast.jet.pipeline.Pipeline
Creates a new, empty pipeline.
createContextFn() - Method in class com.hazelcast.jet.pipeline.ServiceFactory
Returns the function that creates the shared context object.
createDecoder(SchemaStore) - Static method in class com.hazelcast.jet.examples.hadoop.generated.User
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.
createExecutionPlans(NodeEngine, MembersView, DAG, long, long, JobConfig, long) - Static method in class com.hazelcast.jet.impl.execution.init.ExecutionPlanBuilder
 
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
 
createFactory() - Method in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
createFactory() - Method in class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook
 
createFactory() - Method in class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook
 
createFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
A primitive that returns a new accumulator.
createFn() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
createJobConfig(Path, Path) - Static method in class com.hazelcast.jet.examples.hadoop.avro.HadoopAvro
 
createLoggerName(String, String, String, int) - Static method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
createObjectDataInput(NodeEngine, byte[]) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
 
createObjectDataOutput(NodeEngine, int) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
 
createPortableReader(Data) - Method in class com.hazelcast.jet.impl.serialization.DelegatingSerializationService
 
createProcessor(HazelcastInstance, SerializationService) - Method in class com.hazelcast.jet.impl.connector.AbstractHazelcastConnectorSupplier
 
createProcessor(HazelcastInstance, SerializationService) - Method in class com.hazelcast.jet.impl.connector.WriteMapP.Supplier
 
createProcessor(HazelcastInstance, SerializationService) - Method in class com.hazelcast.jet.impl.connector.WriteObservableP.Supplier
 
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.
createSerializer() - Method in class com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.Hook
 
createSerializer() - Method in class com.hazelcast.jet.protobuf.ProtobufSerializerHook
 
createServiceFn() - Method in class com.hazelcast.jet.pipeline.ServiceFactory
Returns the function that creates the service object.
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
 
createTxnFn() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility
 
creationTime() - Method in class com.hazelcast.jet.JobStateSnapshot
Returns the time the snapshot was created.
currentMapName() - Method in class com.hazelcast.jet.impl.execution.SnapshotContext
Returns the name of the map that the current snapshot should be written to.
currentSnapshotId() - Method in class com.hazelcast.jet.impl.execution.SnapshotContext
 
CUSTOM_CLASS_LOADED_OBJECT - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
CustomClassLoadedObject - Class in com.hazelcast.jet.impl.execution.init
Wrapper class used for deserialization using a custom class loader
CustomClassLoadedObject.Hook - Class in com.hazelcast.jet.impl.execution.init
 
CustomClassLoadedObject.Serializer - Class in com.hazelcast.jet.impl.execution.init
 
customProcessorTransform(String, Transform, ProcessorMetaSupplier) - Static method in class com.hazelcast.jet.impl.pipeline.transform.ProcessorTransform
 
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, ProcessorMetaSupplier) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
customTransform(String, ProcessorMetaSupplier) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
customTransform(String, ProcessorMetaSupplier) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
customTransform(String, ProcessorMetaSupplier) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageWithKeyImpl
 
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.
dag - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetSubmitJobCodec.RequestParameters
 
dag - Variable in class com.hazelcast.jet.impl.pipeline.Planner
 
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
DataSourceFromConnectionSupplier - Class in com.hazelcast.jet.impl.connector
An adapter to adapt Supplier<Connection> to a DataSource.
DataSourceFromConnectionSupplier(String) - Constructor for class com.hazelcast.jet.impl.connector.DataSourceFromConnectionSupplier
 
dataSourceSupplier(SupplierEx<? extends CommonDataSource>) - Method in class com.hazelcast.jet.pipeline.JdbcSinkBuilder
Sets the supplier of DataSource or XADataSource.
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetExistsDistributedObjectCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetExportSnapshotCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobConfigCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobIdsByNameCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobIdsCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobMetricsCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobStatusCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSubmissionTimeCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSummaryListCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetJoinSubmittedJobCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetResumeJobCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetSubmitJobCodec
 
decodeRequest(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetTerminateJobCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetExistsDistributedObjectCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetExportSnapshotCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobConfigCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobIdsByNameCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobIdsCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobMetricsCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobStatusCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSubmissionTimeCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSummaryListCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetJoinSubmittedJobCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetResumeJobCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetSubmitJobCodec
 
decodeResponse(ClientMessage) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetTerminateJobCodec
 
decrement() - Method in interface com.hazelcast.jet.core.metrics.Metric
Decrements the current value by 1.
decrement(long) - Method in interface com.hazelcast.jet.core.metrics.Metric
Decrements the current value by the specified amount.
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.
deductFn() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
DEFAULT_BACKUP_COUNT - Static variable in class com.hazelcast.jet.config.InstanceConfig
The default value of the backup-count
DEFAULT_CHUNK_SIZE - Static variable in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
 
DEFAULT_CLUSTER_NAME - Static variable in class com.hazelcast.jet.config.JetConfig
The default cluster name for a Jet cluster.
DEFAULT_FLOW_CONTROL_PERIOD_MS - Static variable in class com.hazelcast.jet.config.InstanceConfig
The default value of the flow-control period.
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_MAX_CONCURRENT_OPS - Static variable in class com.hazelcast.jet.impl.processor.AbstractAsyncTransformUsingServiceP
DEFAULT_PACKET_SIZE_LIMIT - Static variable in class com.hazelcast.jet.config.EdgeConfig
The default packet size limit.
DEFAULT_PRESERVE_ORDER - Static variable in class com.hazelcast.jet.impl.processor.AbstractAsyncTransformUsingServiceP
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.
DelegatingSerializationService - Class in com.hazelcast.jet.impl.serialization
 
DelegatingSerializationService(Map<Class<?>, ? extends Serializer>, AbstractSerializationService) - Constructor for class com.hazelcast.jet.impl.serialization.DelegatingSerializationService
 
deleteSnapshot(JetCommandLine.Verbosity, String) - Method in class com.hazelcast.jet.server.JetCommandLine
 
deserializeWithCustomClassLoader(SerializationService, ClassLoader, Data) - Static method in class com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject
 
DESTINATION_ADDRESS - Static variable in class com.hazelcast.jet.core.metrics.MetricTags
Destination member address for items sent to a distributed edge.
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 (name of the topic or queue).
destroy() - Method in class com.hazelcast.jet.impl.observer.ObservableImpl
 
destroy() - Method in class com.hazelcast.jet.JobStateSnapshot
Destroy the underlying distributed object.
destroy() - Method in interface com.hazelcast.jet.Observable
Removes all previously registered observers and destroys the backing Ringbuffer.
destroyContextFn() - Method in class com.hazelcast.jet.pipeline.ServiceFactory
Returns the function that destroys the shared context object at the end of the Jet job.
destroyFn(ConsumerEx<? super C>) - Method in class com.hazelcast.jet.pipeline.SinkBuilder
Sets the function that will destroy the context object 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
 
destroyServiceFn() - Method in class com.hazelcast.jet.pipeline.ServiceFactory
Returns the function that destroys the service object at the end of the Jet job.
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
 
DISABLE_ROLLING - Static variable in class com.hazelcast.jet.pipeline.FileSinkBuilder
A value to pass to FileSinkBuilder.rollByFileSize(long) if you want to disable rolling by file size.
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.
dispose() - Method in class com.hazelcast.jet.impl.serialization.DelegatingSerializationService
 
distinct() - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
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).
DistinctTransform<T,K> - Class in com.hazelcast.jet.impl.pipeline.transform
 
DistinctTransform(Transform, FunctionEx<? super T, ? extends K>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.DistinctTransform
 
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.
distributeObjects(int, List<T>) - Static method in class com.hazelcast.jet.impl.util.Util
Distributes the objects to count processors in a round-robin fashion.
done() - Method in class com.hazelcast.jet.impl.util.ProgressTracker
Marks the progress as done.
DONE_ITEM - Static variable in class com.hazelcast.jet.impl.execution.DoneItem
 
DONE_ITEM - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
DoneItem - Class in com.hazelcast.jet.impl.execution
 
doRun() - Method in class com.hazelcast.jet.impl.operation.AsyncOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.GetJobIdsByNameOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.GetJobIdsOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.GetJobMetricsOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.GetJobStatusOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.GetJobSubmissionTimeOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.GetJobSummaryListOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.JoinSubmittedJobOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.NotifyMemberShutdownOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.PrepareForPassiveClusterOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.ResumeJobOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase1Operation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase2Operation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.StartExecutionOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.SubmitJobOperation
 
doRun() - Method in class com.hazelcast.jet.impl.operation.TerminateJobOperation
 
DOUBLE_ACC - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
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.
doWithClassLoader(ClassLoader, RunnableEx) - Static method in class com.hazelcast.jet.impl.util.Util
 
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(Collection<E>, int) - Method in interface com.hazelcast.jet.core.Inbox
Drains at most limit elements into the provided Collection.
drainTo(Collection<M>, int, Function<E, M>) - Method in interface com.hazelcast.jet.core.Inbox
Drains and maps at most limit elements into the provided Collection.
drainTo(Predicate<Object>) - Method in class com.hazelcast.jet.impl.execution.ConcurrentInboundEdgeStream
 
drainTo(Predicate<Object>) - Method in interface com.hazelcast.jet.impl.execution.InboundEdgeStream
Passes the items from the queues to the predicate while it returns true.
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.
EDGE_DEF - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
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
 
EdgeDef - Class in com.hazelcast.jet.impl.execution.init
 
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.
emitsJetEvents() - Method in class com.hazelcast.jet.impl.pipeline.transform.StreamSourceTransform
 
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.impl.metrics.RawJobMetrics
 
empty() - Static method in class com.hazelcast.jet.Traversers
Returns a traverser that always returns null.
encodeRequest(String, String) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetExistsDistributedObjectCodec
 
encodeRequest(long, String, boolean) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetExportSnapshotCodec
 
encodeRequest(long) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobConfigCodec
 
encodeRequest(String) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobIdsByNameCodec
 
encodeRequest() - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobIdsCodec
 
encodeRequest(long) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobMetricsCodec
 
encodeRequest(long) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobStatusCodec
 
encodeRequest(long) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSubmissionTimeCodec
 
encodeRequest() - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSummaryListCodec
 
encodeRequest(long) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetJoinSubmittedJobCodec
 
encodeRequest(long) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetResumeJobCodec
 
encodeRequest(long, Data, Data) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetSubmitJobCodec
 
encodeRequest(long, int) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetTerminateJobCodec
 
encodeResponse(boolean) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetExistsDistributedObjectCodec
 
encodeResponse() - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetExportSnapshotCodec
 
encodeResponse(Data) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobConfigCodec
 
encodeResponse(Collection<Long>) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobIdsByNameCodec
 
encodeResponse(Collection<Long>) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobIdsCodec
 
encodeResponse(Data) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobMetricsCodec
 
encodeResponse(int) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobStatusCodec
 
encodeResponse(long) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSubmissionTimeCodec
 
encodeResponse(Data) - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSummaryListCodec
 
encodeResponse() - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetJoinSubmittedJobCodec
 
encodeResponse() - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetResumeJobCodec
 
encodeResponse() - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetSubmitJobCodec
 
encodeResponse() - Static method in class com.hazelcast.jet.impl.client.protocol.codec.JetTerminateJobCodec
 
encodeResponse(Object) - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobMetricsMessageTask
 
end() - Method in class com.hazelcast.jet.datamodel.WindowResult
Returns the ending timestamp of the window.
endAndPrepare() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.LoggingNonThrowingResource
 
endAndPrepare() - Method in interface com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.TransactionalResource
Prepares for a commit.
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
 
EnteringPassiveClusterStateException - Exception in com.hazelcast.jet.impl.exception
An exception thrown internally for InitExecutionOperation and StartExecutionOperation to indicate that the cluster is entering passive state.
EnteringPassiveClusterStateException() - Constructor for exception com.hazelcast.jet.impl.exception.EnteringPassiveClusterStateException
 
entry(K, V) - Static method in class com.hazelcast.jet.Util
Returns a Map.Entry with the given key and value.
entryProcessor(BiFunctionEx<? super K, ? super V, ? extends V>) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
 
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.impl.execution.SnapshotBarrier
 
equals(Object) - Method in class com.hazelcast.jet.impl.metrics.RawJobMetrics
 
equals(Object) - Method in class com.hazelcast.jet.impl.processor.SlidingWindowP.SnapshotKey
 
equals(Object) - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl.SnapshotDataKey
 
equals(Object) - Method in class com.hazelcast.jet.impl.util.ReflectionUtils.ClassResource
 
equals(Object) - Method in class com.hazelcast.jet.pipeline.test.SimpleEvent
 
equals(Object) - Method in class com.hazelcast.jet.python.grpc.InputMessage
 
equals(Object) - Method in class com.hazelcast.jet.python.grpc.OutputMessage
 
escapeGraphviz(String) - Static method in class com.hazelcast.jet.impl.util.Util
Escapes the vertex name for graphviz by prefixing the quote character with backslash.
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.
EvolvingApi - Annotation Type in com.hazelcast.jet.annotation
Indicates that the annotated class, method or interface has stable implementation but its API may change between minor versions.
exactlyOnce(boolean) - Method in class com.hazelcast.jet.kafka.KafkaSinks.Builder
Enables or disables the exactly-once behavior of the sink using two-phase commit of state snapshots.
exactlyOnce(boolean) - Method in class com.hazelcast.jet.pipeline.FileSinkBuilder
Enables or disables the exactly-once behavior of the sink using two-phase commit of state snapshots.
exactlyOnce(boolean) - Method in class com.hazelcast.jet.pipeline.JdbcSinkBuilder
Sets whether the exactly-once mode is enabled for the sink.
exactlyOnce(boolean) - Method in class com.hazelcast.jet.pipeline.JmsSinkBuilder
Enables or disables the exactly-once behavior of the sink using two-phase commit of state snapshots.
exceptionallyCompletedFuture(Throwable) - Static method in class com.hazelcast.jet.impl.util.Util
Returns a future which is already completed with the supplied exception.
ExceptionUtil - Class in com.hazelcast.jet.impl.util
 
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
 
executeBeforeEachRun(Runnable) - Method in class com.hazelcast.jet.core.test.TestSupport
Execute test before each test run
executeSample(Configuration) - Static method in class com.hazelcast.jet.examples.hadoop.avro.HadoopAvro
 
executeSample(JobConf, Path, Path) - Static method in class com.hazelcast.jet.examples.hadoop.HadoopWordCount
 
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.
EXECUTION_COMPLETION_TIME - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the completion time of a given execution of a specific job.
EXECUTION_PLAN - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
EXECUTION_START_TIME - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Tracks the start time of a given execution of a specific job.
ExecutionContext - Class in com.hazelcast.jet.impl.execution
Data pertaining to single job execution on all cluster members.
ExecutionContext(NodeEngine, TaskletExecutionService, long, long, Address, Set<Address>) - Constructor for class com.hazelcast.jet.impl.execution.ExecutionContext
 
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
 
executionId() - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
ExecutionPlan - Class in com.hazelcast.jet.impl.execution.init
 
ExecutionPlanBuilder - Class in com.hazelcast.jet.impl.execution.init
 
existsDistributedObject(NodeEngine, String, String) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
 
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.
exportFn() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
exportSnapshot(String) - Method in interface com.hazelcast.jet.Job
Exports a state snapshot and saves it under the given name.
externalGuarantee() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility
 
extractKeyFn(FunctionEx<? super E, ?>) - Method in class com.hazelcast.jet.kafka.KafkaSinks.Builder
Sets the function to extract the key from the stream items.
extractValueFn(FunctionEx<? super E, ?>) - Method in class com.hazelcast.jet.kafka.KafkaSinks.Builder
Sets the function to extract the value from the stream items.

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
 
FACTORY_ID - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
FACTORY_ID - Static variable in class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook
 
FACTORY_ID - Static variable in class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook
 
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
 
FileId() - Constructor for class com.hazelcast.jet.impl.connector.WriteFileP.FileId
 
files(String, 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, Class<R>, Schema) - Static method in class com.hazelcast.jet.avro.AvroSinks
Convenience for AvroSinks.files(String, Schema, SupplierEx) which uses either SpecificDatumWriter or ReflectDatumWriter depending on the supplied recordClass.
files(String, Schema) - Static method in class com.hazelcast.jet.avro.AvroSinks
Convenience for AvroSinks.files(String, Schema, 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.
fillProperties(Node, Properties) - Method in class com.hazelcast.jet.impl.config.YamlJetDomConfigProcessor
 
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 class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
filter(PredicateEx<T>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
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.
FILTER_JOB_RESULT_BY_NAME - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
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 class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
filterStateful(SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
filterStateful(SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
filterStateful(long, SupplierEx<? extends S>, BiPredicateEx<? super S, ? super T>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageWithKeyImpl
 
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
 
filterUsingService(ServiceFactory<?, S>, BiPredicateEx<? super S, ? super T>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
filterUsingService(ServiceFactory<?, S>, TriPredicate<? super S, ? super K, ? super T>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
filterUsingService(ServiceFactory<?, S>, BiPredicateEx<? super S, ? super T>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
filterUsingService(ServiceFactory<?, S>, TriPredicate<? super S, ? super K, ? super T>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageWithKeyImpl
 
filterUsingService(ServiceFactory<?, S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
filterUsingService(ServiceFactory<?, S>, TriPredicate<? super S, ? super K, ? super T>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
filterUsingService(ServiceFactory<?, S>, BiPredicateEx<? super S, ? 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.
filterUsingService(ServiceFactory<?, S>, TriPredicate<? super S, ? 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.
filterUsingService(ServiceFactory<?, S>, BiPredicateEx<? super S, ? super T>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
filterUsingService(ServiceFactory<?, S>, TriPredicate<? super S, ? super K, ? super T>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
filterUsingServiceP(ServiceFactory<C, S>, BiPredicateEx<? super S, ? 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.
filterUsingServicePartitionedTransform(Transform, ServiceFactory<?, S>, BiPredicateEx<? super S, ? super T>, FunctionEx<? super T, ? extends K>) - Static method in class com.hazelcast.jet.impl.pipeline.transform.PartitionedProcessorTransform
 
filterUsingServiceTransform(Transform, ServiceFactory<?, S>, BiPredicateEx<? super S, ? super T>) - Static method in class com.hazelcast.jet.impl.pipeline.transform.ProcessorTransform
 
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
 
findClass(String) - Method in class com.hazelcast.jet.impl.deployment.JetClassLoader
 
findResource(String) - Method in class com.hazelcast.jet.impl.deployment.JetClassLoader
 
findResources(String) - Method in class com.hazelcast.jet.impl.deployment.JetClassLoader
 
finishActiveTransaction() - Method in class com.hazelcast.jet.impl.processor.UnboundedTransactionsProcessorUtility
Force a new transaction outside of the snapshot cycle.
finishFn() - Method in interface com.hazelcast.jet.aggregate.AggregateOperation
A primitive that transforms the accumulator into a result of the aggregation.
finishFn() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOperationImpl
 
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 in Processor.restoreFromSnapshot(com.hazelcast.jet.core.Inbox).
finishSnapshotRestore() - Method in class com.hazelcast.jet.impl.connector.ConvenientSourceP
 
finishSnapshotRestore() - Method in class com.hazelcast.jet.impl.connector.StreamEventJournalP
 
finishSnapshotRestore() - Method in class com.hazelcast.jet.impl.processor.AsyncTransformUsingServiceUnorderedP
 
finishSnapshotRestore() - Method in class com.hazelcast.jet.impl.processor.InsertWatermarksP
 
finishSnapshotRestore() - Method in class com.hazelcast.jet.impl.processor.ProcessorWrapper
 
finishSnapshotRestore() - Method in class com.hazelcast.jet.impl.processor.SessionWindowP
 
finishSnapshotRestore() - Method in class com.hazelcast.jet.impl.processor.SlidingWindowP
 
FIRST_STAGE_VERTEX_NAME_SUFFIX - Static variable in class com.hazelcast.jet.impl.pipeline.transform.AggregateTransform
 
flatMap(FunctionEx<? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
flatMap(FunctionEx<? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
flatMap(FunctionEx<? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
flatMap(FunctionEx<? 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 the items from the Traverser it returns.
flatMap(FunctionEx<? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
flatMap(Function<? super T, ? extends Traverser<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.
flatMapFn() - Method in class com.hazelcast.jet.impl.pipeline.transform.FlatMapTransform
 
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.
FlatMappingTraverser<T,R> - Class in com.hazelcast.jet.impl.util
A flat-mapping decorator over a traverser.
FlatMappingTraverser(Traverser<T>, Function<? super T, ? extends Traverser<? extends R>>) - Constructor for class com.hazelcast.jet.impl.util.FlatMappingTraverser
 
flatMapStateful(SupplierEx<? extends S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
flatMapStateful(SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
flatMapStateful(SupplierEx<? extends S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
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 class com.hazelcast.jet.impl.pipeline.StreamStageWithKeyImpl
 
flatMapStateful(SupplierEx<? extends S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageWithKeyImpl
 
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.
FlatMapStatefulTransform<T,K,S,R> - Class in com.hazelcast.jet.impl.pipeline.transform
 
FlatMapStatefulTransform(Transform, 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>>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.FlatMapStatefulTransform
 
FlatMapTransform<T,R> - Class in com.hazelcast.jet.impl.pipeline.transform
 
FlatMapTransform(String, Transform, FunctionEx<? super T, ? extends Traverser<? extends R>>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.FlatMapTransform
 
flatMapUsingService(ServiceFactory<?, S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
flatMapUsingService(ServiceFactory<?, S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageWithKeyImpl
 
flatMapUsingService(ServiceFactory<?, S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
flatMapUsingService(ServiceFactory<?, S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageWithKeyImpl
 
flatMapUsingService(ServiceFactory<?, S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStage
 
flatMapUsingService(ServiceFactory<?, S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.BatchStageWithKey
 
flatMapUsingService(ServiceFactory<?, S>, BiFunctionEx<? super S, ? 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.
flatMapUsingService(ServiceFactory<?, S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<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.
flatMapUsingService(ServiceFactory<?, S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStage
 
flatMapUsingService(ServiceFactory<?, S>, TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>>) - Method in interface com.hazelcast.jet.pipeline.StreamStageWithKey
 
flatMapUsingServiceAsyncBatchedPartitionedTransform(Transform, String, ServiceFactory<?, S>, int, int, BiFunctionEx<? super S, ? super List<T>, ? extends CompletableFuture<Traverser<R>>>, FunctionEx<? super T, ? extends K>) - Static method in class com.hazelcast.jet.impl.pipeline.transform.PartitionedProcessorTransform
 
flatMapUsingServiceAsyncBatchedTransform(Transform, String, ServiceFactory<?, S>, int, int, BiFunctionEx<? super S, ? super List<T>, ? extends CompletableFuture<Traverser<R>>>) - Static method in class com.hazelcast.jet.impl.pipeline.transform.ProcessorTransform
 
flatMapUsingServiceAsyncPartitionedTransform(Transform, String, ServiceFactory<?, S>, int, boolean, BiFunctionEx<? super S, ? super T, CompletableFuture<Traverser<R>>>, FunctionEx<? super T, ? extends K>) - Static method in class com.hazelcast.jet.impl.pipeline.transform.PartitionedProcessorTransform
 
flatMapUsingServiceAsyncTransform(Transform, String, ServiceFactory<?, S>, int, boolean, BiFunctionEx<? super S, ? super T, ? extends CompletableFuture<Traverser<R>>>) - Static method in class com.hazelcast.jet.impl.pipeline.transform.ProcessorTransform
 
flatMapUsingServiceP(ServiceFactory<C, S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<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.
flatMapUsingServicePartitionedTransform(Transform, ServiceFactory<?, S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>, FunctionEx<? super T, ? extends K>) - Static method in class com.hazelcast.jet.impl.pipeline.transform.PartitionedProcessorTransform
 
flatMapUsingServiceTransform(Transform, ServiceFactory<?, S>, BiFunctionEx<? super S, ? super T, ? extends Traverser<R>>) - Static method in class com.hazelcast.jet.impl.pipeline.transform.ProcessorTransform
 
floorFrameTs(long) - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the highest frame timestamp less than or equal to the given timestamp.
flush() - Method in class com.hazelcast.jet.impl.deployment.IMapOutputStream
 
flush() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.LoggingNonThrowingResource
 
flush() - Method in interface com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.TransactionalResource
Flushes all previous writes to the external system and ensures all pending items are emitted to the downstream.
flushAndResetMap() - Method in interface com.hazelcast.jet.impl.util.AsyncSnapshotWriter
 
flushAndResetMap() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
Flush all partitions and reset current map.
flushFn(ConsumerEx<? super C>) - Method in class com.hazelcast.jet.pipeline.SinkBuilder
Sets the function that implements the sink's flushing behavior.
flushInternal() - Method in class com.hazelcast.jet.impl.connector.AsyncHazelcastWriterP
 
flushInternal() - Method in class com.hazelcast.jet.impl.connector.UpdateMapP
 
flushInternal() - Method in class com.hazelcast.jet.impl.connector.WriteMapP
 
flushInternal() - Method in class com.hazelcast.jet.impl.connector.WriteObservableP
 
fnAdapter - Variable in class com.hazelcast.jet.impl.pipeline.ComputeStageImplBase
 
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.
from(SerializationService, Map<String, String>) - Static method in class com.hazelcast.jet.impl.serialization.DelegatingSerializationService
 
from(Class<T>, int) - Static method in class com.hazelcast.jet.protobuf.ProtobufSerializer
An utility method that creates an anonymous ProtobufSerializer.
fromByteBuffer(ByteBuffer) - Static method in class com.hazelcast.jet.examples.hadoop.generated.User
Deserializes a User from a ByteBuffer.
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.
FunctionAdapter - Class in com.hazelcast.jet.impl.pipeline
 
FunctionAdapter() - Constructor for class com.hazelcast.jet.impl.pipeline.FunctionAdapter
 
FutureResults - Class in com.hazelcast.jet.examples.returnresults
Demonstrates the usage of observable results on client side in their CompletableFuture form (applicable only to batch jobs).
FutureResults() - Constructor for class com.hazelcast.jet.examples.returnresults.FutureResults
 

G

gcd(long...) - Static method in class com.hazelcast.jet.impl.util.Util
Calculate greatest common divisor of a series of integer numbers.
gcd(long, long) - Static method in class com.hazelcast.jet.impl.util.Util
Calculate greatest common divisor of two integer numbers.
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.
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.generated.User
 
get(int) - Method in class com.hazelcast.jet.examples.kafka.avro.User
 
get(int) - Method in class com.hazelcast.jet.impl.connector.AbstractHazelcastConnectorSupplier
 
get(int) - Method in class com.hazelcast.jet.impl.connector.StreamJmsP.Supplier
 
get() - Method in class com.hazelcast.jet.impl.observer.WrappedThrowable
 
get(Transform, FunctionAdapter, PipelineImpl) - Method in interface com.hazelcast.jet.impl.pipeline.AggBuilder.CreateOutStageFn
 
get(int) - Method in class com.hazelcast.jet.impl.processor.ProcessorSupplierWithService
 
get() - Method in class com.hazelcast.jet.impl.util.ConcurrentMemoizingSupplier
 
get(List<Address>) - Method in class com.hazelcast.jet.impl.util.WrappingProcessorMetaSupplier
 
get(int) - Method in class com.hazelcast.jet.impl.util.WrappingProcessorSupplier
 
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.
GET_JOB_CONFIG_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
GET_JOB_IDS - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
GET_JOB_IDS_BY_NAME_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
GET_JOB_METRICS_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
GET_JOB_STATUS_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
GET_JOB_SUBMISSION_TIME_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
GET_JOB_SUMMARY_LIST_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
GET_LOCAL_JOB_METRICS_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
getAge() - Method in class com.hazelcast.jet.examples.files.avro.User
 
getAge() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Gets the value of the 'age' field.
getAge() - Method in class com.hazelcast.jet.examples.hadoop.generated.User
Gets the value of the 'age' field.
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.
getBlob() - Method in class com.hazelcast.jet.impl.metrics.RawJobMetrics
 
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.
getClassId() - Method in class com.hazelcast.jet.config.JobConfig
 
getClassId() - Method in class com.hazelcast.jet.core.DAG
 
getClassId() - Method in class com.hazelcast.jet.core.Edge
 
getClassId() - Method in class com.hazelcast.jet.core.metrics.JobMetrics
 
getClassId() - Method in class com.hazelcast.jet.core.metrics.Measurement
 
getClassId() - Method in class com.hazelcast.jet.core.Vertex
 
getClassId() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOpAggregator
 
getClassId() - Method in class com.hazelcast.jet.impl.connector.UpdateMapP.ApplyFnEntryProcessor
 
getClassId() - Method in class com.hazelcast.jet.impl.connector.WriteFileP.FileId
 
getClassId() - Method in class com.hazelcast.jet.impl.execution.init.EdgeDef
 
getClassId() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getClassId() - Method in class com.hazelcast.jet.impl.execution.init.VertexDef
 
getClassId() - Method in class com.hazelcast.jet.impl.metrics.RawJobMetrics
 
getClassId() - Method in class com.hazelcast.jet.impl.observer.WrappedThrowable
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.CompleteExecutionOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.GetJobConfigOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.GetJobIdsByNameOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.GetJobIdsOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.GetJobMetricsOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.GetJobStatusOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.GetJobSubmissionTimeOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.GetJobSummaryListOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.GetLocalJobMetricsOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.InitExecutionOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.JoinSubmittedJobOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.NotifyMemberShutdownOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.PrepareForPassiveClusterOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.ResumeJobOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase1Operation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase1Operation.SnapshotPhase1Result
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase2Operation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.StartExecutionOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.SubmitJobOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.TerminateExecutionOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.operation.TerminateJobOperation
 
getClassId() - Method in class com.hazelcast.jet.impl.processor.SessionWindowP.Windows
 
getClassId() - Method in class com.hazelcast.jet.impl.processor.SlidingWindowP.SnapshotKey
 
getClassId() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl.SnapshotDataKey
 
getClassId() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl.SnapshotDataValueTerminator
 
getClassLoaderFactory() - Method in class com.hazelcast.jet.config.JobConfig
Returns the configured JobClassLoaderFactory.
getClassSchema() - Static method in class com.hazelcast.jet.examples.hadoop.generated.User
 
getCluster() - Method in interface com.hazelcast.jet.JetInstance
Returns information about the cluster this Jet instance is part of.
getConfig() - Method in class com.hazelcast.jet.core.Edge
Returns the EdgeConfig instance associated with this edge.
getConfig() - Method in interface com.hazelcast.jet.JetInstance
Returns the configuration for this Jet member.
getConfig() - Method in interface com.hazelcast.jet.Job
Returns the configuration this job was submitted with.
getConfigRoot() - Method in class com.hazelcast.jet.impl.config.YamlJetConfigBuilder
 
getConfigType() - Method in class com.hazelcast.jet.impl.config.XmlJetConfigBuilder
 
getConfiguredCapacity() - Method in class com.hazelcast.jet.impl.observer.ObservableImpl
 
getConfiguredCapacity() - Method in interface com.hazelcast.jet.Observable
Returns the configured capacity of the underlying Ringbuffer..
getConnection() - Method in class com.hazelcast.jet.impl.connector.DataSourceFromConnectionSupplier
 
getConnection(String, String) - Method in class com.hazelcast.jet.impl.connector.DataSourceFromConnectionSupplier
 
getContext() - Method in class com.hazelcast.jet.impl.metrics.MetricsImpl.Container
 
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.
getDecoder() - Static method in class com.hazelcast.jet.examples.hadoop.generated.User
Return the BinaryMessageDecoder instance used by this class.
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
 
getDefaultInstance() - Static method in class com.hazelcast.jet.python.grpc.InputMessage
 
getDefaultInstance() - Static method in class com.hazelcast.jet.python.grpc.OutputMessage
 
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
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.python.grpc.InputMessage
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
 
getDefaultInstanceForType() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
 
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
 
getDescriptor() - Static method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
getDescriptor() - Static method in class com.hazelcast.jet.python.grpc.InputMessage
 
getDescriptor() - Static method in class com.hazelcast.jet.python.grpc.JetToPythonTopLevel
 
getDescriptor() - Static method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
 
getDescriptor() - Static method in class com.hazelcast.jet.python.grpc.OutputMessage
 
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
 
getDescriptorForType() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
getDescriptorForType() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.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.
getError() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase1Operation.SnapshotPhase1Result
 
getError() - Method in interface com.hazelcast.jet.impl.util.AsyncSnapshotWriter
 
getError() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
 
getEventTimePolicy() - Method in class com.hazelcast.jet.impl.pipeline.transform.StreamSourceTransform
 
getEventTimePolicy() - Method in class com.hazelcast.jet.impl.pipeline.transform.TimestampTransform
 
getFactories() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetMessageTaskFactoryProvider
 
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
 
getFactoryId() - Method in class com.hazelcast.jet.impl.aggregate.AggregateOpAggregator
 
getFactoryId() - Method in class com.hazelcast.jet.impl.connector.UpdateMapP.ApplyFnEntryProcessor
 
getFactoryId() - Method in class com.hazelcast.jet.impl.connector.WriteFileP.FileId
 
getFactoryId() - Method in class com.hazelcast.jet.impl.execution.init.EdgeDef
 
getFactoryId() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getFactoryId() - Method in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
getFactoryId() - Method in class com.hazelcast.jet.impl.execution.init.VertexDef
 
getFactoryId() - Method in class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook
 
getFactoryId() - Method in class com.hazelcast.jet.impl.metrics.RawJobMetrics
 
getFactoryId() - Method in class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook
 
getFactoryId() - Method in class com.hazelcast.jet.impl.observer.WrappedThrowable
 
getFactoryId() - Method in class com.hazelcast.jet.impl.operation.AbstractJobOperation
 
getFactoryId() - Method in class com.hazelcast.jet.impl.operation.AsyncOperation
 
getFactoryId() - Method in class com.hazelcast.jet.impl.operation.CompleteExecutionOperation
 
getFactoryId() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase1Operation.SnapshotPhase1Result
 
getFactoryId() - Method in class com.hazelcast.jet.impl.processor.SessionWindowP.Windows
 
getFactoryId() - Method in class com.hazelcast.jet.impl.processor.SlidingWindowP.SnapshotKey
 
getFactoryId() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl.SnapshotDataKey
 
getFactoryId() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl.SnapshotDataValueTerminator
 
getFilePathOfClasspathResource(String) - Static method in class com.hazelcast.jet.Util
Takes the pathname of a classpath resource and returns a Path that corresponds to it.
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.
getHigherPriorityVertexCount() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getId() - Method in class com.hazelcast.jet.config.ResourceConfig
Returns the ID of the resource that will be used to form the IMap key under which it will be stored in the Jet cluster.
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 class com.hazelcast.jet.impl.util.ReflectionUtils.ClassResource
 
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.
getInputValue(int) - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
repeated string inputValue = 1;
getInputValue(int) - Method in class com.hazelcast.jet.python.grpc.InputMessage
repeated string inputValue = 1;
getInputValue(int) - Method in interface com.hazelcast.jet.python.grpc.InputMessageOrBuilder
repeated string inputValue = 1;
getInputValueBytes(int) - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
repeated string inputValue = 1;
getInputValueBytes(int) - Method in class com.hazelcast.jet.python.grpc.InputMessage
repeated string inputValue = 1;
getInputValueBytes(int) - Method in interface com.hazelcast.jet.python.grpc.InputMessageOrBuilder
repeated string inputValue = 1;
getInputValueCount() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
repeated string inputValue = 1;
getInputValueCount() - Method in class com.hazelcast.jet.python.grpc.InputMessage
repeated string inputValue = 1;
getInputValueCount() - Method in interface com.hazelcast.jet.python.grpc.InputMessageOrBuilder
repeated string inputValue = 1;
getInputValueList() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
repeated string inputValue = 1;
getInputValueList() - Method in class com.hazelcast.jet.python.grpc.InputMessage
repeated string inputValue = 1;
getInputValueList() - Method in interface com.hazelcast.jet.python.grpc.InputMessageOrBuilder
repeated string inputValue = 1;
getInstanceConfig() - Method in class com.hazelcast.jet.config.JetConfig
Returns the Jet instance config.
getItem() - Method in class com.hazelcast.jet.impl.util.ObjectWithPartitionId
 
getJetInstance(NodeEngine) - Static method in class com.hazelcast.jet.impl.util.Util
 
getJetService() - Method in class com.hazelcast.jet.impl.operation.AsyncOperation
 
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.
getJobConfig() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
GetJobConfigOperation - Class in com.hazelcast.jet.impl.operation
 
GetJobConfigOperation() - Constructor for class com.hazelcast.jet.impl.operation.GetJobConfigOperation
 
GetJobConfigOperation(long) - Constructor for class com.hazelcast.jet.impl.operation.GetJobConfigOperation
 
getJobCoordinationService() - Method in class com.hazelcast.jet.impl.operation.AsyncOperation
 
GetJobIdsByNameOperation - Class in com.hazelcast.jet.impl.operation
 
GetJobIdsByNameOperation() - Constructor for class com.hazelcast.jet.impl.operation.GetJobIdsByNameOperation
 
GetJobIdsByNameOperation(String) - Constructor for class com.hazelcast.jet.impl.operation.GetJobIdsByNameOperation
 
GetJobIdsOperation - Class in com.hazelcast.jet.impl.operation
 
GetJobIdsOperation() - Constructor for class com.hazelcast.jet.impl.operation.GetJobIdsOperation
 
getJobMetrics() - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
GetJobMetricsOperation - Class in com.hazelcast.jet.impl.operation
An operation sent from a member to master to query metrics for a specific job ID.
GetJobMetricsOperation() - Constructor for class com.hazelcast.jet.impl.operation.GetJobMetricsOperation
 
GetJobMetricsOperation(long) - Constructor for class com.hazelcast.jet.impl.operation.GetJobMetricsOperation
 
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.
GetJobStatusOperation - Class in com.hazelcast.jet.impl.operation
 
GetJobStatusOperation() - Constructor for class com.hazelcast.jet.impl.operation.GetJobStatusOperation
 
GetJobStatusOperation(long) - Constructor for class com.hazelcast.jet.impl.operation.GetJobStatusOperation
 
GetJobSubmissionTimeOperation - Class in com.hazelcast.jet.impl.operation
 
GetJobSubmissionTimeOperation() - Constructor for class com.hazelcast.jet.impl.operation.GetJobSubmissionTimeOperation
 
GetJobSubmissionTimeOperation(long) - Constructor for class com.hazelcast.jet.impl.operation.GetJobSubmissionTimeOperation
 
GetJobSummaryListOperation - Class in com.hazelcast.jet.impl.operation
 
GetJobSummaryListOperation() - Constructor for class com.hazelcast.jet.impl.operation.GetJobSummaryListOperation
 
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() - Method in class com.hazelcast.jet.impl.util.CircularListCursor
 
getList(String) - Method in interface com.hazelcast.jet.JetInstance
Returns the distributed list instance with the specified name.
GetLocalJobMetricsOperation - Class in com.hazelcast.jet.impl.operation
An operation sent from the master to all members to query metrics for a specific execution ID.
GetLocalJobMetricsOperation() - Constructor for class com.hazelcast.jet.impl.operation.GetLocalJobMetricsOperation
 
GetLocalJobMetricsOperation(long, long) - Constructor for class com.hazelcast.jet.impl.operation.GetLocalJobMetricsOperation
 
GetLocalJobMetricsOperation.ExecutionNotFoundException - Exception in com.hazelcast.jet.impl.operation
 
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.
getLoginTimeout() - Method in class com.hazelcast.jet.impl.connector.DataSourceFromConnectionSupplier
 
getLogWriter() - Method in class com.hazelcast.jet.impl.connector.DataSourceFromConnectionSupplier
 
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.
getMemberConnection(NodeEngine, Address) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
 
getMetaSupplier() - Method in class com.hazelcast.jet.core.Vertex
Returns this vertex's meta-supplier of processors.
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetExistsDistributedObjectMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetExportSnapshotMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobConfigMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobIdsByNameMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobIdsMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobMetricsMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobStatusMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobSubmissionTimeMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobSummaryListMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetJoinSubmittedJobMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetResumeJobMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetSubmitJobMessageTask
 
getMethodName() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetTerminateJobMessageTask
 
getMetrics() - Method in interface com.hazelcast.jet.Job
Returns a snapshot of the current values of all job-specific metrics.
getMetricsContext() - Method in class com.hazelcast.jet.impl.execution.ProcessorTasklet
 
getMetricsContext() - Method in interface com.hazelcast.jet.impl.execution.Tasklet
 
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.hadoop.generated.User.Builder
Gets the value of the 'name' field.
getName() - Method in class com.hazelcast.jet.examples.hadoop.generated.User
Gets the value of the 'name' field.
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
getNamespaceType() - Method in class com.hazelcast.jet.impl.config.XmlJetConfigBuilder
 
getNumBytes() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase1Operation.SnapshotPhase1Result
 
getNumChunks() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase1Operation.SnapshotPhase1Result
 
getNumKeys() - Method in class com.hazelcast.jet.impl.operation.SnapshotPhase1Operation.SnapshotPhase1Result
 
getObservable(String) - Method in interface com.hazelcast.jet.JetInstance
Returns an Observable instance with the specified name.
getObservables() - Method in interface com.hazelcast.jet.JetInstance
Returns a list of all the Observables that are active.
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
 
getOutbox() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility
 
getOutputValue(int) - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
repeated string outputValue = 1;
getOutputValue(int) - Method in class com.hazelcast.jet.python.grpc.OutputMessage
repeated string outputValue = 1;
getOutputValue(int) - Method in interface com.hazelcast.jet.python.grpc.OutputMessageOrBuilder
repeated string outputValue = 1;
getOutputValueBytes(int) - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
repeated string outputValue = 1;
getOutputValueBytes(int) - Method in class com.hazelcast.jet.python.grpc.OutputMessage
repeated string outputValue = 1;
getOutputValueBytes(int) - Method in interface com.hazelcast.jet.python.grpc.OutputMessageOrBuilder
repeated string outputValue = 1;
getOutputValueCount() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
repeated string outputValue = 1;
getOutputValueCount() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
repeated string outputValue = 1;
getOutputValueCount() - Method in interface com.hazelcast.jet.python.grpc.OutputMessageOrBuilder
repeated string outputValue = 1;
getOutputValueList() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
repeated string outputValue = 1;
getOutputValueList() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
repeated string outputValue = 1;
getOutputValueList() - Method in interface com.hazelcast.jet.python.grpc.OutputMessageOrBuilder
repeated string outputValue = 1;
getPacketSizeLimit() - Method in class com.hazelcast.jet.config.EdgeConfig
Returns the limit on the network packet size, in bytes
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetExistsDistributedObjectMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetExportSnapshotMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobConfigMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobIdsByNameMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobIdsMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobMetricsMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobStatusMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobSubmissionTimeMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetGetJobSummaryListMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetJoinSubmittedJobMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetResumeJobMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetSubmitJobMessageTask
 
getParameters() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetTerminateJobMessageTask
 
getParentLogger() - Method in class com.hazelcast.jet.impl.connector.DataSourceFromConnectionSupplier
 
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
 
getParserForType() - Method in class com.hazelcast.jet.python.grpc.InputMessage
 
getParserForType() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
 
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.
getPartitionId() - Method in class com.hazelcast.jet.impl.util.ObjectWithPartitionId
 
getPartitionKey() - Method in class com.hazelcast.jet.impl.processor.SlidingWindowP.SnapshotKey
 
getPartitionKey() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl.SnapshotDataKey
 
getPartitions() - Method in class com.hazelcast.jet.impl.execution.ConveyorCollector
 
getPartitions() - Method in interface com.hazelcast.jet.impl.execution.OutboundCollector
Returns the list of partitions handled by this collector (only if edge is partitioned).
getPartitions() - Method in class com.hazelcast.jet.impl.execution.OutboundCollector.Partitioned
 
getPassword() - Method in class com.hazelcast.jet.examples.files.avro.User
 
getPassword() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Gets the value of the 'password' field.
getPassword() - Method in class com.hazelcast.jet.examples.hadoop.generated.User
Gets the value of the 'password' field.
getPassword() - Method in class com.hazelcast.jet.examples.kafka.json.User
 
getPipeline() - Method in class com.hazelcast.jet.impl.pipeline.AbstractStage
 
getPipeline() - Method in interface com.hazelcast.jet.pipeline.Stage
Returns the Pipeline this stage belongs to.
getPortableContext() - Method in class com.hazelcast.jet.impl.serialization.DelegatingSerializationService
 
getPrice() - Method in class com.hazelcast.jet.examples.tradesource.Trade
Price at which the transaction took place.
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.
getProcessors() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getProcessorSuppliers() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getProcessorTaskletCount() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
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.tradesource.Trade
Quantity of the trade, the amount of the instrument that has been traded.
getQueueSize() - Method in class com.hazelcast.jet.config.EdgeConfig
Returns the size of the SPSC queues used to implement this edge.
getReceiverMap() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getReceiveWindowMultiplier() - Method in class com.hazelcast.jet.config.EdgeConfig
 
getReleaseVersion() - Method in class com.hazelcast.jet.impl.config.XmlJetConfigBuilder
 
getReliableTopic(String) - Method in interface com.hazelcast.jet.JetInstance
Returns a distributed reliable topic instance with the specified name.
getRemoteMembers(NodeEngine) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
 
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.
getResourceType() - Method in class com.hazelcast.jet.config.ResourceConfig
Returns the type of the resource.
getResponse() - Method in class com.hazelcast.jet.impl.operation.AsyncOperation
 
getResponse() - Method in class com.hazelcast.jet.impl.operation.CompleteExecutionOperation
 
getResponse() - Method in class com.hazelcast.jet.impl.operation.GetJobConfigOperation
 
getResponse() - Method in class com.hazelcast.jet.impl.operation.GetLocalJobMetricsOperation
 
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.generated.User
 
getSchema() - Method in class com.hazelcast.jet.examples.kafka.avro.User
 
getSenderMap() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getSerializationType() - Method in class com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.Hook
 
getSerializationType() - Method in class com.hazelcast.jet.protobuf.ProtobufSerializerHook
 
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
 
getSerializedSize() - Method in class com.hazelcast.jet.python.grpc.InputMessage
 
getSerializedSize() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
 
getSerializerConfigs() - Method in class com.hazelcast.jet.config.JobConfig
Returns all the registered serializer configurations.
getServiceDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.BrokerServiceGrpc
 
getServiceDescriptor() - Static method in class com.hazelcast.jet.examples.grpc.ProductServiceGrpc
 
getServiceDescriptor() - Static method in class com.hazelcast.jet.python.grpc.JetToPythonGrpc
 
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 class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Gets the value of the 'status' field.
getStatus() - Method in class com.hazelcast.jet.examples.hadoop.generated.User
Gets the value of the 'status' field.
getStatus() - Method in interface com.hazelcast.jet.Job
Returns the current status of this job.
getStoreSnapshotTaskletCount() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getStreamingCallMethod() - Static method in class com.hazelcast.jet.python.grpc.JetToPythonGrpc
 
getSubmissionTime() - Method in interface com.hazelcast.jet.Job
Returns the time when the job was submitted to the cluster.
getTags() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier
Returns the metadata on this supplier, a string-to-string map.
getTags() - Method in class com.hazelcast.jet.impl.util.WrappingProcessorMetaSupplier
 
getTasklets() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
getTicker() - Method in class com.hazelcast.jet.examples.tradesource.Trade
Name of the instrument being traded.
getTime() - Method in class com.hazelcast.jet.examples.tradesource.Trade
Event time of the trade.
getTimestamp() - Method in class com.hazelcast.jet.examples.sessionwindow.ProductEvent
 
getTimestamp() - Method in class com.hazelcast.jet.impl.metrics.RawJobMetrics
 
getTotalChunks() - Method in interface com.hazelcast.jet.impl.util.AsyncSnapshotWriter
 
getTotalChunks() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
 
getTotalKeys() - Method in interface com.hazelcast.jet.impl.util.AsyncSnapshotWriter
 
getTotalKeys() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
 
getTotalPayloadBytes() - Method in interface com.hazelcast.jet.impl.util.AsyncSnapshotWriter
 
getTotalPayloadBytes() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
 
getTypeId() - Method in class com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.Serializer
 
getTypeId() - Method in class com.hazelcast.jet.protobuf.ProtobufSerializer
 
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
 
getUnknownFields() - Method in class com.hazelcast.jet.python.grpc.InputMessage
 
getUnknownFields() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
 
getUrl() - Method in class com.hazelcast.jet.config.ResourceConfig
Returns the URL at which the resource is available.
getUrl() - Method in class com.hazelcast.jet.impl.util.ReflectionUtils.ClassResource
 
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.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.
getWrapped() - Method in class com.hazelcast.jet.impl.processor.ProcessorWrapper
 
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().
GlobalFlatMapStatefulTransform<T,S,R> - Class in com.hazelcast.jet.impl.pipeline.transform
 
GlobalFlatMapStatefulTransform(Transform, ToLongFunctionEx<? super T>, Supplier<? extends S>, TriFunction<? super S, Object, ? super T, ? extends Traverser<R>>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.GlobalFlatMapStatefulTransform
 
GlobalMapStatefulTransform<T,S,R> - Class in com.hazelcast.jet.impl.pipeline.transform
 
GlobalMapStatefulTransform(Transform, ToLongFunctionEx<? super T>, Supplier<? extends S>, TriFunction<? super S, Object, ? super T, ? extends R>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.GlobalMapStatefulTransform
 
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
 
globalProcessorIndex() - Method in class com.hazelcast.jet.impl.execution.init.Contexts.ProcCtx
 
GoogleCloudStorage - Class in com.hazelcast.jet.examples.hadoop.cloud
Word count example adapted to read from and write to Google Cloud Storage using HDFS source and sink.
GoogleCloudStorage() - Constructor for class com.hazelcast.jet.examples.hadoop.cloud.GoogleCloudStorage
 
GrAggBuilder<K> - Class in com.hazelcast.jet.impl.pipeline
GrAggBuilder(BatchStageWithKey<?, K>) - Constructor for class com.hazelcast.jet.impl.pipeline.GrAggBuilder
 
GrAggBuilder(StageWithKeyAndWindow<?, K>) - Constructor for class com.hazelcast.jet.impl.pipeline.GrAggBuilder
 
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 class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
groupingKey(FunctionEx<? super T, ? extends K>) - Method in class com.hazelcast.jet.impl.pipeline.StageWithWindowImpl
 
groupingKey(FunctionEx<? super T, ? extends K>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
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
 
GroupP<K,A,R,OUT> - Class in com.hazelcast.jet.impl.processor
Batch processor that groups items by key and computes the supplied aggregate operation on each group.
GroupP(List<FunctionEx<?, ? extends K>>, AggregateOperation<A, R>, BiFunction<? super K, ? super R, OUT>) - Constructor for class com.hazelcast.jet.impl.processor.GroupP
 
GroupP(FunctionEx<? super T, ? extends K>, AggregateOperation1<? super T, A, R>, BiFunction<? super K, ? super R, OUT>) - Constructor for class com.hazelcast.jet.impl.processor.GroupP
 
GroupTransform<K,A,R,OUT> - Class in com.hazelcast.jet.impl.pipeline.transform
 
GroupTransform(List<Transform>, List<FunctionEx<?, ? extends K>>, AggregateOperation<A, R>, BiFunctionEx<? super K, ? super R, OUT>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.GroupTransform
 
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 Hadoop using Apache Avro input format, filters and writes back to Hadoop using Apache Avro output format
HadoopAvro() - Constructor for class com.hazelcast.jet.examples.hadoop.avro.HadoopAvro
 
HadoopParquet - Class in com.hazelcast.jet.examples.hadoop.parquet
A sample which reads records from Apache Parquet file from Hadoop using Apache Avro schema, filters and writes back to Hadoop using Apache Parquet output format with the same schema.
HadoopParquet() - Constructor for class com.hazelcast.jet.examples.hadoop.parquet.HadoopParquet
 
HadoopProcessors - Class in com.hazelcast.jet.hadoop
Static utility class with factories of Apache Hadoop Hadoop source and sink processors.
HadoopSinks - Class in com.hazelcast.jet.hadoop
Factories of Apache Hadoop sinks.
HadoopSources - Class in com.hazelcast.jet.hadoop
Contains factory methods for Apache Hadoop sources.
HadoopWordCount - Class in com.hazelcast.jet.examples.hadoop
Word count example adapted to read from and write to Hadoop instead of Jet in-memory maps.
HadoopWordCount() - Constructor for class com.hazelcast.jet.examples.hadoop.HadoopWordCount
 
handlePacket(int, int, Address, byte[], int) - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
handlerFile() - Method in class com.hazelcast.jet.python.PythonServiceConfig
Returns the Python handler file.
handlerFunction() - Method in class com.hazelcast.jet.python.PythonServiceConfig
Returns the name of the handler function.
handlerModule() - Method in class com.hazelcast.jet.python.PythonServiceConfig
Returns the handler module name.
handleSerializedLambdaCce(HazelcastSerializationException) - Static method in class com.hazelcast.jet.impl.util.ExceptionUtil
If the given exception has "java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda" in the causes, wrap it in another JetException explaining the possible reason.
hasAge() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Checks whether the 'age' field has been set.
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.
HASH_MAP - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
HASH_SET - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
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.impl.execution.SnapshotBarrier
 
hashCode() - Method in class com.hazelcast.jet.impl.metrics.RawJobMetrics
 
hashCode() - Method in class com.hazelcast.jet.impl.processor.SlidingWindowP.SnapshotKey
 
hashCode() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl.SnapshotDataKey
 
hashCode() - Method in class com.hazelcast.jet.impl.util.ReflectionUtils.ClassResource
 
hashCode() - Method in class com.hazelcast.jet.pipeline.test.SimpleEvent
 
hashCode() - Method in class com.hazelcast.jet.python.grpc.InputMessage
 
hashCode() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
 
hashJoin(BatchStage<T1_IN>, JoinClause<K, ? super T, ? super T1_IN, ? extends T1>, BiFunctionEx<T, T1, R>) - Method in class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
hashJoin(BatchStage<T1_IN>, JoinClause<K, ? super T, ? super T1_IN, ? extends T1>, BiFunctionEx<T, T1, R>) - Method in class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
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 class com.hazelcast.jet.impl.pipeline.BatchStageImpl
 
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 class com.hazelcast.jet.impl.pipeline.StreamStageImpl
 
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
 
HashJoinCollectP<K,T,V> - Class in com.hazelcast.jet.impl.processor
Implements the "collector" stage in a hash join transformation.
HashJoinCollectP(Function<T, K>, Function<T, V>) - Constructor for class com.hazelcast.jet.impl.processor.HashJoinCollectP
 
HashJoinP<E0> - Class in com.hazelcast.jet.impl.processor
Implements the hash-join transform.
HashJoinP(List<Function<E0, Object>>, List<Tag>, BiFunction, TriFunction) - Constructor for class com.hazelcast.jet.impl.processor.HashJoinP
 
HashJoinTransform<T0,R> - Class in com.hazelcast.jet.impl.pipeline.transform
 
HashJoinTransform(List<Transform>, List<JoinClause<?, ? super T0, ?, ?>>, List<Tag>, BiFunctionEx) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.HashJoinTransform
 
HashJoinTransform(List<Transform>, List<JoinClause<?, ? super T0, ?, ?>>, List<Tag>, TriFunction<T0, T1, T2, R>) - Constructor for class com.hazelcast.jet.impl.pipeline.transform.HashJoinTransform
 
hasName() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Checks whether the 'name' field has been set.
hasNext() - Method in class com.hazelcast.jet.impl.observer.BlockingIteratorObserver
 
hasParticipant(Address) - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
hasPassword() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Checks whether the 'password' field has been set.
hasPendingAsyncOps() - Method in interface com.hazelcast.jet.impl.util.AsyncSnapshotWriter
 
hasPendingAsyncOps() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
 
hasStatus() - Method in class com.hazelcast.jet.examples.hadoop.generated.User.Builder
Checks whether the 'status' field has been set.
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
 
hasUnfinishedItem() - Method in class com.hazelcast.jet.impl.execution.OutboxImpl
 
HazelcastReaders - Class in com.hazelcast.jet.impl.connector
 
HazelcastWriters - Class in com.hazelcast.jet.impl.connector
This is private API.
HelloWorld - Class in com.hazelcast.jet.examples.helloworld
Demonstrates a simple job which calculates the top 10 numbers from a stream of random numbers.
HelloWorld() - Constructor for class com.hazelcast.jet.examples.helloworld.HelloWorld
 
higherFrameTs(long) - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Returns the lowest frame timestamp greater than the given timestamp.
Hook() - Constructor for class com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.Hook
 
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

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() - Method in class com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.LoggingNonThrowingResource
 
id() - Method in interface com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.TransactionalResource
Returns the ID of this transaction, it should be the ID passed to the TwoPhaseSnapshotCommitUtility.createTxnFn().
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
 
idFromString(String) - Static method in class com.hazelcast.jet.Util
Parses the jobId formatted with Util.idToString(long).
IDLE_MESSAGE - Static variable in class com.hazelcast.jet.impl.execution.WatermarkCoalescer
 
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.
IMapInputStream - Class in com.hazelcast.jet.impl.deployment
 
IMapInputStream(IMap<String, byte[]>, String) - Constructor for class com.hazelcast.jet.impl.deployment.IMapInputStream
 
IMapOutputStream - Class in com.hazelcast.jet.impl.deployment
 
IMapOutputStream(IMap<String, byte[]>, String) - Constructor for class com.hazelcast.jet.impl.deployment.IMapOutputStream
 
iMapService(String) - Static method in class com.hazelcast.jet.pipeline.ServiceFactories
Returns a factory that provides an IMap as the service.
ImdgUtil - Class in com.hazelcast.jet.impl.util
 
InboundEdgeStream - Interface in com.hazelcast.jet.impl.execution
The inbound side of a data stream corresponding to a single DAG edge identified by its ordinal.
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.
increment() - Method in interface com.hazelcast.jet.core.metrics.Metric
Increments the current value by 1.
increment(long) - Method in interface com.hazelcast.jet.core.metrics.Metric
Increments the current value by the specified amount.
index() - Method in class com.hazelcast.jet.datamodel.Tag
Returns the index associated with this tag.
index() - Method in class com.hazelcast.jet.impl.connector.WriteFileP.FileId
 
index() - Method in interface com.hazelcast.jet.impl.processor.TwoPhaseSnapshotCommitUtility.TransactionId
Returns the index of the processor that will handle this transaction ID.
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(ProcessorSupplier.Context) - Method in class com.hazelcast.jet.impl.connector.AbstractHazelcastConnectorSupplier
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.connector.ConvenientSourceP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.connector.ReadFilesP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.connector.ReadIListP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.connector.ReadJdbcP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.connector.StreamEventJournalP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.connector.StreamFilesP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.connector.StreamJmsP
 
init(ProcessorSupplier.Context) - Method in class com.hazelcast.jet.impl.connector.StreamJmsP.Supplier
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.connector.StreamSocketP
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.connector.UpdateMapP
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.connector.WriteBufferedP
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.connector.WriteFileP
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.connector.WriteJdbcP
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.connector.WriteJmsP
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.connector.WriteMapP
 
init(ProcessorSupplier.Context) - Method in class com.hazelcast.jet.impl.connector.WriteMapP.Supplier
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.connector.WriteObservableP
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.connector.XaSinkProcessorBase
 
init() - Method in class com.hazelcast.jet.impl.execution.ProcessorTasklet
 
init() - Method in interface com.hazelcast.jet.impl.execution.Tasklet
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.pipeline.test.AssertionP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.processor.AbstractTransformUsingServiceP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.processor.AsyncTransformUsingServiceOrderedP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.processor.AsyncTransformUsingServiceUnorderedP
 
init(ProcessorSupplier.Context) - Method in class com.hazelcast.jet.impl.processor.ProcessorSupplierWithService
 
init(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.processor.ProcessorWrapper
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.processor.SessionWindowP
 
init(Processor.Context) - Method in class com.hazelcast.jet.impl.processor.SlidingWindowP
 
init(ProcessorMetaSupplier.Context) - Method in class com.hazelcast.jet.impl.util.WrappingProcessorMetaSupplier
 
init(ProcessorSupplier.Context) - Method in class com.hazelcast.jet.impl.util.WrappingProcessorSupplier
 
init() - Method in class com.hazelcast.jet.spring.JetNamespaceHandler
 
INIT_EXECUTION_OP - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
InitExecutionOperation - Class in com.hazelcast.jet.impl.operation
Operation sent from master to members to initialize execution of a job.
InitExecutionOperation() - Constructor for class com.hazelcast.jet.impl.operation.InitExecutionOperation
 
InitExecutionOperation(long, long, int, Set<MemberInfo>, Data) - Constructor for class com.hazelcast.jet.impl.operation.InitExecutionOperation
 
initFactories() - Method in class com.hazelcast.jet.impl.client.protocol.task.JetMessageTaskFactoryProvider
 
initialize(ExecutionPlan) - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
initialize(NodeEngine, long, long, SnapshotContext, ConcurrentHashMap<String, File>, InternalSerializationService) - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
initWrapper(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.processor.PeekWrappedP
 
initWrapper(Outbox, Processor.Context) - Method in class com.hazelcast.jet.impl.processor.ProcessorWrapper
 
input(List<?>) - Method in class com.hazelcast.jet.core.test.TestSupport
Sets the input objects for processor.
inputFormat(Configuration, BiFunctionEx<K, V, E>) - Static method in class com.hazelcast.jet.hadoop.HadoopSources
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 projection function.
inputFormat(Configuration) - Static method in class com.hazelcast.jet.hadoop.HadoopSources
Convenience for HadoopSources.inputFormat(Configuration, BiFunctionEx) with Map.Entry as its output type.
InputMessage - Class in com.hazelcast.jet.python.grpc
Protobuf type jet_to_python.InputMessage
InputMessage.Builder - Class in com.hazelcast.jet.python.grpc
Protobuf type jet_to_python.InputMessage
InputMessageOrBuilder - Interface in com.hazelcast.jet.python.grpc
 
inputPartitionKeyFunction() - Method in class com.hazelcast.jet.impl.pipeline.SinkImpl
 
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.
INPUTVALUE_FIELD_NUMBER - Static variable in class com.hazelcast.jet.python.grpc.InputMessage
 
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.
InsertWatermarksP<T> - Class in com.hazelcast.jet.impl.processor
InsertWatermarksP(EventTimePolicy<? super T>) - Constructor for class com.hazelcast.jet.impl.processor.InsertWatermarksP
 
instance() - Method in class com.hazelcast.jet.examples.spring.config.AppConfig
JetInstance bean which configured programmatically with SpringManagedContext
instance() - Method in class com.hazelcast.jet.impl.connector.AsyncHazelcastWriterP
 
INSTANCE - Static variable in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl.SnapshotDataValueTerminator
 
InstanceConfig - Class in com.hazelcast.jet.config
General configuration options pertaining to a Jet instance.
InstanceConfig() - Constructor for class com.hazelcast.jet.config.InstanceConfig
 
internalComplete() - Method in class com.hazelcast.jet.impl.util.NonCompletableFuture
 
internalCompleteExceptionally(Throwable) - Method in class com.hazelcast.jet.impl.util.NonCompletableFuture
 
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
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.python.grpc.InputMessage
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
 
internalGetFieldAccessorTable() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
 
IOUtil - Class in com.hazelcast.jet.impl.util
 
isAutoScaling() - Method in class com.hazelcast.jet.config.JobConfig
Returns whether auto scaling is enabled, see JobConfig.setAutoScaling(boolean).
isClassArchive() - Method in enum com.hazelcast.jet.config.ResourceType
Returns whether this resource type represents an archive containing classes.
isClosed() - Method in interface com.hazelcast.jet.impl.connector.ConvenientSourceP.SourceBufferConsumerSide
 
isClosed() - Method in class com.hazelcast.jet.impl.pipeline.SourceBufferImpl
 
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.impl.connector.ConvenientSourceP
 
isCooperative() - Method in class com.hazelcast.jet.impl.connector.ReadFilesP
 
isCooperative() - Method in class com.hazelcast.jet.impl.connector.ReadIListP
 
isCooperative() - Method in class com.hazelcast.jet.impl.connector.ReadJdbcP
 
isCooperative() - Method in class com.hazelcast.jet.impl.connector.StreamFilesP
 
isCooperative() - Method in class com.hazelcast.jet.impl.connector.StreamJmsP
 
isCooperative() - Method in class com.hazelcast.jet.impl.connector.WriteBufferedP
 
isCooperative() - Method in class com.hazelcast.jet.impl.connector.WriteLoggerP
 
isCooperative() - Method in class com.hazelcast.jet.impl.connector.XaSinkProcessorBase
 
isCooperative() - Method in class com.hazelcast.jet.impl.execution.ProcessorTasklet
 
isCooperative() - Method in interface com.hazelcast.jet.impl.execution.Tasklet
 
isCooperative() - Method in class com.hazelcast.jet.impl.processor.AbstractTransformUsingServiceP
 
isCooperative() - Method in class com.hazelcast.jet.impl.processor.ProcessorWrapper
 
isCooperative() - Method in class com.hazelcast.jet.pipeline.ServiceFactory
Returns the isCooperative flag, see ServiceFactory.toNonCooperative().
isDistributed() - Method in class com.hazelcast.jet.core.Edge
Says whether this edge is distributed.
isDone() - Method in class com.hazelcast.jet.impl.execution.ConcurrentInboundEdgeStream
 
isDone() - Method in interface com.hazelcast.jet.impl.execution.InboundEdgeStream
Returns true after all the input queues are done.
isDone() - Method in enum com.hazelcast.jet.impl.util.ProgressState
 
isDone() - Method in class com.hazelcast.jet.impl.util.ProgressTracker
 
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
 
isEmpty() - Method in interface com.hazelcast.jet.impl.connector.ConvenientSourceP.SourceBufferConsumerSide
 
isEmpty() - Method in class com.hazelcast.jet.impl.pipeline.SourceBufferImpl
 
isEmpty() - Method in class com.hazelcast.jet.impl.util.ArrayDequeInbox
 
isEmpty() - Method in interface com.hazelcast.jet.impl.util.AsyncSnapshotWriter
 
isEmpty() - Method in class com.hazelcast.jet.impl.util.AsyncSnapshotWriterImpl
 
isExport(int) - Static method in class com.hazelcast.jet.impl.execution.SnapshotFlags
 
isExportOnly() - Method in class com.hazelcast.jet.impl.execution.SnapshotContext
 
isExportOnly(int) - Static method in class com.hazelcast.jet.impl.execution.SnapshotFlags
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
 
isInitialized() - Method in class com.hazelcast.jet.python.grpc.InputMessage.Builder
 
isInitialized() - Method in class com.hazelcast.jet.python.grpc.InputMessage
 
isInitialized() - Method in class com.hazelcast.jet.python.grpc.OutputMessage.Builder
 
isInitialized() - Method in class com.hazelcast.jet.python.grpc.OutputMessage
 
isLocal() - Method in class com.hazelcast.jet.impl.connector.AsyncHazelcastWriterP
 
isLosslessRestartEnabled() - Method in class com.hazelcast.jet.config.InstanceConfig
Returns if lossless restart is enabled, see InstanceConfig.setLosslessRestartEnabled(boolean).
isMadeProgress() - Method in enum com.hazelcast.jet.impl.util.ProgressState
 
isMadeProgress() - Method in class com.hazelcast.jet.impl.util.ProgressTracker
 
isMemberInstance(HazelcastInstance) - Static method in class com.hazelcast.jet.impl.util.ImdgUtil
 
isMetricsEnabled() - Method in class com.hazelcast.jet.config.JobConfig
Returns if metrics collection is enabled for the job.
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.
isOverwritable() - Method in class com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.Hook
 
isOverwritable() - Method in class com.hazelcast.jet.protobuf.ProtobufSerializerHook
 
isRestartableException(Throwable) - Static method in class com.hazelcast.jet.impl.util.ExceptionUtil
Returns true if the exception is one of a kind upon which the job restarts rather than fails.
isShutdown() - Method in class com.hazelcast.jet.impl.deployment.JetClassLoader
 
isSnapshotsEnabled() - Method in class com.hazelcast.jet.core.test.TestSupport.TestMode
Are snapshots enabled.
isSnapshotVertex(String) - Static method in class com.hazelcast.jet.impl.execution.init.VertexDef
 
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.
isTerminal() - Method in class com.hazelcast.jet.impl.execution.SnapshotBarrier
 
isTerminal(int) - Static method in class com.hazelcast.jet.impl.execution.SnapshotFlags
 
isTopologyException(Throwable) - Static method in class com.hazelcast.jet.impl.util.ExceptionUtil
 
isTotalParallelismOne() - Method in class com.hazelcast.jet.impl.pipeline.SinkImpl
 
isTumbling() - Method in class com.hazelcast.jet.core.SlidingWindowPolicy
Tells whether this definition describes a tumbling window.
isWrapperFor(Class<?>) - Method in class com.hazelcast.jet.impl.connector.DataSourceFromConnectionSupplier
 
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.
ITEMS_BY_TAG - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
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.
IterableResults - Class in com.hazelcast.jet.examples.returnresults
Demonstrates the usage of observable results on client side via an Iterator (applicable only to batch jobs).
IterableResults() - Constructor for class com.hazelcast.jet.examples.returnresults.IterableResults
 
iterator() - Method in class com.hazelcast.jet.core.DAG
Returns an iterator over the DAG's vertices in topological order.
iterator() - Method in interface com.hazelcast.jet.core.Inbox
Returns an iterator over the items in the inbox in the order they would be returned by the Inbox.poll() method.
iterator() - Method in class com.hazelcast.jet.core.test.TestInbox
 
iterator() - Method in class com.hazelcast.jet.impl.util.ArrayDequeInbox
 
iterator() - Method in interface com.hazelcast.jet.Observable
Returns an iterator over the sequence of events produced by this Observable.

J

jdbc(String, SupplierEx<? extends CommonDataSource>, BiConsumerEx<PreparedStatement, T>) - Static method in class com.hazelcast.jet.pipeline.Sinks
A shortcut for:
jdbc(String, String, BiConsumerEx<PreparedStatement, T>) - Static method in class com.hazelcast.jet.pipeline.Sinks
A shortcut for:
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
jdbcBuilder() - Static method in class com.hazelcast.jet.pipeline.Sinks
Returns a builder to build a sink that connects to a JDBC database, prepares an SQL statement and executes it for each item.
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
 
JdbcSinkBuilder<T> - Class in com.hazelcast.jet.pipeline
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
 
jdbcUrl(String) - Method in class com.hazelcast.jet.pipeline.JdbcSinkBuilder
Sets the connection URL for the target database.
Jet - Class in com.hazelcast.jet
Entry point to the Jet product.
JET_EVENT - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
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_OBSERVABLE_NAME_PREFIX - Static variable in class com.hazelcast.jet.impl.observer.ObservableImpl
Prefix of all topic names used to back Observable implementations, necessary so that such topics can't clash with regular topics used for other purposes.
JET_RESERVED_SPACE_END - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
End of reserved space for Jet-specific serializers.
JET_RESERVED_SPACE_START - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
Start of reserved space for Jet-specific serializers.
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.
JetCacheManager - Interface in com.hazelcast.jet
JetCacheManager is the entry point to access JSR-107 (JCache) caches via JetInstance interface.
JetClassLoader - Class in com.hazelcast.jet.impl.deployment
 
JetClassLoader(NodeEngine, ClassLoader, String, long, JobRepository) - Constructor for class com.hazelcast.jet.impl.deployment.JetClassLoader
 
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.
JetConsoleLogHandler - Class in com.hazelcast.jet.impl.util
 
JetConsoleLogHandler() - Constructor for class com.hazelcast.jet.impl.util.JetConsoleLogHandler
 
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
 
JetDeclarativeConfigUtil - Class in com.hazelcast.jet.impl.config
 
JetDomConfigProcessor - Class in com.hazelcast.jet.impl.config
 
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
 
JetExistsDistributedObjectCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetExistsDistributedObjectCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetExistsDistributedObjectCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetExistsDistributedObjectMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetExistsDistributedObjectMessageTask(ClientMessage, Node, Connection) - Constructor for class com.hazelcast.jet.impl.client.protocol.task.JetExistsDistributedObjectMessageTask
 
JetExportSnapshotCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetExportSnapshotCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetExportSnapshotCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetExportSnapshotMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetGetJobConfigCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobConfigCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobConfigCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobConfigMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetGetJobConfigMessageTask(ClientMessage, Node, Connection) - Constructor for class com.hazelcast.jet.impl.client.protocol.task.JetGetJobConfigMessageTask
 
JetGetJobIdsByNameCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobIdsByNameCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobIdsByNameCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobIdsByNameMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetGetJobIdsCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobIdsCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobIdsCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobIdsMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetGetJobMetricsCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobMetricsCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobMetricsCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobMetricsMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetGetJobStatusCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobStatusCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobStatusCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobStatusMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetGetJobSubmissionTimeCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobSubmissionTimeCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobSubmissionTimeCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobSubmissionTimeMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetGetJobSummaryListCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobSummaryListCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobSummaryListCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetGetJobSummaryListMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetHazelcastBeanDefinitionParser - Class in com.hazelcast.jet.spring
BeanDefinitionParser for Hazelcast Instance created via Jet Instance.
JetHazelcastBeanDefinitionParser() - Constructor for class com.hazelcast.jet.spring.JetHazelcastBeanDefinitionParser
 
JetInitDataSerializerHook - Class in com.hazelcast.jet.impl.execution.init
 
JetInitDataSerializerHook() - Constructor for class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
jetInstance() - Method in interface com.hazelcast.jet.core.ProcessorMetaSupplier.Context
Returns the current Jet instance.
jetInstance() - Method in class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext
 
jetInstance(JetInstance) - Method in class com.hazelcast.jet.core.test.TestSupport
JetInstance - Interface in com.hazelcast.jet
Represents either an instance of a Jet server node or a Jet client instance that connects to a remote cluster.
JetInstanceBeanDefinitionParser - Class in com.hazelcast.jet.spring
BeanDefinitionParser for Hazelcast Jet Instance Configuration.
JetInstanceBeanDefinitionParser() - Constructor for class com.hazelcast.jet.spring.JetInstanceBeanDefinitionParser
 
JetJoinSubmittedJobCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetJoinSubmittedJobCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetJoinSubmittedJobCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetJoinSubmittedJobMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetJoinSubmittedJobMessageTask(ClientMessage, Node, Connection) - Constructor for class com.hazelcast.jet.impl.client.protocol.task.JetJoinSubmittedJobMessageTask
 
JetMemberStarter - Class in com.hazelcast.jet.server
Main class that starts a Hazelcast Jet instance.
JetMessageTaskFactoryProvider - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetMessageTaskFactoryProvider(NodeEngine) - Constructor for class com.hazelcast.jet.impl.client.protocol.task.JetMessageTaskFactoryProvider
 
JetMetricsDataSerializerHook - Class in com.hazelcast.jet.impl.metrics
 
JetMetricsDataSerializerHook() - Constructor for class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook
 
JetNamespaceHandler - Class in com.hazelcast.jet.spring
Hazelcast Jet Custom Namespace Definitions.
JetNamespaceHandler() - Constructor for class com.hazelcast.jet.spring.JetNamespaceHandler
 
JetObserverDataSerializerHook - Class in com.hazelcast.jet.impl.observer
 
JetObserverDataSerializerHook() - Constructor for class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook
 
JetProperties - Class in com.hazelcast.jet.core
Defines the names and default values for internal Hazelcast Jet properties.
JetResumeJobCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetResumeJobCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetResumeJobCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetResumeJobMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetResumeJobMessageTask(ClientMessage, Node, Connection) - Constructor for class com.hazelcast.jet.impl.client.protocol.task.JetResumeJobMessageTask
 
JetSpringServiceFactories - Class in com.hazelcast.jet.spring
Utility class with methods that create several useful Spring Bean service factories and transform functions.
JetSubmitJobCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetSubmitJobCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetSubmitJobCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetSubmitJobMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetSubmitJobMessageTask(ClientMessage, Node, Connection) - Constructor for class com.hazelcast.jet.impl.client.protocol.task.JetSubmitJobMessageTask
 
JetTerminateJobCodec - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetTerminateJobCodec.RequestParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetTerminateJobCodec.ResponseParameters - Class in com.hazelcast.jet.impl.client.protocol.codec
 
JetTerminateJobMessageTask - Class in com.hazelcast.jet.impl.client.protocol.task
 
JetToPythonGrpc - Class in com.hazelcast.jet.python.grpc
 
JetToPythonGrpc.JetToPythonBlockingStub - Class in com.hazelcast.jet.python.grpc
 
JetToPythonGrpc.JetToPythonFutureStub - Class in com.hazelcast.jet.python.grpc
 
JetToPythonGrpc.JetToPythonImplBase - Class in com.hazelcast.jet.python.grpc
 
JetToPythonGrpc.JetToPythonStub - Class in com.hazelcast.jet.python.grpc
 
JetToPythonImplBase() - Constructor for class com.hazelcast.jet.python.grpc.JetToPythonGrpc.JetToPythonImplBase
 
JetToPythonTopLevel - Class in com.hazelcast.jet.python.grpc
 
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(String, SupplierEx<ConnectionFactory>) - Static method in class com.hazelcast.jet.pipeline.Sinks
jmsQueue(SupplierEx<? extends ConnectionFactory>, String) - Static method in class com.hazelcast.jet.pipeline.Sources
jmsQueue(String, SupplierEx<? extends ConnectionFactory>) - Static method in class com.hazelcast.jet.pipeline.Sources
Shortcut equivalent to:
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(String, SupplierEx<ConnectionFactory>) - Static method in class com.hazelcast.jet.pipeline.Sinks
Shortcut for:
jmsTopic(SupplierEx<? extends ConnectionFactory>, String) - Static method in class com.hazelcast.jet.pipeline.Sources
jmsTopic(String, SupplierEx<? extends ConnectionFactory>) - Static method in class com.hazelcast.jet.pipeline.Sources
Shortcut equivalent to:
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_EXECUTION_RECORD - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
JOB_EXECUTIONS_COMPLETED - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Number of job executions finished on the Jet cluster.
JOB_EXECUTIONS_STARTED - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Number of job executions started on the Jet cluster.
JOB_METRICS - Static variable in class com.hazelcast.jet.core.metrics.MetricsDataSerializerHook
Serialization ID of the JobMetrics class.
JOB_RECORD - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
JOB_RESULT - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
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.
JOB_SUMMARY - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
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
 
jobConfig - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetSubmitJobCodec.RequestParameters
 
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 - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetExportSnapshotCodec.RequestParameters
 
jobId - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobConfigCodec.RequestParameters
 
jobId - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobMetricsCodec.RequestParameters
 
jobId - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobStatusCodec.RequestParameters
 
jobId - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetGetJobSubmissionTimeCodec.RequestParameters
 
jobId - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetJoinSubmittedJobCodec.RequestParameters
 
jobId - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetResumeJobCodec.RequestParameters
 
jobId - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetSubmitJobCodec.RequestParameters
 
jobId - Variable in class com.hazelcast.jet.impl.client.protocol.codec.JetTerminateJobCodec.RequestParameters
 
jobId() - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
jobId() - Method in class com.hazelcast.jet.impl.operation.AbstractJobOperation
 
jobId() - Method in class com.hazelcast.jet.impl.operation.AsyncJobOperation
 
jobId() - Method in class com.hazelcast.jet.JobStateSnapshot
Returns the job ID of the job the snapshot was originally exported from.
jobIdAndExecutionId(long, long) - Static method in class com.hazelcast.jet.impl.util.Util
 
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.
JobMetricsPublisher - Class in com.hazelcast.jet.impl.metrics
A publisher which updates the latest metric values in JobExecutionService.
JobMetricsPublisher(JobExecutionService, Member) - Constructor for class com.hazelcast.jet.impl.metrics.JobMetricsPublisher
 
jobName() - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
jobName() - Method in class com.hazelcast.jet.JobStateSnapshot
Returns the job name of the job the snapshot was originally exported from.
jobNameAndExecutionId() - Method in class com.hazelcast.jet.impl.execution.ExecutionContext
 
jobNameAndExecutionId(String, long) - Static method in class com.hazelcast.jet.impl.util.Util
 
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
 
JOBS_COMPLETED_SUCCESSFULLY - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Number of jobs successfully completed by the Jet cluster.
JOBS_COMPLETED_WITH_FAILURE - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Number of jobs that have failed on the Jet cluster.
JOBS_SUBMITTED - Static variable in class com.hazelcast.jet.core.metrics.MetricNames
Number of jobs submitted to the Jet cluster.
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
 
JobTerminateRequestedException - Exception in com.hazelcast.jet.impl.exception
 
JobTerminateRequestedException(TerminationMode) - Constructor for exception com.hazelcast.jet.impl.exception.JobTerminateRequestedException
 
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.
JOIN_SUBMITTED_JOB - Static variable in class com.hazelcast.jet.impl.execution.init.JetInitDataSerializerHook
 
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.
JoinSubmittedJobOperation - Class in com.hazelcast.jet.impl.operation
 
JoinSubmittedJobOperation() - Constructor for class com.hazelcast.jet.impl.operation.JoinSubmittedJobOperation
 
JoinSubmittedJobOperation(long) - Constructor for class com.hazelcast.jet.impl.operation.JoinSubmittedJobOperation
 
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 sink that publishes messages to Apache Kafka topic(s).
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) - Static method in class com.hazelcast.jet.kafka.KafkaSinks
Returns a builder object that you can use to create an Apache Kafka pipeline sink.
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.
KafkaSinks.Builder<E> - Class in com.hazelcast.jet.kafka
A builder for Kafka sink.
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.
KEYED_WINDOW_RESULT - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
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 of a particular Vertex.
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 of a particular Vertex.
lastForwardedWm() - Method in class com.hazelcast.jet.core.test.TestOutbox
 
lastForwardedWm() - Method in class com.hazelcast.jet.impl.execution.OutboxImpl
 
lastForwardedWm() - Method in interface com.hazelcast.jet.impl.execution.OutboxInternal
Returns the timestamp of the last forwarded watermark.
lastSnapshotId() - Method in class com.hazelcast.jet.impl.execution.init.ExecutionPlan
 
lazy(Supplier<Traverser<T>>) - Static method in class com.hazelcast.jet.Traversers
Flattens a supplier of traverser into a lazy-initialized traverser.
lazyAdd(AtomicLongArray, int, long) - Static method in class com.hazelcast.jet.impl.util.Util
Adds addend to the counter, using lazySet.
lazyIncrement(AtomicLongArray, int) - Static method in class com.hazelcast.jet.impl.util.Util
 
leftKeyFn() - Method in class com.hazelcast.jet.pipeline.JoinClause
Returns the left-hand key extractor function.
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.
LIN_TREND_ACC - Static variable in class com.hazelcast.jet.impl.serialization.SerializerHookConstants
 
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 the specified Hazelcast IList.
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
 
loadClass(ClassLoader, String) - Static method in class com.hazelcast.jet.impl.util.ReflectionUtils
 
loadConfig(InputStream, Properties) - Static method in class com.hazelcast.jet.impl.config.XmlJetConfigBuilder
Deprecated.
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".
localOrRemoteListSupplier(String, ClientConfig) - Static method in class com.hazelcast.jet.impl.connector.HazelcastReaders
 
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.
localParallelism(int) - Method in class com.hazelcast.jet.impl.pipeline.transform.AbstractTransform
 
localParallelism() - Method in class com.hazelcast.jet.impl.pipeline.transform.AbstractTransform
 
localParallelism(int) - Method in class com.hazelcast.jet.impl.pipeline.transform.TimestampTransform
 
localParallelism() - Method in interface com.hazelcast.jet.impl.pipeline.transform.Transform
 
localParallelism(int) - Method in interface com.hazelcast.jet.impl.pipeline.transform.Transform
 
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
 
localProcessorIndex() - Method in class com.hazelcast.jet.impl.execution.init.Contexts.ProcCtx
 
locateAndGetClientConfig() - Static method in class com.hazelcast.jet.impl.config.ConfigProvider
 
locateAndGetJetConfig() - Static method in class com.hazelcast.jet.impl.config.ConfigProvider
 
locateAndGetJetConfig(Properties) - Static method in class com.hazelcast.jet.impl.config.ConfigProvider
 
locateAndGetMemberConfig(Properties) - Static method in class com.hazelcast.jet.impl.config.ConfigProvider
 
locateDefault() - Method in class com.hazelcast.jet.impl.config.XmlJetClientConfigLocator
 
locateDefault() - Method in class com.hazelcast.jet.impl.config.XmlJetConfigLocator
 
locateDefault() - Method in class com.hazelcast.jet.impl.config.XmlJetMemberConfigLocator
 
locateDefault() - Method in class com.hazelcast.jet.impl.config.YamlJetClientConfigLocator
 
locateDefault() - Method in class com.hazelcast.jet.impl.config.YamlJetConfigLocator
 
locateDefault() - Method in class com.hazelcast.jet.impl.config.YamlJetMemberConfigLocator
 
locateFromSystemProperty() - Method in class com.hazelcast.jet.impl.config.XmlJetClientConfigLocator
 
locateFromSystemProperty() - Method in class com.hazelcast.jet.impl.config.XmlJetConfigLocator
 
locateFromSystemProperty() - Method in class com.hazelcast.jet.impl.config.XmlJetMemberConfigLocator
 
locateFromSystemProperty() - Method in class com.hazelcast.jet.impl.config.