Euphoria API

易於使用的 Java 8 DSL，適用於 Beam Java SDK。提供 Beam 轉換的高階抽象化，易於閱讀和編寫。可以作為現有 Beam 管線的補充（可來回轉換）。您可以瀏覽 WordCount 範例來一窺此 API 的樣貌。

• 議題: dsl-euphoria / BEAM-3900
• 聯絡人: David Moravek

“加鹽” 連接實作

連接的實作，可以處理高度傾斜資料集的大規模連接。此實作使用計數最小略圖資料結構近似的鍵分佈，將大型鍵拆分為多個分割。

管線取樣

為了在不讓使用者干預的情況下選擇操作符的正確轉換，我們可以利用先前管線運行的知識。我們想要提供一種方便且可移植的方式來收集這些知識。

Fluent API

在 Euphoria DSL 之上實作易於使用的 Fluent API。

側邊輸出

方便的多個輸出 API。

表格-串流連接

引入用於將串流轉換為表格（KStream <-> KTable 方法）的 API，以及對它們進行的各種（帶視窗和不帶視窗的）連接類型。