aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [java8API] SPARK-964 Investigate the potential for using JDK 8 lambda express...Prashant Sharma2014-03-035-158/+130
* SPARK-1158: Fix flaky RateLimitedOutputStreamSuite.Reynold Xin2014-03-032-20/+32
* SPARK-1121: Include avro for yarn-alpha buildsPatrick Wendell2014-03-021-0/+14
* SPARK-1084.2 (resubmitted)Sean Owen2014-03-021-5/+0
* Ignore RateLimitedOutputStreamSuite for now.Reynold Xin2014-03-021-1/+1
* Remove remaining references to incubationPatrick Wendell2014-03-021-2/+2
* SPARK 1084.1 (resubmitted)Sean Owen2014-02-274-55/+105
* SPARK-1071: Tidy logging strategy and use of log4jSean Owen2014-02-231-5/+0
* Merge pull request #567 from ScrapCodes/style2.Prashant Sharma2014-02-0918-65/+108
* Merge pull request #557 from ScrapCodes/style. Closes #557.Patrick Wendell2014-02-091-7/+10
* Merge pull request #542 from markhamstra/versionBump. Closes #542.Mark Hamstra2014-02-081-1/+1
* Merge pull request #529 from hsaputra/cleanup_right_arrowop_scalaHenry Saputra2014-02-021-8/+8
* Fix ClassCastException in JavaPairRDD.collectAsMap() (SPARK-1040)Josh Rosen2014-01-252-3/+3
* Updated java API docs for streaming, along with very minor changes in the cod...Tathagata Das2014-01-167-73/+77
* Made some classes private[stremaing] and deprecated a method in JavaStreaming...Tathagata Das2014-01-155-4/+11
* Merge remote-tracking branch 'apache/master' into filestream-fixTathagata Das2014-01-141-0/+17
|\
| * Add missing header filesPatrick Wendell2014-01-141-0/+17
* | Changed SparkConf to not be serializable. And also fixed unit-test log paths ...Tathagata Das2014-01-144-13/+53
|/
* Fixed loose ends in docs.Tathagata Das2014-01-141-2/+0
* Merge remote-tracking branch 'apache/master' into filestream-fixTathagata Das2014-01-137-33/+186
|\
| * Merge pull request #413 from rxin/scaladocPatrick Wendell2014-01-133-5/+127
| |\
| | * Adjusted visibility of various components.Reynold Xin2014-01-133-5/+127
| * | Merge pull request #409 from tdas/unpersistPatrick Wendell2014-01-134-27/+61
| |\ \
| | * | Added unpersisting and modified testsuite to better test out metadata cleaning.Tathagata Das2014-01-134-27/+61
| * | | Merge pull request #411 from tdas/filestream-fixPatrick Wendell2014-01-132-62/+69
| |\ \ \ | | |_|/ | |/| |
* | | | Removed StreamingContext.registerInputStream and registerOutputStream - they ...Tathagata Das2014-01-1314-80/+92
* | | | Merge remote-tracking branch 'apache/master' into filestream-fixTathagata Das2014-01-131-1/+1
|\| | | | |/ / |/| |
| * | Updated JavaStreamingContext to make scaladoc compile.Reynold Xin2014-01-131-1/+1
| |/
* / Improved file input stream further.Tathagata Das2014-01-132-62/+69
|/
* Merge pull request #400 from tdas/dstream-movePatrick Wendell2014-01-1332-45/+76
|\
| * Merge remote-tracking branch 'apache/master' into dstream-moveTathagata Das2014-01-125-13/+50
| |\
| * | Fixed persistence logic of WindowedDStream, and fixed default persistence lev...Tathagata Das2014-01-125-9/+33
| * | Merge branch 'error-handling' into dstream-moveTathagata Das2014-01-1211-70/+110
| |\ \
| * | | Moved DStream, DStreamCheckpointData and PairDStream from org.apache.spark.st...Tathagata Das2014-01-1230-39/+46
* | | | Merge pull request #397 from pwendell/host-portReynold Xin2014-01-125-7/+1
|\ \ \ \
| * | | | Removing mentions in testsPatrick Wendell2014-01-125-7/+1
* | | | | Merge pull request #395 from hsaputra/remove_simpleredundantreturn_scalaPatrick Wendell2014-01-126-10/+10
|\ \ \ \ \ | |_|_|_|/ |/| | | |
| * | | | Merge branch 'master' into remove_simpleredundantreturn_scalaHenry Saputra2014-01-1211-204/+483
| |\| | |
| * | | | Remove simple redundant return statement for Scala methods/functions:Henry Saputra2014-01-126-10/+10
* | | | | Merge pull request #394 from tdas/error-handlingPatrick Wendell2014-01-1220-228/+588
|\ \ \ \ \ | | |_|_|/ | |/| | |
| * | | | Changed StreamingContext.stopForWait to awaitTermination.Tathagata Das2014-01-124-15/+15
| * | | | Fixed bugs to ensure better cleanup of JobScheduler, JobGenerator and Network...Tathagata Das2014-01-129-56/+96
| | |_|/ | |/| |
| * | | Fixed bugs.Tathagata Das2014-01-121-1/+1
| * | | Merge remote-tracking branch 'apache/master' into error-handlingTathagata Das2014-01-111-10/+19
| |\ \ \ | | | |/ | | |/|
| * | | Added waitForStop and stop to JavaStreamingContext.Tathagata Das2014-01-112-3/+23
| * | | Converted JobScheduler to use actors for event handling. Changed protected[st...Tathagata Das2014-01-1116-184/+484
* | | | Adding deprecated versions of old codePatrick Wendell2014-01-122-8/+45
* | | | Rename DStream.foreach to DStream.foreachRDDPatrick Wendell2014-01-124-12/+12
| |/ / |/| |
* | | 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
|\ \ \