Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.avro |
Apache Avro file read/write support for Hazelcast Jet.
|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
com.hazelcast.jet.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.hadoop |
Apache Hadoop HDFS read/write support for Hazelcast Jet.
|
com.hazelcast.jet.kafka |
Apache Kafka reader/writer support for Hazelcast Jet.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Class and Description |
---|
DistributedFunction
Serializable variant of java.util.function.Function
which declares checked exception. |
DistributedPredicate
Serializable variant of java.util.function.Predicate which declares checked exception. |
Class and Description |
---|
DistributedBiConsumer
Serializable variant of java.util.function.BiConsumer which declares checked exception. |
DistributedBiFunction
Serializable variant of java.util.function.BiFunction which declares checked exception. |
DistributedBinaryOperator
Serializable variant of java.util.function.BinaryOperator which declares checked exception. |
DistributedComparator
Serializable variant of java.util.Comparator
which declares checked exception. |
DistributedFunction
Serializable variant of java.util.function.Function
which declares checked exception. |
DistributedSupplier
Serializable variant of java.util.function.Supplier
which declares checked exception. |
DistributedToDoubleFunction
Serializable variant of java.util.function.ToDoubleFunction which declares checked exception. |
DistributedToLongFunction
Serializable variant of java.util.function.ToLongFunction which declares checked exception. |
DistributedTriFunction
Serializable variant of TriFunction which declares checked
exception. |
Class and Description |
---|
DistributedBiFunction
Serializable variant of java.util.function.BiFunction which declares checked exception. |
DistributedSupplier
Serializable variant of java.util.function.Supplier
which declares checked exception. |
Class and Description |
---|
DistributedFunction
Serializable variant of java.util.function.Function
which declares checked exception. |
DistributedObjLongBiFunction
Serializable variant of com.hazelcast.jet.function.ObjLongBiFunction declares throws checked
exception. |
DistributedSupplier
Serializable variant of java.util.function.Supplier
which declares checked exception. |
DistributedToLongFunction
Serializable variant of java.util.function.ToLongFunction which declares checked exception. |
Class and Description |
---|
DistributedBiConsumer
Serializable variant of java.util.function.BiConsumer which declares checked exception. |
DistributedBiFunction
Serializable variant of java.util.function.BiFunction which declares checked exception. |
DistributedBinaryOperator
Serializable variant of java.util.function.BinaryOperator which declares checked exception. |
DistributedBiPredicate
Serializable variant of java.util.function.BiPredicate which declares checked exception. |
DistributedConsumer
Serializable variant of java.util.function.Consumer
which declares checked exception. |
DistributedFunction
Serializable variant of java.util.function.Function
which declares checked exception. |
DistributedPredicate
Serializable variant of java.util.function.Predicate which declares checked exception. |
DistributedSupplier
Serializable variant of java.util.function.Supplier
which declares checked exception. |
DistributedToLongFunction
Serializable variant of java.util.function.ToLongFunction which declares checked exception. |
DistributedTriFunction
Serializable variant of TriFunction which declares checked
exception. |
KeyedWindowResultFunction
Represents the function you pass to a windowed group-and-aggregate
method in the Pipeline API, such as
stage.aggregate() . |
ToResultSetFunction
A function that accepts a JDBC connection to the database, the total
parallelism and processor index as arguments and produces a result set.
|
Class and Description |
---|
DistributedSupplier
Serializable variant of java.util.function.Supplier
which declares checked exception. |
Class and Description |
---|
DistributedBiConsumer
Serializable variant of java.util.function.BiConsumer which declares checked exception. |
DistributedBiFunction
Serializable variant of java.util.function.BiFunction which declares checked exception. |
DistributedBinaryOperator
Serializable variant of java.util.function.BinaryOperator which declares checked exception. |
DistributedBiPredicate
Serializable variant of java.util.function.BiPredicate which declares checked exception. |
DistributedComparator
Serializable variant of java.util.Comparator
which declares checked exception. |
DistributedConsumer
Serializable variant of java.util.function.Consumer
which declares checked exception. |
DistributedDoubleConsumer
Serializable variant of java.util.function.DoubleConsumer which declares checked exception. |
DistributedDoublePredicate
Serializable variant of java.util.function.DoublePredicate which declares checked exception. |
DistributedDoubleUnaryOperator
Serializable variant of java.util.function.DoubleUnaryOperator which declares checked exception. |
DistributedFunction
Serializable variant of java.util.function.Function
which declares checked exception. |
DistributedIntConsumer
Serializable variant of java.util.function.IntConsumer which declares checked exception. |
DistributedIntPredicate
Serializable variant of java.util.function.IntPredicate which declares checked exception. |
DistributedIntUnaryOperator
Serializable variant of java.util.function.IntUnaryOperator which declares checked exception. |
DistributedLongConsumer
Serializable variant of java.util.function.LongConsumer which declares checked exception. |
DistributedLongPredicate
Serializable variant of java.util.function.LongPredicate which declares checked exception. |
DistributedLongUnaryOperator
Serializable variant of java.util.function.LongUnaryOperator which declares checked exception. |
DistributedPredicate
Serializable variant of java.util.function.Predicate which declares checked exception. |
DistributedToDoubleFunction
Serializable variant of java.util.function.ToDoubleFunction which declares checked exception. |
DistributedToIntFunction
Serializable variant of java.util.function.ToIntFunction which declares checked exception. |
DistributedToLongFunction
Serializable variant of java.util.function.ToLongFunction which declares checked exception. |
DistributedTriPredicate
Serializable variant of TriPredicate which declares checked
exception. |
DistributedUnaryOperator
Serializable variant of java.util.function.UnaryOperator which declares checked exception. |
KeyedWindowResult2Function
Represents the function you pass to a windowed group-and-aggregate
method in the Pipeline API, such as
stage.aggregate2() . |
KeyedWindowResult3Function
Represents the function you pass to a windowed group-and-aggregate
method in the Pipeline API, such as
stage.aggregate3() . |
KeyedWindowResultFunction
Represents the function you pass to a windowed group-and-aggregate
method in the Pipeline API, such as
stage.aggregate() . |
ObjLongBiFunction
Represents a specialization of
BiFunction where
the second argument is a long . |
QuadFunction
Represents a four-arity function that accepts four arguments and
produces a result.
|
TriFunction
Represents a three-arity function that accepts three arguments and
produces a result.
|
TriPredicate
Represents a predicate which accepts three arguments.
|
Class and Description |
---|
DistributedBiFunction
Serializable variant of java.util.function.BiFunction which declares checked exception. |
DistributedFunction
Serializable variant of java.util.function.Function
which declares checked exception. |
Class and Description |
---|
DistributedFunction
Serializable variant of java.util.function.Function
which declares checked exception. |
Class and Description |
---|
DistributedBiConsumer
Serializable variant of java.util.function.BiConsumer which declares checked exception. |
DistributedBiFunction
Serializable variant of java.util.function.BiFunction which declares checked exception. |
DistributedBinaryOperator
Serializable variant of java.util.function.BinaryOperator which declares checked exception. |
DistributedBiPredicate
Serializable variant of java.util.function.BiPredicate which declares checked exception. |
DistributedConsumer
Serializable variant of java.util.function.Consumer
which declares checked exception. |
DistributedFunction
Serializable variant of java.util.function.Function
which declares checked exception. |
DistributedPredicate
Serializable variant of java.util.function.Predicate which declares checked exception. |
DistributedQuadFunction
Serializable variant of QuadFunction which declares checked
exception. |
DistributedSupplier
Serializable variant of java.util.function.Supplier
which declares checked exception. |
DistributedToLongFunction
Serializable variant of java.util.function.ToLongFunction which declares checked exception. |
DistributedTriFunction
Serializable variant of TriFunction which declares checked
exception. |
DistributedTriPredicate
Serializable variant of TriPredicate which declares checked
exception. |
KeyedWindowResult2Function
Represents the function you pass to a windowed group-and-aggregate
method in the Pipeline API, such as
stage.aggregate2() . |
KeyedWindowResult3Function
Represents the function you pass to a windowed group-and-aggregate
method in the Pipeline API, such as
stage.aggregate3() . |
KeyedWindowResultFunction
Represents the function you pass to a windowed group-and-aggregate
method in the Pipeline API, such as
stage.aggregate() . |
ToResultSetFunction
A function that accepts a JDBC connection to the database, the total
parallelism and processor index as arguments and produces a result set.
|
WindowResult2Function
Represents the function you pass to a windowed aggregation method in the
Pipeline API, such as
stage.aggregate2() , that aggregates two input streams. |
WindowResult3Function
Represents the function you pass to a windowed aggregation method in the
Pipeline API, such as
stage.aggregate2() , that aggregates two input streams. |
WindowResultFunction
Represents the function you pass to a windowed aggregation method in the
Pipeline API, such as
stage.aggregate() . |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.