草庐IT

HadoopFileSystemOptions

全部标签

hadoop - 如何将 hdfs 文件读入 apache beam?

我无法理解如何使用TextIO阅读它。谁能举例说明一下? 最佳答案 尝试以下操作。它适用于我的情况。String[]args1=newString[]{"--hdfsConfiguration=[{\"fs.defaultFS\":\"hdfs://localhost:9000\"}]"};HadoopFileSystemOptionsoptions=PipelineOptionsFactory.fromArgs(args1).withValidation().as(HadoopFileSystemOptions.class);Pi