按组中的更改筛选分组关系

4sup72z8  于 2021-05-30  发布在  Hadoop
关注(0)|答案(0)|浏览(193)

我又是一个学Pig拉丁语的新手,希望能得到一些帮助。
我有一个数据源,看起来或多或少像这样:

{ time:chararray, id:chararray, value:chararray }
{ '1:00', 'id1', 'value1' }
{ '1:00', 'id2', 'value2' }
{ '2:00', 'id1', 'value1' }
{ '2:00', 'id2', 'value4' }
{ '2:00', 'id3', 'value3' }

我想得到数据在时间间隔之间发生变化的所有示例。在这种情况下:

{ '2:00', 'id2', 'value4' }
{ '2:00', 'id3', 'value3' }

我知道如何在关系之间做集减法,但不知道在一组包之间做集减法。请记住,我不知道时间字段中的值是什么(即,我不知道值是“1:00”和“2:00”),只是它们是时间的级数。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题