aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* Merge remote-tracking branch 'apache/master' into driver-testTathagata Das2014-01-102-8/+8
|\
| * 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
* | | 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
|\ \ \ \ | |/ / / |/| / / | |/ /
| * / Use typed getters for configuration settingsMatei Zaharia2014-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
|\|
| * 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
| | |\ \ \ \ \ | | | | |/ / / | | | |/| | |
| | * | | | | Fix a few settings that were being read as system properties after mergeMatei Zaharia2013-12-291-2/+2
| | * | | | | Merge remote-tracking branch 'origin/master' into conf2Matei Zaharia2013-12-2923-203/+583
| | |\ \ \ \ \ | | | | |/ / / | | | |/| | |
| | * | | | | Fix other failing testsMatei Zaharia2013-12-284-18/+22
| | * | | | | Add a StreamingContext constructor that takes a conf objectMatei Zaharia2013-12-281-1/+20
| | * | | | | Fix CheckpointSuite test failuresMatei Zaharia2013-12-281-4/+3
| | * | | | | Fix test failures due to setting / clearing clock type in StreamingMatei Zaharia2013-12-284-10/+14
| | * | | | | Various fixes to configuration codeMatei Zaharia2013-12-288-37/+44
| | * | | | | spark-544, introducing SparkConf and related configuration overhaul.Prashant Sharma2013-12-257-25/+27
| * | | | | | Removed extra empty lines.Tathagata Das2013-12-311-1/+0
| * | | | | | Removed unnecessary comments.Tathagata Das2013-12-313-55/+8
| * | | | | | Added pom.xml for external projects and removed unnecessary dependencies and ...Tathagata Das2013-12-311-54/+29
| * | | | | | Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-3012-978/+81
| * | | | | | Refactored streaming project to separate out the twitter functionality.Tathagata Das2013-12-263-105/+8
| | |/ / / / | |/| | | |
* | | | | | 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
|\ \ \ \ \ \ | | |_|/ / / | |/| | | |
| * | | | | 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