Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Merge branch 'master' into streaming | Matei Zaharia | 2013-01-20 | 4 | -21/+78 |
|\ | |||||
| * | Added accumulators to PySpark | Matei Zaharia | 2013-01-20 | 1 | -16/+67 |
| * | Fix code that assumed spark.local.dir is only a single directory | Matei Zaharia | 2013-01-17 | 2 | -2/+11 |
| * | changed HttpBroadcast server cache to be in spark.local.dir instead of java.i... | Fernand Pajot | 2013-01-17 | 1 | -1/+1 |
| * | Merge pull request #381 from squito/remove_threadpool | Matei Zaharia | 2013-01-16 | 1 | -3/+0 |
| |\ | |||||
| | * | remove unused thread pool | Imran Rashid | 2013-01-16 | 1 | -3/+0 |
* | | | Merge branch 'mesos-streaming' into streaming | Tathagata Das | 2013-01-20 | 5 | -31/+141 |
|\ \ \ | |||||
| * \ \ | Merge branch 'streaming' into streaming-java-api | Patrick Wendell | 2013-01-17 | 1 | -3/+3 |
| |\ \ \ | |||||
| | * \ \ | Merge pull request #375 from tdas/streaming | Tathagata Das | 2013-01-14 | 1 | -3/+3 |
| | |\ \ \ | |||||
| * | | | | | Adding checkpointing to Java API | Patrick Wendell | 2013-01-17 | 3 | -0/+81 |
| |/ / / / | |||||
| * | | | | Merge pull request #370 from tdas/streaming | Tathagata Das | 2013-01-13 | 1 | -3/+3 |
| |\ \ \ \ | |||||
| * | | | | | switch to uppercase constants | Ryan LeCompte | 2013-01-13 | 1 | -4/+4 |
| * | | | | | more code cleanup | Ryan LeCompte | 2013-01-13 | 1 | -31/+32 |
| * | | | | | add comment | Ryan LeCompte | 2013-01-12 | 1 | -0/+1 |
| * | | | | | add one extra test | Ryan LeCompte | 2013-01-12 | 1 | -0/+1 |
| * | | | | | correct test params | Ryan LeCompte | 2013-01-12 | 1 | -2/+2 |
| * | | | | | add unit test | Ryan LeCompte | 2013-01-11 | 2 | -1/+23 |
| * | | | | | add missing return | Ryan LeCompte | 2013-01-11 | 1 | -0/+1 |
| * | | | | | attempt to sleep for more accurate time period, minor cleanup | Ryan LeCompte | 2013-01-11 | 1 | -8/+11 |
| * | | | | | Merge pull request #350 from tdas/streaming | Matei Zaharia | 2013-01-07 | 42 | -307/+1535 |
| |\ \ \ \ \ | |||||
| * | | | | | | Fix Accumulators in Java, and add a test for them | Matei Zaharia | 2013-01-05 | 4 | -13/+79 |
* | | | | | | | Fixed issue https://spark-project.atlassian.net/browse/STREAMING-29, along wi... | Tathagata Das | 2013-01-19 | 3 | -16/+16 |
* | | | | | | | Merge branch 'master' into streaming | Tathagata Das | 2013-01-16 | 4 | -15/+110 |
|\ \ \ \ \ \ \ | | |_|_|_|/ / | |/| | | | | | |||||
| * | | | | | | Merge pull request #374 from woggling/null-mapout | Matei Zaharia | 2013-01-15 | 2 | -12/+64 |
| |\ \ \ \ \ \ | |||||
| | * | | | | | | Remove broken attempt to test fetching case. | Charles Reiss | 2013-01-15 | 1 | -46/+2 |
| | * | | | | | | Fix accidental spark.master.host reuse | Charles Reiss | 2013-01-14 | 1 | -0/+2 |
| | * | | | | | | Additional tests for MapOutputTracker. | Charles Reiss | 2013-01-14 | 1 | -2/+80 |
| | * | | | | | | Throw FetchFailedException for cached missing locs | Charles Reiss | 2013-01-14 | 1 | -10/+26 |
| | | |_|_|_|/ | | |/| | | | | |||||
| * | | | | | | Add a test. | Stephen Haberman | 2013-01-15 | 1 | -0/+43 |
| * | | | | | | Call executeOnCompleteCallbacks in a finally block. | Stephen Haberman | 2013-01-15 | 1 | -3/+5 |
| |/ / / / / | |||||
* | | | | | | Disabled checkpoint for PairwiseRDD (pySpark). | Tathagata Das | 2013-01-16 | 1 | -0/+1 |
* | | | | | | Merge branch 'master' into streaming | Tathagata Das | 2013-01-15 | 30 | -267/+725 |
|\| | | | | | |_|_|_|/ |/| | | | | |||||
| * | | | | Merge branch 'master' of github.com:mesos/spark | Matei Zaharia | 2013-01-13 | 1 | -4/+12 |
| |\ \ \ \ | |||||
| | * \ \ \ | Merge pull request #360 from rxin/cogroup-java | Matei Zaharia | 2013-01-13 | 1 | -4/+12 |
| | |\ \ \ \ | |||||
| | | * | | | | Removed the use of getOrElse to avoid Scala wrapper for every call. | Reynold Xin | 2013-01-13 | 1 | -3/+10 |
| | | * | | | | Changed CoGroupRDD's hash map from Scala to Java. | Reynold Xin | 2013-01-10 | 1 | -2/+3 |
| * | | | | | | Make filter preserve partitioner info, since it can | Matei Zaharia | 2013-01-13 | 2 | -1/+7 |
| |/ / / / / | |||||
| * | | | | | Add missing dependency spray-json to Maven build | Mikhail Bautin | 2013-01-13 | 1 | -0/+4 |
| * | | | | | Merge pull request #346 from JoshRosen/python-api | Matei Zaharia | 2013-01-12 | 3 | -1/+288 |
| |\ \ \ \ \ | |||||
| | * | | | | | Add mapPartitionsWithSplit() to PySpark. | Josh Rosen | 2013-01-08 | 1 | -0/+5 |
| | * | | | | | Change PySpark RDD.take() to not call iterator(). | Josh Rosen | 2013-01-03 | 1 | -0/+4 |
| | * | | | | | Rename top-level 'pyspark' directory to 'python' | Josh Rosen | 2013-01-01 | 1 | -1/+1 |
| | * | | | | | Minor documentation and style fixes for PySpark. | Josh Rosen | 2013-01-01 | 2 | -15/+32 |
| | * | | | | | Update PySpark for compatibility with TaskContext. | Josh Rosen | 2012-12-29 | 1 | -8/+5 |
| | * | | | | | Merge remote-tracking branch 'origin/master' into python-api | Josh Rosen | 2012-12-29 | 97 | -1531/+2892 |
| | |\ \ \ \ \ | | | | |/ / / | | | |/| | | | |||||
| | * | | | | | Fix bug (introduced by batching) in PySpark take() | Josh Rosen | 2012-12-28 | 1 | -1/+1 |
| | * | | | | | Mark api.python classes as private; echo Java output to stderr. | Josh Rosen | 2012-12-28 | 2 | -30/+22 |
| | * | | | | | Remove debug output from PythonPartitioner. | Josh Rosen | 2012-12-26 | 1 | -2/+0 |
| | * | | | | | Use filesystem to collect RDDs in PySpark. | Josh Rosen | 2012-12-24 | 1 | -42/+24 |
| | * | | | | | Fix PySpark hash partitioning bug. | Josh Rosen | 2012-10-28 | 2 | -6/+45 |