我正在尝试将管道输出到不同的目录中,以便每个目录的输出将基于某些ID进行存储。因此,在普通 map 精简代码中,我将使用MultipleOutputs类,并在精简器中执行类似的操作。 protected void reduce(final SomeKey key, final Iterable<SomeValue> values, final Context context) { ... for (SomeValue value: values) { String bucketId = computeB…

2019年7月29日 0条评论 16点热度 阅读全文