Flink自定義TableSink TableSource

基本知識 TableSource提供了從外部系統（消息隊列，KV存儲，數據庫，文件系統等）接入數據，以後註冊到TableEnvironment中，而後能夠經過Table API或者SQL進行查詢。java TableSink提供了將flink內部註冊的Table中的數據寫出到外部系統（Es ,Hbase ,消息隊列數據庫，文件系統等）。web TableFactory用來建立TableSource

>>阅读原文<<