Uses of Class
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.
Uses of EvolvingApi in com.hazelcast.jet.cdc
Classes in com.hazelcast.jet.cdc with annotations of type EvolvingApi Modifier and Type Interface Description
ChangeRecordInformation pertaining to a single data change event (insert, delete or update), affecting a single database record.
DebeziumCdcSourcesContains factory methods for creating Change Data Capture (CDC) sources.
OperationDescribes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion.
ParsingExceptionException to indicate that parsing CDC JSON data has failed irrecoverably.
RecordPartRepresents the top-level component of a
ChangeRecord, such as the key or the value.
Uses of EvolvingApi in com.hazelcast.jet.cdc.mysql
Uses of EvolvingApi in com.hazelcast.jet.cdc.postgres
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>>
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
AssertionCompletedExceptionAn exception which indicates that an assertion passed successfully.
TestSourcesContains 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
itemStream(int itemsPerSecond)Returns a streaming source that generates events of type
SimpleEventat the specified rate.
static <T> StreamSource<T>
itemStream(int itemsPerSecond, GeneratorFunction<? extends T> generatorFn)Returns a streaming source that generates events created by the
generatorFnat the specified rate.
Uses of EvolvingApi in com.hazelcast.jet.python