多線程從MongoDB讀取數據，並以固定大小寫入HDFS

從Mongo裏多線程取數據，我一開始嘗試了用Executors.newFixedThreadPool線程池來實現。實際操做中，發現只有第一個線程會正常取數據，後創建的線程訪問Mongo的cursor會報錯。 後來改變了實現方式，經過Thread.start()來進行多線程取數據。代碼以下：java RsUserTagsRunner job = new RsUserTagsRunner(start,

>>阅读原文<<