aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* STREAMING-50: Support transform workaround in JavaPairDStreamPatrick Wendell2013-02-121-0/+45
* Using tuple swap()Patrick Wendell2013-02-111-2/+2
* small fixPatrick Wendell2013-02-111-2/+2
* Fix for MapPartitionsPatrick Wendell2013-02-111-15/+52
* Fix for flatmapPatrick Wendell2013-02-111-0/+42
* Indentation fixPatrick Wendell2013-02-111-10/+10
* Initial cut at replacing K, V in Java filesPatrick Wendell2013-02-111-0/+56
* Replace old 'master' term with 'driver'.Stephen Haberman2013-01-256-6/+6
* Move JavaAPISuite into spark.streaming.Stephen Haberman2013-01-212-0/+0
* 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
|\|
| * Optimized checkpoint writing by reusing FileSystem object. Fixed bug in updat...Tathagata Das2012-11-133-54/+61
* | Merge branch 'dev' into kafkaDenny2012-11-122-28/+134
|\|
| * Speeded up CheckpointSuiteTathagata Das2012-11-121-12/+14
| * Fixed bug in FileInputDStream that allowed it to miss new files. Added tests ...Tathagata Das2012-11-111-16/+120
* | Kafka Stream comments.Denny2012-11-111-6/+6
|/
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-19 08:58:24 +0000