Module envelopes 

Constants

DBZ_ROW_TYPE_ID 🔒

TRANSACTION_TYPE_ID 🔒

Statics

ENVELOPE_CUSTOM_NAMES

Functions

dbz_envelope 🔒

dbz_format

for_each_diff_pair

Walks batch and invokes on_diff_pair for each DiffPair at each (key, timestamp).

for_each_diff_pair_async

Just like for_each_diff_pair, but async and fallible.

iter_diff_pairs

Walks batch and emits, for each key, an iterator of the DiffPairs at each timestamp.