aboutsummaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Merge branch 'streaming' into streaming-java-apiPatrick Wendell2013-01-172-6/+6
|\
| * Merge pull request #375 from tdas/streamingTathagata Das2013-01-144-11/+11
| |\
| | * Fixed updateStateByKey to work with primitive types.Tathagata Das2013-01-143-8/+8
| | * Fixed bug in RDD checkpointing.Tathagata Das2013-01-141-3/+3
* | | Import fixupPatrick Wendell2013-01-173-3/+0
* | | Style cleanupPatrick Wendell2013-01-173-3/+26
* | | Checkpointing in Streaming java APIPatrick Wendell2013-01-173-3/+93
* | | Adding flatMapPatrick Wendell2013-01-172-4/+106
* | | Adding checkpointing to Java APIPatrick Wendell2013-01-173-0/+81
* | | Adding other updateState functionsPatrick Wendell2013-01-171-13/+49
* | | Bug fix and test cleanupPatrick Wendell2013-01-172-9/+12
* | | StashPatrick Wendell2013-01-142-1/+61
* | | BugfixPatrick Wendell2013-01-141-2/+4
* | | Remove AnyRef constraint in updateStatePatrick Wendell2013-01-142-5/+5
* | | Bug fixPatrick Wendell2013-01-141-2/+1
* | | Making comments consistent w/ Spark stylePatrick Wendell2013-01-145-232/+196
* | | Two changes:Patrick Wendell2013-01-143-7/+271
* | | Some style cleanupPatrick Wendell2013-01-142-53/+93
* | | Flume example and bug fixPatrick Wendell2013-01-142-2/+57
* | | More work on InputStreamsPatrick Wendell2013-01-143-10/+130
* | | Porting to new Duration classPatrick Wendell2013-01-145-78/+78
* | | Fixing issue with <Long> typesPatrick Wendell2013-01-142-10/+16
* | | More work on StreamingContextPatrick Wendell2013-01-141-2/+45
* | | Import CleanupPatrick Wendell2013-01-143-4/+3
* | | Some docs for the JavaTestUtilsPatrick Wendell2013-01-141-6/+22
* | | Docs, some tests, and work onPatrick Wendell2013-01-145-32/+617
* | | Squashing a few TODOsPatrick Wendell2013-01-141-4/+15
* | | Style cleanup and moving functionsPatrick Wendell2013-01-143-67/+128
* | | More pair functionsPatrick Wendell2013-01-141-1/+42
* | | PairDStream and DStreamLikePatrick Wendell2013-01-145-100/+359
* | | Adding transform and unionPatrick Wendell2013-01-142-4/+72
* | | Reduce testsPatrick Wendell2013-01-141-6/+63
* | | Adding more testsPatrick Wendell2013-01-142-10/+173
* | | Better equality test (thanks Josh)Patrick Wendell2013-01-141-4/+3
* | | Remving main method from testsPatrick Wendell2013-01-141-27/+0
* | | Adding some initial tests to streaming API.Patrick Wendell2013-01-143-3/+79
* | | A very rough, early cut at some Java functionality for Streaming.Patrick Wendell2013-01-144-1/+190
|/ /
* | Merge pull request #370 from tdas/streamingTathagata Das2013-01-1313-89/+411
|\|
| * Minor name fixTathagata Das2013-01-131-2/+2
| * Fixed bugTathagata Das2013-01-131-1/+3
| * Added documentation for PairDStreamFunctions.Tathagata Das2013-01-135-50/+331
| * Removed stream id from the constructor of NetworkReceiver to make it easier f...Tathagata Das2013-01-137-37/+76
* | Merge pull request #366 from tdas/streamingTathagata Das2013-01-1336-378/+514
|\|
| * Changed variable name form ***Time to ***Duration to keep things consistent.Tathagata Das2013-01-0926-186/+176
| * Split Time to Time (absolute instant of time) and Duration (duration of time).Tathagata Das2013-01-0925-152/+174
| * Making the Twitter example distributed.Patrick Wendell2013-01-072-37/+62
| * Moved Twitter example to the where the other examples are.Tathagata Das2013-01-072-10/+11
| * Merge branch 'streaming-merge' into dev-mergeTathagata Das2013-01-073-1/+108
| |\
| | * Merge pull request #8 from radlab/twitter-examplePatrick Wendell2012-12-293-1/+108
| | |\
| | | * Minor changes after review and general cleanup.Patrick Wendell2012-12-212-11/+19
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-08 11:46:09 +0000