a是有原始数据的袋子,我给它们排序。
A = LOAD '$input' USING PigStorage(','); RA = rank A;
需要从ra中排除$3并将结果存储到hdfs中。这可以做,而装载本身,但我需要他们作为2袋。原始数据和临时数据(从原始数据中排除$3之后)。
xytpbqjk1#
排名后,尝试以下操作:
A1 = FOREACH RA GENERATE $0, $1, $2, $4 .. ; A2 = FOREACH RA GENERATE $3;
1条答案
按热度按时间xytpbqjk1#
排名后,尝试以下操作: