Commit message (Expand) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
| * | | | Adding flatMap | Patrick Wendell | 2013-01-17 | 2 | -4/+106 | |
| * | | | Adding other updateState functions | Patrick Wendell | 2013-01-17 | 1 | -13/+49 | |
| * | | | Bug fix and test cleanup | Patrick Wendell | 2013-01-17 | 2 | -9/+12 | |
| * | | | Stash | Patrick Wendell | 2013-01-14 | 2 | -1/+61 | |
| * | | | 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 | 3 | -10/+130 | |
| * | | | Porting to new Duration class | Patrick Wendell | 2013-01-14 | 5 | -78/+78 | |
| * | | | Fixing issue with <Long> types | Patrick Wendell | 2013-01-14 | 2 | -10/+16 | |
| * | | | More work on StreamingContext | Patrick Wendell | 2013-01-14 | 1 | -2/+45 | |
| * | | | Import Cleanup | Patrick Wendell | 2013-01-14 | 3 | -4/+3 | |
| * | | | Some docs for the JavaTestUtils | Patrick Wendell | 2013-01-14 | 1 | -6/+22 | |
| * | | | Docs, some tests, and work on | Patrick Wendell | 2013-01-14 | 5 | -32/+617 | |
| * | | | 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 | 5 | -100/+359 | |
| * | | | Adding transform and union | Patrick Wendell | 2013-01-14 | 2 | -4/+72 | |
| * | | | Reduce tests | Patrick Wendell | 2013-01-14 | 1 | -6/+63 | |
| * | | | Adding more tests | Patrick Wendell | 2013-01-14 | 2 | -10/+173 | |
| * | | | Better equality test (thanks Josh) | Patrick Wendell | 2013-01-14 | 1 | -4/+3 | |
| * | | | Remving main method from tests | Patrick Wendell | 2013-01-14 | 1 | -27/+0 | |
| * | | | Adding some initial tests to streaming API. | Patrick Wendell | 2013-01-14 | 3 | -3/+79 | |
| * | | | A very rough, early cut at some Java functionality for Streaming. | Patrick Wendell | 2013-01-14 | 3 | -0/+188 | |
| | |/ | |/| | ||||||
* | | | Fixed issue https://spark-project.atlassian.net/browse/STREAMING-29, along wi... | Tathagata Das | 2013-01-19 | 1 | -1/+7 | |
| |/ |/| | ||||||
* | | Fixed updateStateByKey to work with primitive types. | Tathagata Das | 2013-01-14 | 3 | -8/+8 | |
|/ | ||||||
* | Minor name fix | Tathagata Das | 2013-01-13 | 1 | -2/+2 | |
* | Fixed bug | Tathagata Das | 2013-01-13 | 1 | -1/+3 | |
* | 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 | 26 | -186/+176 | |
* | 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 | 16 | -639/+37 | |
|\ \ \ | ||||||
| * | | | Changed locations for unit test logs. | Tathagata Das | 2013-01-07 | 1 | -2/+2 | |
| * | | | Fixed bug | Tathagata Das | 2013-01-07 | 1 | -1/+1 | |
| * | | | Renamed examples and added documentation. | Tathagata Das | 2013-01-07 | 3 | -21/+35 | |
| * | | | 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 | 46 | -507/+721 | |
|\| | | | ||||||
| * | | | Updated Streaming Programming Guide. | Tathagata Das | 2013-01-01 | 1 | -0/+1 |