Flink:RetractStreamTableSink 自定義sink寫數據到Phoenix

文章目錄 目標 Sink定義 使用自定義Sink 測試 目標 兩張表left join的結果更新寫入Phoenix 數據樣例:java (true,12,2,3,2020-06-18T00:00,2020-06-18T00:00) (true,12,2,5,2020-06-18T00:00,2020-06-18T00:00) (true,12,2,2,2020-06-18T00:00,2020-0
相關文章
相關標籤/搜索