MatrixEngine |
src/engine/mod.rs |
Struct trung tâm giữ các ngưỡng chất lượng |
| Binding engine |
src/pyapi/engine.rs |
#[pymethods] phơi ra Python |
default_engine() |
src/pyapi/mod.rs |
Singleton engine cấp tiến trình (OnceLock) |
BazanError |
src/error.rs |
Enum lỗi; ánh xạ bởi bazan_to_pyerr() |
| Bộ lọc tĩnh |
src/engine/filter.rs |
Đường tắt ngưỡng cố định (filter_batch_native) |
| Cờ bit audit |
src/filter.rs |
ERR_INVALID_PASSENGER / _FARE / _SPEED |
| Nhân động |
src/engine/dynamic_filter.rs |
FilterRule::parse + bitmask đa khối |
| Cắt lát |
src/engine/slice.rs |
slice_rows_native, slice_cols_native |
| Lọc song song |
src/engine/parallel_filter.rs |
Chạy đa tệp Rayon, ParallelFilterSummary |
| Cắt tỉa phân vùng |
src/engine/partition.rs |
Phân tích đường dẫn kiểu Hive & lọc tệp |
| Splitter |
src/engine/splitter.rs |
Bộ ghi chia phần split_file_native |
| Ingest |
src/engine/ingest.rs |
Nạp thư mục, chuẩn hóa sang Parquet |
| Bộ ghi lake |
src/engine/formats/core/parquet.rs |
Ghi lake sạch/rác, bảng gold, ZSTD |
| Tầng SQL |
src/engine/sql.rs |
Phiên DataFusion, ListingTable vs MemTable, .br_cache |
PyBatchIterator |
src/pyapi/iterator.rs |
Nguồn batch Eager/Lazy, to_pyarrow() |
| Trait định dạng |
src/engine/formats/mod.rs |
FormatHandler, registry, bộ sniff magic-byte |
| Handler tầng 1 đến 3 |
formats/core/, common/, plugins/adapters/ |
Parquet/Feather · họ CSV & JSON · XLSX/Avro/ORC/MsgPack |
| Row chunking |
formats/plugins/base_templates/row_chunker.rs |
Template chuyển dòng → batch dùng chung |
| Lake Map |
src/engine/map.rs |
LakeMap, IO .br_map.bazan, doctor_lake_map |
| Ngân sách bộ nhớ |
src/engine/memory.rs |
Trần RAM, tính batch, runtime tokio/Rayon |
| CSV Guard |
src/engine/csv_guard.rs |
Bộ khử nhiễm formula injection |
| Sơ đồ ER |
src/engine/graph.rs |
Trình sinh sơ đồ ER Mermaid |
| Duyệt tệp |
src/utils.rs |
Bộ duyệt đệ quy, có sort, hiểu phân vùng |