Module parser 

Message parsing: WebSocket frames → Arrow RecordBatch.

Converts incoming WebSocket text/binary messages into Arrow RecordBatch rows for ingestion into Ring 0.

Structs

MessageParser

Parses raw WebSocket messages into Arrow RecordBatch data.

Functions

extract_max_event_time

Extracts the maximum event time (as epoch milliseconds) from a named column.

infer_schema_from_json

Creates a default schema for JSON messages when no explicit schema is provided.

infer_schema_from_json_with_path

Like infer_schema_from_json but navigates a json.path first.