flink 事件時間
阿新 • • 發佈:2019-01-09
當流媒體程式在處理時間執行時,所有基於時間的操作(如時間視窗)將使用執行相應操作員的機器的系統時鐘。例如,每小時處理時間視窗將包括在系統時鐘顯示整整一小時的時間和到達特定操作員的所有記錄。處理時間是最簡單的時間概念,不需要流和機器之間的協調。它提供了最佳的效能和最低的延遲。然而,在分散式和非同步環境中,處理時間並不能提供確定性,因為它容易受到記錄到達系統的速度(例如來自訊息佇列)的影響,以及記錄在系統。
- 事件時間:事件時間是每個事件在其生產裝置上發生的時間。這段時間通常嵌入記錄中,然後進入Flink,並且可以從記錄中提取事件時間戳。每小時事件時間視窗將包含攜帶落入該小時的事件時間戳的所有記錄,而不管記錄何時到達以及它們以何種順序到達。
- 進入處理時間