Como emitir no método de fechamento do redutor
oclose
método herdado deMapReduceBase
não tem argumento:
public void close()
Então eu não tenhoOutputCollector
Comoreduce
método faz:
void reduce(K2 key, Iterator<V2> values, OutputCollector<K3, V3> output, Reporter reporter)
Na nova API hadoop, acho que a classe Reducer tem umsetup
método:
void setup(Context context)
Eu acho que o argumento de contexto pode emitir chave e valor. O problema é que eu tenho que usar a API antiga e não sei como emitir no método close. O que eu quero é executar algum código quando o último método de redução de tempo for chamado e emitir dados.