aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-4027][Streaming] WriteAheadLogBackedBlockRDD to read received either f...Tathagata Das2014-10-301-0/+151
* [SPARK-4028][Streaming] ReceivedBlockHandler interface to abstract the functi...Tathagata Das2014-10-302-13/+279
* [SPARK-4053][Streaming] Made the ReceiverSuite test more reliable, by fixing ...Tathagata Das2014-10-291-14/+30
* [SPARK-4080] Only throw IOException from [write|read][Object|External]Josh Rosen2014-10-241-2/+2
* [SPARK-4026][Streaming] Write ahead log managementHari Shreedharan2014-10-241-0/+357
* [SPARK-2805] Upgrade Akka to 2.3.4Anand Avati2014-10-101-71/+0
* SPARK-3811 [CORE] More robust / standard Utils.deleteRecursively, Utils.creat...Sean Owen2014-10-094-9/+5
* Revert "[SPARK-2805] Upgrade to akka 2.3.4"Patrick Wendell2014-10-091-0/+71
* [SPARK-2805] Upgrade to akka 2.3.4Anand Avati2014-10-081-71/+0
* [SPARK-3377] [SPARK-3610] Metrics can be accidentally aggregated / History se...Kousuke Saruta2014-10-031-4/+10
* [SPARK-3748] Log thread name in unit test logsReynold Xin2014-10-011-1/+1
* Minor cleanup to tighten visibility and remove compilation warning.Reynold Xin2014-09-271-23/+24
* SPARK-2932 [STREAMING] Move MasterFailureTest out of "main" source directorySean Owen2014-09-252-1/+401
* [SPARK-546] Add full outer join to RDD and DStream.Aaron Staple2014-09-241-0/+15
* [SPARK-1853] Show Streaming application code context (file, line number) in S...Mubarak Seyed2014-09-231-2/+43
* SPARK-2745 [STREAMING] Add Java friendly methods to Duration classSean Owen2014-09-234-0/+368
* SPARK-2482: Resolve sbt warnings during buildwitgo2014-09-114-5/+0
* [Spark-3490] Disable SparkUI for testsAndrew Or2014-09-111-4/+12
* [SPARK-3285] [examples] Using values.sum is easier to understand than using v...Yadong Qi2014-08-282-3/+3
* [HOTFIX][Streaming][MLlib] use temp folder for checkpointXiangrui Meng2014-08-191-6/+11
* [SPARK-3128][MLLIB] Use streaming test suite for StreamingLRfreeman2014-08-191-1/+3
* [SPARK-2517] Remove some compiler warnings.Reynold Xin2014-07-161-1/+4
* [SPARK-1341] [Streaming] Throttle BlockGenerator to limit rate of data consum...Issac Buenrostro2014-07-101-0/+38
* [STREAMING] SPARK-2343: Fix QueueInputDStream with oneAtATime falseManuel Laflamme2014-07-091-1/+91
* SPARK-2113: awaitTermination() after stop() will hang in Spark StremaingLars Albertsson2014-06-111-0/+12
* Resolve scalatest warnings during buildwitgo2014-06-102-3/+2
* [SPARK-1841]: update scalatest to version 2.1.5witgo2014-06-061-6/+6
* [SPARK-1942] Stop clearing spark.driver.port in unit testsSyed Hashmi2014-06-033-7/+0
* SPARK-1878: Fix the incorrect initialization orderzsxwing2014-05-191-0/+4
* SPARK-1798. Tests should clean up temp filesSean Owen2014-05-124-2/+8
* [SPARK-1504], [SPARK-1505], [SPARK-1558] Updated Spark Streaming guideTathagata Das2014-05-051-0/+1
* [SPARK-1633][Streaming] Java API unit test and example for custom streaming r...Tathagata Das2014-04-285-4/+150
* [Spark-1382] Fix NPE in DStream.slice (updated version of #365)zsxwing2014-04-251-1/+11
* [SPARK-1617] and [SPARK-1618] Improvements to streaming ui and bug fix to soc...Tathagata Das2014-04-242-9/+14
* [SPARK-1592][streaming] Automatically remove streaming input blocksTathagata Das2014-04-243-14/+76
* SPARK-1488. Squash more language feature warnings in new commits by importing...Sean Owen2014-04-242-0/+2
* [streaming][SPARK-1578] Removed requirement for TTL in StreamingContext.Tathagata Das2014-04-223-35/+13
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-215-44/+359
* HOTFIX: Ignore streaming UI testPatrick Wendell2014-04-171-1/+2
* SPARK-1488. Resolve scalac feature warnings during buildSean Owen2014-04-142-0/+3
* [SPARK-1386] Web UI for Spark StreamingTathagata Das2014-04-113-4/+49
* Remove Unnecessary Whitespace'sSandeep2014-04-101-1/+1
* Spark 1271: Co-Group and Group-By should pass Iterable[X]Holden Karau2014-04-082-11/+51
* [SPARK-1331] Added graceful shutdown to Spark StreamingTathagata Das2014-04-083-16/+98
* HOTFIX: Disable actor input stream test.Patrick Wendell2014-04-071-2/+2
* SPARK-1365 [HOTFIX] Fix RateLimitedOutputStream testPatrick Wendell2014-03-311-2/+3
* SPARK-1096, a space after comment start style checker.Prashant Sharma2014-03-282-2/+3
* SPARK-1316. Remove use of Commons IOSean Owen2014-03-253-28/+24
* [java8API] SPARK-964 Investigate the potential for using JDK 8 lambda express...Prashant Sharma2014-03-031-30/+32
* SPARK-1158: Fix flaky RateLimitedOutputStreamSuite.Reynold Xin2014-03-031-5/+8
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-07 16:41:15 +0000