aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
...
* | Flume example and bug fixPatrick Wendell2013-01-141-2/+7
* | More work on InputStreamsPatrick Wendell2013-01-142-9/+62
* | Porting to new Duration classPatrick Wendell2013-01-144-68/+68
* | Fixing issue with <Long> typesPatrick Wendell2013-01-141-6/+12
* | More work on StreamingContextPatrick Wendell2013-01-141-2/+45
* | Import CleanupPatrick Wendell2013-01-142-2/+1
* | Docs, some tests, and work onPatrick Wendell2013-01-144-7/+283
* | 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-143-97/+248
* | Adding transform and unionPatrick Wendell2013-01-141-0/+14
* | Adding more testsPatrick Wendell2013-01-141-1/+1
* | Adding some initial tests to streaming API.Patrick Wendell2013-01-142-64/+1
* | 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
* Added documentation for PairDStreamFunctions.Tathagata Das2013-01-133-27/+303
* Removed stream id from the constructor of NetworkReceiver to make it easier f...Tathagata Das2013-01-136-30/+68
* Changed variable name form ***Time to ***Duration to keep things consistent.Tathagata Das2013-01-0923-152/+142
* 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
| |\
| | * Minor changes after review and general cleanup.Patrick Wendell2012-12-212-11/+19
| | * Adding a Twitter InputDStream with an examplePatrick Wendell2012-12-212-0/+96
* | | Merge branch 'dev' into dev-mergeTathagata Das2013-01-0714-636/+34
|\ \ \
| * | | Renamed examples and added documentation.Tathagata Das2013-01-072-20/+34
| * | | Moved Spark Streaming examples to examples sub-project.Tathagata Das2013-01-0612-616/+0
* | | | BufferingBlockCreator -> NetworkReceiver.BlockGeneratorPatrick Wendell2013-01-025-94/+89
* | | | Merge branch 'dev-merge' into datahandler-fixPatrick Wendell2013-01-0241-496/+665
|\| | |
| * | | Updated Streaming Programming Guide.Tathagata Das2013-01-011-0/+1
| * | | More classes made private[streaming] to hide from scala docs.Tathagata Das2012-12-3017-52/+135
| * | | Refactored a whole lot to push all DStreams into the spark.streaming.dstream ...Tathagata Das2012-12-3035-323/+346
| * | | Improved jekyll and scala docs. Made many classes and method private to remov...Tathagata Das2012-12-2915-138/+200
* | | | Several code-quality improvements to DataHandler.Patrick Wendell2013-01-025-88/+84
|/ / /
* | | Merge branch 'dev' of github.com:radlab/spark into dev-checkpointTathagata Das2012-12-2011-102/+620
|\| |
| * | Changes in response to TD's review.Patrick Wendell2012-12-076-15/+29
| * | Adding Flume InputDStreamPatrick Wendell2012-12-077-4/+189
| |/
| * Adjust Kafka code to work with new streaming changes.Denny2012-12-052-4/+5
| * Merge branch 'dev' into kafkaDenny2012-12-0518-95/+131
| |\
| * | Added Kafka Wordcount producerDenny2012-11-192-25/+52
| * | Comment out code for fault-tolerance.Denny2012-11-191-17/+18
| * | Merge branch 'dev' into kafkaDenny2012-11-194-3/+173
| |\ \
| * \ \ Merge branch 'dev' into kafkaDenny2012-11-136-69/+94
| |\ \ \
| * | | | change import for example functionDenny2012-11-131-1/+1
| * | | | Merge branch 'dev' into kafkaDenny2012-11-1224-2027/+197
| |\ \ \ \
| * | | | | Updated comment.Denny2012-11-111-1/+1
| * | | | | Add comment.Denny2012-11-111-0/+2
| * | | | | Kafka Stream comments.Denny2012-11-114-47/+93
| * | | | | Merge branch 'dev' of github.com:radlab/spark into kafkaDenny2012-11-094-12/+27
| |\ \ \ \ \
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-19 12:21:29 +0000