Module materialize

Structs

MaterializeBuffer

MaterializeBuffer is a buffer to handle chunk into KeyOp.

MaterializeCache

A cache for materialize executors.

MaterializeExecutor

MaterializeExecutor materializes changes in stream into a materialized view on storage.

Functions

execute_do_update_if_not_null_replacement 🔒

Generates a new row with the behavior of “do update if not null” by replacing columns in the old row with non-empty columns in the new row.

generate_output 🔒

Construct output StreamChunk from given buffer.

get_op_consistency_level 🔒

should_handle_conflict 🔒

Determines whether pk conflict should be handled based on the version column of the new and old rows.

Type Aliases

CacheValue 🔒