MapReduce 統計手機用戶的上行流量,下行流量,總流量,並對輸出的結果進行倒序排序。(一)

  首先,要知道hadoop自帶的LongWritable 是沒辦法存儲三個變量,即用戶的上行流量,下行流量,總流量。 這個時候,沒辦法,你就要去寫一個屬於你自己的接口,去實現能夠放入這三個數據。 MapReduce中傳輸自定義數據類型(Bean->setter+getter) (1) 要在Hadoop的各個節點之間傳輸,就必須實現其序列化機制,實現 Writable接口 ,重寫兩個方法: rea
相關文章
相關標籤/搜索