Commit message (Expand) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
| * | | | | | | | | | | | Added StatsReportListener to generate processing time statistics across multi... | Tathagata Das | 2013-12-18 | 2 | -2/+45 | |
| * | | | | | | | | | | | Refactored streaming scheduler and added listener interface. | Tathagata Das | 2013-12-12 | 22 | -195/+496 | |
| | |_|_|_|_|_|_|_|_|/ | |/| | | | | | | | | | ||||||
* / | | | | | | | | | | Fixed multiple file stream and checkpointing bugs. | Tathagata Das | 2013-12-11 | 5 | -74/+117 | |
|/ / / / / / / / / / | ||||||
* | | | | | | | | / | Fix pom.xml for maven build | Raymond Liu | 2013-12-03 | 1 | -8/+1 | |
| |_|_|_|_|_|_|_|/ |/| | | | | | | | | ||||||
* | | | | | | | | | Another set of changes to remove unnecessary semicolon (;) from Scala code. | Henry Saputra | 2013-11-19 | 1 | -1/+3 | |
* | | | | | | | | | Remove the semicolons at the end of Scala code to make it more pure Scala code. | Henry Saputra | 2013-11-19 | 5 | -10/+9 | |
| |_|_|_|_|_|_|/ |/| | | | | | | | ||||||
* | | | | | | | | Made block generator thread safe to fix Kafka bug. | Tathagata Das | 2013-11-12 | 2 | -7/+80 | |
| |_|_|_|_|_|/ |/| | | | | | | ||||||
* | | | | | | | Merge branch 'apache-master' into transform | Tathagata Das | 2013-10-25 | 9 | -15/+180 | |
|\ \ \ \ \ \ \ | ||||||
| * | | | | | | | Exclude jopt from kafka dependency. | Patrick Wendell | 2013-10-25 | 1 | -0/+4 | |
| * | | | | | | | Style fixes | Patrick Wendell | 2013-10-24 | 1 | -9/+9 | |
| * | | | | | | | Spacing fix | Patrick Wendell | 2013-10-24 | 1 | -4/+4 | |
| * | | | | | | | Small spacing fix | Patrick Wendell | 2013-10-24 | 1 | -2/+2 | |
| * | | | | | | | Adding Java versions and associated tests | Patrick Wendell | 2013-10-24 | 4 | -0/+68 | |
| * | | | | | | | Some clean-up of tests | Patrick Wendell | 2013-10-24 | 3 | -7/+10 | |
| * | | | | | | | Removing Java for now | Patrick Wendell | 2013-10-24 | 1 | -7/+0 | |
| * | | | | | | | Adding tests | Patrick Wendell | 2013-10-24 | 2 | -5/+88 | |
| * | | | | | | | Add a `repartition` operator. | Patrick Wendell | 2013-10-24 | 2 | -0/+14 | |
* | | | | | | | | Fixed accidental bug. | Tathagata Das | 2013-10-24 | 1 | -1/+1 | |
* | | | | | | | | Merge branch 'apache-master' into transform | Tathagata Das | 2013-10-24 | 3 | -0/+129 | |
|\| | | | | | | | ||||||
| * | | | | | | | Merge pull request #64 from prabeesh/master | Matei Zaharia | 2013-10-23 | 3 | -0/+129 | |
| |\ \ \ \ \ \ \ | ||||||
| | * | | | | | | | Update MQTTInputDStream.scala | Prabeesh K | 2013-10-18 | 1 | -4/+11 | |
| | * | | | | | | | modify code, use Spark Logging Class | prabeesh | 2013-10-17 | 1 | -35/+26 | |
| | * | | | | | | | add maven dependencies for mqtt | prabeesh | 2013-10-16 | 1 | -0/+5 | |
| | * | | | | | | | added mqtt adapter | prabeesh | 2013-10-16 | 1 | -0/+15 | |
| | * | | | | | | | mqttinputdstream for mqttstreaming adapter | prabeesh | 2013-10-16 | 1 | -0/+111 | |
| | | |_|_|/ / / | | |/| | | | | | ||||||
* | | | | | | | | Added JavaStreamingContext.transform | Tathagata Das | 2013-10-24 | 4 | -33/+158 | |
* | | | | | | | | Merge branch 'apache-master' into transform | Tathagata Das | 2013-10-22 | 15 | -88/+125 | |
|\| | | | | | | | ||||||
| * | | | | | | | Merge pull request #56 from jerryshao/kafka-0.8-dev | Matei Zaharia | 2013-10-21 | 15 | -94/+109 | |
| |\ \ \ \ \ \ \ | ||||||
| | * | | | | | | | Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streaming | jerryshao | 2013-10-12 | 15 | -88/+109 | |
| | | |_|_|_|_|/ | | |/| | | | | | ||||||
| * | | | | | | | Exclusion rules for Maven build files. | Reynold Xin | 2013-10-19 | 1 | -0/+22 | |
* | | | | | | | | Fixed bug in Java transformWith, added more Java testcases for transform and ... | Tathagata Das | 2013-10-22 | 6 | -176/+421 | |
* | | | | | | | | Updated TransformDStream to allow n-ary DStream transform. Added transformWit... | Tathagata Das | 2013-10-21 | 9 | -33/+457 | |
|/ / / / / / / | ||||||
* | | | | | | | Merge pull request #8 from vchekan/checkpoint-ttl-restore | Matei Zaharia | 2013-10-15 | 2 | -0/+6 | |
|\ \ \ \ \ \ \ | ||||||
| * | | | | | | | Serialize and restore spark.cleaner.ttl to savepoint | Vadim Chekan | 2013-09-20 | 2 | -0/+6 | |
| | |/ / / / / | |/| | | | | | ||||||
* | | | | | | | Refactor BlockId into an actual type | Aaron Davidson | 2013-10-12 | 4 | -16/+17 | |
| |/ / / / / |/| | | | | | ||||||
* | | | | | | Merging build changes in from 0.8 | Patrick Wendell | 2013-10-05 | 1 | -4/+5 | |
| |_|_|_|/ |/| | | | | ||||||
* | | | | | Update build version in master | Patrick Wendell | 2013-09-24 | 1 | -1/+1 | |
|/ / / / | ||||||
* | | | | Move some classes to more appropriate packages: | Matei Zaharia | 2013-09-01 | 31 | -60/+70 | |
* | | | | Fix some URLs | Matei Zaharia | 2013-09-01 | 1 | -1/+1 | |
* | | | | Initial work to rename package to org.apache.spark | Matei Zaharia | 2013-09-01 | 59 | -261/+266 | |
* | | | | Merge pull request #701 from ScrapCodes/documentation-suggestions | Matei Zaharia | 2013-08-22 | 3 | -3/+7 | |
|\ \ \ \ | ||||||
| * | | | | Linking custom receiver guide | Prashant Sharma | 2013-08-23 | 2 | -0/+4 | |
| * | | | | Corrections in documentation comment | Prashant Sharma | 2013-08-23 | 1 | -3/+3 | |
| | |_|/ | |/| | | ||||||
* | | | | Remove redundant dependencies from POMs | Jey Kottalam | 2013-08-18 | 1 | -5/+0 | |
* | | | | Maven build now also works with YARN | Jey Kottalam | 2013-08-16 | 1 | -40/+0 | |
* | | | | Maven build now works with CDH hadoop-2.0.0-mr1 | Jey Kottalam | 2013-08-16 | 1 | -27/+0 | |
* | | | | Initial changes to make Maven build agnostic of hadoop version | Jey Kottalam | 2013-08-16 | 1 | -32/+10 | |
* | | | | Change scala.Option to Guava Optional in Java APIs. | Josh Rosen | 2013-08-11 | 1 | -5/+2 | |
* | | | | Changed other LZF uses to use the compression codec interface. | Reynold Xin | 2013-07-31 | 1 | -9/+17 | |
* | | | | Add Apache license headers and LICENSE and NOTICE files | Matei Zaharia | 2013-07-16 | 60 | -6/+1026 | |
|/ / / |