Mapreduce Pipe: выполнение очистки в редукторе

Я пытаюсь реализовать метод очистки редуктора в C ++.
Я попробовал следующую тестовую работу.

class WordCountReducer : public HadoopPipes::Reducer {
public:
WordCountReducer(HadoopPipes::TaskContext& context) {}
// Reduce function
void reduce(HadoopPipes::ReduceContext& context) {
//dont emit anything in reducer
}

void cleanup(HadoopPipes::ReduceContext& context) {
//emit key and value as 1
context.emit(context.getInputKey(), HadoopUtils::toString(1));
}
};

Хотя задание выполняется успешно, оно ничего не печатает в выходном файле. Делать то же самое, но излучать в редукторах, работает отлично.

Использовал это ссылка на сайт для реализации Java, которая работает как шарм!

Я любитель C ++ и труб.