Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Clean up setup code in PySpark checkpointing tests | Josh Rosen | 2013-01-20 | 2 | -16/+6 |
* | Update checkpointing API docs in Python/Java. | Josh Rosen | 2013-01-20 | 4 | -34/+28 |
* | Add checkpointFile() and more tests to PySpark. | Josh Rosen | 2013-01-20 | 3 | -2/+37 |
* | Add RDD checkpointing to Python API. | Josh Rosen | 2013-01-20 | 6 | -4/+93 |
* | Merge pull request #361 from mesos/streaming | Matei Zaharia | 2013-01-20 | 124 | -332/+10770 |
|\ | |||||
| * | Merge branch 'master' into streaming | Matei Zaharia | 2013-01-20 | 18 | -67/+424 |
| |\ | |||||
| * \ | Merge pull request #380 from tdas/streaming | Tathagata Das | 2013-01-20 | 82 | -319/+3579 |
| |\ \ | |||||
| | * | | Fixed streaming testsuite bugs | Tathagata Das | 2013-01-20 | 7 | -6/+24 |
| | * | | Merge branch 'mesos-streaming' into streaming | Tathagata Das | 2013-01-20 | 17 | -152/+2768 |
| | |\ \ | | |/ / | |/| | | |||||
| * | | | Merge pull request #369 from pwendell/streaming-java-api | Patrick Wendell | 2013-01-17 | 15 | -121/+2708 |
| |\ \ \ | |||||
| | * | | | NetworkWordCount example | Patrick Wendell | 2013-01-17 | 2 | -1/+63 |
| | * | | | Moving tests to appropriate directory | Patrick Wendell | 2013-01-17 | 2 | -0/+0 |
| | * | | | Adding queueStream and some slight refactoring | Patrick Wendell | 2013-01-17 | 4 | -83/+226 |
| | * | | | Small doc fix | Patrick Wendell | 2013-01-17 | 1 | -1/+1 |
| | * | | | Merge branch 'streaming' into streaming-java-api | Patrick Wendell | 2013-01-17 | 2 | -6/+6 |
| | |\ \ \ | | |/ / / | |/| | | | |||||
| * | | | | Merge pull request #375 from tdas/streaming | Tathagata Das | 2013-01-14 | 4 | -11/+11 |
| |\ \ \ \ | |||||
| | | * | | | Import fixup | Patrick Wendell | 2013-01-17 | 3 | -3/+0 |
| | | * | | | Style cleanup | Patrick Wendell | 2013-01-17 | 3 | -3/+26 |
| | | * | | | Checkpointing in Streaming java API | Patrick Wendell | 2013-01-17 | 3 | -3/+93 |
| | | * | | | Adding flatMap | Patrick Wendell | 2013-01-17 | 2 | -4/+106 |
| | | * | | | Adding checkpointing to Java API | Patrick Wendell | 2013-01-17 | 3 | -0/+81 |
| | | * | | | 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 | 3 | -7/+271 |
| | | * | | | Some style cleanup | Patrick Wendell | 2013-01-14 | 2 | -53/+93 |
| | | * | | | Flume example and bug fix | Patrick Wendell | 2013-01-14 | 2 | -2/+57 |
| | | * | | | 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 | 4 | -1/+190 |
| | |/ / / | |/| | | | |||||
| * | | | | Merge pull request #370 from tdas/streaming | Tathagata Das | 2013-01-13 | 13 | -89/+411 |
| |\ \ \ \ |