Module mz_storage::render::upsert
source · [−]Structs
Functions
Evaluates predicates and dummy column information.
Given a stream of rows and a description of the columns that form their key, produce a stream of keys and thinned values.
This function fills pending_values with new data
from the timely operator input.
This function processes a batch of ready (i.e. whose time is below the current
input frontier) values and evaluate them against the intermediate upsert
data (current_values) and output issues and retractions for the output timely
stream. It is used exclusively by upsert_core
rehydrate uses information from the source description to find which indices in the row
are keys and add them back in in the right places. key_indices is a map
from the each key-part’s index in the value to its index in the key.
thin uses information from the source description to find which indices in the row
are keys and skip them. It requires that key_indices is sorted.
Entrypoint to the upsert-specific transformations involved in rendering a stream that came from an upsert source. Upsert-specific operators are different from the rest of the rendering pipeline in that their input is a stream with two components instead of one, and the second component can be null or empty.
Internal core upsert logic.