hi all,

flink在使用temporal join只支持look up table source。我在做單元測試的時候, 下載了hive
表裡面的數據,嘗試了用filesystem註冊temporal table。可是後來發現file system不支持lookup。查詢了文檔(
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/legacySourceSinks.html),用戶可以自定義look
up table source。可是我找不到類似用csv設置look up table source的方法。所以想請問有什麼例子我可以參考嗎?

Regards,


*Hau ChongAih*

Reply via email to