Flink 的 API 大體上可以劃分為三個層次:處於最底層的 ProcessFunction、中間一層的 DataStream API 和最上層的 SQL/Table API,這三層中的每一層都非常依賴於時間屬性。時間屬性是流處理中最重要的一個方面,是流處理系統的基石之一,貫穿這三層 API。在 ...
Flink 的 API 大體上可以劃分為三個層次:處於最底層的 ProcessFunction、中間一層的 DataStream API 和最上層的 SQL/Table API,這三層中的每一層都非常依賴於時間屬性。時間屬性是流處理中最重要的一個方面,是流處理系統的基石之一,貫穿這三層 API。在 DataStream API 這一層中因為封裝方面的原因,我們能夠接觸到時間的地方不是很多,所以我們將重點放在底層的 ProcessFunction 和最上層的 SQL/Table API。
查看原文。