java使用Map reduce查找最低数量

Question

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

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

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

Answer 1

听起来你想建立一个以Tag_id+'_'+Listiner_id+'_'+timestamp为键，以最低rssi_值为值的映射。所以只需在行上迭代，如果这是一个新的键或更低的值，则添加每一行