aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* Merge remote-tracking branch 'origin/master' into conf2Matei Zaharia2013-12-2923-203/+583
|\
| * 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
| |\
| * | 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 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
| |/ |/|
* | Use scala.binary.version in POMsMark Hamstra2013-12-151-7/+7
* | Merge branch 'master' into akka-bug-fixPrashant Sharma2013-12-111-8/+1
|\|
| * Fix pom.xml for maven buildRaymond Liu2013-12-031-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
|\|
| * 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
* | 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
| |\|
| | * Made block generator thread safe to fix Kafka bug.Tathagata Das2013-11-122-7/+80
| * | Merge branch 'master' into scala-2.10Raymond Liu2013-11-1331-228/+1421
| |\|
| | * 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
| | | | * modify code, use Spark Logging Classprabeesh2013-10-171-35/+26
| | | | * add maven dependencies for mqttprabeesh2013-10-161-0/+5
| | | | * added mqtt adapterprabeesh2013-10-161-0/+15
| | | | * mqttinputdstream for mqttstreaming adapterprabeesh2013-10-161-0/+111
| | * | | Added JavaStreamingContext.transformTathagata Das2013-10-244-33/+158
| | * | | Merge branch 'apache-master' into transformTathagata Das2013-10-2215-88/+125
| | |\| |
| | | * | Merge pull request #56 from jerryshao/kafka-0.8-devMatei Zaharia2013-10-2115-94/+109
| | | |\ \
| | | | * | Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streamingjerryshao2013-10-1215-88/+109