Flinkx運行流程圖

1. FlinkX簡介 FlinkX 本質就是根據配置文件,創建一個Flink執行環境StreamExecutionEnvironment。添加source、sink,最後執行env.execute() 創建Source:   由Reader的readData方法創建InputFormat讀取數據並轉化爲DataStream。 創建Sink: 由Writer的writeData方法創建的Outpu
相關文章
相關標籤/搜索