Euphoria API

Beam Java SDK向けの使いやすいJava 8 DSL。Beam変換の高レベルな抽象化を提供し、読み書きが容易です。既存のBeamパイプラインの補完として使用でき（相互変換可能）、WordCountの例でAPIの概要を確認できます。

• 課題: dsl-euphoria / BEAM-3900
• 連絡先: David Moravek

「ソルト化」された結合の実装

非常に歪んだデータセットの大規模な結合を処理できる結合の実装。この実装では、カウント最小スケッチデータ構造によって近似されたキーの分散を使用して、大きなキーを複数のスプリットに分割します。

パイプラインサンプリング

ユーザーの干渉なしに演算子の適切な変換を選択するために、以前のパイプライン実行からの知識を活用できます。この知識を収集するための便利で移植可能な方法を提供したいと考えています。

Fluent API

Euphoria DSLの上に使いやすいFluent APIを実装します。

サイド出力

複数の出力のための便利なAPI。

テーブルストリーム結合

ストリームをテーブルに変換するAPI（KStream <-> KTableアプローチ）と、それらに対するさまざまな種類の（ウィンドウ付きおよびウィンドウなしの）結合を導入します。