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)

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 types::StorageTable;
pub use types::TableStorageAdapter;

Modules§

insert
INSERT operation utilities.
scan
translation
Expression and query plan translation utilities.
types
Type definitions 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.
current_time_micros
Returns the current time in microseconds since the Unix epoch.
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.