2017-05-23 39 views
-1

我們有來自不同傳感器的傳感器數據。傳感器數據將會像使用地圖查找最小號碼減少

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 

這是可能的。任何人都可以通過編程幫助我理解邏輯。

回答

0

這聽起來像你想建立一個與Tag_id+'_'+Listiner_id+'_'+timestamp作爲關鍵和最低的rssi_value作爲值的地圖。因此,只需遍歷行,如果這是一個新的鍵或更低的值,則添加它們。