aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test/scala
Commit message (Expand)AuthorAgeFilesLines
* [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-032-3/+0
* SPARK-1798. Tests should clean up temp filesSean Owen2014-05-122-0/+3
* [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-283-2/+4
* [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-214-38/+356
* 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
* Spark 1271: Co-Group and Group-By should pass Iterable[X]Holden Karau2014-04-081-2/+2
* [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
* SPARK-1158: Fix flaky RateLimitedOutputStreamSuite.Reynold Xin2014-03-031-5/+8
* Ignore RateLimitedOutputStreamSuite for now.Reynold Xin2014-03-021-1/+1
* Changed SparkConf to not be serializable. And also fixed unit-test log paths ...Tathagata Das2014-01-141-8/+20
* Merge remote-tracking branch 'apache/master' into filestream-fixTathagata Das2014-01-132-23/+89
|\
| * Merge pull request #413 from rxin/scaladocPatrick Wendell2014-01-131-0/+40
| |\
| | * Adjusted visibility of various components.Reynold Xin2014-01-131-0/+40
| * | Added unpersisting and modified testsuite to better test out metadata cleaning.Tathagata Das2014-01-131-23/+49
| |/
* / Removed StreamingContext.registerInputStream and registerOutputStream - they ...Tathagata Das2014-01-135-12/+7
|/
* Merge pull request #400 from tdas/dstream-movePatrick Wendell2014-01-136-3/+21
|\
| * Merge remote-tracking branch 'apache/master' into dstream-moveTathagata Das2014-01-122-2/+2
| |\
| * | Fixed persistence logic of WindowedDStream, and fixed default persistence lev...Tathagata Das2014-01-121-0/+14
| * | Merge branch 'error-handling' into dstream-moveTathagata Das2014-01-122-10/+21
| |\ \
| * | | Moved DStream, DStreamCheckpointData and PairDStream from org.apache.spark.st...Tathagata Das2014-01-126-2/+6
* | | | Merge pull request #397 from pwendell/host-portReynold Xin2014-01-122-2/+0
|\ \ \ \ | |_|_|/ |/| | |
| * | | Removing mentions in testsPatrick Wendell2014-01-122-2/+0
* | | | Merge pull request #394 from tdas/error-handlingPatrick Wendell2014-01-124-8/+245
|\ \ \ \ | | |_|/ | |/| |
| * | | Changed StreamingContext.stopForWait to awaitTermination.Tathagata Das2014-01-122-9/+9
| * | | Fixed bugs to ensure better cleanup of JobScheduler, JobGenerator and Network...Tathagata Das2014-01-122-2/+13
| | |/ | |/|
| * | Converted JobScheduler to use actors for event handling. Changed protected[st...Tathagata Das2014-01-114-6/+232
* | | Rename DStream.foreach to DStream.foreachRDDPatrick Wendell2014-01-121-1/+1
| |/ |/|
* | Revert "Fix one unit test that was not setting spark.cleaner.ttl"Patrick Wendell2014-01-111-1/+1
* | Merge pull request #381 from mateiz/default-ttlMatei Zaharia2014-01-101-1/+1
|\ \ | |/ |/|
| * Fix one unit test that was not setting spark.cleaner.ttlMatei Zaharia2014-01-101-1/+1
* | Merge branch 'standalone-driver' into driver-testTathagata Das2014-01-095-110/+34
|\|
| * Merge remote-tracking branch 'apache/master' into project-refactorTathagata Das2014-01-065-56/+52
| |\
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-09 21:05:51 +0000