Skip to main content Module executor Copy item path Source SequenceMatcher Finite state machine for ordered event pattern detection within a time window.
Processes records sequentially and emits the record that completes each sequence. apply_pipeline_stages_to_vec Helper to apply stages sequentially on a Vector. compare_values Evaluates comparisons with cross-type numeric coercion, startsWith, and set-membership (in). cosine_similarity datavalue_to_json Generic converter from DataValue to serde_json::Value enrich_record Performs lazy streaming enrichment lookup. evaluate_filter_expr Evaluates recursive FilterExpr boolean trees. evaluate_record_field Evaluates a field on a Record, supporting both system fields and nested payload fields. execute_explain Analyses a parsed Query and returns a structured execution plan as Records.
Does not access storage. Does not execute the query. execute_query Executes any full parsed Query on the StorageEngine, returning results or execution errors. execute_query_historical Executes a pipeline query on static historical database records. execute_query_stream Executes a pipeline query as a continuous live-streaming channel. extract_field Dynamic field extraction from DataValue (supports JSON in DataValue::String and MessagePack in DataValue::Binary) json_to_datavalue Converts a JSON Value into its corresponding DataValue type. merge_record_values Merges the value of a target record into the source record value
as a nested JSON field named after the target stream. project_record Dynamic projection mapping for columns. to_vector