Module merge_scan 

Structs

MergeScanExec

MergeScanLogicalPlan

MergeScanMetric 🔒

PartitionMetrics 🔒

Metrics for a partition of a MergeScanExec.

RegionMetrics 🔒

Metrics for a region of a partition.

SubscriberRollbackGuard 🔒

Functions

acquire_remote_dyn_filter_registry_lease 🔒

fields_semantically_equal 🔒

Returns true when two fields describe the same column semantics: same name, same data type, and same nullability.

is_json_field 🔒

Returns true when the field is a JSON column, identified either by its Arrow extension type (greptime.json / greptime.json2) or by its greptime:type=Json marker.

json_fields_compatible 🔒

Returns true when two fields are semantically equivalent JSON columns.

query_engine_state_from_task_context 🔒

query_load_region_id 🔒

record_merge_scan_schema_error 🔒

region_scan_load 🔒

register_remote_dyn_filters_for_region 🔒

remote_dyn_filter_enabled 🔒

remote_plan_row_bound 🔒

Returns a deterministic upper bound on rows emitted by the remote plan for one region.

remote_schema_mismatch 🔒

report_region_query_load 🔒

validate_remote_schema 🔒

Validates the remote schema before positional column handling.