我有一些数据，比如： type1, 2type1, 3type1, 5type1, 1type3, 5 我想按类型对它们进行分组，预期结果应该是： type1, 11type3, 10 下面是我的PIG脚本： data = LOAD 'my_data.txt' USING
a = GROUP data
浏览 3提问于2020-04-10得票数 1
1回答
猪未命名列之和
、、、
= GROUP >> BY( >> )最后一列是未命名的，现在我希望生成由Shi节点和delivery_node) <<------- sum of similar 我试着这样做：
grunt> sum_group_all_shipnode =FOREACH group</e
浏览 3提问于2016-07-08得票数 0
回答已采纳
2回答
我试图在pig中对我的数据执行sum操作，但它不接受显式类型转换，我尝试在执行sum时将(int)替换为double。timedata by $0;
drivinfo = foreach drivgrp generate group as id , SUM(timedata.$2) as totalhr , SUM(- ERROR 1045: <line 10, column 41> Could not infer the matching function
浏览 6提问于2017-12-14得票数 0
1回答
我想在Amazon上加速一个简单的Apache (0.13.1)或Pig (版本0.12.0)的聚合工作。我的数据已经在需要聚合的键上排序了，我希望作业能够利用这一点。(occurrences) from ngrams where year >= 1910 group by gram;summed = FOREACH grouped GENERATE group, SUM</
浏览 2提问于2015-06-27得票数 1
2回答
--加载数据(尝试使用HCatLoader()和使用PigStorage())。data = LOAD 'data' USING org.apache.hcatalog.pig.HCatLoader();
FLATTEN(gr
浏览 7提问于2015-01-05得票数 0
回答已采纳
1回答
我从Hive加载以下三个表：users = LOAD 'users' USING org.apache.hive.hcatalog.pig.HCatLoader
浏览 8提问于2017-05-04得票数 0
回答已采纳
3回答
不工作的猪中的转储命令
、、、
我编写了一个简单的PIG程序，如下所示，用于分析AWS上google gram数据集的一个小版本和一个修改版本。filter_input BY ngram;但是，转储命令不能工作，因此会出现以下错误：
浏览 3提问于2018-03-28得票数 0
回答已采纳
x = SUM(nb_actions_by_unite_and_action.$2);2015-05-08 14:43:44,712[main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1200: Pig script failed to parse: generate <
浏览 4提问于2015-05-08得票数 0
回答已采纳
我正在使用Pig处理数据来创建每天每小时一次的报告。(因此，我每晚发布报告，其中24行表示过去24小时。)DEFINE ISOToUnix org.apache.pig.piggybank.evaluation.datetime.convert.ISOToUnix();DEFINE UnixToISO org.apache.pig.piggybank.evaluation.datetime.convert.UnixToISO();reldata BY hs;
report = FORE
浏览 1提问于2014-08-09得票数 0
1回答
我希望在相同的业务和地点的情况下，为下列数据提供每个期间的累积薪金：--------+--------+------+-------B = group A by (business, location); C1 = order A by period;
gen
浏览 1提问于2014-12-11得票数 2
回答已采纳
2回答
我是pig语法的新手，我想知道是否有人可以提供一个提示，将这段SQL代码翻译成pig。SELECT column1, column2, SUM(column3)WHERE column5 = 100到目前为止，我有：filterColumn = FILTER data BY column5 = 100;result
浏览 0提问于2017-02-22得票数 1
, group.Year, group.$2, SUM(A.ArrDelay);下面是运行脚本时给出的异常。at org.apache.pig.PigServer$Graph.parseQuery(PigServer.java:1607) at org.apache.pig.tool
浏览 0提问于2013-12-06得票数 1
回答已采纳
我在Pig中有以下代码(win、request和response只是直接从文件系统加载的表)：
win_count = FOREACH win_<em
浏览 0提问于2012-10-31得票数 9
回答已采纳
3回答
假设我有一个别名transactions，其中包含以下数据：A S 3.3B Sstore visitors revenueT 1 3.4stores = foreach (grouptransactions by store) generate
group as store, SUM(tran
浏览 7提问于2013-12-17得票数 2
回答已采纳
1回答
我有这样的数据-1 2014-12-14 101 100076559 2014-12-14 106 1000000首先，我使用以下方法加载数据：
table = LOAD 'table' USING org.apache.hcatalog.pig.
浏览 1提问于2015-01-01得票数 1
1回答
我在google n-gram数据集上的pig上运行了以下命令：
sum_occ = FOREACH groupinp GENERATE FLATTEN(group) as ngram, SUM(filter_input.occurencesfeatures used in the script: <em
浏览 0提问于2018-04-06得票数 1
我有两个数据集，EmployeeDetail包含4列(id、name、性别、位置)和SalaryDetail(id、工资)。我加入了这两个数据集，并将它们分组为位置。<line 11, column 58> Could not infer the matching function for org.apache.pig.builtin.AVG as multipleAverageSalary = foreach GroupedByLocation {
Sum =
浏览 1提问于2015-01-04得票数 0
回答已采纳
occurrences:int, books:int);bg_tmp_2 = GROUPbg_tmp ALL;x = LIMIT occ_cnt100;这就是我在计算occ_cnt时遇到的错误
81201 [main] ERROR org.apa
浏览 1提问于2018-10-26得票数 0
回答已采纳
我正在尝试使用Apache Pig拉丁语进行一些日志处理，我想知道是否有更简单的方法来做到这一点：(SUM(filtered_logs.reqSize) + SUM(filtered_logs.optimizedSize以及计算其他数据，如OrigMB，CompressionAvg，
浏览 0提问于2011-08-02得票数 2
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号