Uses of Package
com.hazelcast.function
Package | Description |
---|---|
com.hazelcast.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
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.cdc |
Contains source/sink connectors that deal with Change Data Capture (CDC)
events from various databases as well as a generic connector for Debezium
CDC sources.
|
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.elastic |
Contains sources and sinks for Elasticsearch 7
|
com.hazelcast.jet.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.grpc |
Contributes
gRPC service factories that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service. |
com.hazelcast.jet.hadoop |
Apache Hadoop 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.
|
com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
com.hazelcast.jet.python |
Contributes a
PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig)
transform that allows you to transform Jet pipeline data using a Python
function. |
com.hazelcast.jet.s3 |
AWS S3 read/write support for Hazelcast Jet.
|
-
Classes in com.hazelcast.function used by com.hazelcast.function Class Description BiConsumerEx Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.BiFunctionEx Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.BinaryOperatorEx Serializable
variant ofjava.util.function.BinaryOperator
which declares checked exception.BiPredicateEx Serializable
variant ofjava.util.function.BiPredicate
which declares checked exception.ComparatorEx Serializable
variant ofjava.util.Comparator
which declares checked exception.ConsumerEx Serializable
variant ofjava.util.function.Consumer
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.PredicateEx Serializable
variant ofjava.util.function.Predicate
which declares checked exception.ToDoubleFunctionEx Serializable
variant ofjava.util.function.ToDoubleFunction
which declares checked exception.ToIntFunctionEx Serializable
variant ofjava.util.function.ToIntFunction
which declares checked exception.ToLongFunctionEx Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet Class Description FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.PredicateEx Serializable
variant ofjava.util.function.Predicate
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.aggregate Class Description BiConsumerEx Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.BiFunctionEx Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.BinaryOperatorEx Serializable
variant ofjava.util.function.BinaryOperator
which declares checked exception.ComparatorEx Serializable
variant ofjava.util.Comparator
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.PredicateEx Serializable
variant ofjava.util.function.Predicate
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception.ToDoubleFunctionEx Serializable
variant ofjava.util.function.ToDoubleFunction
which declares checked exception.ToLongFunctionEx Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.avro Class Description BiFunctionEx Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.cdc Class Description FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.core Class Description ComparatorEx Serializable
variant ofjava.util.Comparator
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception.ToLongFunctionEx Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.core.processor Class Description BiConsumerEx Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.BiFunctionEx Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.BinaryOperatorEx Serializable
variant ofjava.util.function.BinaryOperator
which declares checked exception.BiPredicateEx Serializable
variant ofjava.util.function.BiPredicate
which declares checked exception.ConsumerEx Serializable
variant ofjava.util.function.Consumer
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.PredicateEx Serializable
variant ofjava.util.function.Predicate
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception.ToLongFunctionEx Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.core.test Class Description SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.elastic Class Description FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.function Class Description ConsumerEx Serializable
variant ofjava.util.function.Consumer
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.grpc Class Description BiConsumerEx Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.hadoop Class Description BiFunctionEx Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.kafka Class Description FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.pipeline Class Description BiConsumerEx Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.BiFunctionEx Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.BinaryOperatorEx Serializable
variant ofjava.util.function.BinaryOperator
which declares checked exception.BiPredicateEx Serializable
variant ofjava.util.function.BiPredicate
which declares checked exception.ComparatorEx Serializable
variant ofjava.util.Comparator
which declares checked exception.ConsumerEx Serializable
variant ofjava.util.function.Consumer
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.PredicateEx Serializable
variant ofjava.util.function.Predicate
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception.ToLongFunctionEx Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.pipeline.test Class Description BiConsumerEx Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.ConsumerEx Serializable
variant ofjava.util.function.Consumer
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.python Class Description FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.s3 Class Description BiFunctionEx Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.FunctionEx Serializable
variant ofjava.util.function.Function
which declares checked exception.SupplierEx Serializable
variant ofjava.util.function.Supplier
which declares checked exception.