Как излучать в тесном методе Редуктор
close
метод, унаследованный отMapReduceBase
не имеет аргументов:
public void close()
Так что у меня нетOutputCollector
какreduce
метод делает:
void reduce(K2 key, Iterator<V2> values, OutputCollector<K3, V3> output, Reporter reporter)
В новом API Hadoop я обнаружил, что класс Reducer имеетsetup
метод:
void setup(Context context)
Я думаю, что аргумент контекста может излучать ключ и значение. Проблема в том, что мне нужно использовать старый API, и я не знаю, как использовать метод close. Что я хочу, так это запустить некоторый код, когда последний раз вызывается метод Reduce, и выдавать данные.