追記

  • PyroなんかでMapReduce.Workerをリモートのマシンで実行するようにすれば、分散処理が比較的手軽に可能になるかもしれません。
  • Pythonのデコレータを使って、クライアントコードをもっとシンプルに記述できないかなぁ。
  • reduceの実行順序を「元データの並び順」から「処理が終わったものから順次適用」に変えればパフォーマンスが上がるだろうな。。
    • メソッドrectify(=整流)によって、このように動作するように修正しました。(10/2 12:46)