Commit message (Expand) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
* | | | | Rename DStream.foreach to DStream.foreachRDD | Patrick Wendell | 2014-01-12 | 4 | -12/+12 | |
| |/ / |/| | | ||||||
* | | | Revert "Fix one unit test that was not setting spark.cleaner.ttl" | Patrick Wendell | 2014-01-11 | 1 | -1/+1 | |
* | | | Merge pull request #381 from mateiz/default-ttl | Matei Zaharia | 2014-01-10 | 1 | -1/+1 | |
|\ \ \ | ||||||
| * | | | Fix one unit test that was not setting spark.cleaner.ttl | Matei Zaharia | 2014-01-10 | 1 | -1/+1 | |
* | | | | Merge pull request #383 from tdas/driver-test | Patrick Wendell | 2014-01-10 | 10 | -193/+463 | |
|\ \ \ \ | | |/ / | |/| | | ||||||
| * | | | Merge remote-tracking branch 'apache/master' into driver-test | Tathagata Das | 2014-01-10 | 2 | -8/+8 | |
| |\| | | ||||||
| * | | | Modified streaming.FailureSuite tests to test StreamingContext.getOrCreate. | Tathagata Das | 2014-01-10 | 1 | -21/+34 | |
| * | | | Updated docs based on Patrick's comments in PR 383. | Tathagata Das | 2014-01-10 | 2 | -11/+16 | |
| * | | | Merge branch 'driver-test' of github.com:tdas/incubator-spark into driver-test | Tathagata Das | 2014-01-10 | 2 | -55/+96 | |
| |\ \ \ | ||||||
| | * | | | Removed spark.hostPort and other setting from SparkConf before saving to chec... | Tathagata Das | 2014-01-10 | 1 | -18/+6 | |
| | * | | | Merge branch 'driver-test' of github.com:tdas/incubator-spark into driver-test | Tathagata Das | 2014-01-10 | 4 | -5/+5 | |
| | |\ \ \ | ||||||
| | * | | | | Refactored graph checkpoint file reading and writing code to make it cleaner ... | Tathagata Das | 2014-01-10 | 2 | -49/+102 | |
| * | | | | | Fixed conf/slaves and updated docs. | Tathagata Das | 2014-01-10 | 2 | -5/+15 | |
| | |/ / / | |/| | | | ||||||
| * | | | | Merge remote-tracking branch 'apache/master' into driver-test | Tathagata Das | 2014-01-09 | 4 | -5/+5 | |
| |\ \ \ \ | | |/ / / | |/| | / | | | |/ | | |/| | ||||||
| * | | | Fixed bugs in reading of checkpoints. | Tathagata Das | 2014-01-10 | 2 | -17/+20 | |
| * | | | Merge branch 'standalone-driver' into driver-test | Tathagata Das | 2014-01-09 | 29 | -1273/+270 | |
| |\ \ \ | ||||||
| * | | | | Changed the way StreamingContext finds and reads checkpoint files, and added ... | Tathagata Das | 2014-01-09 | 5 | -109/+210 | |
| * | | | | More bug fixes. | Tathagata Das | 2014-01-08 | 1 | -19/+26 | |
| * | | | | Modified checkpoing file clearing policy. | Tathagata Das | 2014-01-08 | 7 | -52/+104 | |
| * | | | | Added a hashmap to cache file mod times. | Tathagata Das | 2014-01-05 | 1 | -6/+24 | |
| * | | | | Merge branch 'filestream-fix' into driver-test | Tathagata Das | 2014-01-06 | 7 | -142/+219 | |
| |\ \ \ \ | ||||||
| * | | | | | Bug fixes to the DriverRunner and minor changes here and there. | Tathagata Das | 2014-01-06 | 2 | -5/+5 | |
| * | | | | | Added StreamingContext.getOrCreate to for automatic recovery, and added Recov... | Tathagata Das | 2014-01-02 | 2 | -4/+26 | |
* | | | | | | Merge pull request #377 from andrewor14/master | Patrick Wendell | 2014-01-10 | 1 | -10/+19 | |
|\ \ \ \ \ \ | |_|_|_|_|/ |/| | | | | | ||||||
| * | | | | | Fix wonky imports from merge | Andrew Or | 2014-01-09 | 1 | -8/+1 | |
| * | | | | | Merge github.com:apache/incubator-spark | Andrew Or | 2014-01-09 | 17 | -1189/+135 | |
| |\ \ \ \ \ | | | |_|_|/ | | |/| | | | ||||||
| * | | | | | Merge remote-tracking branch 'spark/master' | Andrew Or | 2014-01-02 | 21 | -241/+378 | |
| |\ \ \ \ \ | ||||||
| * | | | | | | Address Aaron's comments | Andrew Or | 2013-12-29 | 1 | -4/+4 | |
| * | | | | | | Fix streaming JavaAPISuite again | Andrew Or | 2013-12-26 | 1 | -8/+12 | |
| * | | | | | | Fix streaming JavaAPISuite that depended on order | Aaron Davidson | 2013-12-26 | 1 | -11/+16 | |
| | |_|/ / / | |/| | | | | ||||||
* | | | | | | Merge pull request #363 from pwendell/streaming-logs | Patrick Wendell | 2014-01-09 | 2 | -5/+5 | |
|\ \ \ \ \ \ | |_|_|/ / / |/| | | | | | ||||||
| * | | | | | Set default logging to WARN for Spark streaming examples. | Patrick Wendell | 2014-01-09 | 2 | -5/+5 | |
| | |_|_|/ | |/| | | | ||||||
* / | | | | Use typed getters for configuration settings | Matei Zaharia | 2014-01-09 | 4 | -5/+5 | |
|/ / / / | ||||||
* | | | | Merge remote-tracking branch 'apache/master' into project-refactor | Tathagata Das | 2014-01-06 | 21 | -234/+377 | |
|\ \ \ \ | ||||||
| * | | | | Removing SPARK_EXAMPLES_JAR in the code | Patrick Wendell | 2014-01-05 | 2 | -10/+21 | |
| | |/ / | |/| | | ||||||
| * | | | Merge pull request #297 from tdas/window-improvement | Patrick Wendell | 2014-01-02 | 5 | -15/+45 | |
| |\ \ \ | ||||||
| | * | | | Removed unncessary options from WindowedDStream. | Tathagata Das | 2013-12-26 | 1 | -5/+3 | |
| | * | | | Updated groupByKeyAndWindow to be computed incrementally, and added mapSideCo... | Tathagata Das | 2013-12-26 | 5 | -12/+34 | |
| | * | | | Merge branch 'scheduler-update' into window-improvement | Tathagata Das | 2013-12-23 | 4 | -5/+32 | |
| | |\| | | ||||||
| | * | | | Merge branch 'scheduler-update' into window-improvement | Tathagata Das | 2013-12-19 | 57 | -632/+1024 | |
| | |\ \ \ | ||||||
| | * | | | | Added flag in window operation to use partition awaare union. | Tathagata Das | 2013-11-21 | 1 | -1/+3 | |
| | * | | | | Added partitioner aware union, modified DStream.window. | Tathagata Das | 2013-11-21 | 1 | -39/+2 | |
| | * | | | | Added partition aware union to improve reduceByKeyAndWindow | Tathagata Das | 2013-11-20 | 1 | -2/+49 | |
| * | | | | | Miscellaneous fixes from code review. | Matei Zaharia | 2014-01-01 | 3 | -6/+6 | |
| * | | | | | Merge remote-tracking branch 'apache/master' into conf2 | Matei Zaharia | 2014-01-01 | 7 | -14/+0 | |
| |\ \ \ \ \ | ||||||
| | * \ \ \ \ | Merge remote-tracking branch 'apache-github/master' into log4j-fix-2 | Patrick Wendell | 2014-01-01 | 7 | -142/+220 | |
| | |\ \ \ \ \ | | | | |_|_|/ | | | |/| | | | ||||||
| | * | | | | | Removing initLogging entirely | Patrick Wendell | 2013-12-30 | 7 | -13/+0 | |
| | | |_|_|/ | | |/| | | | ||||||
| * | | | | | Fix two compile errors introduced in merge | Matei Zaharia | 2013-12-31 | 2 | -2/+2 | |
| * | | | | | Merge remote-tracking branch 'apache/master' into conf2 | Matei Zaharia | 2013-12-31 | 7 | -141/+221 | |
| |\ \ \ \ \ | | | |/ / / | | |/| | | | ||||||
| | * | | | | Fixed comments and long lines based on comments on PR 289. | Tathagata Das | 2013-12-31 | 3 | -9/+17 |