gpt4 book ai didi

hadoop - pig 窝为每一个澄清

转载 作者:行者123 更新时间:2023-12-02 21:09:10 25 4
gpt4 key购买 nike

我对 pig 的订单运算符(operator)有以下说明。
有人可以澄清一下吗?

示例代码

x = LOAD '/home/hadoop/Desktop/HadoopSetup/input/Data/StockData' using PigStorage(',') As (exchange:chararray, symbol:chararray, date:chararray, open:double, high:double, low:double, close:double, volume:long, adj_close:double);

y = GROUP x by symbol;

z = foreach y {
t = order x by open DESC;
k = limit t 1;
generate group, k.volume;
};

问题

y relation contains group,x in it's schema. x is not relation so how can we select x in below order statement since it is not a relation. Could anybody elaborate on below statement?


t = order x by open DESC

最佳答案

Apache pig 使用 的概念场投影使用嵌套 FOREACH 语句时,在您的代码中使用 嵌套投影

因此,当您使用 FOREACH 时,这意味着对于 Y 中存在的每条记录(Y 中存在的每条记录都分组为 X),现在 apache pig 不需要将分组的 X 放在单独的关系中,他可以从已经投影的字段中引用它,即Y。

请注意这里的一点,FOREACH 操作将对 Y 中存在的每条记录/行执行。

  • 项目范围可用于星号表达式(*
    ) 被允许。
  • 项目范围可用于以下语句:FOREACH、JOIN、
    GROUP、COGROUP 和 ORDER BY(当 ORDER BY 在
    嵌套的 FOREACH block )。

  • 请点击此链接: https://pig.apache.org/docs/r0.14.0/basic.html

    关于hadoop - pig 窝为每一个澄清,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40866834/

    25 4 0
    Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
    广告合作:1813099741@qq.com 6ren.com