You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Kevin Liao <li...@gmail.com> on 2019/09/09 10:38:51 UTC

请教 flink 如何读取存放于 hdfs 的 lzo 压缩文件？

Hi, ALL

现在想讲过去的一组 mr 程序迁移到 flink 平台，原始日志存储在 hdfs 上，以 lzo 压缩，想读取成一个 datastream 处理，看到
StreamExecutionEnvironment.readFile(FileInputFormat<OUT> inputFormat, String
filePath), 这个方法似乎符合要求，但是 lzo 的解压应该用哪个包呢？

google 没有找到什么明确的线索

请教各位，谢谢