Flink 1.9.1:JDBCUpsertTableSInk 寫數據到Phoenix

文章目錄 目的 實現 測試 目的 Flink插入跟新數據到Phoenixjava 實現 目前使用的JDBCUpsertTableSink支持以下幾種RDB: Derby Mysql Postgresql 因此須要定義一下Apache Phoenix的寫入形式:git https://github.com/apache/flink/blob/release-1.9.1/flink-connector
相關文章
相關標籤/搜索