Flink實現狀態數據互相訪問(即依賴數據訪問,相似表之間的Join)

在流處理應用中,對單個event的處理若是不涉及與其餘event交互或訪問是比較簡單的。可是若是對單個event的處理依賴其餘topic過來的event或者後續處理的event依賴當前處理的event,這種情景相似於多表之間join,A和B join取A表的某幾個字段。使用flink的state就能夠實現。java 一個場景以下:apache      課程信息(table,class_id,cl
相關文章
相關標籤/搜索