aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* 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
|\ \ \
| * | | Fix one unit test that was not setting spark.cleaner.ttlMatei Zaharia2014-01-101-1/+1
* | | | Merge pull request #383 from tdas/driver-testPatrick Wendell2014-01-1010-193/+463
|\ \ \ \ | | |/ / | |/| |
| * | | Merge remote-tracking branch 'apache/master' into driver-testTathagata Das2014-01-102-8/+8
| |\| |
| * | | 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