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