aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* 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-015-119/+197
| |\
| * | 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-315-118/+198
|\ \ \ | | |/ | |/|
| * | 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-261-38/+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-231-1/+9
| * | Merge branch 'scheduler-update' into filestream-fixTathagata Das2013-12-232-3/+25
| |\|
| * | 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-1947-468/+784
| |\ \ \
| * | | | Fixed multiple file stream and checkpointing bugs.Tathagata Das2013-12-114-59/+94
* | | | | 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-2916-149/+458
|\ \ \ \ \ | | |_|_|/ | |/| | |
| * | | | 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-188-31/+35
| * | Merge branch 'apache-master' into scheduler-updateTathagata Das2013-12-1837-315/+352
| |\ \
| * | | Added StatsReportListener to generate processing time statistics across multi...Tathagata Das2013-12-182-2/+45
| * | | Refactored streaming scheduler and added listener interface.Tathagata Das2013-12-1215-138/+373
| | |/ | |/|
* | | Fix other failing testsMatei Zaharia2013-12-282-7/+16
* | | Add a StreamingContext constructor that takes a conf objectMatei Zaharia2013-12-281-1/+20
* | | Various fixes to configuration codeMatei Zaharia2013-12-286-32/+37
* | | spark-544, introducing SparkConf and related configuration overhaul.Prashant Sharma2013-12-254-8/+9
| |/ |/|
* | Style fixes and addressed review comments at #221Prashant Sharma2013-12-101-2/+2
* | Merge branch 'master' of github.com:apache/incubator-spark into scala-2.10-tempPrashant Sharma2013-11-213-8/+9
|\|
| * Another set of changes to remove unnecessary semicolon (;) from Scala code.Henry Saputra2013-11-191-1/+3
| * Remove the semicolons at the end of Scala code to make it more pure Scala code.Henry Saputra2013-11-193-7/+6
* | Merge branch 'scala210-master' of github.com:colorant/incubator-spark into sc...Prashant Sharma2013-11-2116-212/+741
|\ \
| * | Various merge correctionsAaron Davidson2013-11-145-63/+2
| * | Merge branch 'master' into scala-2.10Raymond Liu2013-11-141-2/+2
| |\|
| | * Made block generator thread safe to fix Kafka bug.Tathagata Das2013-11-121-2/+2
| * | Merge branch 'master' into scala-2.10Raymond Liu2013-11-1315-150/+740
| |\|
| | * Merge branch 'apache-master' into transformTathagata Das2013-10-253-0/+19
| | |\
| | | * Adding Java versions and associated testsPatrick Wendell2013-10-242-0/+12
| | | * Removing Java for nowPatrick Wendell2013-10-241-7/+0
| | | * Add a `repartition` operator.Patrick Wendell2013-10-242-0/+14
| | * | Merge branch 'apache-master' into transformTathagata Das2013-10-242-0/+124
| | |\|
| | | * Merge pull request #64 from prabeesh/masterMatei Zaharia2013-10-232-0/+124
| | | |\
| | | | * Update MQTTInputDStream.scalaPrabeesh K2013-10-181-4/+11
| | | | * modify code, use Spark Logging Classprabeesh2013-10-171-35/+26