@Override
protected void reduce(
final GeoWaveInputKey key,
final Iterable<ObjectWritable> values,
final Reducer<GeoWaveInputKey, ObjectWritable, GeoWaveInputKey, ObjectWritable>.Context context )
throws IOException,
InterruptedException {
final Iterator<ObjectWritable> it = values.iterator();
while (it.hasNext()) {
final ObjectWritable next = it.next();
if (next != null) {
context.write(
key,
next);
return;
}
}
}
GeoWaveDedupeCombiner.java 文件源码
java
阅读 28
收藏 0
点赞 0
评论 0
项目:geowave
作者:
评论列表
文章目录