Module formatter

Modules

append_only 🔒

debezium_json 🔒

upsert 🔒

Structs

AppendOnlyFormatter

DebeziumAdapterOpts

DebeziumJsonFormatter

EncoderParams

FormatterParams 🔒

UpsertFormatter

Enums

SinkFormatterImpl

Traits

EncoderBuild

Each encoder shall be able to be built from parameters.

FormatterBuild 🔒

Each formatter shall be able to be built from parameters.

SinkFormatter

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 🔒