aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* 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
|/
* Fixed bug in InputStreamsSuitetdas2012-11-081-0/+2
* Added FailureTestsuite for testing multiple, repeated master failures.Tathagata Das2012-11-063-38/+234
* Made more bug fixes for checkpointing.Tathagata Das2012-11-051-27/+50
* Fixed major bugs in checkpointing.Tathagata Das2012-11-053-45/+137
* Made checkpointing of dstream graph to work with checkpointing of RDDs. For s...Tathagata Das2012-11-043-26/+92
* Fixed serialization bug in countByWindow, added countByKey and countByKeyAndW...Tathagata Das2012-11-023-43/+164
* Merge branch 'dev' of github.com:radlab/spark into devTathagata Das2012-10-251-1/+1
|\
| * Merge remote-tracking branch 'public/master' into devMatei Zaharia2012-10-241-1/+1
* | Added tests for the file input stream.Tathagata Das2012-10-241-6/+62
|/
* Minor fixes.Tathagata Das2012-10-241-7/+9
* Added tests for testing network input stream.Tathagata Das2012-10-241-0/+112
* Renamed the streaming testsuites.Tathagata Das2012-10-234-6/+8
* Updated StateDStream api to use Options instead of nulls.Tathagata Das2012-10-231-5/+2
* Added MapValueDStream, FlatMappedValuesDStream and CoGroupedDStream, and ther...Tathagata Das2012-10-212-4/+141
* Fixed some bugs in tests for forgetting RDDs, and made sure that use of manua...Tathagata Das2012-10-213-59/+51
* Added functionality to forget RDDs from DStreams.Tathagata Das2012-10-193-15/+88
* Minor modifications.Tathagata Das2012-10-151-1/+1
* Refactored DStreamSuiteBase to create CheckpointSuite- testsuite for testing ...Tathagata Das2012-10-144-64/+199
* Fixed bugs in the streaming testsuites.Tathagata Das2012-10-132-7/+18
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-09 03:29:06 +0000