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
相关文章
相关标签/搜索