Module from_proto

Build executor from protobuf.

Modules

agg_common 🔒

append_only_dedup 🔒

approx_percentile 🔒

asof_join 🔒

barrier_recv 🔒

batch_query 🔒

cdc_filter 🔒

changelog 🔒

dml 🔒

dynamic_filter 🔒

eowc_over_window 🔒

expand 🔒

filter 🔒

group_top_n 🔒

hash_agg 🔒

Streaming Hash Aggregator

hash_join 🔒

hop_window 🔒

lookup 🔒

lookup_union 🔒

materialized_exprs 🔒

merge 🔒

mview 🔒

no_op 🔒

now 🔒

over_window 🔒

project 🔒

project_set 🔒

row_id_gen 🔒

row_merge 🔒

simple_agg 🔒

Streaming Simple Aggregator

sink 🔒

sort 🔒

source 🔒

source_backfill 🔒

stateless_simple_agg 🔒

stream_cdc_scan 🔒

stream_scan 🔒

sync_log_store 🔒

temporal_join 🔒

top_n 🔒

union 🔒

values 🔒

watermark_filter 🔒

Macros

build_executor 🔒

Traits

ExecutorBuilder 🔒

Functions

create_executor

Create an executor from protobuf [StreamNode].