Flink關係型API簡介

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