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 🔒