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.

Functions

generate_output 🔒

Construct output StreamChunk from given buffer.

get_op_consistency_level 🔒

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.

version_is_newer_or_equal 🔒

Determines whether pk conflict handling should update an existing row with newly-received value, according to the value of version column of the new and old rows.

Type Aliases

CacheValue 🔒