Как использовать формат MultipleOutputs для генерации произвольного имени файла с генерацией других файлов

Я пишу файлы Orc, используя формат MultipleOutputs для создания собственного имени файла. Я настройки в драйвере, как показано ниже

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

0 ответов

Другие вопросы по тегам