| Package | Description | 
|---|---|
| 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.cdc.mysql | 
 Contains connectors for change data capture events from MySQL
 databases. 
 | 
| com.hazelcast.jet.cdc.postgres | 
 Contains connectors for change data capture events from PostgreSQL
 databases. 
 | 
| com.hazelcast.jet.config | 
 Jet's configuration data objects. 
 | 
| com.hazelcast.jet.pipeline.test | 
 This package contains various mock sources to help with pipeline testing
 and development. 
 | 
| Package | Description | 
|---|---|
| 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.python | 
 Contributes a  
PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig)
 transform that allows you to transform Jet pipeline data using a Python
 function. | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ChangeRecord
Information pertaining to a single data change event (insert, delete or
 update), affecting a single database record. 
 | 
class  | 
DebeziumCdcSources
Contains factory methods for creating Change Data Capture (CDC) sources. 
 | 
class  | 
Operation
Describes the nature of a CDC event, mainly the type of action performed
 on a database record: insertion, update and deletion. 
 | 
class  | 
ParsingException
Exception to indicate that parsing CDC JSON data has failed irrecoverably. 
 | 
interface  | 
RecordPart
Represents the top-level component of a  
ChangeRecord, such as
 the key or the value. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
MySqlCdcSources
Contains factory methods for creating change data capture sources
 based on MySQL databases. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
PostgresCdcSources
Contains factory methods for creating change data capture sources
 based on PostgreSQL databases. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T,S extends StreamSerializer<T>> | 
JobConfig.registerSerializer(Class<T> clazz,
                  Class<S> serializerClass)
Registers the given serializer for the given class for the scope of the
 job. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AssertionCompletedException
An exception which indicates that an assertion passed successfully. 
 | 
class  | 
TestSources
Contains factory methods for various mock sources which can be used for
 pipeline testing and development. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static StreamSource<SimpleEvent> | 
TestSources.itemStream(int itemsPerSecond)
Returns a streaming source that generates events of type  
SimpleEvent 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 the  
generatorFn at the specified rate. | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.