Uses of Package
com.hazelcast.function
Packages that use 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.
-
Classes in com.hazelcast.function used by com.hazelcast.functionClassDescription
Serializablevariant ofjava.util.function.BiConsumerwhich declares checked exception.Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.BinaryOperatorwhich declares checked exception.Serializablevariant ofjava.util.function.BiPredicatewhich declares checked exception.Serializablevariant ofjava.util.Comparatorwhich declares checked exception.Serializablevariant ofjava.util.function.Consumerwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Predicatewhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception.Serializablevariant ofjava.util.function.ToDoubleFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.ToIntFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.ToLongFunctionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jetClassDescription
Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Predicatewhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.aggregateClassDescription
Serializablevariant ofjava.util.function.BiConsumerwhich declares checked exception.Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.BinaryOperatorwhich declares checked exception.Serializablevariant ofjava.util.Comparatorwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Predicatewhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception.Serializablevariant ofjava.util.function.ToDoubleFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.ToLongFunctionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.avroClassDescription
Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.cdcClassDescription
Serializablevariant ofjava.util.function.Functionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.coreClassDescription
Serializablevariant ofjava.util.Comparatorwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception.Serializablevariant ofjava.util.function.ToLongFunctionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.core.processorClassDescription
Serializablevariant ofjava.util.function.BiConsumerwhich declares checked exception.Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.BinaryOperatorwhich declares checked exception.Serializablevariant ofjava.util.function.BiPredicatewhich declares checked exception.Serializablevariant ofjava.util.function.Consumerwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Predicatewhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception.Serializablevariant ofjava.util.function.ToLongFunctionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.core.testClassDescription
Serializablevariant ofjava.util.function.Supplierwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.elasticClassDescription
Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.functionClassDescription
Serializablevariant ofjava.util.function.Consumerwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.grpcClassDescription
Serializablevariant ofjava.util.function.BiConsumerwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.hadoopClassDescription
Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.Consumerwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.kafkaClassDescription
Serializablevariant ofjava.util.function.Functionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.kafka.connectClassDescription
Serializablevariant ofjava.util.function.Functionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.kinesisClassDescription
Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.mongodbClassDescription
Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.Consumerwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.pipelineClassDescription
Serializablevariant ofjava.util.function.BiConsumerwhich declares checked exception.Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.BinaryOperatorwhich declares checked exception.Serializablevariant ofjava.util.function.BiPredicatewhich declares checked exception.Serializablevariant ofjava.util.Comparatorwhich declares checked exception.Serializablevariant ofjava.util.function.Consumerwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Predicatewhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception.Serializablevariant ofjava.util.function.ToLongFunctionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.pipeline.testClassDescription
Serializablevariant ofjava.util.function.BiConsumerwhich declares checked exception.Serializablevariant ofjava.util.function.Consumerwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.pythonClassDescription
Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception. -
Classes in com.hazelcast.function used by com.hazelcast.jet.s3ClassDescription
Serializablevariant ofjava.util.function.BiFunctionwhich declares checked exception.Serializablevariant ofjava.util.function.Functionwhich declares checked exception.Serializablevariant ofjava.util.function.Supplierwhich declares checked exception.