Modulesยง
- append_
only ๐ - debezium_
json ๐ - upsert ๐
Structsยง
- Append
Only Formatter - Debezium
Adapter Opts - Debezium
Json Formatter - Encoder
Params - Formatter
Params ๐ - Upsert
Formatter
Enumsยง
Traitsยง
- Encoder
Build - Each encoder shall be able to be built from parameters.
- Formatter
Build ๐ - Each formatter shall be able to be built from parameters.
- Sink
Formatter - Transforms a
StreamChunk
into a sequence of key-value pairs according a specific format, for example append-only, upsert or debezium.
Functionsยง
- ensure_
only_ ๐one_ pk