我正在使用 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 的空文件。