aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* 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
| | | | * added mqtt adapterprabeesh2013-10-161-0/+15
| | | | * mqttinputdstream for mqttstreaming adapterprabeesh2013-10-161-0/+111
| | * | | Added JavaStreamingContext.transformTathagata Das2013-10-243-3/+56
| | * | | Merge branch 'apache-master' into transformTathagata Das2013-10-223-43/+71
| | |\| |
| | | * | Merge pull request #56 from jerryshao/kafka-0.8-devMatei Zaharia2013-10-213-43/+71
| | | |\ \
| | | | * | Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streamingjerryshao2013-10-123-43/+71
| | | | |/
| | * | | Fixed bug in Java transformWith, added more Java testcases for transform and ...Tathagata Das2013-10-225-161/+217
| | * | | Updated TransformDStream to allow n-ary DStream transform. Added transformWit...Tathagata Das2013-10-217-28/+270
| | |/ /
| | * | 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
|/ /
* | fixed some warningsMartin Weindel2013-10-0514-15/+28
* | Akka 2.2 migrationPrashant Sharma2013-09-225-11/+14
* | Merged with masterPrashant Sharma2013-09-0666-612/+1462
|\|
| * Move some classes to more appropriate packages:Matei Zaharia2013-09-0130-58/+67
| * Initial work to rename package to org.apache.sparkMatei Zaharia2013-09-0150-211/+215
| * Merge pull request #701 from ScrapCodes/documentation-suggestionsMatei Zaharia2013-08-223-3/+7
| |\
| | * Linking custom receiver guidePrashant Sharma2013-08-232-0/+4
| | * Corrections in documentation commentPrashant Sharma2013-08-231-3/+3
| * | Change scala.Option to Guava Optional in Java APIs.Josh Rosen2013-08-111-5/+2
| * | Changed other LZF uses to use the compression codec interface.Reynold Xin2013-07-311-9/+17
| * | Add Apache license headers and LICENSE and NOTICE filesMatei Zaharia2013-07-1650-4/+854
| |/
* | 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
|\|
| * Catch RejectedExecution exception in Checkpoint handler.Shivaram Venkataraman2013-07-071-2/+7
| * Merge remote-tracking branch 'pwendell/ui-updates'Matei Zaharia2013-07-061-1/+5
| |\
| | * Handful of changes based on matei's reviewPatrick Wendell2013-06-271-1/+5
| * | Merge pull request #655 from tgravescs/masterMatei Zaharia2013-07-061-1/+2
| |\ \
| | * | Rework from pull request. Removed --user option from Spark on Yarn Client, ma...Y.CORP.YAHOO.COM\tgraves2013-07-021-4/+0