Uses of Class
com.hazelcast.jet.annotation.EvolvingApi
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.
|
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. |
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. |
-
Uses of EvolvingApi in com.hazelcast.jet.cdc
Classes in com.hazelcast.jet.cdc with annotations of type EvolvingApi Modifier and Type Interface 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 aChangeRecord
, such as the key or the value. -
Uses of EvolvingApi in com.hazelcast.jet.cdc.mysql
Classes in com.hazelcast.jet.cdc.mysql with annotations of type EvolvingApi Modifier and Type Class Description class
MySqlCdcSources
Contains factory methods for creating change data capture sources based on MySQL databases. -
Uses of EvolvingApi in com.hazelcast.jet.cdc.postgres
Classes in com.hazelcast.jet.cdc.postgres with annotations of type EvolvingApi Modifier and Type Class Description class
PostgresCdcSources
Contains factory methods for creating change data capture sources based on PostgreSQL databases. -
Uses of EvolvingApi in com.hazelcast.jet.config
Methods in com.hazelcast.jet.config with annotations of type EvolvingApi Modifier and Type Method Description <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
Classes in com.hazelcast.jet.pipeline.test with annotations of type EvolvingApi Modifier and Type Class 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.Methods in com.hazelcast.jet.pipeline.test with annotations of type EvolvingApi Modifier and Type Method Description static 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. -
Uses of EvolvingApi in com.hazelcast.jet.python
Classes in com.hazelcast.jet.python with annotations of type EvolvingApi Modifier and Type Class Description class
PythonTransforms
Transforms which allow the user to call Python user-defined functions from inside a Jet pipeline.