java - 如何在 Flink 中读取 .bsq 文件？

Question

正确设置我的项目后，我需要将几个 .bsq 文件读取/导入到我的环境中。我尝试使用 env.readFile()像这样的方法:

DataSet<T> data = env.readFile(*insertFileInputFormatHere*, filePath);

但我无法获得正确的FileInputFormat。因为它是抽象的，所以我不能有自己的实例。我是否应该扩展 abstract class FileInputFormat 并使用我自己的扩展来实例化 FileInputFormat？还是有其他我不认识的方式？

Answer 1

似乎.bsq文件是二进制格式，不存在 Flink 或 Hadoop InputFormat(我包括 Hadoop InputFormats，因为 Flink 也支持 Hadoop IF)

因此您必须实现自己的InputFormat 来读取文件。我建议从 Flink 的 org.apache.flink.api.common.io.FileInputFormat 扩展您自己的 InputFormat。

要使用你自己的输入格式，你必须这样调用它

final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
env.createInput(new MyInputFormat());