aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* Added filter functionality to reduceByKeyAndWindow with inverse. Consolidated...Tathagata Das2013-02-132-17/+34
* Changed scheduler and file input stream to fix bugs in the driver fault toler...Tathagata Das2013-02-138-348/+136
* Fixed bugs in FileInputDStream and Scheduler that occasionally failed to repr...Tathagata Das2013-02-101-81/+200
* Added an initial spark job to ensure worker nodes are initialized.Tathagata Das2013-02-091-1/+1
* Merge branch 'mesos-master' into streamingTathagata Das2013-02-077-6/+6
|\
| * Replace old 'master' term with 'driver'.Stephen Haberman2013-01-256-6/+6
| * Move JavaAPISuite into spark.streaming.Stephen Haberman2013-01-212-0/+0
* | Merge branch 'mesos-streaming' into streamingTathagata Das2013-02-072-0/+50
|\ \
| * \ Merge pull request #373 from Reinvigorate/sm-updateStateByKeyTathagata Das2013-02-072-0/+50
| |\ \ | | |/ | |/|
| | * adding updateStateByKey object lifecycle testseanm2013-01-202-0/+50
* | | Fixed checkpoint testcasesTathagata Das2013-01-233-172/+129
* | | Added support for rescheduling unprocessed batches on master failure.Tathagata Das2013-01-231-7/+16
* | | Added support for saving input files of FileInputDStream to graph checkpoints...Tathagata Das2013-01-221-20/+44
* | | Refactored DStreamCheckpointData.Tathagata Das2013-01-221-6/+6
|/ /
* | Fixed streaming testsuite bugsTathagata Das2013-01-207-6/+24
* | Moving tests to appropriate directoryPatrick Wendell2013-01-172-0/+0
* | Adding queueStream and some slight refactoringPatrick Wendell2013-01-171-81/+105
* | Merge branch 'streaming' into streaming-java-apiPatrick Wendell2013-01-171-3/+3
|\|
| * Fixed updateStateByKey to work with primitive types.Tathagata Das2013-01-141-3/+3
* | Import fixupPatrick Wendell2013-01-171-1/+0
* | Checkpointing in Streaming java APIPatrick Wendell2013-01-172-1/+76
* | Adding flatMapPatrick Wendell2013-01-171-4/+77
* | Bug fix and test cleanupPatrick Wendell2013-01-171-7/+10
* | StashPatrick Wendell2013-01-141-0/+33
* | More work on InputStreamsPatrick Wendell2013-01-141-1/+68
* | Porting to new Duration classPatrick Wendell2013-01-141-10/+10
* | Fixing issue with <Long> typesPatrick Wendell2013-01-141-4/+4
* | Import CleanupPatrick Wendell2013-01-141-2/+2
* | Some docs for the JavaTestUtilsPatrick Wendell2013-01-141-6/+22
* | Docs, some tests, and work onPatrick Wendell2013-01-141-25/+334
* | PairDStream and DStreamLikePatrick Wendell2013-01-142-3/+111
* | Adding transform and unionPatrick Wendell2013-01-141-4/+58
* | Reduce testsPatrick Wendell2013-01-141-6/+63
* | Adding more testsPatrick Wendell2013-01-141-9/+172
* | 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-142-0/+139
|/
* Fixed bugTathagata Das2013-01-131-1/+3
* Changed variable name form ***Time to ***Duration to keep things consistent.Tathagata Das2013-01-093-34/+34
* 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-071-1/+1
* Refactored a whole lot to push all DStreams into the spark.streaming.dstream ...Tathagata Das2012-12-305-10/+55
* Improved jekyll and scala docs. Made many classes and method private to remov...Tathagata Das2012-12-291-1/+1
* Modifications to make sure LocalScheduler terminate cleanly without errors wh...Tathagata Das2012-12-271-5/+8
* Adding Flume InputDStreamPatrick Wendell2012-12-071-2/+57
* Merge branch 'dev' into kafkaDenny2012-12-054-14/+8
|\
| * Merged branch mesos/master to branch dev.Tathagata Das2012-11-261-1/+1
| * Modified StreamingContext API to make constructor accept the batch size (sinc...Tathagata Das2012-11-193-13/+7
* | Merge branch 'dev' into kafkaDenny2012-11-133-54/+61
|\|
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-18 12:24:34 +0000