我们有来自不同传感器的传感器数据。传感器数据将像

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

这可能吗 。谁能在编程逻辑上帮助我。

最佳答案

听起来您好像想用Tag_id+'_'+Listiner_id+'_'+timestamp作为键,并使用最低的rssi_value作为值来构建Map。因此,只需遍历各行,如果这是新键或更低的值,则将它们相加。

关于java - 使用Map reduce查找最低编号,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/44143856/

10-10 16:59