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.

RefreshableMaterializeArgs

Arguments and state for refreshable materialized views

Enums

ChangeBufferKeyOp 🔒

KeyOp variant for ChangeBuffer that stores OwnedRow instead of Bytes

MaterializeStreamState

Functions

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.

Type Aliases

CacheValue 🔒