diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2012-11-19 23:22:07 +0000 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2012-11-19 23:22:07 +0000 |
| commit | c97ebf64377e853ab7c616a103869a4417f25954 (patch) | |
| tree | b915b399fa0369c7398e1916e4b003635b388daa /ec2/spark_ec2.py | |
| parent | 3fd7b8319ba9886a74fb4abce96bbc88c98472dc (diff) | |
| download | spark-c97ebf64377e853ab7c616a103869a4417f25954.tar.gz spark-c97ebf64377e853ab7c616a103869a4417f25954.tar.bz2 spark-c97ebf64377e853ab7c616a103869a4417f25954.zip | |
Fixed bug in the number of splits in RDD after checkpointing. Modified reduceByKeyAndWindow (naive) computation from window+reduceByKey to reduceByKey+window+reduceByKey.
Diffstat (limited to 'ec2/spark_ec2.py')
0 files changed, 0 insertions, 0 deletions