Uses of Annotation Interface
com.hazelcast.jet.annotation.EvolvingApi
Package
Description
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.
Contains connectors for change data capture events from MySQL
databases.
Contains connectors for change data capture events from PostgreSQL
databases.
Jet's configuration data objects.
This package contains various mock sources to help with pipeline testing
and development.
Package
Description
Contributes
gRPC service factories
that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service.Contributes a
PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig)
transform that allows you to transform Jet pipeline data using a Python
function.-
Uses of EvolvingApi in com.hazelcast.jet.cdc
Modifier and TypeInterfaceDescriptioninterface
Information pertaining to a single data change event (insert, delete or update), affecting a single database record.final class
Contains factory methods for creating Change Data Capture (CDC) sources.enum
Describes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion.class
Exception to indicate that parsing CDC JSON data has failed irrecoverably.interface
Represents the top-level component of aChangeRecord
, such as the key or the value. -
Uses of EvolvingApi in com.hazelcast.jet.cdc.mysql
Modifier and TypeClassDescriptionfinal class
Contains factory methods for creating change data capture sources based on MySQL databases. -
Uses of EvolvingApi in com.hazelcast.jet.cdc.postgres
Modifier and TypeClassDescriptionfinal class
Contains factory methods for creating change data capture sources based on PostgreSQL databases. -
Uses of EvolvingApi in com.hazelcast.jet.config
Modifier and TypeMethodDescription<T,
S extends StreamSerializer<T>>
JobConfigJobConfig.registerSerializer
(Class<T> clazz, Class<S> serializerClass) Registers the given serializer for the given class for the scope of the job. -
Uses of EvolvingApi in com.hazelcast.jet.pipeline.test
Modifier and TypeClassDescriptionfinal class
An exception which indicates that an assertion passed successfully.final class
Contains factory methods for various mock sources which can be used for pipeline testing and development.Modifier and TypeMethodDescriptionstatic StreamSource<SimpleEvent>
TestSources.itemStream
(int itemsPerSecond) Returns a streaming source that generates events of typeSimpleEvent
at the specified rate.static <T> StreamSource<T>
TestSources.itemStream
(int itemsPerSecond, GeneratorFunction<? extends T> generatorFn) Returns a streaming source that generates events created by thegeneratorFn
at the specified rate.