Crate llkv_executor

Crate llkv_executor 

Source
Expand description

Query execution engine for LLKV.

This crate provides the query execution layer that sits between the query planner (llkv-plan) and the storage layer (llkv-table, llkv-column-map).

§Module Organization

  • translation: Expression and projection translation utilities
  • types: Core type definitions (tables, schemas, columns)
  • insert: INSERT operation support (value coercion)
  • utils: Utility functions (time)

The QueryExecutor and SelectExecution implementations are defined inline in this module for now, but should be extracted to a dedicated query module in a future refactoring.

Re-exports§

pub use insert::build_array_for_column;
pub use insert::normalize_insert_value_for_column;
pub use insert::resolve_insert_columns;
pub use translation::build_projected_columns;
pub use translation::build_wildcard_projections;
pub use translation::full_table_scan_filter;
pub use translation::resolve_field_id_from_schema;
pub use translation::schema_for_projections;
pub use translation::translate_predicate;
pub use translation::translate_predicate_with;
pub use translation::translate_scalar;
pub use translation::translate_scalar_with;
pub use types::ExecutorColumn;
pub use types::ExecutorMultiColumnUnique;
pub use types::ExecutorRowBatch;
pub use types::ExecutorSchema;
pub use types::ExecutorTable;
pub use types::ExecutorTableProvider;
pub use utils::current_time_micros;

Modules§

insert
INSERT operation utilities.
translation
Expression and query plan translation utilities.
types
Type definitions for the executor.
utils
Utility functions for the executor.

Structs§

QueryExecutor
Query executor that executes SELECT plans.
QueryLogGuard
Guard object that pops the current query label when dropped.
SelectExecution
Streaming execution handle for SELECT queries.

Functions§

current_query_label
Fetch the innermost query label associated with the current execution thread.
push_query_label
Install a query label for the current thread so that executor logs can annotate diagnostics with the originating SQL statement.

Type Aliases§

ExecutorResult
Result type for executor operations.