Index (hazelcast-jet-all 0.1 API)

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

A

Accumulator<V,R extends Serializable> - Interface in com.hazelcast.jet.counters: Represents accumulator;
accumulator() - Method in interface com.hazelcast.jet.stream.Distributed.Collector: A function that folds a value into a mutable result container.
add(V) - Method in interface com.hazelcast.jet.counters.Accumulator
addApplicationConfig(ApplicationConfig) - Method in class com.hazelcast.jet.config.JetClientConfig: Sets the configuration for a given application
addApplicationConfig(ApplicationConfig) - Method in class com.hazelcast.jet.config.JetConfig: Sets the configuration for a given application
addEdge(Edge) - Method in class com.hazelcast.jet.dag.DAG: Add edge to dag
addInputVertex(Vertex, Edge) - Method in class com.hazelcast.jet.dag.Vertex: Add inputVertex as inout vertex for the corresponding edge and this vertex
addOutputVertex(Vertex, Edge) - Method in class com.hazelcast.jet.dag.Vertex: Add outputVertex as output vertex for the corresponding edge and this vertex
addResource(Class...) - Method in interface com.hazelcast.jet.application.Application: Add classes to the calculation's classLoader
addResource(URL) - Method in interface com.hazelcast.jet.application.Application: Add all bytecode for url to the calculation classLoader
addResource(InputStream, String, LocalizationResourceType) - Method in interface com.hazelcast.jet.application.Application: Add all bytecode for url to the calculation classLoader
addSink(SinkTap) - Method in class com.hazelcast.jet.dag.Vertex: Add abstract sink tap object to the vertex
addSource(SourceTap) - Method in class com.hazelcast.jet.dag.Vertex: Add abstract source tap object to the vertex
addVertex(Vertex) - Method in class com.hazelcast.jet.dag.DAG
afterProcessing(ProcessorContext) - Method in interface com.hazelcast.jet.processor.ContainerProcessor: Will be invoked strictly after last invocation of the corresponding task, strictly from the executor thread
allMatch(Distributed.DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns whether all elements of this stream match the provided predicate.
allMatch(DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
allMatch(Distributed.IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns whether all elements of this stream match the provided predicate.
allMatch(IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
allMatch(Distributed.LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns whether all elements of this stream match the provided predicate.
allMatch(LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
allMatch(Distributed.Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns whether all elements of this stream match the provided predicate.
allMatch(Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
and(Distributed.BiPredicate<? super T, ? super U>) - Method in interface com.hazelcast.jet.stream.Distributed.BiPredicate: Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.
and(Distributed.DoublePredicate) - Method in interface com.hazelcast.jet.stream.Distributed.DoublePredicate: Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.
and(Distributed.IntPredicate) - Method in interface com.hazelcast.jet.stream.Distributed.IntPredicate: Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.
and(Distributed.LongPredicate) - Method in interface com.hazelcast.jet.stream.Distributed.LongPredicate: Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.
and(Distributed.Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.Distributed.Predicate: Returns a composed predicate that represents a short-circuiting logical AND of this predicate and another.
andThen(Distributed.BiConsumer<? super T, ? super U>) - Method in interface com.hazelcast.jet.stream.Distributed.BiConsumer: Returns a composed BiConsumer that performs, in sequence, this operation followed by the after operation.
andThen(Distributed.Function<? super R, ? extends V>) - Method in interface com.hazelcast.jet.stream.Distributed.BiFunction: Returns a composed function that first applies this function to its input, and then applies the after function to the result.
andThen(Distributed.Consumer<? super T>) - Method in interface com.hazelcast.jet.stream.Distributed.Consumer: Returns a composed Consumer that performs, in sequence, this operation followed by the after operation.
andThen(Distributed.DoubleConsumer) - Method in interface com.hazelcast.jet.stream.Distributed.DoubleConsumer: Returns a composed DoubleConsumer that performs, in sequence, this operation followed by the after operation.
andThen(Distributed.DoubleUnaryOperator) - Method in interface com.hazelcast.jet.stream.Distributed.DoubleUnaryOperator: Returns a composed operator that first applies this operator to its input, and then applies the after operator to the result.
andThen(Distributed.Function<? super R, ? extends V>) - Method in interface com.hazelcast.jet.stream.Distributed.Function: Returns a composed function that first applies this function to its input, and then applies the after function to the result.
andThen(Distributed.IntConsumer) - Method in interface com.hazelcast.jet.stream.Distributed.IntConsumer: Returns a composed IntConsumer that performs, in sequence, this operation followed by the after operation.
andThen(Distributed.IntUnaryOperator) - Method in interface com.hazelcast.jet.stream.Distributed.IntUnaryOperator: Returns a composed operator that first applies this operator to its input, and then applies the after operator to the result.
andThen(Distributed.LongConsumer) - Method in interface com.hazelcast.jet.stream.Distributed.LongConsumer: Returns a composed LongConsumer that performs, in sequence, this operation followed by the after operation.
andThen(Distributed.LongUnaryOperator) - Method in interface com.hazelcast.jet.stream.Distributed.LongUnaryOperator: Returns a composed operator that first applies this operator to its input, and then applies the after operator to the result.
anyMatch(Distributed.DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns whether any elements of this stream match the provided predicate.
anyMatch(DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
anyMatch(Distributed.IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns whether any elements of this stream match the provided predicate.
anyMatch(IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
anyMatch(Distributed.LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns whether any elements of this stream match the provided predicate.
anyMatch(LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
anyMatch(Distributed.Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns whether any elements of this stream match the provided predicate.
anyMatch(Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
Application - Interface in com.hazelcast.jet.application: Represents abstract application
ApplicationConfig - Class in com.hazelcast.jet.config: Config for a Application
ApplicationConfig() - Constructor for class com.hazelcast.jet.config.ApplicationConfig: Constructs an empty ApplicationConfig
ApplicationConfig(String) - Constructor for class com.hazelcast.jet.config.ApplicationConfig: Constructs an ApplicationConfig with the given name
ApplicationListener - Interface in com.hazelcast.jet.application: Interface for registration of the application listener
asDoubleStream() - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a DoubleStream consisting of the elements of this stream, converted to double.
asDoubleStream() - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a DoubleStream consisting of the elements of this stream, converted to double.
asLongStream() - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a LongStream consisting of the elements of this stream, converted to long.
available() - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
averagingDouble(Distributed.ToDoubleFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that produces the arithmetic mean of a double-valued function applied to the input elements.
averagingInt(Distributed.ToIntFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that produces the arithmetic mean of an integer-valued function applied to the input elements.
averagingLong(Distributed.ToLongFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that produces the arithmetic mean of a long-valued function applied to the input elements.

B

beforeProcessing(ProcessorContext) - Method in interface com.hazelcast.jet.processor.ContainerProcessor: Will be invoked strictly before first invocation of the corresponding task, strictly from the executor thread
boxed() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a DistributedStream consisting of the elements of this stream, boxed to Double.
boxed() - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a Stream consisting of the elements of this stream, each boxed to an Integer.
boxed() - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a Stream consisting of the elements of this stream, each boxed to a Long.
build() - Method in class com.hazelcast.jet.dag.Edge.EdgeBuilder: Build and return the edge
build() - Method in class com.hazelcast.jet.processor.ProcessorDescriptor.Builder: Construct and return ProcessorDescriptor object
builder(Class<? extends ContainerProcessor>) - Static method in class com.hazelcast.jet.processor.ProcessorDescriptor: Creates builder to construct instance of ProcessorDescriptor
builder(Class<? extends ContainerProcessor>, Object...) - Static method in class com.hazelcast.jet.processor.ProcessorDescriptor: Creates builder to construct instance of ProcessorDescriptor
Builder(Class<? extends ContainerProcessor>, Object...) - Constructor for class com.hazelcast.jet.processor.ProcessorDescriptor.Builder: Constructs a new builder with given class and arguments
byReference() - Method in interface com.hazelcast.jet.strategy.DataTransferringStrategy

C

CalculationStrategy - Interface in com.hazelcast.jet.strategy: Represents abstract calculation strategy It wraps 2 notions:
CalculationStrategyAware - Interface in com.hazelcast.jet.strategy: Represents something which can be configured with CalculationStrategy Examples:
checkKeyIndex(int) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
checkValueIndex(int) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
clean(T) - Method in interface com.hazelcast.jet.strategy.DataTransferringStrategy: Clean object's internals
cleanApplicationVariable(String) - Method in interface com.hazelcast.jet.container.ContainerDescriptor
clear() - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
clear() - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
clearResources() - Method in interface com.hazelcast.jet.application.Application: Clear all submitted resources
cloneKeys() - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
cloneKeys() - Method in interface com.hazelcast.jet.io.tuple.Tuple: Returns a shallow clone of the key array.
cloneKeys() - Method in class com.hazelcast.jet.io.tuple.Tuple2
cloneValues() - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
cloneValues() - Method in interface com.hazelcast.jet.io.tuple.Tuple: Returns a shallow clone of the value array.
cloneValues() - Method in class com.hazelcast.jet.io.tuple.Tuple2
close() - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
collect(StreamContext, Pipeline<? extends T>) - Method in interface com.hazelcast.jet.stream.Distributed.Collector: Executes the collector with the given context and upstream pipeline.
collect(Distributed.Supplier<R>, Distributed.ObjDoubleConsumer<R>, Distributed.BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Performs a mutable reduction operation on the elements of this stream.
collect(Supplier<R>, ObjDoubleConsumer<R>, BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
collect(Distributed.Supplier<R>, Distributed.ObjIntConsumer<R>, Distributed.BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Performs a mutable reduction operation on the elements of this stream.
collect(Supplier<R>, ObjIntConsumer<R>, BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
collect(Distributed.Supplier<R>, Distributed.ObjLongConsumer<R>, Distributed.BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Performs a mutable reduction operation on the elements of this stream.
collect(Supplier<R>, ObjLongConsumer<R>, BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
collect(Distributed.Supplier<R>, Distributed.BiConsumer<R, ? super T>, Distributed.BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Performs a mutable reduction operation on the elements of this stream.
collect(Distributed.Collector<? super T, A, R>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Performs a mutable reduction operation on the elements of this stream using a Distributed.Collector.
collect(Supplier<R>, BiConsumer<R, ? super T>, BiConsumer<R, R>) - Method in interface com.hazelcast.jet.stream.DistributedStream
collect(Collector<? super T, A, R>) - Method in interface com.hazelcast.jet.stream.DistributedStream
collectingAndThen(Distributed.Collector<T, A, R>, Distributed.Function<R, RR>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Adapts a Distributed.Collector to perform an additional finishing transformation.
com.hazelcast.jet - package com.hazelcast.jet: Provides JET API
com.hazelcast.jet.application - package com.hazelcast.jet.application: Provides JET API to work with application-level JET objects
com.hazelcast.jet.config - package com.hazelcast.jet.config: Provides APi to work with JET config
com.hazelcast.jet.container - package com.hazelcast.jet.container: Provides API to work with JET-container level
com.hazelcast.jet.counters - package com.hazelcast.jet.counters: Provides API for the Jet-Hazelcast accumulators
com.hazelcast.jet.dag - package com.hazelcast.jet.dag: Provides abstract API for DAG configuring
com.hazelcast.jet.dag.tap - package com.hazelcast.jet.dag.tap: Provides API to work with taps
com.hazelcast.jet.data - package com.hazelcast.jet.data: Represents API to work with data and serialization
com.hazelcast.jet.data.io - package com.hazelcast.jet.data.io: Represents API to work with data and serialization
com.hazelcast.jet.data.tuple - package com.hazelcast.jet.data.tuple: Provides API to work with tuple
com.hazelcast.jet.executor - package com.hazelcast.jet.executor: Provides API to work with Task-executor objects
com.hazelcast.jet.io - package com.hazelcast.jet.io: Represents SPI to work with input/output
com.hazelcast.jet.io.serialization - package com.hazelcast.jet.io.serialization
com.hazelcast.jet.io.tuple - package com.hazelcast.jet.io.tuple
com.hazelcast.jet.processor - package com.hazelcast.jet.processor: Provides JET-processors
com.hazelcast.jet.strategy - package com.hazelcast.jet.strategy: Provides processing strategies
com.hazelcast.jet.stream - package com.hazelcast.jet.stream: java.util.stream implementation using Hazelcast Jet
CombinedJetException - Exception in com.hazelcast.jet: Collects exception from different nodes
CombinedJetException(List<Throwable>) - Constructor for exception com.hazelcast.jet.CombinedJetException: Create a combined JetException with multiple errors
combiner() - Method in interface com.hazelcast.jet.stream.Distributed.Collector: A function that accepts two partial results and merges them.
compose(Distributed.DoubleUnaryOperator) - Method in interface com.hazelcast.jet.stream.Distributed.DoubleUnaryOperator: Returns a composed operator that first applies the before operator to its input, and then applies this operator to the result.
compose(Distributed.Function<? super V, ? extends T>) - Method in interface com.hazelcast.jet.stream.Distributed.Function: Returns a composed function that first applies the before function to its input, and then applies this function to the result.
compose(Distributed.IntUnaryOperator) - Method in interface com.hazelcast.jet.stream.Distributed.IntUnaryOperator: Returns a composed operator that first applies the before operator to its input, and then applies this operator to the result.
compose(Distributed.LongUnaryOperator) - Method in interface com.hazelcast.jet.stream.Distributed.LongUnaryOperator: Returns a composed operator that first applies the before operator to its input, and then applies this operator to the result.
consume(T) - Method in interface com.hazelcast.jet.data.io.ConsumerOutputStream: Consumes one object
consumeChunk(T[], int) - Method in interface com.hazelcast.jet.data.io.ConsumerOutputStream: Consumes chunk of objects with size actualSize
ConsumerOutputStream<T> - Interface in com.hazelcast.jet.data.io: Represents abstract output-stream to consume data chunk of data-stream
consumeStream(ProducerInputStream<T>) - Method in interface com.hazelcast.jet.data.io.ConsumerOutputStream: Consumes all objects from inputStream
ContainerDescriptor - Interface in com.hazelcast.jet.container: Interface which describe container's internal entries and let's manage container-level structures
ContainerListener - Interface in com.hazelcast.jet.container: Listener which will be invoked on change of container's state
ContainerProcessor<I,O> - Interface in com.hazelcast.jet.processor: Abstract JET processor for application's execution Should be implemented by user and will be used during container's execution There are two phases of execution:
containsEdge(Edge) - Method in class com.hazelcast.jet.dag.DAG
containsVertex(Vertex) - Method in class com.hazelcast.jet.dag.DAG
copy(T, T) - Method in interface com.hazelcast.jet.strategy.DataTransferringStrategy: Copy data from one object to another
CounterKey - Interface in com.hazelcast.jet.container: Interface which represents key of the accumulators
counting() - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector accepting elements of type T that counts the number of input elements.
create(Class<? extends ContainerProcessor>, Object...) - Static method in class com.hazelcast.jet.processor.ProcessorDescriptor: Create a new descriptor with given Processor class and arguments
createInput(MemoryManager, JetSerializationService, boolean) - Method in interface com.hazelcast.jet.io.serialization.JetInputFactory
createObjectDataInput(MemoryManager, boolean) - Method in interface com.hazelcast.jet.io.serialization.JetSerializationService
createObjectDataOutput(MemoryManager, boolean) - Method in interface com.hazelcast.jet.io.serialization.JetSerializationService
createOutput(MemoryManager, JetSerializationService, boolean) - Method in interface com.hazelcast.jet.io.serialization.JetOutputFactory

D

DAG - Class in com.hazelcast.jet.dag: Direct acyclic graph representation
DAG() - Constructor for class com.hazelcast.jet.dag.DAG: Empty constructor
DAG(String) - Constructor for class com.hazelcast.jet.dag.DAG: Create a DAG with a given name
data - Variable in class com.hazelcast.jet.io.tuple.DefaultTuple
DataReader - Interface in com.hazelcast.jet.data: Represents abstract reader from some source with data
dataTransferringStrategy(DataTransferringStrategy) - Method in class com.hazelcast.jet.dag.Edge.EdgeBuilder: Set the data transferring strategy for the edge
DataTransferringStrategy<T> - Interface in com.hazelcast.jet.strategy: Represents strategy of data transferring Jet uses ringBuffers to pass data from one vertex to another RingBuffers can work by reference or by value By references means that all input objects will be copied into the ringBuffer by reference (without internal copy) By value means ringBuffer has pre-allocated objects Data will be copied from input objects into pre-allocated objects Used depends on the flow to avoid copy or in opposite to avoid garbage creation
DataType - Interface in com.hazelcast.jet.io: Interface to represent dataType Examples:
DataWriter - Interface in com.hazelcast.jet.data: Represents abstract writer to some sink
DEFAULT_APP_ATTEMPTS_COUNT - Static variable in class com.hazelcast.jet.config.ApplicationConfig: Represents default number of attempts to create localization directories
DEFAULT_CHUNK_SIZE - Static variable in class com.hazelcast.jet.config.ApplicationConfig: Default chunk size for data passed between JET-containers
DEFAULT_CONNECTIONS_CHECKING_INTERVAL_MS - Static variable in class com.hazelcast.jet.config.ApplicationConfig: Represents default connection checking interval
DEFAULT_CONNECTIONS_SILENCE_TIMEOUT_MS - Static variable in class com.hazelcast.jet.config.ApplicationConfig: Represents default value for timeout when socket accepted as broken
DEFAULT_FILE_CHUNK_SIZE_BYTES - Static variable in class com.hazelcast.jet.config.ApplicationConfig: Represents default value for localization process chunks to be used
DEFAULT_SECONDS_TO_AWAIT - Static variable in class com.hazelcast.jet.config.JetConfig: Represents default value for any futures in system
DEFAULT_TCP_BUFFER_SIZE - Static variable in class com.hazelcast.jet.config.ApplicationConfig: Represents default value for TCP-buffer
DefaultTuple<K,V> - Class in com.hazelcast.jet.io.tuple
DefaultTuple() - Constructor for class com.hazelcast.jet.io.tuple.DefaultTuple
DefaultTuple(K, V) - Constructor for class com.hazelcast.jet.io.tuple.DefaultTuple
DefaultTuple(K[], V) - Constructor for class com.hazelcast.jet.io.tuple.DefaultTuple
DefaultTuple(K, V[]) - Constructor for class com.hazelcast.jet.io.tuple.DefaultTuple
DefaultTuple(K[], V[]) - Constructor for class com.hazelcast.jet.io.tuple.DefaultTuple
DefaultTupleFactory - Class in com.hazelcast.jet.io.tuple
DefaultTupleFactory() - Constructor for class com.hazelcast.jet.io.tuple.DefaultTupleFactory
distinct() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a stream consisting of the distinct elements of this stream.
distinct() - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a stream consisting of the distinct elements of this stream.
distinct() - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a stream consisting of the distinct elements of this stream.
distinct() - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the distinct elements (according to Object.equals(Object)) of this stream.
Distributed - Class in com.hazelcast.jet.stream: Enclosing class for serializable versions of java.util.function interfaces.
Distributed.BiConsumer<T,U> - Interface in com.hazelcast.jet.stream: Represents an operation that accepts two input arguments and returns no result.
Distributed.BiFunction<T,U,R> - Interface in com.hazelcast.jet.stream: Represents a function that accepts two arguments and produces a result.
Distributed.BinaryOperator<T> - Interface in com.hazelcast.jet.stream: Represents an operation upon two operands of the same type, producing a result of the same type as the operands.
Distributed.BiPredicate<T,U> - Interface in com.hazelcast.jet.stream: Represents a predicate (boolean-valued function) of two arguments.
Distributed.BooleanSupplier - Interface in com.hazelcast.jet.stream: Represents a supplier of boolean-valued results.
Distributed.Collector<T,A,R> - Interface in com.hazelcast.jet.stream: A mutable reduction operation that accumulates input elements into a mutable result container, optionally transforming the accumulated result into a final representation after all input elements have been processed.
Distributed.Comparator<T> - Interface in com.hazelcast.jet.stream: A comparison function, which imposes a total ordering on some collection of objects.
Distributed.Consumer<T> - Interface in com.hazelcast.jet.stream: Represents an operation that accepts a single input argument and returns no result.
Distributed.DoubleBinaryOperator - Interface in com.hazelcast.jet.stream: Represents an operation upon two double-valued operands and producing a double-valued result.
Distributed.DoubleConsumer - Interface in com.hazelcast.jet.stream: Represents an operation that accepts a single double-valued argument and returns no result.
Distributed.DoubleFunction<R> - Interface in com.hazelcast.jet.stream: Represents a function that accepts a double-valued argument and produces a result.
Distributed.DoublePredicate - Interface in com.hazelcast.jet.stream: Represents a predicate (boolean-valued function) of one double-valued argument.
Distributed.DoubleToIntFunction - Interface in com.hazelcast.jet.stream: Represents a function that accepts a double-valued argument and produces an int-valued result.
Distributed.DoubleToLongFunction - Interface in com.hazelcast.jet.stream: Represents a function that accepts a double-valued argument and produces a long-valued result.
Distributed.DoubleUnaryOperator - Interface in com.hazelcast.jet.stream: Represents an operation on a single double-valued operand that produces a double-valued result.
Distributed.Function<T,R> - Interface in com.hazelcast.jet.stream: Represents a function that accepts one argument and produces a result.
Distributed.IntBinaryOperator - Interface in com.hazelcast.jet.stream: Represents an operation upon two int-valued operands and producing an int-valued result.
Distributed.IntConsumer - Interface in com.hazelcast.jet.stream: Represents an operation that accepts a single int-valued argument and returns no result.
Distributed.IntFunction<R> - Interface in com.hazelcast.jet.stream: Represents a function that accepts an int-valued argument and produces a result.
Distributed.IntPredicate - Interface in com.hazelcast.jet.stream: Represents a predicate (boolean-valued function) of one int-valued argument.
Distributed.IntToDoubleFunction - Interface in com.hazelcast.jet.stream: Represents a function that accepts an int-valued argument and produces a double-valued result.
Distributed.IntToLongFunction - Interface in com.hazelcast.jet.stream: Represents a function that accepts an int-valued argument and produces a long-valued result.
Distributed.IntUnaryOperator - Interface in com.hazelcast.jet.stream: Represents an operation on a single int-valued operand that produces an int-valued result.
Distributed.LongBinaryOperator - Interface in com.hazelcast.jet.stream: Represents an operation upon two long-valued operands and producing a long-valued result.
Distributed.LongConsumer - Interface in com.hazelcast.jet.stream: Represents an operation that accepts a single long-valued argument and returns no result.
Distributed.LongFunction<R> - Interface in com.hazelcast.jet.stream: Represents a function that accepts a long-valued argument and produces a result.
Distributed.LongPredicate - Interface in com.hazelcast.jet.stream: Represents a predicate (boolean-valued function) of one long-valued argument.
Distributed.LongToDoubleFunction - Interface in com.hazelcast.jet.stream: Represents a function that accepts a long-valued argument and produces a double-valued result.
Distributed.LongToIntFunction - Interface in com.hazelcast.jet.stream: Represents a function that accepts a long-valued argument and produces an int-valued result.
Distributed.LongUnaryOperator - Interface in com.hazelcast.jet.stream: Represents an operation on a single long-valued operand that produces a long-valued result.
Distributed.ObjDoubleConsumer<T> - Interface in com.hazelcast.jet.stream: Represents an operation that accepts an object-valued and a double-valued argument, and returns no result.
Distributed.ObjIntConsumer<T> - Interface in com.hazelcast.jet.stream: Represents an operation that accepts an object-valued and a int-valued argument, and returns no result.
Distributed.ObjLongConsumer<T> - Interface in com.hazelcast.jet.stream: Represents an operation that accepts an object-valued and a long-valued argument, and returns no result.
Distributed.Optional<T> - Class in com.hazelcast.jet.stream: A container object which may or may not contain a non-null value.
Distributed.Predicate<T> - Interface in com.hazelcast.jet.stream: Represents a predicate (boolean-valued function) of one argument.
Distributed.Supplier<T> - Interface in com.hazelcast.jet.stream: Represents a supplier of results.
Distributed.ToDoubleBiFunction<T,U> - Interface in com.hazelcast.jet.stream: Represents a function that accepts two arguments and produces a double-valued result.
Distributed.ToDoubleFunction<T> - Interface in com.hazelcast.jet.stream: Represents a function that produces a double-valued result.
Distributed.ToIntBiFunction<T,U> - Interface in com.hazelcast.jet.stream: Represents a function that accepts two arguments and produces an int-valued result.
Distributed.ToIntFunction<T> - Interface in com.hazelcast.jet.stream: Represents a function that produces an int-valued result.
Distributed.ToLongBiFunction<T,U> - Interface in com.hazelcast.jet.stream: Represents a function that accepts two arguments and produces a long-valued result.
Distributed.ToLongFunction<T> - Interface in com.hazelcast.jet.stream: Represents a function that produces a long-valued result.
Distributed.UnaryOperator<T> - Interface in com.hazelcast.jet.stream: Represents an operation on a single operand that produces a result of the same type as its operand.
DistributedCollectors - Class in com.hazelcast.jet.stream: Distributed implementations of Collectors Implementations of Distributed.Collector that implement various useful reduction operations, such as accumulating elements into collections, summarizing elements according to various criteria, etc.
DistributedCollectors() - Constructor for class com.hazelcast.jet.stream.DistributedCollectors
DistributedDoubleStream - Interface in com.hazelcast.jet.stream: An extension of DoubleStream to support distributed stream operations by replacing functional interfaces with their serializable equivalents.
DistributedIntStream - Interface in com.hazelcast.jet.stream: An extension of IntStream to support distributed stream operations by replacing functional interfaces with their serializable equivalents.
DistributedLongStream - Interface in com.hazelcast.jet.stream: An extension of LongStream to support distributed stream operations by replacing functional interfaces with their serializable equivalents.
DistributedStream<T> - Interface in com.hazelcast.jet.stream: An extension of Stream to support distributed stream operations by replacing functional interfaces with their serializable equivalents.

E

Edge - Class in com.hazelcast.jet.dag: Represents an edge between two vertices in a DAG
Edge(String, Vertex, Vertex) - Constructor for class com.hazelcast.jet.dag.Edge: Creates an edge between two vertices.
Edge.EdgeBuilder - Class in com.hazelcast.jet.dag: A builder class for Edge
EdgeBuilder(String, Vertex, Vertex) - Constructor for class com.hazelcast.jet.dag.Edge.EdgeBuilder: Creates a builder for an edge between two vertices.
empty() - Static method in class com.hazelcast.jet.stream.Distributed.Optional: Returns an empty Optional instance.
equals(Object) - Method in class com.hazelcast.jet.dag.Edge
equals(Object) - Method in class com.hazelcast.jet.dag.Vertex
equals(Object) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
equals(Object) - Method in class com.hazelcast.jet.strategy.IListBasedShufflingStrategy
equals(Object) - Method in class com.hazelcast.jet.stream.Distributed.Optional: Indicates whether some other object is "equal to" this Optional.
execute() - Method in interface com.hazelcast.jet.application.Application: Execute application
EXECUTED_LISTENER_CALLER - Static variable in interface com.hazelcast.jet.container.ContainerListener: Predefined listener to be invoked on container executed

F

FAILURE_LISTENER_CALLER - Static variable in interface com.hazelcast.jet.container.ContainerListener: Predefined listener to be invoked on container failure
FileSink - Class in com.hazelcast.jet.dag.tap: A sink which uses a file as output.
FileSink(String) - Constructor for class com.hazelcast.jet.dag.tap.FileSink: Constructs a sink with the given filename
FileSource - Class in com.hazelcast.jet.dag.tap: A source which uses a file as the input.
FileSource(String) - Constructor for class com.hazelcast.jet.dag.tap.FileSource: Constructs a source with the given filename
filter(Distributed.Predicate<? super T>) - Method in class com.hazelcast.jet.stream.Distributed.Optional: If a value is present, and the value matches the given predicate, return an Optional describing the value, otherwise return an empty Optional.
filter(Distributed.DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a stream consisting of the elements of this stream that match the given predicate.
filter(DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
filter(Distributed.IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a stream consisting of the elements of this stream that match the given predicate.
filter(IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
filter(Distributed.LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a stream consisting of the elements of this stream that match the given predicate.
filter(LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
filter(Distributed.Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the elements of this stream that match the given predicate.
filter(Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
finalizeApplication() - Method in interface com.hazelcast.jet.application.Application: Finalizes application
finalizeProcessor(ConsumerOutputStream<O>, ProcessorContext) - Method in interface com.hazelcast.jet.processor.ContainerProcessor: Will be invoked on finalization phase
finisher() - Method in interface com.hazelcast.jet.stream.Distributed.Collector: Perform the final transformation from the intermediate accumulation type A to the final result type R.
flatMap(Distributed.Function<? super T, Distributed.Optional>) - Method in class com.hazelcast.jet.stream.Distributed.Optional: If a value is present, apply the provided Optional-bearing mapping function to it, return that result, otherwise return an empty Optional.
flatMap(Distributed.DoubleFunction<? extends DoubleStream>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
flatMap(DoubleFunction<? extends DoubleStream>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
flatMap(Distributed.IntFunction<? extends IntStream>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
flatMap(IntFunction<? extends IntStream>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
flatMap(Distributed.LongFunction<? extends LongStream>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
flatMap(LongFunction<? extends LongStream>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
flatMap(Distributed.Function<? super T, ? extends Stream<? extends R>>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
flatMap(Function<? super T, ? extends Stream<? extends R>>) - Method in interface com.hazelcast.jet.stream.DistributedStream
flatMapToDouble(Distributed.Function<? super T, ? extends DoubleStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns an DoubleStream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
flatMapToDouble(Function<? super T, ? extends DoubleStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream
flatMapToInt(Distributed.Function<? super T, ? extends IntStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns an IntStream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
flatMapToInt(Function<? super T, ? extends IntStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream
flatMapToLong(Distributed.Function<? super T, ? extends LongStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns an LongStream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
flatMapToLong(Function<? super T, ? extends LongStream>) - Method in interface com.hazelcast.jet.stream.DistributedStream
forEach(Distributed.DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Performs an action for each element of this stream.
forEach(DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
forEach(Distributed.IntConsumer) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Performs an action for each element of this stream.
forEach(IntConsumer) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
forEach(Distributed.LongConsumer) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Performs an action for each element of this stream.
forEach(LongConsumer) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
forEach(Distributed.Consumer<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Performs an action for each element of this stream.
forEach(Consumer<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
forEachOrdered(Distributed.DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Performs an action for each element of this stream, guaranteeing that each element is processed in encounter order for streams that have a defined encounter order.
forEachOrdered(DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
forEachOrdered(Distributed.IntConsumer) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Performs an action for each element of this stream, guaranteeing that each element is processed in encounter order for streams that have a defined encounter order.
forEachOrdered(IntConsumer) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
forEachOrdered(Distributed.LongConsumer) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Performs an action for each element of this stream, guaranteeing that each element is processed in encounter order for streams that have a defined encounter order.
forEachOrdered(LongConsumer) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
forEachOrdered(Distributed.Consumer<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Performs an action for each element of this stream, in the encounter order of the stream if the stream has a defined encounter order.
forEachOrdered(Consumer<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream

G

get(int) - Method in interface com.hazelcast.jet.data.io.ProducerInputStream: Return object with corresponding index
get() - Method in class com.hazelcast.jet.stream.Distributed.Optional: If a value is present in this Optional, returns the value, otherwise throws NoSuchElementException.
getAccumulator(CounterKey) - Method in interface com.hazelcast.jet.container.ContainerDescriptor: Return accumulator to collect statistics
getAccumulator(CounterKey) - Method in interface com.hazelcast.jet.executor.TaskContext: Accumulator for the statistics gathering
getAccumulators() - Method in interface com.hazelcast.jet.application.Application: Returns map with statistic counters info for the certain application
getAllocatedSize() - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
getApplicationConfig(String) - Method in class com.hazelcast.jet.config.JetClientConfig: Gets the configuration for a given application name
getApplicationConfig(String) - Method in class com.hazelcast.jet.config.JetConfig: Gets the configuration for a given application name
getApplicationDirectoryCreationAttemptsCount() - Method in class com.hazelcast.jet.config.ApplicationConfig: Gets the maximum number of attempts to create a temp directory during localization
getApplicationName() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getApplicationState() - Method in interface com.hazelcast.jet.application.Application
getApplicationVariable(String) - Method in interface com.hazelcast.jet.container.ContainerDescriptor: Return variable registered on application-level
getArgs() - Method in class com.hazelcast.jet.processor.ProcessorDescriptor
getCalculationStrategy() - Method in class com.hazelcast.jet.data.tuple.JetTuple2
getCalculationStrategy() - Method in interface com.hazelcast.jet.strategy.CalculationStrategyAware
getCause() - Method in exception com.hazelcast.jet.CombinedJetException: Return first exception or null if there are no exceptions
getChunkSize() - Method in class com.hazelcast.jet.config.ApplicationConfig: Gets the size of the chunk that will be processed at each call in ContainerProcessor.process
getClazz() - Method in interface com.hazelcast.jet.io.DataType
getClazz() - Method in enum com.hazelcast.jet.io.Types
getConfig() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getContainerProcessorClazz() - Method in class com.hazelcast.jet.processor.ProcessorDescriptor
getDAG() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getDataTransferringStrategy() - Method in class com.hazelcast.jet.dag.Edge
getDataType(byte) - Method in interface com.hazelcast.jet.io.IOContext
getDataType(Object) - Method in interface com.hazelcast.jet.io.IOContext
getDataType(Object) - Method in interface com.hazelcast.jet.io.ObjectWriterFactory: Corresponding DataType object for passed Java object;
getDataType(byte) - Static method in enum com.hazelcast.jet.io.Types
getDataType(Object) - Static method in enum com.hazelcast.jet.io.Types
getDescriptor() - Method in class com.hazelcast.jet.dag.Vertex
getErrors() - Method in exception com.hazelcast.jet.CombinedJetException: Returns combined list of errors
getHashingStrategy() - Method in class com.hazelcast.jet.dag.Edge
getHashingStrategy() - Method in interface com.hazelcast.jet.strategy.CalculationStrategy
getHazelcastInstance() - Method in interface com.hazelcast.jet.application.Application
getID() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getInputEdges() - Method in class com.hazelcast.jet.dag.Vertex
getInputVertex() - Method in class com.hazelcast.jet.dag.Edge
getInputVertices() - Method in class com.hazelcast.jet.dag.Vertex
getIoThreadCount() - Method in class com.hazelcast.jet.config.JetConfig: Gets the number of I/O threads to use
getJetApplication(HazelcastInstance, String) - Static method in class com.hazelcast.jet.JetEngine: Create a new application given a Hazelcast instance and name
getJetApplication(HazelcastInstance, String, ApplicationConfig) - Static method in class com.hazelcast.jet.JetEngine: Create a new application given a Hazelcast instance, name and application configuration
getKey(int) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
getKey(int) - Method in interface com.hazelcast.jet.io.tuple.Tuple: Returns the key at the given index.
getKey(int) - Method in class com.hazelcast.jet.io.tuple.Tuple2
getKeyData(NodeEngine) - Method in interface com.hazelcast.jet.data.tuple.JetTuple: Represents binary representation of key-data
getKeyData(CalculationStrategy, NodeEngine) - Method in interface com.hazelcast.jet.data.tuple.JetTuple: Represents binary representation of key-data Use calculationStrategy to construct Data
getKeyData(int, CalculationStrategy, NodeEngine) - Method in interface com.hazelcast.jet.data.tuple.JetTuple: Represents binary representation of key-object with specified index
getKeyData(NodeEngine) - Method in class com.hazelcast.jet.data.tuple.JetTuple2
getKeyData(CalculationStrategy, NodeEngine) - Method in class com.hazelcast.jet.data.tuple.JetTuple2
getKeyData(int, CalculationStrategy, NodeEngine) - Method in class com.hazelcast.jet.data.tuple.JetTuple2
getLocalizationDirectory() - Method in class com.hazelcast.jet.config.ApplicationConfig: Gets the name of the directory to be used for localization
getLocalValue() - Method in interface com.hazelcast.jet.counters.Accumulator
getName() - Method in interface com.hazelcast.jet.application.Application
getName() - Method in class com.hazelcast.jet.config.ApplicationConfig: Returns the name of the application
getName() - Method in class com.hazelcast.jet.dag.DAG
getName() - Method in class com.hazelcast.jet.dag.Edge
getName() - Method in class com.hazelcast.jet.dag.tap.FileSink
getName() - Method in class com.hazelcast.jet.dag.tap.FileSource
getName() - Method in class com.hazelcast.jet.dag.tap.ListSink
getName() - Method in class com.hazelcast.jet.dag.tap.ListSource
getName() - Method in class com.hazelcast.jet.dag.tap.MapSink
getName() - Method in class com.hazelcast.jet.dag.tap.MapSource
getName() - Method in interface com.hazelcast.jet.dag.tap.SinkTap
getName() - Method in interface com.hazelcast.jet.dag.tap.SourceTap
getName() - Method in class com.hazelcast.jet.dag.Vertex
getNodeEngine() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getObjectReader() - Method in interface com.hazelcast.jet.io.DataType
getObjectReader() - Method in enum com.hazelcast.jet.io.Types
getObjectReaderFactory() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getObjectReaderFactory() - Method in interface com.hazelcast.jet.executor.TaskContext
getObjectReaderFactory() - Method in interface com.hazelcast.jet.io.IOContext
getObjectWriter() - Method in interface com.hazelcast.jet.io.DataType
getObjectWriter() - Method in enum com.hazelcast.jet.io.Types
getObjectWriterFactory() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getObjectWriterFactory() - Method in interface com.hazelcast.jet.executor.TaskContext
getObjectWriterFactory() - Method in interface com.hazelcast.jet.io.IOContext
getOutputEdges() - Method in class com.hazelcast.jet.dag.Vertex
getOutputVertex() - Method in class com.hazelcast.jet.dag.Edge
getOutputVertices() - Method in class com.hazelcast.jet.dag.Vertex
getPartitionId() - Method in interface com.hazelcast.jet.data.DataWriter
getPartitionId() - Method in class com.hazelcast.jet.data.tuple.JetTuple2
getPartitionId() - Method in interface com.hazelcast.jet.PartitionIdAware: Returns the partition id for the object
getPartitioningStrategy() - Method in class com.hazelcast.jet.dag.Edge
getPartitioningStrategy() - Method in interface com.hazelcast.jet.strategy.CalculationStrategy
getPartitionWriter(ContainerDescriptor, int) - Method in class com.hazelcast.jet.dag.tap.MapSink
getPartitionWriter(ContainerDescriptor, int) - Method in class com.hazelcast.jet.dag.tap.MultiMapSink
getPointer() - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
getPort() - Method in class com.hazelcast.jet.config.JetConfig: Gets the port which Jet listens on
getProcessingStrategy() - Method in class com.hazelcast.jet.dag.Edge
getProcessingThreadCount() - Method in class com.hazelcast.jet.config.JetConfig: Gets the number of processing threads to use
getProperties() - Method in class com.hazelcast.jet.config.ApplicationConfig: Gets application specific properties
getReader(ContainerDescriptor, JetTupleFactory, int) - Method in class com.hazelcast.jet.dag.tap.MapSource
getReader(ContainerDescriptor, JetTupleFactory, int) - Method in class com.hazelcast.jet.dag.tap.MultiMapSource
getReader(byte) - Method in interface com.hazelcast.jet.io.ObjectReaderFactory: Returns reader for the corresponding typeID;
getReaders(ContainerDescriptor, Vertex, JetTupleFactory) - Method in class com.hazelcast.jet.dag.tap.FileSource
getReaders(ContainerDescriptor, Vertex, JetTupleFactory) - Method in class com.hazelcast.jet.dag.tap.ListSource
getReaders(ContainerDescriptor, Vertex, JetTupleFactory) - Method in class com.hazelcast.jet.dag.tap.MapSource
getReaders(ContainerDescriptor, Vertex, JetTupleFactory) - Method in interface com.hazelcast.jet.dag.tap.SourceTap: Array of the input readers
getRevertedTopologicalVertexIterator() - Method in class com.hazelcast.jet.dag.DAG
getRingbufferSize() - Method in class com.hazelcast.jet.config.ApplicationConfig: Gets the size of the ringbuffer used when passing data between processors
getSecondsToAwait() - Method in class com.hazelcast.jet.config.ApplicationConfig: Gets the internal timeout of the application
getShufflingAddress(ContainerDescriptor) - Method in class com.hazelcast.jet.strategy.IListBasedShufflingStrategy
getShufflingAddress(ContainerDescriptor) - Method in interface com.hazelcast.jet.strategy.ShufflingStrategy: List of the address
getShufflingBatchSizeBytes() - Method in class com.hazelcast.jet.config.ApplicationConfig: Gets the size of the batch to send when shuffling data to other nodes
getShufflingStrategy() - Method in class com.hazelcast.jet.dag.Edge
getShutdownTimeoutSeconds() - Method in class com.hazelcast.jet.config.JetConfig: Gets the timeout to use when shutting down threads
getSinks() - Method in class com.hazelcast.jet.dag.Vertex
getSources() - Method in class com.hazelcast.jet.dag.Vertex
getTaskCount() - Method in interface com.hazelcast.jet.executor.TaskContext
getTaskCount() - Method in class com.hazelcast.jet.processor.ProcessorDescriptor
getTaskNumber() - Method in interface com.hazelcast.jet.executor.TaskContext
getTcpBufferSize() - Method in class com.hazelcast.jet.config.ApplicationConfig: Get the TCP buffer size used when writing to network
getTopologicalVertexIterator() - Method in class com.hazelcast.jet.dag.DAG
getTupleFactory() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getTypeID() - Method in interface com.hazelcast.jet.io.DataType
getTypeID() - Method in enum com.hazelcast.jet.io.Types
getValue(int) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
getValue(int) - Method in interface com.hazelcast.jet.io.tuple.Tuple: Returns the value at the given index.
getValue(int) - Method in class com.hazelcast.jet.io.tuple.Tuple2
getValueData(NodeEngine) - Method in interface com.hazelcast.jet.data.tuple.JetTuple: Represents binary representation of value-data
getValueData(CalculationStrategy, NodeEngine) - Method in interface com.hazelcast.jet.data.tuple.JetTuple: Represents binary representation of value-data Use calculationStrategy to construct Data
getValueData(int, CalculationStrategy, NodeEngine) - Method in interface com.hazelcast.jet.data.tuple.JetTuple: Represents binary representation of value-object with specified index
getValueData(NodeEngine) - Method in class com.hazelcast.jet.data.tuple.JetTuple2
getValueData(CalculationStrategy, NodeEngine) - Method in class com.hazelcast.jet.data.tuple.JetTuple2
getValueData(int, CalculationStrategy, NodeEngine) - Method in class com.hazelcast.jet.data.tuple.JetTuple2
getVertex() - Method in interface com.hazelcast.jet.container.ContainerDescriptor
getVertex(String) - Method in class com.hazelcast.jet.dag.DAG: Return vertex with corresponding name
getVertices() - Method in class com.hazelcast.jet.dag.DAG
getWriter(Object) - Method in interface com.hazelcast.jet.io.ObjectWriterFactory: Writer to be used to serialize object;
getWriters(NodeEngine, ContainerDescriptor) - Method in class com.hazelcast.jet.dag.tap.FileSink
getWriters(NodeEngine, ContainerDescriptor) - Method in class com.hazelcast.jet.dag.tap.ListSink
getWriters(NodeEngine, ContainerDescriptor) - Method in class com.hazelcast.jet.dag.tap.MapSink
getWriters(NodeEngine, ContainerDescriptor) - Method in interface com.hazelcast.jet.dag.tap.SinkTap: Return writers for the corresponding tap
getWrittenSize() - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
groupingBy(Distributed.Function<? super T, ? extends K>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector implementing a "group by" operation on input elements of type T, grouping elements according to a classification function, and returning the results in a Map.
groupingBy(Distributed.Function<? super T, ? extends K>, Distributed.Collector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream Distributed.Collector.
groupingBy(Distributed.Function<? super T, ? extends K>, Distributed.Supplier<M>, Distributed.Collector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream Distributed.Collector.
groupingByToIMap(Distributed.Function<? super T, ? extends K>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector implementing a "group by" operation on input elements of type T, grouping elements according to a classification function, and returning the results in a new distributed Hazelcast IMap.
groupingByToIMap(Distributed.Function<? super T, ? extends K>, Distributed.Collector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector implementing a cascaded "group by" operation on input elements of type T, grouping elements according to a classification function, and then performing a reduction operation on the values associated with a given key using the specified downstream Distributed.Collector.

H

hash(Object) - Method in interface com.hazelcast.jet.strategy.CalculationStrategy: Calculates hash of the corresponding object
hash(O, K, ContainerDescriptor) - Method in interface com.hazelcast.jet.strategy.HashingStrategy: Calculates the hash for a given object and partition key
hashCode() - Method in class com.hazelcast.jet.dag.Edge
hashCode() - Method in class com.hazelcast.jet.dag.Vertex
hashCode() - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
hashCode() - Method in class com.hazelcast.jet.strategy.IListBasedShufflingStrategy
hashCode() - Method in class com.hazelcast.jet.stream.Distributed.Optional: Returns the hash code value of the present value, if any, or 0 (zero) if no value is present.
hashingStrategy(HashingStrategy) - Method in class com.hazelcast.jet.dag.Edge.EdgeBuilder: Set the hashing strategy for the edge
HashingStrategy<O,K> - Interface in com.hazelcast.jet.strategy: Strategy to calculate hash for data passed between JET containers Used for example to determine correct task which should consume data For example object can be a tuple, partitionKey fields to be used for hash calculation
hasOutputShuffler() - Method in class com.hazelcast.jet.dag.Vertex

I

identity() - Static method in interface com.hazelcast.jet.stream.Distributed.DoubleUnaryOperator: Returns a unary operator that always returns its input argument.
identity() - Static method in interface com.hazelcast.jet.stream.Distributed.Function: Returns a function that always returns its input argument.
identity() - Static method in interface com.hazelcast.jet.stream.Distributed.IntUnaryOperator: Returns a unary operator that always returns its input argument.
identity() - Static method in interface com.hazelcast.jet.stream.Distributed.LongUnaryOperator: Returns a unary operator that always returns its input argument.
identity() - Static method in interface com.hazelcast.jet.stream.Distributed.UnaryOperator: Returns a unary operator that always returns its input argument.
ifPresent(Distributed.Consumer<? super T>) - Method in class com.hazelcast.jet.stream.Distributed.Optional: If a value is present, invoke the specified consumer with the value, otherwise do nothing.
IListBasedShufflingStrategy - Class in com.hazelcast.jet.strategy: Shuffling strategy based on IList internal logic
IListBasedShufflingStrategy(String) - Constructor for class com.hazelcast.jet.strategy.IListBasedShufflingStrategy: Constructs a new strategy with a given list name
interrupt() - Method in interface com.hazelcast.jet.application.Application: Interrupts application
INTERRUPTED_LISTENER_CALLER - Static variable in interface com.hazelcast.jet.container.ContainerListener: Predefined listener to be invoked on container interrupted
IOContext - Interface in com.hazelcast.jet.io: Context to work with Input/Output system
isClosed() - Method in interface com.hazelcast.jet.data.DataWriter
isEqual(Object) - Static method in interface com.hazelcast.jet.stream.Distributed.Predicate: Returns a predicate that tests if two arguments are equal according to Objects.equals(Object, Object).
isPartitioned() - Method in class com.hazelcast.jet.dag.tap.FileSink
isPartitioned() - Method in class com.hazelcast.jet.dag.tap.ListSink
isPartitioned() - Method in class com.hazelcast.jet.dag.tap.MapSink
isPartitioned() - Method in interface com.hazelcast.jet.dag.tap.SinkTap: Returns trueif sink is partitioned.
isPartitioned() - Method in interface com.hazelcast.jet.data.DataWriter
isPresent() - Method in class com.hazelcast.jet.stream.Distributed.Optional: Return true if there is a value present, otherwise false.
isShuffled() - Method in class com.hazelcast.jet.dag.Edge
IStreamList<E> - Interface in com.hazelcast.jet.stream: A decorator for IList for supporting distributed Stream implementation.
IStreamMap<K,V> - Interface in com.hazelcast.jet.stream: A decorator for IMap for supporting distributed Stream implementation.
iterator() - Method in interface com.hazelcast.jet.data.io.ProducerInputStream: Creates and return iterator over objects in inputStream

J

JetClientConfig - Class in com.hazelcast.jet.config: Extension of Hazelcast client configuration with Jet specific additions.
JetClientConfig() - Constructor for class com.hazelcast.jet.config.JetClientConfig: Constructs an empty config
JetConfig - Class in com.hazelcast.jet.config: Extension of Hazelcast member configuration with Jet specific additions.
JetConfig() - Constructor for class com.hazelcast.jet.config.JetConfig: Constructs an empty config
JetDataInput - Interface in com.hazelcast.jet.io.serialization: Provides serialization methods for arrays of primitive types which are located in off-heap Let us to work with long pointers
JetDataOutput - Interface in com.hazelcast.jet.io.serialization: Provides methods which let to access to serialized data
JetEngine - Class in com.hazelcast.jet: Utility class for creating new Jet Applications
JetException - Exception in com.hazelcast.jet: General Jet-exception
JetException(String) - Constructor for exception com.hazelcast.jet.JetException: Constructs an exception with a given message
JetInputFactory - Interface in com.hazelcast.jet.io.serialization: This is factory interface to create JetDataInput instance It lets us to de-serialize data directly from memory managed by some MemoryManager.
JetOutputFactory - Interface in com.hazelcast.jet.io.serialization: This is factory interface to create JetDataOutput instance It lets us to serialize data directly to some memory managed by some MemoryManager.
JetSerializationService - Interface in com.hazelcast.jet.io.serialization: Represents serialization service for JET module
JetTuple<K,V> - Interface in com.hazelcast.jet.data.tuple: Represents abstract tuple of integrated with another JET's abstractions
JetTuple2<K,V> - Class in com.hazelcast.jet.data.tuple: Jet Tuple implementation
JetTuple2(K, V) - Constructor for class com.hazelcast.jet.data.tuple.JetTuple2: Constructs a tuple with the given key and value
JetTuple2(K, V, int, CalculationStrategy) - Constructor for class com.hazelcast.jet.data.tuple.JetTuple2: Constructs a tuple with the given key, value, partition id and calculation strategy
JetTupleFactory - Interface in com.hazelcast.jet.data.tuple: Factory to create jet-tuple
joining() - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that concatenates the input elements into a String, in encounter order.
joining(CharSequence) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that concatenates the input elements, separated by the specified delimiter, in encounter order.
joining(CharSequence, CharSequence, CharSequence) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that concatenates the input elements, separated by the specified delimiter, with the specified prefix and suffix, in encounter order.

K

key - Variable in class com.hazelcast.jet.io.tuple.Tuple2
keySize - Variable in class com.hazelcast.jet.io.tuple.DefaultTuple
keySize() - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
keySize() - Method in interface com.hazelcast.jet.io.tuple.Tuple: Returns the size of the key array.
keySize() - Method in class com.hazelcast.jet.io.tuple.Tuple2

L

limit(long) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a stream consisting of the elements of this stream, truncated to be no longer than maxSize in length.
limit(long) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a stream consisting of the elements of this stream, truncated to be no longer than maxSize in length.
limit(long) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a stream consisting of the elements of this stream, truncated to be no longer than maxSize in length.
limit(long) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the elements of this stream, truncated to be no longer than maxSize in length.
ListSink - Class in com.hazelcast.jet.dag.tap: A sink which uses a Hazelcast IList as output.
ListSink(String) - Constructor for class com.hazelcast.jet.dag.tap.ListSink: Constructs a sink with the given list name.
ListSink(IList) - Constructor for class com.hazelcast.jet.dag.tap.ListSink: Constructs a sink with the given list instance.
ListSource - Class in com.hazelcast.jet.dag.tap: A source which uses a Hazelcast IList as the input.
ListSource(String) - Constructor for class com.hazelcast.jet.dag.tap.ListSource: Constructs a source with the given list name.
ListSource(IList) - Constructor for class com.hazelcast.jet.dag.tap.ListSource: Constructs a source with the given list.

M

map(Distributed.Function<? super T, ? extends U>) - Method in class com.hazelcast.jet.stream.Distributed.Optional: If a value is present, apply the provided mapping function to it, and if the result is non-null, return an Optional describing the result.
map(Distributed.DoubleUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a stream consisting of the results of applying the given function to the elements of this stream.
map(DoubleUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
map(Distributed.IntUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a stream consisting of the results of applying the given function to the elements of this stream.
map(IntUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
map(Distributed.LongUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a stream consisting of the results of applying the given function to the elements of this stream.
map(LongUnaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
map(Distributed.Function<? super T, ? extends R>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the results of applying the given function to the elements of this stream.
map(Function<? super T, ? extends R>) - Method in interface com.hazelcast.jet.stream.DistributedStream
mapping(Distributed.Function<? super T, ? extends U>, Distributed.Collector<? super U, A, R>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Adapts a Distributed.Collector accepting elements of type U to one accepting elements of type T by applying a mapping function to each input element before accumulation.
MapSink - Class in com.hazelcast.jet.dag.tap: A sink which uses a Hazelcast IMap as output.
MapSink(String) - Constructor for class com.hazelcast.jet.dag.tap.MapSink: Constructs a sink with the given map name.
MapSink(IMap) - Constructor for class com.hazelcast.jet.dag.tap.MapSink: Constructs a sink with the given list instance.
MapSource - Class in com.hazelcast.jet.dag.tap: A source which uses a Hazelcast IMap as the input.
MapSource(String) - Constructor for class com.hazelcast.jet.dag.tap.MapSource: Constructs a source with the given map name.
MapSource(IMap) - Constructor for class com.hazelcast.jet.dag.tap.MapSource: Constructs a source with the given map.
mapToDouble(Distributed.IntToDoubleFunction) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a DistributedDoubleStream consisting of the results of applying the given function to the elements of this stream.
mapToDouble(IntToDoubleFunction) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
mapToDouble(Distributed.LongToDoubleFunction) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a DoubleStream consisting of the results of applying the given function to the elements of this stream.
mapToDouble(LongToDoubleFunction) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
mapToDouble(Distributed.ToDoubleFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a DistributedDoubleStream consisting of the results of applying the given function to the elements of this stream.
mapToDouble(ToDoubleFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
mapToInt(Distributed.DoubleToIntFunction) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns an IntStream consisting of the results of applying the given function to the elements of this stream.
mapToInt(DoubleToIntFunction) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
mapToInt(Distributed.LongToIntFunction) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns an IntStream consisting of the results of applying the given function to the elements of this stream.
mapToInt(LongToIntFunction) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
mapToInt(Distributed.ToIntFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns an DistributedIntStream consisting of the results of applying the given function to the elements of this stream.
mapToInt(ToIntFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
mapToLong(Distributed.DoubleToLongFunction) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a LongStream consisting of the results of applying the given function to the elements of this stream.
mapToLong(DoubleToLongFunction) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
mapToLong(Distributed.IntToLongFunction) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a DistributedLongStream consisting of the results of applying the given function to the elements of this stream.
mapToLong(IntToLongFunction) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
mapToLong(Distributed.ToLongFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a DistributedLongStream consisting of the results of applying the given function to the elements of this stream.
mapToLong(ToLongFunction<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
mapToObj(Distributed.DoubleFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.
mapToObj(DoubleFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
mapToObj(Distributed.IntFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns an object-valued DistributedStream consisting of the results of applying the given function to the elements of this stream.
mapToObj(IntFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
mapToObj(Distributed.LongFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.
mapToObj(LongFunction<? extends U>) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
max(Distributed.Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns the maximum element of this stream according to the provided Distributed.Comparator.
max(Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
maxBy(Comparator<? super T>) - Static method in interface com.hazelcast.jet.stream.Distributed.BinaryOperator: Returns a Distributed.BinaryOperator which returns the greater of two elements according to the specified Comparator.
maxBy(Distributed.Comparator<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that produces the maximal element according to a given Distributed.Comparator, described as an Optional<T>.
merge(Accumulator<V, R>) - Method in interface com.hazelcast.jet.counters.Accumulator: Used by system internally to merge the collected parts of an accumulator at the end of the job.
min(Distributed.Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns the minimum element of this stream according to the provided Distributed.Comparator.
min(Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
minBy(Comparator<? super T>) - Static method in interface com.hazelcast.jet.stream.Distributed.BinaryOperator: Returns a Distributed.BinaryOperator which returns the lesser of two elements according to the specified Comparator.
minBy(Distributed.Comparator<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that produces the minimal element according to a given Distributed.Comparator, described as an Optional<T>.
MultiMapSink - Class in com.hazelcast.jet.dag.tap: A sink which uses a Hazelcast MultiMap as output.
MultiMapSink(String) - Constructor for class com.hazelcast.jet.dag.tap.MultiMapSink: Constructs a sink with the given multimap name.
MultiMapSink(MultiMap) - Constructor for class com.hazelcast.jet.dag.tap.MultiMapSink: Constructs a sink with the given multimap instance.
MultiMapSource - Class in com.hazelcast.jet.dag.tap: A source which uses a Hazelcast MultiMap as the input.
MultiMapSource(String) - Constructor for class com.hazelcast.jet.dag.tap.MultiMapSource: Constructs a source with the given multimap name.
MultiMapSource(MultiMap) - Constructor for class com.hazelcast.jet.dag.tap.MultiMapSource: Constructs a source with the given multimap.

N

naturalOrder() - Static method in interface com.hazelcast.jet.stream.Distributed.Comparator: Returns a comparator that compares Comparable objects in natural order.
negate() - Method in interface com.hazelcast.jet.stream.Distributed.BiPredicate: Returns a predicate that represents the logical negation of this predicate.
negate() - Method in interface com.hazelcast.jet.stream.Distributed.DoublePredicate: Returns a predicate that represents the logical negation of this predicate.
negate() - Method in interface com.hazelcast.jet.stream.Distributed.IntPredicate: Returns a predicate that represents the logical negation of this predicate.
negate() - Method in interface com.hazelcast.jet.stream.Distributed.LongPredicate: Returns a predicate that represents the logical negation of this predicate.
negate() - Method in interface com.hazelcast.jet.stream.Distributed.Predicate: Returns a predicate that represents the logical negation of this predicate.
newInstance() - Method in interface com.hazelcast.jet.strategy.DataTransferringStrategy: Creates new instance of object
noneMatch(Distributed.DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns whether no elements of this stream match the provided predicate.
noneMatch(DoublePredicate) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
noneMatch(Distributed.IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns whether no elements of this stream match the provided predicate.
noneMatch(IntPredicate) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
noneMatch(Distributed.LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns whether no elements of this stream match the provided predicate.
noneMatch(LongPredicate) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
noneMatch(Distributed.Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns whether no elements of this stream match the provided predicate.
noneMatch(Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
NULL_TYPE_ID - Static variable in interface com.hazelcast.jet.io.DataType: Type for the null values

O

ObjectReader<T> - Interface in com.hazelcast.jet.io: Represents abstract object reader from binary structure to Java.
ObjectReaderFactory - Interface in com.hazelcast.jet.io: Provides interface to work with object reader;
ObjectWriter<T> - Interface in com.hazelcast.jet.io: Represents abstract writer of Java object into binary format;
ObjectWriterFactory - Interface in com.hazelcast.jet.io: Provides API to create writers of Java objects into binary format;
of(Distributed.Supplier<R>, Distributed.BiConsumer<R, T>, Distributed.BinaryOperator<R>, Collector.Characteristics...) - Static method in interface com.hazelcast.jet.stream.Distributed.Collector: Returns a new Distributed.Collector described by the given supplier, accumulator, and combiner functions.
of(Distributed.Supplier<A>, Distributed.BiConsumer<A, T>, Distributed.BinaryOperator<A>, Distributed.Function<A, R>, Collector.Characteristics...) - Static method in interface com.hazelcast.jet.stream.Distributed.Collector: Returns a new Distributed.Collector described by the given supplier, accumulator, combiner, and finisher functions.
of(T) - Static method in class com.hazelcast.jet.stream.Distributed.Optional: Returns an Optional with the specified present non-null value.
ofNullable(T) - Static method in class com.hazelcast.jet.stream.Distributed.Optional: Returns an Optional describing the specified value, if non-null, otherwise returns an empty Optional.
onApplicationExecuted(ApplicationContext) - Method in interface com.hazelcast.jet.application.ApplicationListener: Will be invoked after finish of application execution
onContainerExecuted() - Method in interface com.hazelcast.jet.container.ContainerListener: Will be invoked when container has been executed
onContainerExecutionFailure(Throwable) - Method in interface com.hazelcast.jet.container.ContainerListener: Will be invoked on container's execution failure
onContainerExecutionInterrupted() - Method in interface com.hazelcast.jet.container.ContainerListener: Will be invoked when container has been interrupted
or(Distributed.BiPredicate<? super T, ? super U>) - Method in interface com.hazelcast.jet.stream.Distributed.BiPredicate: Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.
or(Distributed.DoublePredicate) - Method in interface com.hazelcast.jet.stream.Distributed.DoublePredicate: Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.
or(Distributed.IntPredicate) - Method in interface com.hazelcast.jet.stream.Distributed.IntPredicate: Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.
or(Distributed.LongPredicate) - Method in interface com.hazelcast.jet.stream.Distributed.LongPredicate: Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.
or(Distributed.Predicate<? super T>) - Method in interface com.hazelcast.jet.stream.Distributed.Predicate: Returns a composed predicate that represents a short-circuiting logical OR of this predicate and another.
orElse(T) - Method in class com.hazelcast.jet.stream.Distributed.Optional: Return the value if present, otherwise return other.
orElseGet(Distributed.Supplier<? extends T>) - Method in class com.hazelcast.jet.stream.Distributed.Optional: Return the value if present, otherwise invoke other and return the result of that invocation.
orElseThrow(Distributed.Supplier<? extends X>) - Method in class com.hazelcast.jet.stream.Distributed.Optional: Return the contained value, if present, otherwise throw an exception to be created by the provided supplier.

P

parallel() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns an equivalent stream that is parallel.
parallel() - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns an equivalent stream that is parallel.
parallel() - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns an equivalent stream that is parallel.
parallel() - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns an equivalent stream that is parallel.
parallelStream() - Method in interface com.hazelcast.jet.stream.IStreamList: Returns a parallel Stream with this list as its source.
PartitionIdAware - Interface in com.hazelcast.jet: Something which knows about partitionId Examples:
partitioningBy(Distributed.Predicate<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector which partitions the input elements according to a Distributed.Predicate, and organizes them into a Map<Boolean, List<T>>.
partitioningBy(Distributed.Predicate<? super T>, Distributed.Collector<? super T, A, D>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector which partitions the input elements according to a Distributed.Predicate, reduces the values in each partition according to another Distributed.Collector, and organizes them into a Map<Boolean, D> whose values are the result of the downstream reduction.
partitioningStrategy(PartitioningStrategy) - Method in class com.hazelcast.jet.dag.Edge.EdgeBuilder: Set the partitioning strategy for the edge
peek(Distributed.DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
peek(DoubleConsumer) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
peek(Distributed.IntConsumer) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
peek(IntConsumer) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
peek(Distributed.LongConsumer) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
peek(LongConsumer) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
peek(Distributed.Consumer<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
peek(Consumer<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
position() - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
position(long) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
position() - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
position(long) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
printStackTrace(PrintStream) - Method in exception com.hazelcast.jet.CombinedJetException: Print stack trace of all the exceptions
process(ProducerInputStream, ConsumerOutputStream<O>, String, ProcessorContext) - Method in interface com.hazelcast.jet.processor.ContainerProcessor: Performs next iteration of execution
processingStrategy(ProcessingStrategy) - Method in class com.hazelcast.jet.dag.Edge.EdgeBuilder: Set the processing strategy for the edge
ProcessingStrategy - Enum in com.hazelcast.jet.strategy: Strategy which determines how data should be passed from one JET container to another
ProcessorContext - Interface in com.hazelcast.jet.container: Represents context of processing container
ProcessorDescriptor - Class in com.hazelcast.jet.processor: Descriptor with vertex properties Used inside vertex construction
ProcessorDescriptor() - Constructor for class com.hazelcast.jet.processor.ProcessorDescriptor
ProcessorDescriptor.Builder - Class in com.hazelcast.jet.processor: Builder class to construct ProcessorDescriptor instances
ProducerInputStream<T> - Interface in com.hazelcast.jet.data.io: Represents abstract inputStream to read objects
putApplicationVariable(String, T) - Method in interface com.hazelcast.jet.container.ContainerDescriptor: Set-up application variable

R

read(ObjectDataInput, ObjectReaderFactory) - Method in interface com.hazelcast.jet.io.ObjectReader: Read object from the binary source represented by objectDataInput;
read() - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
read(long) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readBoolean(long) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readByte(long) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readChar(long) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readData(ObjectDataInput) - Method in class com.hazelcast.jet.dag.DAG
readData(ObjectDataInput) - Method in class com.hazelcast.jet.data.tuple.JetTuple2
readData(ObjectDataInput) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
readData(ObjectDataInput) - Method in class com.hazelcast.jet.io.tuple.Tuple2
readDouble(int) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readDouble(ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readDouble(long, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readFloat(int) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readFloat(ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readFloat(int, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readInt(ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readInt(long, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readLong(ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readLong(long, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readShort(long) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readShort(ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
readShort(long, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
reduce(double, Distributed.DoubleBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Performs a reduction on the elements of this stream, using the provided identity value and an associative accumulation function, and returns the reduced value.
reduce(Distributed.DoubleBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Performs a reduction on the elements of this stream, using an associative accumulation function, and returns an OptionalDouble describing the reduced value, if any.
reduce(double, DoubleBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
reduce(DoubleBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream
reduce(int, Distributed.IntBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Performs a reduction on the elements of this stream, using the provided identity value and an associative accumulation function, and returns the reduced value.
reduce(Distributed.IntBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Performs a reduction on the elements of this stream, using an associative accumulation function, and returns an OptionalInt describing the reduced value, if any.
reduce(int, IntBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
reduce(IntBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedIntStream
reduce(long, Distributed.LongBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Performs a reduction on the elements of this stream, using the provided identity value and an associative accumulation function, and returns the reduced value.
reduce(Distributed.LongBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Performs a reduction on the elements of this stream, using an associative accumulation function, and returns an OptionalLong describing the reduced value, if any.
reduce(long, LongBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
reduce(LongBinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedLongStream
reduce(T, Distributed.BinaryOperator<T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Performs a reduction on the elements of this stream, using the provided identity value and an associative accumulation function, and returns the reduced value.
reduce(Distributed.BinaryOperator<T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Performs a reduction on the elements of this stream, using an associative accumulation function, and returns an Optional describing the reduced value, if any.
reduce(U, Distributed.BiFunction<U, ? super T, U>, Distributed.BinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedStream: Performs a reduction on the elements of this stream, using the provided identity, accumulation and combining functions.
reduce(T, BinaryOperator<T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
reduce(BinaryOperator<T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
reduce(U, BiFunction<U, ? super T, U>, BinaryOperator) - Method in interface com.hazelcast.jet.stream.DistributedStream
reducing(T, Distributed.BinaryOperator<T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector which performs a reduction of its input elements under a specified Distributed.BinaryOperator using the provided identity.
reducing(Distributed.BinaryOperator<T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector which performs a reduction of its input elements under a specified Distributed.BinaryOperator.
reducing(U, Distributed.Function<? super T, ? extends U>, Distributed.BinaryOperator) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector which performs a reduction of its input elements under a specified mapping function and Distributed.BinaryOperator.
registerApplicationListener(ApplicationListener) - Method in interface com.hazelcast.jet.container.ContainerDescriptor: Performs registration of application listener
registerContainerListener(String, ContainerListener) - Method in interface com.hazelcast.jet.container.ContainerDescriptor: Performs registration of container listener
registerDataType(DataType) - Method in interface com.hazelcast.jet.executor.TaskContext: Register dataType for serialization purposes
registerDataType(DataType) - Method in interface com.hazelcast.jet.io.IOContext
reset(long, long) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
resetLocal() - Method in interface com.hazelcast.jet.counters.Accumulator: Reset the local value.
reverseOrder() - Static method in interface com.hazelcast.jet.stream.Distributed.Comparator: Returns a comparator that imposes the reverse of the natural ordering.

S

sequential() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns an equivalent stream that is sequential.
sequential() - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns an equivalent stream that is sequential.
sequential() - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns an equivalent stream that is sequential.
sequential() - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns an equivalent stream that is sequential.
setAccumulator(CounterKey, Accumulator<V, R>) - Method in interface com.hazelcast.jet.container.ContainerDescriptor
setAccumulator(CounterKey, Accumulator<V, R>) - Method in interface com.hazelcast.jet.executor.TaskContext: Set new accumulator assigned to corresponding counterKey
setApplicationDirectoryCreationAttemptsCount(int) - Method in class com.hazelcast.jet.config.ApplicationConfig: Sets the maximum number of attempts to create a temp directory during localization
setChunkSize(int) - Method in class com.hazelcast.jet.config.ApplicationConfig: Sets the size of the chunk that will be processed at each call in ContainerProcessor.process
setIoThreadCount(int) - Method in class com.hazelcast.jet.config.JetConfig: Sets the number of I/O threads to use
setKey(int, K) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
setKey(int, K) - Method in interface com.hazelcast.jet.io.tuple.Tuple: Puts the given object into the given key slot.
setKey(int, K) - Method in class com.hazelcast.jet.io.tuple.Tuple2
setLocalizationDirectory(String) - Method in class com.hazelcast.jet.config.ApplicationConfig: Sets the name of the directory to be used for localization
setMemoryManager(MemoryManager) - Method in interface com.hazelcast.jet.io.serialization.JetDataInput
setMemoryManager(MemoryManager) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
setName(String) - Method in class com.hazelcast.jet.config.ApplicationConfig: Sets the name of the application
setPort(int) - Method in class com.hazelcast.jet.config.JetConfig: Sets the port which Jet listens on
setProcessingThreadCount(int) - Method in class com.hazelcast.jet.config.JetConfig: Sets the number of processing threads to use
setRingbufferSize(int) - Method in class com.hazelcast.jet.config.ApplicationConfig: Sets the size of the ringbuffer used when passing data between processors
setSecondsToAwait(int) - Method in class com.hazelcast.jet.config.ApplicationConfig: Sets the internal timeout of the application
setShufflingBatchSizeBytes(int) - Method in class com.hazelcast.jet.config.ApplicationConfig: Sets the size of the batch to send when shuffling data to other nodes
setShutdownTimeoutSeconds(int) - Method in class com.hazelcast.jet.config.JetConfig: Sets the timeout to use when shutting down threads
setTcpBufferSize(int) - Method in class com.hazelcast.jet.config.ApplicationConfig: Set the TCP buffer size used when writing to network
setValue(int, V) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
setValue(int, V) - Method in interface com.hazelcast.jet.io.tuple.Tuple: Puts the given object into the given value slot.
setValue(int, V) - Method in class com.hazelcast.jet.io.tuple.Tuple2
shuffling(boolean) - Method in class com.hazelcast.jet.dag.Edge.EdgeBuilder: Set if the edge is shuffled
shufflingStrategy(ShufflingStrategy) - Method in class com.hazelcast.jet.dag.Edge.EdgeBuilder: Set the shuffling strategy on the edge
ShufflingStrategy - Interface in com.hazelcast.jet.strategy: Strategy which determines Hazelcast's nodes addresses where data should be sent during shuffling process between vertices For example:
SimpleAccumulator<T extends Serializable> - Interface in com.hazelcast.jet.counters: Accumulator with the similar of the input and output types
SinkTap - Interface in com.hazelcast.jet.dag.tap: Abstract class which represents any sink tap
size() - Method in interface com.hazelcast.jet.data.io.ProducerInputStream
skip(long) - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a stream consisting of the remaining elements of this stream after discarding the first n elements of the stream.
skip(long) - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a stream consisting of the remaining elements of this stream after discarding the first n elements of the stream.
skip(long) - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a stream consisting of the remaining elements of this stream after discarding the first n elements of the stream.
skip(long) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the remaining elements of this stream after discarding the first n elements of the stream.
sorted() - Method in interface com.hazelcast.jet.stream.DistributedDoubleStream: Returns a stream consisting of the elements of this stream in sorted order.
sorted() - Method in interface com.hazelcast.jet.stream.DistributedIntStream: Returns a stream consisting of the elements of this stream in sorted order.
sorted() - Method in interface com.hazelcast.jet.stream.DistributedLongStream: Returns a stream consisting of the elements of this stream in sorted order.
sorted() - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the elements of this stream, sorted according to natural order.
sorted(Distributed.Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns a stream consisting of the elements of this stream, sorted according to the provided Comparator.
sorted(Comparator<? super T>) - Method in interface com.hazelcast.jet.stream.DistributedStream
SourceTap - Interface in com.hazelcast.jet.dag.tap: Represents abstract source tap
stepOn(long) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
stream() - Method in interface com.hazelcast.jet.stream.IStreamList: Returns a sequential Stream with this list as its source.
stream() - Method in interface com.hazelcast.jet.stream.IStreamMap: Returns a parallel and distributed Stream with this list as its source.
streamList(IList<E>) - Static method in interface com.hazelcast.jet.stream.IStreamList: Returns an IList with a DistributedStream support.
streamMap(IMap<K, V>) - Static method in interface com.hazelcast.jet.stream.IStreamMap: Returns an IMap with DistributedStream support.
submit(DAG, Class...) - Method in interface com.hazelcast.jet.application.Application: Submit dag to the cluster
summarizingDouble(Distributed.ToDoubleFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector which applies an double-producing mapping function to each input element, and returns summary statistics for the resulting values.
summarizingInt(Distributed.ToIntFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector which applies an int-producing mapping function to each input element, and returns summary statistics for the resulting values.
summarizingLong(Distributed.ToLongFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector which applies an long-producing mapping function to each input element, and returns summary statistics for the resulting values.
summingDouble(Distributed.ToDoubleFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that produces the sum of a double-valued function applied to the input elements.
summingInt(Distributed.ToIntFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that produces the sum of a integer-valued function applied to the input elements.
summingLong(Distributed.ToLongFunction<? super T>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that produces the sum of a long-valued function applied to the input elements.
supplier() - Method in interface com.hazelcast.jet.stream.Distributed.Collector: A function that creates and returns a new mutable result container.

T

TaskContext - Interface in com.hazelcast.jet.executor: Represents task context Holds task's information
toCollection(Distributed.Supplier<C>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates the input elements into a new Collection, in encounter order.
toIList() - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates the input elements into a new Hazelcast IList.
toIMap(Distributed.Function<? super T, ? extends K>, Distributed.Function<? super T, ? extends U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates elements into a new Hazelcast IMap whose keys and values are the result of applying the provided mapping functions to the input elements.
toIMap() - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates elements into a new distributed Hazelcast IMap whose keys and values are the keys and values of the corresponding Map.Entry.
toIMap(Distributed.Function<? super T, ? extends K>, Distributed.Function<? super T, ? extends U>, Distributed.BinaryOperator) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates elements into a new distributed Hazelcast IMap whose keys and values are the result of applying the provided mapping functions to the input elements.
toList() - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates the input elements into a new List.
toMap(Distributed.Function<? super T, ? extends K>, Distributed.Function<? super T, ? extends U>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.
toMap(Distributed.Function<? super T, ? extends K>, Distributed.Function<? super T, ? extends U>, Distributed.BinaryOperator) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.
toMap(Distributed.Function<? super T, ? extends K>, Distributed.Function<? super T, ? extends U>, Distributed.BinaryOperator, Distributed.Supplier<M>) - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates elements into a Map whose keys and values are the result of applying the provided mapping functions to the input elements.
toSet() - Static method in class com.hazelcast.jet.stream.DistributedCollectors: Returns a Distributed.Collector that accumulates the input elements into a new Set.
toString() - Method in class com.hazelcast.jet.dag.Edge
toString() - Method in class com.hazelcast.jet.stream.Distributed.Optional: Returns a non-empty string representation of this Optional suitable for debugging.
tuple(K, V, int, CalculationStrategy) - Method in interface com.hazelcast.jet.data.tuple.JetTupleFactory: Will create tuple with 1-element key part and 1-element value part
tuple(K, V[], int, CalculationStrategy) - Method in interface com.hazelcast.jet.data.tuple.JetTupleFactory: Will create tuple with 1-element key part and multi-element value part
tuple(K[], V[], int, CalculationStrategy) - Method in interface com.hazelcast.jet.data.tuple.JetTupleFactory: Will create tuple with multi-element key part and multi-element value part
tuple(K, V) - Method in class com.hazelcast.jet.io.tuple.DefaultTupleFactory
tuple(K, V[]) - Method in class com.hazelcast.jet.io.tuple.DefaultTupleFactory
tuple(K[], V[]) - Method in class com.hazelcast.jet.io.tuple.DefaultTupleFactory
Tuple<K,V> - Interface in com.hazelcast.jet.io.tuple: A record consisting (conceptually) of an array of keys and an array of values.
tuple(K, V) - Method in interface com.hazelcast.jet.io.tuple.TupleFactory: Will create tuple with 1-element key part and 1-element value part;
tuple(K, V[]) - Method in interface com.hazelcast.jet.io.tuple.TupleFactory: Will create tuple with 1-element key part and multi-element value part
tuple(K[], V[]) - Method in interface com.hazelcast.jet.io.tuple.TupleFactory: Will create tuple with multi-element key part and multi-element value part;
Tuple2<K,V> - Class in com.hazelcast.jet.io.tuple
Tuple2() - Constructor for class com.hazelcast.jet.io.tuple.Tuple2
Tuple2(K, V) - Constructor for class com.hazelcast.jet.io.tuple.Tuple2
TupleFactory - Interface in com.hazelcast.jet.io.tuple: Factory to create tuple;
Types - Enum in com.hazelcast.jet.io

U

unordered() - Method in interface com.hazelcast.jet.stream.DistributedStream: Returns an equivalent stream that is unordered.

V

validate() - Method in class com.hazelcast.jet.dag.DAG: Validate DAG's consistency
value - Variable in class com.hazelcast.jet.io.tuple.Tuple2
valueOf(String) - Static method in enum com.hazelcast.jet.io.Types: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.hazelcast.jet.strategy.ProcessingStrategy: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.hazelcast.jet.io.Types: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.hazelcast.jet.strategy.ProcessingStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
valueSize - Variable in class com.hazelcast.jet.io.tuple.DefaultTuple
valueSize() - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
valueSize() - Method in interface com.hazelcast.jet.io.tuple.Tuple: Returns the size of the value array.
valueSize() - Method in class com.hazelcast.jet.io.tuple.Tuple2
Vertex - Class in com.hazelcast.jet.dag: Represents vertex of the Direct Acyclic Graph
Vertex(String, ProcessorDescriptor) - Constructor for class com.hazelcast.jet.dag.Vertex: Constructs a new vertex with given name and processor descriptor

W

withTaskCount(int) - Method in class com.hazelcast.jet.processor.ProcessorDescriptor.Builder: Define amount of tasks inside the corresponding container
write(T, ObjectDataOutput, ObjectWriterFactory) - Method in interface com.hazelcast.jet.io.ObjectWriter: Write type and entries of the object;
write(long, int) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeBoolean(long, boolean) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeByte(long, int) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeChar(long, int) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeData(ObjectDataOutput) - Method in class com.hazelcast.jet.dag.DAG
writeData(ObjectDataOutput) - Method in class com.hazelcast.jet.data.tuple.JetTuple2
writeData(ObjectDataOutput) - Method in class com.hazelcast.jet.io.tuple.DefaultTuple
writeData(ObjectDataOutput) - Method in class com.hazelcast.jet.io.tuple.Tuple2
writeDouble(long, double) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeDouble(double, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeDouble(long, double, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeFloat(long, float) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeFloat(float, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeFloat(long, float, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeInt(long, int) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeInt(int, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeInt(long, int, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeLong(long, long) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeLong(long, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeLong(long, long, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writePayLoad(T, ObjectDataOutput, ObjectWriterFactory) - Method in interface com.hazelcast.jet.io.ObjectWriter: Write entries of the object as binary representation;
writeShort(long, int) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeShort(int, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeShort(long, int, ByteOrder) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput
writeType(T, ObjectDataOutput, ObjectWriterFactory) - Method in interface com.hazelcast.jet.io.ObjectWriter: Writes type of the object;
writeZeroBytes(int) - Method in interface com.hazelcast.jet.io.serialization.JetDataOutput

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