aboutsummaryrefslogtreecommitdiff
path: root/streaming/src
Commit message (Expand)AuthorAgeFilesLines
...
| | * | | | 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-1956-611/+996
| | |\ \ \ \ \ | | | | |_|_|/ | | | |/| | |
| | * | | | | 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
* | | | | | | 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-1841-397/+445
|\| | |
| * | | 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-215-11/+12
| |\| |
| * | | Merge branch 'scala210-master' of github.com:colorant/incubator-spark into sc...Prashant Sharma2013-11-2122-257/+1454
| |\ \ \
| | * | | Various merge correctionsAaron Davidson2013-11-145-63/+2
| | * | | Merge branch 'master' into scala-2.10Raymond Liu2013-11-142-7/+80
| | |\ \ \ | | | | |/ | | | |/|
| | * | | Merge branch 'master' into scala-2.10Raymond Liu2013-11-1321-190/+1375
| | |\ \ \
| * | | | | Remove deprecated actorFor and use actorSelection everywhere.Prashant Sharma2013-11-121-1/+1
| |/ / / /
| * | | | fixed some warningsMartin Weindel2013-10-0515-61/+76
| * | | | Akka 2.2 migrationPrashant Sharma2013-09-226-12/+15
| * | | | Few more fixes to tests broken during mergePrashant Sharma2013-09-101-3/+3
| * | | | Merged with masterPrashant Sharma2013-09-0676-699/+1706
| |\ \ \ \
| * | | | | code formatting, The warning related to scope exit and enter is not worth fix...Prashant Sharma2013-07-161-14/+14
| * | | | | Fixed warning erasure -> runtimeClassPrashant Sharma2013-07-161-1/+1
| * | | | | Fixed warning ThrowablesPrashant Sharma2013-07-161-1/+1
| * | | | | Fixed warning ClassManifest -> ClassTagPrashant Sharma2013-07-161-1/+1
| * | | | | Merge branch 'master' into master-mergePrashant Sharma2013-07-125-18/+25
| |\ \ \ \ \
| * \ \ \ \ \ Merge branch 'master' into master-mergePrashant Sharma2013-07-0315-148/+249
| |\ \ \ \ \ \
| * | | | | | | Fixied other warningsPrashant Sharma2013-04-291-3/+1
| * | | | | | | Fixed warning: erasure -> runtimeClassPrashant Sharma2013-04-291-4/+4
| * | | | | | | Fixed Warning: ClassManifest -> ClassTagPrashant Sharma2013-04-2939-239/+285
| * | | | | | | Fixed breaking tests in streaming checkpoint suite. Changed RichInt to Int as...Prashant Sharma2013-04-251-16/+19
| * | | | | | | scala 2.10 and master mergePrashant Sharma2013-04-244-15/+16
* | | | | | | | 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-1222-195/+496
| |_|_|_|_|_|/ |/| | | | | |
* | | | | | | 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-195-10/+9
| |_|_|_|_|/ |/| | | | |
* | | | | | Made block generator thread safe to fix Kafka bug.Tathagata Das2013-11-122-7/+80
| |_|_|_|/ |/| | | |