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 🔒