我有一个Flink Job，它根据时间窗口计算流中元素的数量 .
val countStream: DataStream[Int] = env
.addSource(kafkaConsumer)
.map(_ => 1)
.timeWindowAll(Time.minutes(1))
.reduce((x, y) => x + y)
我想将countStream写入postgreSQL中的一个表 .
我想我必须使用JDBC的东西，但我只在Java中找到资源而不是Scala .
有关如何做到这一点的任何资源或帮助？谢谢 ！