aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
...
| * | | Merge branch 'master' into akka-bug-fixPrashant Sharma2013-12-111-8/+1
| |\| |
| * | | Style fixes and addressed review comments at #221Prashant Sharma2013-12-102-10/+10
| * | | Incorporated Patrick's feedback comment on #211 and made maven build/dep-reso...Prashant Sharma2013-12-071-1/+1
| * | | 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-2132-295/+1500
| |\ \ \ \
| | * | | | 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-1331-228/+1421
| | |\ \ \ \
| * | | | | | Remove deprecated actorFor and use actorSelection everywhere.Prashant Sharma2013-11-121-1/+1
| |/ / / / /
| * | | | | Merge branch 'scala-2.10' of github.com:ScrapCodes/spark into scala-2.10Prashant Sharma2013-10-101-3/+4
| |\ \ \ \ \
| | * \ \ \ \ Merge branch 'master' into wip-merge-masterPrashant Sharma2013-10-081-2/+3
| | |\ \ \ \ \
| | * \ \ \ \ \ Merge branch 'master' into scala-2.10Prashant Sharma2013-10-011-1/+1
| | |\ \ \ \ \ \
| * | | | | | | | fixed some warningsMartin Weindel2013-10-0515-61/+76
| |/ / / / / / /
| * | | | | | | fixed maven build for scala 2.10Prashant Sharma2013-09-261-5/+9
| * | | | | | | 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-0677-801/+1731
| |\ \ \ \ \ \ \
| * | | | | | | | 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-126-18/+29
| |\ \ \ \ \ \ \ \
| * \ \ \ \ \ \ \ \ Merge branch 'master' into master-mergePrashant Sharma2013-07-0316-148/+292
| |\ \ \ \ \ \ \ \ \
| * | | | | | | | | | Updated to latest stable scala 2.10.1 and akka 2.1.2Prashant Sharma2013-05-011-12/+2
| * | | | | | | | | | 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 pom.xml with updated dependencies.Prashant Sharma2013-04-291-1/+11
| * | | | | | | | | | 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
| |_|_|_|_|_|_|_|_|/ |/| | | | | | | | |
* | | | | | | | | | Fix pom.xml for maven buildRaymond Liu2013-12-031-8/+1
| |_|_|_|_|_|_|_|/ |/| | | | | | | |
* | | | | | | | | 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
| |_|_|_|_|_|/ |/| | | | | |
* | | | | | | Merge branch 'apache-master' into transformTathagata Das2013-10-259-15/+180
|\ \ \ \ \ \ \
| * | | | | | | Exclude jopt from kafka dependency.Patrick Wendell2013-10-251-0/+4
| * | | | | | | Style fixesPatrick Wendell2013-10-241-9/+9
| * | | | | | | Spacing fixPatrick Wendell2013-10-241-4/+4
| * | | | | | | Small spacing fixPatrick Wendell2013-10-241-2/+2
| * | | | | | | Adding Java versions and associated testsPatrick Wendell2013-10-244-0/+68
| * | | | | | | Some clean-up of testsPatrick Wendell2013-10-243-7/+10
| * | | | | | | Removing Java for nowPatrick Wendell2013-10-241-7/+0
| * | | | | | | Adding testsPatrick Wendell2013-10-242-5/+88
| * | | | | | | Add a `repartition` operator.Patrick Wendell2013-10-242-0/+14
* | | | | | | | Fixed accidental bug.Tathagata Das2013-10-241-1/+1
* | | | | | | | Merge branch 'apache-master' into transformTathagata Das2013-10-243-0/+129
|\| | | | | | |
| * | | | | | | Merge pull request #64 from prabeesh/masterMatei Zaharia2013-10-233-0/+129
| |\ \ \ \ \ \ \
| | * | | | | | | Update MQTTInputDStream.scalaPrabeesh K2013-10-181-4/+11