我需要从hdfs读取数据并将其发布到kafka主题。因为它们是dataset和datastream API的一部分，所以有可能在一个工作中完成我想要的任务吗？
vc6uscn91#
flink的数据流api可用于读取hdfs文件。看到了吗 readfile() 在https://ci.apache.org/projects/flink/flink-docs-stable/dev/datastream_api.html#data-消息来源。也可以将文件系统连接器与表和SQLAPI一起使用，但它只支持csv。
readfile()
1条答案
按热度按时间vc6uscn91#
flink的数据流api可用于读取hdfs文件。看到了吗
readfile()在https://ci.apache.org/projects/flink/flink-docs-stable/dev/datastream_api.html#data-消息来源。也可以将文件系统连接器与表和SQLAPI一起使用，但它只支持csv。