Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Adding queueStream and some slight refactoring | Patrick Wendell | 2013-01-17 | 1 | -0/+58 |
* | Import fixup | Patrick Wendell | 2013-01-17 | 2 | -2/+0 |
* | Style cleanup | Patrick Wendell | 2013-01-17 | 3 | -3/+26 |
* | Checkpointing in Streaming java API | Patrick Wendell | 2013-01-17 | 1 | -2/+17 |
* | Adding flatMap | Patrick Wendell | 2013-01-17 | 1 | -0/+29 |
* | Adding other updateState functions | Patrick Wendell | 2013-01-17 | 1 | -13/+49 |
* | Bug fix and test cleanup | Patrick Wendell | 2013-01-17 | 1 | -2/+2 |
* | Stash | Patrick Wendell | 2013-01-14 | 1 | -1/+28 |
* | Bugfix | Patrick Wendell | 2013-01-14 | 1 | -2/+4 |
* | Remove AnyRef constraint in updateState | Patrick Wendell | 2013-01-14 | 2 | -5/+5 |
* | Bug fix | Patrick Wendell | 2013-01-14 | 1 | -2/+1 |
* | Making comments consistent w/ Spark style | Patrick Wendell | 2013-01-14 | 5 | -232/+196 |
* | Two changes: | Patrick Wendell | 2013-01-14 | 2 | -5/+269 |
* | Some style cleanup | Patrick Wendell | 2013-01-14 | 2 | -53/+93 |
* | Flume example and bug fix | Patrick Wendell | 2013-01-14 | 1 | -2/+7 |
* | More work on InputStreams | Patrick Wendell | 2013-01-14 | 2 | -9/+62 |
* | Porting to new Duration class | Patrick Wendell | 2013-01-14 | 4 | -68/+68 |
* | Fixing issue with <Long> types | Patrick Wendell | 2013-01-14 | 1 | -6/+12 |
* | More work on StreamingContext | Patrick Wendell | 2013-01-14 | 1 | -2/+45 |
* | Import Cleanup | Patrick Wendell | 2013-01-14 | 2 | -2/+1 |
* | Docs, some tests, and work on | Patrick Wendell | 2013-01-14 | 4 | -7/+283 |
* | Squashing a few TODOs | Patrick Wendell | 2013-01-14 | 1 | -4/+15 |
* | Style cleanup and moving functions | Patrick Wendell | 2013-01-14 | 3 | -67/+128 |
* | More pair functions | Patrick Wendell | 2013-01-14 | 1 | -1/+42 |
* | PairDStream and DStreamLike | Patrick Wendell | 2013-01-14 | 3 | -97/+248 |
* | Adding transform and union | Patrick Wendell | 2013-01-14 | 1 | -0/+14 |
* | Adding more tests | Patrick Wendell | 2013-01-14 | 1 | -1/+1 |
* | Adding some initial tests to streaming API. | Patrick Wendell | 2013-01-14 | 2 | -64/+1 |
* | A very rough, early cut at some Java functionality for Streaming. | Patrick Wendell | 2013-01-14 | 3 | -0/+188 |
* | Minor name fix | Tathagata Das | 2013-01-13 | 1 | -2/+2 |
* | Added documentation for PairDStreamFunctions. | Tathagata Das | 2013-01-13 | 3 | -27/+303 |
* | Removed stream id from the constructor of NetworkReceiver to make it easier f... | Tathagata Das | 2013-01-13 | 6 | -30/+68 |
* | Changed variable name form ***Time to ***Duration to keep things consistent. | Tathagata Das | 2013-01-09 | 23 | -152/+142 |
* | Split Time to Time (absolute instant of time) and Duration (duration of time). | Tathagata Das | 2013-01-09 | 25 | -152/+174 |
* | Moved Twitter example to the where the other examples are. | Tathagata Das | 2013-01-07 | 2 | -104/+0 |
* | Merge branch 'streaming-merge' into dev-merge | Tathagata Das | 2013-01-07 | 2 | -0/+104 |
|\ | |||||
| * | Merge pull request #8 from radlab/twitter-example | Patrick Wendell | 2012-12-29 | 2 | -0/+104 |
| |\ | |||||
| | * | Minor changes after review and general cleanup. | Patrick Wendell | 2012-12-21 | 2 | -11/+19 |
| | * | Adding a Twitter InputDStream with an example | Patrick Wendell | 2012-12-21 | 2 | -0/+96 |
* | | | Merge branch 'dev' into dev-merge | Tathagata Das | 2013-01-07 | 14 | -636/+34 |
|\ \ \ | |||||
| * | | | Renamed examples and added documentation. | Tathagata Das | 2013-01-07 | 2 | -20/+34 |
| * | | | Moved Spark Streaming examples to examples sub-project. | Tathagata Das | 2013-01-06 | 12 | -616/+0 |
* | | | | BufferingBlockCreator -> NetworkReceiver.BlockGenerator | Patrick Wendell | 2013-01-02 | 5 | -94/+89 |
* | | | | Merge branch 'dev-merge' into datahandler-fix | Patrick Wendell | 2013-01-02 | 41 | -496/+665 |
|\| | | | |||||
| * | | | Updated Streaming Programming Guide. | Tathagata Das | 2013-01-01 | 1 | -0/+1 |
| * | | | More classes made private[streaming] to hide from scala docs. | Tathagata Das | 2012-12-30 | 17 | -52/+135 |
| * | | | Refactored a whole lot to push all DStreams into the spark.streaming.dstream ... | Tathagata Das | 2012-12-30 | 35 | -323/+346 |
| * | | | Improved jekyll and scala docs. Made many classes and method private to remov... | Tathagata Das | 2012-12-29 | 15 | -138/+200 |
* | | | | Several code-quality improvements to DataHandler. | Patrick Wendell | 2013-01-02 | 5 | -88/+84 |
|/ / / | |||||
* | | | Merge branch 'dev' of github.com:radlab/spark into dev-checkpoint | Tathagata Das | 2012-12-20 | 11 | -102/+620 |
|\| | |