aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* 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
| | | * | | Exclusion rules for Maven build files.Reynold Xin2013-10-191-0/+22
| | * | | | Fixed bug in Java transformWith, added more Java testcases for transform and ...Tathagata Das2013-10-226-176/+421
| | * | | | Updated TransformDStream to allow n-ary DStream transform. Added transformWit...Tathagata Das2013-10-219-33/+457
| | |/ / /
| | * | | Merge pull request #8 from vchekan/checkpoint-ttl-restoreMatei Zaharia2013-10-152-0/+6
| | |\ \ \
| | | * | | Serialize and restore spark.cleaner.ttl to savepointVadim Chekan2013-09-202-0/+6
| | | | |/ | | | |/|
| | * | | Refactor BlockId into an actual typeAaron Davidson2013-10-124-16/+17
| | | |/ | | |/|
* | / | 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
| |\| |
| | * | Merging build changes in from 0.8Patrick Wendell2013-10-051-4/+5
| * | | Merge branch 'master' into scala-2.10Prashant Sharma2013-10-011-1/+1
| |\| |
| | * | Update build version in masterPatrick Wendell2013-09-241-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