Ex4pmEngine.StreamingEngine (ex4pm v26.9.9)

Copy Markdown View Source

Ultra-high-throughput streaming engine for processing large-scale IEEE OCEL 2.0 NDJSON event streams.

Utilizes ETS-backed lock-free counters, parallel chunk processing across BEAM schedulers, and binary-stream decoders to achieve >50,000 events/second.

Summary

Functions

Streams and analyzes an entire production OCEL NDJSON log file.

Functions

process_file(path, opts \\ [])

Streams and analyzes an entire production OCEL NDJSON log file.