• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:bucket

bucket

如何在Scalding中存储输出

如何在Scalding中存储输出
我正在尝试将管道输出到不同的目录中,以便每个目录的输出将基于某些ID进行存储。因此,在普通 map 精简代码中,我将使用MultipleOutputs类,并在精简器中执行类似的操作。 protected void reduce(final SomeKey key, final Iterable<SomeValue> values, ……继续阅读 »