级联中的笛卡尔积

xbp102n0  于 2021-06-04  发布在  Hadoop
关注(0)|答案(1)|浏览(531)

我正在开发一个级联程序,它不仅需要找到字数,还需要找到所有单词的总分数。我没有任何问题,因为字计数本身,也计算所有计数的总和,进入一个单独的管道,一个字段和一个元组。
如果我能得到每个单词计数元组的总数,我做计算就没有问题了。这是一个简单的笛卡尔积。。。但我该怎么做呢?似乎它应该是一个没有连接字段的cogroup,但这是不允许的。

zed5wv10

zed5wv101#

级联中的笛卡尔积可以通过使用缓冲区来实现。
给我一个输入数据的例子,这样我就可以帮助你解决问题。
看看这个

相关问题