Structs

Functions

evaluate 🔒

Evaluates predicates and dummy column information.

extract_kv 🔒

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 🔒

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 🔒

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.

upsert 🔒

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.