Euphoria API

易于使用的 Java 8 DSL，用于 Beam Java SDK。提供 Beam 变换的高级抽象，既易于阅读又易于编写。可以作为现有 Beam 管道的补充（可以相互转换）。您可以在 WordCount 示例 中一窥 API 的风采。

• 问题：dsl-euphoria / BEAM-3900
• 联系：David Moravek

“加盐”连接实现

连接的实现，可以处理高度倾斜数据集的大规模连接。此实现使用 count min sketch 数据结构将大型键拆分为多个拆分，使用键分布近似值。

管道采样

为了在没有用户干预的情况下为操作符选择正确的翻译，我们可以利用来自先前管道运行的知识。我们希望提供一种方便且可移植的方式来收集这些知识。

Fluent API

在 Euphoria DSL 之上实现易于使用的 Fluent API。

侧输出

一个方便的 API，用于多个输出。

表流连接

引入 API 用于将流转换为表（KStream <-> KTable 方法）以及对它们的各种类型（带窗口和不带窗口）连接。