aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
...
| * | 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
| * | | | | Fixed conf/slaves and updated docs.Tathagata Das2014-01-102-5/+15
| | |/ / / | |/| | |
| * | | | Merge remote-tracking branch 'apache/master' into driver-testTathagata Das2014-01-094-5/+5
| |\ \ \ \ | | |/ / / | |/| | / | | | |/ | | |/|
| * | | Fixed bugs in reading of checkpoints.Tathagata Das2014-01-102-17/+20
| * | | Merge branch 'standalone-driver' into driver-testTathagata Das2014-01-0929-1273/+270
| |\ \ \
| * | | | Changed the way StreamingContext finds and reads checkpoint files, and added ...Tathagata Das2014-01-095-109/+210
| * | | | More bug fixes.Tathagata Das2014-01-081-19/+26
| * | | | Modified checkpoing file clearing policy.Tathagata Das2014-01-087-52/+104
| * | | | Added a hashmap to cache file mod times.Tathagata Das2014-01-051-6/+24
| * | | | Merge branch 'filestream-fix' into driver-testTathagata Das2014-01-067-142/+219
| |\ \ \ \
| * | | | | Bug fixes to the DriverRunner and minor changes here and there.Tathagata Das2014-01-062-5/+5
| * | | | | Added StreamingContext.getOrCreate to for automatic recovery, and added Recov...Tathagata Das2014-01-022-4/+26
* | | | | | Merge pull request #377 from andrewor14/masterPatrick Wendell2014-01-101-10/+19
|\ \ \ \ \ \ | |_|_|_|_|/ |/| | | | |
| * | | | | Fix wonky imports from mergeAndrew Or2014-01-091-8/+1
| * | | | | Merge github.com:apache/incubator-sparkAndrew Or2014-01-0917-1189/+135
| |\ \ \ \ \ | | | |_|_|/ | | |/| | |
| * | | | | Merge remote-tracking branch 'spark/master'Andrew Or2014-01-0221-241/+378
| |\ \ \ \ \
| * | | | | | Address Aaron's commentsAndrew Or2013-12-291-4/+4
| * | | | | | Fix streaming JavaAPISuite againAndrew Or2013-12-261-8/+12
| * | | | | | Fix streaming JavaAPISuite that depended on orderAaron Davidson2013-12-261-11/+16
| | |_|/ / / | |/| | | |
* | | | | | 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
| | |_|_|/ | |/| | |
* / | | | Use typed getters for configuration settingsMatei Zaharia2014-01-094-5/+5
|/ / / /
* | | | Merge remote-tracking branch 'apache/master' into project-refactorTathagata Das2014-01-0621-234/+377
|\ \ \ \