Uses of Annotation Interface
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.
gRPC service factories that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service.
transform that allows you to transform Jet pipeline data using a Python
Uses of EvolvingApi in com.hazelcast.jet.cdcModifier and TypeInterfaceDescription
interfaceInformation pertaining to a single data change event (insert, delete or update), affecting a single database record.
final classContains factory methods for creating Change Data Capture (CDC) sources.
enumDescribes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion.
classException to indicate that parsing CDC JSON data has failed irrecoverably.
interfaceRepresents the top-level component of a
ChangeRecord, such as the key or the value.
Uses of EvolvingApi in com.hazelcast.jet.cdc.mysqlModifier and TypeClassDescription
final classContains factory methods for creating change data capture sources based on MySQL databases.
Uses of EvolvingApi in com.hazelcast.jet.cdc.postgresModifier and TypeClassDescription
final classContains factory methods for creating change data capture sources based on PostgreSQL databases.
Uses of EvolvingApi in com.hazelcast.jet.config
Uses of EvolvingApi in com.hazelcast.jet.pipeline.testModifier and TypeClassDescription
final classAn exception which indicates that an assertion passed successfully.
final classContains factory methods for various mock sources which can be used for pipeline testing and development.Modifier and TypeMethodDescriptionTestSources.
(int itemsPerSecond)Returns a streaming source that generates events of type
SimpleEventat the specified rate.
static <T> StreamSource<T>Returns a streaming source that generates events created by the
generatorFnat the specified rate.