Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Merge branch 'scheduler-update' into filestream-fix | Tathagata Das | 2013-12-22 | 2 | -1/+6 |
|\ | |||||
| * | Minor updated based on comments on PR 277. | Tathagata Das | 2013-12-20 | 2 | -1/+6 |
* | | Merge branch 'scheduler-update' into filestream-fix | Tathagata Das | 2013-12-19 | 56 | -611/+996 |
|\| | |||||
| * | Minor changes. | Tathagata Das | 2013-12-18 | 9 | -32/+36 |
| * | Merge branch 'apache-master' into scheduler-update | Tathagata Das | 2013-12-18 | 41 | -397/+445 |
| |\ | |||||
| | * | Style fixes and addressed review comments at #221 | Prashant Sharma | 2013-12-10 | 1 | -2/+2 |
| | * | Merge branch 'master' of github.com:apache/incubator-spark into scala-2.10-temp | Prashant Sharma | 2013-11-21 | 5 | -11/+12 |
| | |\ | |||||
| | * \ | Merge branch 'scala210-master' of github.com:colorant/incubator-spark into sc... | Prashant Sharma | 2013-11-21 | 22 | -257/+1454 |
| | |\ \ | |||||
| | | * | | Various merge corrections | Aaron Davidson | 2013-11-14 | 5 | -63/+2 |
| | | * | | Merge branch 'master' into scala-2.10 | Raymond Liu | 2013-11-14 | 2 | -7/+80 |
| | | |\ \ | |||||
| | | * \ \ | Merge branch 'master' into scala-2.10 | Raymond Liu | 2013-11-13 | 21 | -190/+1375 |
| | | |\ \ \ | |||||
| | * | | | | | Remove deprecated actorFor and use actorSelection everywhere. | Prashant Sharma | 2013-11-12 | 1 | -1/+1 |
| | |/ / / / | |||||
| | * | | | | fixed some warnings | Martin Weindel | 2013-10-05 | 15 | -61/+76 |
| | * | | | | Akka 2.2 migration | Prashant Sharma | 2013-09-22 | 6 | -12/+15 |
| | * | | | | Few more fixes to tests broken during merge | Prashant Sharma | 2013-09-10 | 1 | -3/+3 |
| | * | | | | Merged with master | Prashant Sharma | 2013-09-06 | 76 | -699/+1706 |
| | |\ \ \ \ | |||||
| | * | | | | | code formatting, The warning related to scope exit and enter is not worth fix... | Prashant Sharma | 2013-07-16 | 1 | -14/+14 |
| | * | | | | | Fixed warning erasure -> runtimeClass | Prashant Sharma | 2013-07-16 | 1 | -1/+1 |
| | * | | | | | Fixed warning Throwables | Prashant Sharma | 2013-07-16 | 1 | -1/+1 |
| | * | | | | | Fixed warning ClassManifest -> ClassTag | Prashant Sharma | 2013-07-16 | 1 | -1/+1 |
| | * | | | | | Merge branch 'master' into master-merge | Prashant Sharma | 2013-07-12 | 5 | -18/+25 |
| | |\ \ \ \ \ | |||||
| | * \ \ \ \ \ | Merge branch 'master' into master-merge | Prashant Sharma | 2013-07-03 | 15 | -148/+249 |
| | |\ \ \ \ \ \ | |||||
| | * | | | | | | | Fixied other warnings | Prashant Sharma | 2013-04-29 | 1 | -3/+1 |
| | * | | | | | | | Fixed warning: erasure -> runtimeClass | Prashant Sharma | 2013-04-29 | 1 | -4/+4 |
| | * | | | | | | | Fixed Warning: ClassManifest -> ClassTag | Prashant Sharma | 2013-04-29 | 39 | -239/+285 |
| | * | | | | | | | Fixed breaking tests in streaming checkpoint suite. Changed RichInt to Int as... | Prashant Sharma | 2013-04-25 | 1 | -16/+19 |
| | * | | | | | | | scala 2.10 and master merge | Prashant Sharma | 2013-04-24 | 4 | -15/+16 |
| * | | | | | | | | 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 |
|/ / / / / / / | |||||
* | | | | | | | 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 | 8 | -15/+176 |
|\ \ \ \ \ | |||||
| * | | | | | 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 | 2 | -0/+124 |
|\| | | | | | |||||
| * | | | | | Merge pull request #64 from prabeesh/master | Matei Zaharia | 2013-10-23 | 2 | -0/+124 |
| |\ \ \ \ \ | |||||
| | * | | | | | Update MQTTInputDStream.scala | Prabeesh K | 2013-10-18 | 1 | -4/+11 |
| | * | | | | | modify code, use Spark Logging Class | prabeesh | 2013-10-17 | 1 | -35/+26 |
| | * | | | | | 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 |