aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
...
| * | | | | | | | | | | 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
| | |_|_|_|_|_|_|_|_|/ | |/| | | | | | | | |
* / | | | | | | | | | Fixed multiple file stream and checkpointing bugs.Tathagata Das2013-12-115-74/+117
|/ / / / / / / / / /
* | | | | | | | | / 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
| | * | | | | | | 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
|/ / /