论文标题
最高绩效流处理
Highest-performance Stream Processing
论文作者
论文摘要
我们介绍了流程库，该库可以实现现有的OCAML流库库的最高性能，从而达到了手写状态机的速度和记忆效率。它以熟悉的声明界面的任何组合，过滤器，拍摄（while），drop（while），邮政编码，flatmap组合器和术语的任何组合来支持有限和无限的流。经验丰富的用户可以使用状态流的低级接口并实现累积的地图，压缩和窗口。该图书馆基于确保的代码生成（目前，OCAML和C），并在所有情况下都保证完全融合。
We present the stream processing library that achieves the highest performance of existing OCaml streaming libraries, attaining the speed and memory efficiency of hand-written state machines. It supports finite and infinite streams with the familiar declarative interface, of any combination of map, filter, take(while), drop(while), zip, flatmap combinators and tupling. Experienced users may use the lower-level interface of stateful streams and implement accumulating maps, compression and windowing. The library is based on assured code generation (at present, of OCaml and C) and guarantees in all cases complete fusion.
