Flink關係型API簡介

在接觸關係型API以前，用戶一般會採用DataStream、DataSet API來編寫Flink程序，它們都提供了豐富的處理能力，以DataStream爲例，它有以下這些優勢：web 富有表現力的流處理，包括但不限於：轉換數據，更新狀態，定義窗口、聚合，事件時間語義，有狀態且保證正確性等； 高度自定義的窗口邏輯：分配器、觸發器、逐出器以及容許延遲等； 提高與外部系統鏈接能力的異步I/O接口； P

>>阅读原文<<