aboutsummaryrefslogtreecommitdiff
path: root/streaming/src
Commit message (Collapse)AuthorAgeFilesLines
* Merge branch 'streaming' into streaming-java-apiPatrick Wendell2013-01-171-3/+3
|\
| * Fixed updateStateByKey to work with primitive types.Tathagata Das2013-01-143-8/+8
| |
* | 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 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-142-5/+269
| | | | | | | | | | - Updating countByX() types based on bug fix - Porting new documentation to Java
* | Some style cleanupPatrick Wendell2013-01-142-53/+93
| |
* | Flume example and bug fixPatrick Wendell2013-01-141-2/+7
| |
* | 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
| | | | | | | | StreamingContext
* | 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-143-0/+188
|/
* Minor name fixTathagata Das2013-01-131-2/+2
|
* Fixed bugTathagata Das2013-01-131-1/+3
|
* Added documentation for PairDStreamFunctions.Tathagata Das2013-01-133-27/+303
|
* Removed stream id from the constructor of NetworkReceiver to make it easier ↵Tathagata Das2013-01-136-30/+68
| | | | for PluggableNetworkInputDStream.
* 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
|
* Moved Twitter example to the where the other examples are.Tathagata Das2013-01-072-104/+0
|
* Merge branch 'streaming-merge' into dev-mergeTathagata Das2013-01-072-0/+104
|\
| * Merge pull request #8 from radlab/twitter-examplePatrick Wendell2012-12-292-0/+104
| |\ | | | | | | Adding a Twitter InputDStream with an example
| | * Minor changes after review and general cleanup.Patrick Wendell2012-12-212-11/+19
| | | | | | | | | | | | | | | | | | - Added filters to Twitter example - Removed un-used import - Some code clean-up
| | * Adding a Twitter InputDStream with an examplePatrick Wendell2012-12-212-0/+96
| | |
* | | Merge branch 'dev' into dev-mergeTathagata Das2013-01-0716-639/+37
|\ \ \
| * | | Changed locations for unit test logs.Tathagata Das2013-01-071-2/+2
| | | |
| * | | Fixed bugTathagata Das2013-01-071-1/+1
| | | |
| * | | Renamed examples and added documentation.Tathagata Das2013-01-073-21/+35
| | | |
| * | | Moved Spark Streaming examples to examples sub-project.Tathagata Das2013-01-0612-616/+0
| | | |
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-08 11:50:43 +0000