jjzjj

RichPipe

全部标签

scala - 从 RichPipe 获取一个值

我有一个包含3个字段的RichPipe:名称:String、时间:Long和值:Int。我需要获取特定名称、时间对的值。我该怎么做?我无法从scalding文档中弄清楚,因为它非常神秘并且找不到任何这样做的例子。 最佳答案 RichPipe不是键值存储,这就是为什么没有关于用作键值存储的文档的原因:)应该考虑RichPipe作为管道-因此如果不首先进入管道的一端并遍历管道直到找到所需的元素,就无法在中间获取数据。此外,这在Scalding中有点痛苦,因为您必须将结果写入磁盘(因为它构建在Hadoop之上),然后从磁盘读取结果以便在您