使用Pyflink将Apache Flink连接到Apache Kudu作为接收端

Question

我对Flink还不太熟悉，现在需要把Apache Flink的流数据连接到Apache Kudu，作为数据的去处。

1. 数据源是一个包含X条记录的CSV文件，这个文件是从文件系统中读取的。
2. 数据源是一个Kafka连接器（使用Kafka连接器和CSV格式创建一个表）。

我需要用Python来实现（pyflink）。有没有人能给我一个基本的例子或者指导一下？文档里关于KUDU的相关信息太少了。