Uses of Package
com.hazelcast.function
Package
Description
Serializable and exception-declaring variants of functional interfaces from
java.util.function
.Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Contains
AggregateOperation
and its several variants, as well
as a builder object for the aggregate operations.Apache Avro file read/write support for Hazelcast Jet.
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.
Jet's Core API.
Contains static utility classes with factories of Jet processors.
Utilities for writing tests of Core API Processors.
Contains sources and sinks for Elasticsearch 7
Serializable and exception-declaring variants of functional interfaces from
java.util.function
.Contributes
gRPC service factories
that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service.Apache Hadoop read/write support for Hazelcast Jet.
Apache Kafka reader/writer support for Hazelcast Jet.
Contains a generic Kafka Connect source provides ability to plug any Kafka
Connect source for data ingestion to Jet pipelines.
Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.
Contains sources and sinks for MongoDB.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
This package contains various mock sources to help with pipeline testing
and development.
Contributes a
PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig)
transform that allows you to transform Jet pipeline data using a Python
function.AWS S3 read/write support for Hazelcast Jet.
-
ClassDescription
Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.BinaryOperator
which declares checked exception.Serializable
variant ofjava.util.function.BiPredicate
which declares checked exception.Serializable
variant ofjava.util.Comparator
which declares checked exception.Serializable
variant ofjava.util.function.Consumer
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Predicate
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception.Serializable
variant ofjava.util.function.ToDoubleFunction
which declares checked exception.Serializable
variant ofjava.util.function.ToIntFunction
which declares checked exception.Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Predicate
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.BinaryOperator
which declares checked exception.Serializable
variant ofjava.util.Comparator
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Predicate
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception.Serializable
variant ofjava.util.function.ToDoubleFunction
which declares checked exception.Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.Function
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.Comparator
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception.Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.BinaryOperator
which declares checked exception.Serializable
variant ofjava.util.function.BiPredicate
which declares checked exception.Serializable
variant ofjava.util.function.Consumer
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Predicate
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception.Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.Consumer
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.Consumer
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.Function
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.Function
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.Consumer
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.BinaryOperator
which declares checked exception.Serializable
variant ofjava.util.function.BiPredicate
which declares checked exception.Serializable
variant ofjava.util.Comparator
which declares checked exception.Serializable
variant ofjava.util.function.Consumer
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Predicate
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception.Serializable
variant ofjava.util.function.ToLongFunction
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiConsumer
which declares checked exception.Serializable
variant ofjava.util.function.Consumer
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception. -
ClassDescription
Serializable
variant ofjava.util.function.BiFunction
which declares checked exception.Serializable
variant ofjava.util.function.Function
which declares checked exception.Serializable
variant ofjava.util.function.Supplier
which declares checked exception.