aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
...
| * | | Fix one unit test that was not setting spark.cleaner.ttlMatei Zaharia2014-01-101-1/+1
* | | | Merge pull request #383 from tdas/driver-testPatrick Wendell2014-01-1010-193/+463
|\ \ \ \ | | |/ / | |/| |
| * | | Merge remote-tracking branch 'apache/master' into driver-testTathagata Das2014-01-102-8/+8
| |\| |
| * | | Modified streaming.FailureSuite tests to test StreamingContext.getOrCreate.Tathagata Das2014-01-101-21/+34
| * | | Updated docs based on Patrick's comments in PR 383.Tathagata Das2014-01-102-11/+16
| * | | Merge branch 'driver-test' of github.com:tdas/incubator-spark into driver-testTathagata Das2014-01-102-55/+96
| |\ \ \
| | * | | Removed spark.hostPort and other setting from SparkConf before saving to chec...Tathagata Das2014-01-101-18/+6
| | * | | Merge branch 'driver-test' of github.com:tdas/incubator-spark into driver-testTathagata Das2014-01-104-5/+5
| | |\ \ \
| | * | | | Refactored graph checkpoint file reading and writing code to make it cleaner ...Tathagata Das2014-01-102-49/+102
| * | | | | Fixed conf/slaves and updated docs.Tathagata Das2014-01-102-5/+15
| | |/ / / | |/| | |
| * | | | Merge remote-tracking branch 'apache/master' into driver-testTathagata Das2014-01-094-5/+5
| |\ \ \ \ | | |/ / / | |/| | / | | | |/ | | |/|
| * | | Fixed bugs in reading of checkpoints.Tathagata Das2014-01-102-17/+20
| * | | Merge branch 'standalone-driver' into driver-testTathagata Das2014-01-0929-1273/+270
| |\ \ \
| * | | | Changed the way StreamingContext finds and reads checkpoint files, and added ...Tathagata Das2014-01-095-109/+210
| * | | | More bug fixes.Tathagata Das2014-01-081-19/+26
| * | | | Modified checkpoing file clearing policy.Tathagata Das2014-01-087-52/+104
| * | | | Added a hashmap to cache file mod times.Tathagata Das2014-01-051-6/+24
| * | | | Merge branch 'filestream-fix' into driver-testTathagata Das2014-01-067-142/+219
| |\ \ \ \
| * | | | | Bug fixes to the DriverRunner and minor changes here and there.Tathagata Das2014-01-062-5/+5
| * | | | | Added StreamingContext.getOrCreate to for automatic recovery, and added Recov...Tathagata Das2014-01-022-4/+26
* | | | | | Merge pull request #377 from andrewor14/masterPatrick Wendell2014-01-101-10/+19
|\ \ \ \ \ \ | |_|_|_|_|/ |/| | | | |
| * | | | | Fix wonky imports from mergeAndrew Or2014-01-091-8/+1
| * | | | | Merge github.com:apache/incubator-sparkAndrew Or2014-01-0917-1189/+135
| |\ \ \ \ \ | | | |_|_|/ | | |/| | |
| * | | | | Merge remote-tracking branch 'spark/master'Andrew Or2014-01-0221-241/+378
| |\ \ \ \ \
| * | | | | | Address Aaron's commentsAndrew Or2013-12-291-4/+4
| * | | | | | Fix streaming JavaAPISuite againAndrew Or2013-12-261-8/+12
| * | | | | | Fix streaming JavaAPISuite that depended on orderAaron Davidson2013-12-261-11/+16
| | |_|/ / / | |/| | | |
* | | | | | Merge pull request #363 from pwendell/streaming-logsPatrick Wendell2014-01-092-5/+5
|\ \ \ \ \ \ | |_|_|/ / / |/| | | | |
| * | | | | Set default logging to WARN for Spark streaming examples.Patrick Wendell2014-01-092-5/+5
| | |_|_|/ | |/| | |
* / | | | Use typed getters for configuration settingsMatei Zaharia2014-01-094-5/+5
|/ / / /
* | | | Merge remote-tracking branch 'apache/master' into project-refactorTathagata Das2014-01-0621-234/+377
|\ \ \ \
| * | | | Removing SPARK_EXAMPLES_JAR in the codePatrick Wendell2014-01-052-10/+21
| | |/ / | |/| |
| * | | Merge pull request #297 from tdas/window-improvementPatrick Wendell2014-01-025-15/+45
| |\ \ \
| | * | | Removed unncessary options from WindowedDStream.Tathagata Das2013-12-261-5/+3
| | * | | Updated groupByKeyAndWindow to be computed incrementally, and added mapSideCo...Tathagata Das2013-12-265-12/+34
| | * | | Merge branch 'scheduler-update' into window-improvementTathagata Das2013-12-234-5/+32
| | |\| |
| | * | | Merge branch 'scheduler-update' into window-improvementTathagata Das2013-12-1957-632/+1024
| | |\ \ \
| | * | | | Added flag in window operation to use partition awaare union.Tathagata Das2013-11-211-1/+3
| | * | | | Added partitioner aware union, modified DStream.window.Tathagata Das2013-11-211-39/+2
| | * | | | Added partition aware union to improve reduceByKeyAndWindowTathagata Das2013-11-201-2/+49
| * | | | | Miscellaneous fixes from code review.Matei Zaharia2014-01-013-6/+6
| * | | | | Merge remote-tracking branch 'apache/master' into conf2Matei Zaharia2014-01-017-14/+0
| |\ \ \ \ \
| | * \ \ \ \ Merge remote-tracking branch 'apache-github/master' into log4j-fix-2Patrick Wendell2014-01-017-142/+220
| | |\ \ \ \ \ | | | | |_|_|/ | | | |/| | |
| | * | | | | Removing initLogging entirelyPatrick Wendell2013-12-307-13/+0
| | | |_|_|/ | | |/| | |
| * | | | | Fix two compile errors introduced in mergeMatei Zaharia2013-12-312-2/+2
| * | | | | Merge remote-tracking branch 'apache/master' into conf2Matei Zaharia2013-12-317-141/+221
| |\ \ \ \ \ | | | |/ / / | | |/| | |
| | * | | | Fixed comments and long lines based on comments on PR 289.Tathagata Das2013-12-313-9/+17
| | * | | | Minor changes in comments and strings to address comments in PR 289.Tathagata Das2013-12-271-8/+6
| | * | | | Added warning if filestream adds files with no data in them (file RDDs have 0...Tathagata Das2013-12-261-0/+7
| | * | | | Changed file stream to not catch any exceptions related to finding new files ...Tathagata Das2013-12-261-19/+11