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 © 2022 Hazelcast, Inc.. All rights reserved.