草庐IT

ReduceContext

全部标签

java - 可以覆盖 ReduceContext 中的 context.write() 方法吗?

使用0.20.2...是否可以覆盖ReduceContext中的context.write()方法?我有一整套Reducers,我希望在每个context.write()之前都使用一个特定的函数,但我不想让他们担心这个逻辑,只是为了处理它透明地。例如:Iteratorvit=values.iterator();if(trans2!=null){key=(Text)trans2.transform(key);}while(vit.hasNext()){Textitem=vit.next();if(trans1!=null){item=(Text)trans1.transform(item