使用map reduce查找最小的数字

63lcw9qa  于 2021-06-01  发布在  Hadoop
关注(0)|答案(1)|浏览(272)

我们有来自不同传感器的传感器数据。传感器数据如下

Tag id , listener_id,rssi_value,time 
5 , 50 , -35 , 1495568512( epoch time)
5, 50 , -80, 1495569916
5,50, --33 ,1495568512
5 ,50,-32 ,1495568512
6,50,-10,1495568512
6,60,-99,1495568512
6,60,-33,1495568512

以上是样本数据,我们想用map reduce找到最小rssi值。
逻辑需要检查
对于特定标记id和适当的侦听器id,最小rssi值应该是特定时间戳的输出(时间戳可能不同),并且应该打印相应的值
输出类似

5 ,50,-32 ,1495568512
5, 50 , -80, 1495569916
6,50,-10,1495568512
6,60,-33,1495568512

这可能吗。有人能帮我学逻辑编程吗。

r6hnlfcb

r6hnlfcb1#

听起来你好像想用它来建立一个Map Tag_id+'_'+Listiner_id+'_'+timestamp 作为键和最低rssièu值作为值。所以只要遍历行,如果这是一个新的键或更低的值,就添加每一行。

相关问题