aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* 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
| | * | | | Removed slack time in file stream and added better handling of exceptions due...Tathagata Das2013-12-263-50/+21
| | * | | | Fixed Python API for sc.setCheckpointDir. Also other fixes based on Reynold's...Tathagata Das2013-12-242-8/+9
| | * | | | Minor formatting fixes.Tathagata Das2013-12-233-9/+13
| | * | | | Updated testsuites to work with the slack time of file stream.Tathagata Das2013-12-233-2/+22
| | * | | | Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-233-4/+26
| | |\| | |
| | * | | | Fixed bug in file stream that prevented some files from being readTathagata Das2013-12-231-9/+12
| | * | | | Updated CheckpointWriter and FileInputDStream to be robust against failed Fil...Tathagata Das2013-12-223-35/+78
| | * | | | Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-222-1/+6
| | |\ \ \ \
| | * \ \ \ \ Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-1957-620/+1009
| | |\ \ \ \ \ | | | | |_|_|/ | | | |/| | |
| | * | | | | Fixed multiple file stream and checkpointing bugs.Tathagata Das2013-12-115-74/+117
| * | | | | | 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
| |/ / / / / |/| | | | |
* | | | | | Minor change for PR 277.Tathagata Das2013-12-231-1/+1
* | | | | | Minor formatting fixes.Tathagata Das2013-12-231-5/+4
* | | | | | Added comments to BatchInfo and JobSet, based on Patrick's comment on PR 277.Tathagata Das2013-12-232-3/+26
| |_|_|/ / |/| | | |
* | | | | Minor updated based on comments on PR 277.Tathagata Das2013-12-202-1/+6
| |_|/ / |/| | |
* | | | Minor changes.Tathagata Das2013-12-189-32/+36
* | | | Merge branch 'apache-master' into scheduler-updateTathagata Das2013-12-1842-406/+458
|\| | |
| * | | Use scala.binary.version in POMsMark Hamstra2013-12-151-7/+7