1

我正在使用 MultipleOutputs 格式编写 Orc 文件来创建自定义文件名。我将驱动程序设置如下

MultipleOutputs.addNamedOutput(job, "MyPrefix", OrcNewOutputFormat.class, NullWritable.class, Writable.class);

在减速器中如下

设置:

_multipleOutputs = new MultipleOutputs<NullWritable, Writable>(context);

减少方法:

_multipleOutputs.write("MyPrefix", NullWritable.get(), row);

清理方法:

_multipleOutputs.close();

尽管对于具有前缀“MyPrefix”生成的数据的文件,但也会生成没有记录的part-00000文件。

请让我知道如何停止减速器生成这个名为 part-00000 的空文件。

4

0 回答 0