aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* [java8API] SPARK-964 Investigate the potential for using JDK 8 lambda express...Prashant Sharma2014-03-034-128/+98
* SPARK-1158: Fix flaky RateLimitedOutputStreamSuite.Reynold Xin2014-03-031-15/+24
* SPARK 1084.1 (resubmitted)Sean Owen2014-02-273-18/+18
* 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 #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-154-1/+8
* 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-143-5/+33
|/
* Fixed loose ends in docs.Tathagata Das2014-01-141-2/+0
* Merge remote-tracking branch 'apache/master' into filestream-fixTathagata Das2014-01-135-10/+97
|\
| * Merge pull request #413 from rxin/scaladocPatrick Wendell2014-01-132-5/+87
| |\
| | * Adjusted visibility of various components.Reynold Xin2014-01-132-5/+87
| * | Merge pull request #409 from tdas/unpersistPatrick Wendell2014-01-133-4/+12
| |\ \
| | * | Added unpersisting and modified testsuite to better test out metadata cleaning.Tathagata Das2014-01-133-4/+12
| * | | Merge pull request #411 from tdas/filestream-fixPatrick Wendell2014-01-132-62/+69
| |\ \ \ | | |_|/ | |/| |
* | | | Removed StreamingContext.registerInputStream and registerOutputStream - they ...Tathagata Das2014-01-138-66/+84
* | | | 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-1326-42/+55
|\
| * Merge remote-tracking branch 'apache/master' into dstream-moveTathagata Das2014-01-123-11/+48
| |\
| * | Fixed persistence logic of WindowedDStream, and fixed default persistence lev...Tathagata Das2014-01-124-9/+19
| * | Merge branch 'error-handling' into dstream-moveTathagata Das2014-01-129-60/+89
| |\ \
| * | | Moved DStream, DStreamCheckpointData and PairDStream from org.apache.spark.st...Tathagata Das2014-01-1224-37/+40
* | | | Merge pull request #397 from pwendell/host-portReynold Xin2014-01-122-3/+1
|\ \ \ \
| * | | | Removing mentions in testsPatrick Wendell2014-01-122-3/+1
* | | | | Merge pull request #395 from hsaputra/remove_simpleredundantreturn_scalaPatrick Wendell2014-01-126-10/+10
|\ \ \ \ \ | |_|_|_|/ |/| | | |
| * | | | Merge branch 'master' into remove_simpleredundantreturn_scalaHenry Saputra2014-01-129-189/+459
| |\| | |
| * | | | 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-1216-220/+343
|\ \ \ \ \ | | |_|_|/ | |/| | |
| * | | | Changed StreamingContext.stopForWait to awaitTermination.Tathagata Das2014-01-122-6/+6
| * | | | Fixed bugs to ensure better cleanup of JobScheduler, JobGenerator and Network...Tathagata Das2014-01-127-54/+83
| | |_|/ | |/| |
| * | | Fixed bugs.Tathagata Das2014-01-121-1/+1
| * | | 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-1112-178/+252
| | |/ | |/|
* | | Adding deprecated versions of old codePatrick Wendell2014-01-122-8/+45
* | | Rename DStream.foreach to DStream.foreachRDDPatrick Wendell2014-01-123-11/+11
|/ /
* | Merge remote-tracking branch 'apache/master' into driver-testTathagata Das2014-01-102-8/+8
|\ \
| * \ Merge pull request #363 from pwendell/streaming-logsPatrick Wendell2014-01-092-5/+5
| |\ \ | | |/ | |/|
| | * Set default logging to WARN for Spark streaming examples.Patrick Wendell2014-01-092-5/+5
* | | Modified streaming.FailureSuite tests to test StreamingContext.getOrCreate.Tathagata Das2014-01-101-21/+34
* | | Updated docs based on Patrick's comments in PR 383.Tathagata Das2014-01-102-11/+16
* | | Merge branch 'driver-test' of github.com:tdas/incubator-spark into driver-testTathagata Das2014-01-102-55/+96
|\ \ \
| * | | Removed spark.hostPort and other setting from SparkConf before saving to chec...Tathagata Das2014-01-101-18/+6
| * | | Merge branch 'driver-test' of github.com:tdas/incubator-spark into driver-testTathagata Das2014-01-104-5/+5
| |\ \ \
| * | | | Refactored graph checkpoint file reading and writing code to make it cleaner ...Tathagata Das2014-01-102-49/+102