aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* 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
| |/ |/|
* | Merging build changes in from 0.8Patrick Wendell2013-10-051-4/+5
* | Update build version in masterPatrick Wendell2013-09-241-1/+1
|/
* Move some classes to more appropriate packages:Matei Zaharia2013-09-0131-60/+70
* Fix some URLsMatei Zaharia2013-09-011-1/+1
* Initial work to rename package to org.apache.sparkMatei Zaharia2013-09-0159-261/+266
* 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
* | Remove redundant dependencies from POMsJey Kottalam2013-08-181-5/+0
* | Maven build now also works with YARNJey Kottalam2013-08-161-40/+0
* | Maven build now works with CDH hadoop-2.0.0-mr1Jey Kottalam2013-08-161-27/+0
* | Initial changes to make Maven build agnostic of hadoop versionJey Kottalam2013-08-161-32/+10
* | 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-1660-6/+1026
|/
* Merge pull request #688 from markhamstra/scalaDependenciesMatei Zaharia2013-07-081-0/+4
|\
| * pom cleanupMark Hamstra2013-07-081-1/+0
| * Explicit dependencies for scala-library and scalap to prevent 2.9.2 vs. 2.9.3...Mark Hamstra2013-07-081-0/+5
* | 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
| * | Add support for Spark on Yarn on a secure Hadoop clusterThomas Graves2013-06-191-1/+6
| |/
* | Reduced the number of Iterator to ArrayBuffer copies in NetworkReceiver.Tathagata Das2013-07-052-14/+11
* | Initialize Twitter4J OAuth from system properties instead of promptingMatei Zaharia2013-06-294-38/+23
* | Merge remote-tracking branch 'mrpotes/master'Matei Zaharia2013-06-293-35/+85
|\ \
| * | Include a default OAuth implementation, and update examples and JavaStreaming...James Phillpotts2013-06-253-25/+78
| * | Twitter API v1 is retired - username/password auth no longer possibleJames Phillpotts2013-06-241-15/+1
| * | Allow other twitter authorizations than username/passwordJames Phillpotts2013-06-212-9/+20
| |/
* | Merge branch 'master' into streamingTathagata Das2013-06-2414-75/+202
|\|
| * Exclude old versions of Netty from Maven-based buildJey Kottalam2013-05-181-0/+6