Module materialize

Structs§

ChangeBuffer 🔒: ChangeBuffer is a buffer to handle chunk into KeyOp. TODO(rc): merge with TopNStaging.
MaterializeCache 🔒: A cache for materialize executors.
MaterializeExecutor: MaterializeExecutor materializes changes in stream into a materialized view on storage.

ChangeBufferKeyOp 🔒: KeyOp variant for ChangeBuffer that stores OwnedRow instead of Bytes

generate_output 🔒: Construct output StreamChunk from given buffer.
get_op_consistency_level 🔒
handle_toast_columns_for_postgres_cdc 🔒: Fix TOAST columns by replacing unavailable values with old row values.
is_debezium_unavailable_value 🔒: Check if a datum represents Debezium’s unavailable value placeholder. This function handles both scalar types and one-dimensional arrays.
is_unavailable_value_str 🔒: Fast string comparison to check if a string equals DEBEZIUM_UNAVAILABLE_VALUE. Optimized by checking length first to avoid expensive string comparison.
replace_if_not_null 🔒: Replace columns in an existing row with the corresponding columns in a replacement row, if the column value in the replacement row is not null.
versions_are_newer_or_equal 🔒: Compare multiple version columns lexicographically. Returns true if new_row has a newer or equal version compared to old_row.