aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-4999][Streaming] Change storeInBlockManager to false by defaultjerryshao2015-01-121-1/+1
* [SPARK-5181] do not print writing WAL log when WAL is disabledCodingCat2015-01-101-2/+4
* [SPARK-1600] Refactor FileInputStream tests to remove Thread.sleep() calls an...Josh Rosen2015-01-062-7/+15
* [SPARK-4835] Disable validateOutputSpecs for Spark Streaming jobsJosh Rosen2015-01-043-4/+16
* [SPARK-3325][Streaming] Add a parameter to the method print in class DStreamYadong Qi2015-01-022-4/+20
* [SPARK-5035] [Streaming] ReceiverMessage trait should extend SerializableJosh Rosen2014-12-311-1/+1
* [SPARK-5028][Streaming]Add total received and processed records metrics to St...jerryshao2014-12-311-0/+6
* [SPARK-4790][STREAMING] Fix ReceivedBlockTrackerSuite waits for old file...Hari Shreedharan2014-12-314-12/+24
* [SPARK-4813][Streaming] Fix the issue that ContextWaiter didn't handle 'spuri...zsxwing2014-12-301-15/+48
* SPARK-4971: Fix typo in BlockGenerator commentCodingCat2014-12-261-1/+1
* [SPARK-4608][Streaming] Reorganize StreamingContext implicit to improve API c...zsxwing2014-12-256-17/+23
* [SPARK-4537][Streaming] Expand StreamingSource to add more metricsjerryshao2014-12-252-15/+57
* [SPARK-4873][Streaming] Use `Future.zip` instead of `Future.flatMap`(for-loop...zsxwing2014-12-241-4/+1
* [SPARK-4671][Streaming]Do not replicate streaming block when WAL is enabledjerryshao2014-12-231-1/+19
* [SPARK-4802] [streaming] Remove receiverInfo once receiver is de-registeredIlayaperumal Gopinathan2014-12-231-2/+2
* [SPARK-4668] Fix some documentation typos.Ryan Williams2014-12-151-1/+1
* [SPARK-4196][SPARK-4602][Streaming] Fix serialization issue in PairDStreamFun...Tathagata Das2014-11-251-14/+16
* [SPARK-4601][Streaming] Set correct call site for streaming jobs so that it i...Tathagata Das2014-11-251-0/+1
* [SPARK-4381][Streaming]Add warning log when user set spark.master to local in...jerryshao2014-11-251-0/+5
* [SPARK-4535][Streaming] Fix the error in commentsq002515982014-11-254-7/+7
* [SPARK-4518][SPARK-4519][Streaming] Refactored file stream to prevent files f...Tathagata Das2014-11-242-106/+187
* [SPARK-4294][Streaming] UnionDStream stream should express the requirements i...Yadong Qi2014-11-191-11/+4
* [SPARK-4481][Streaming][Doc] Fix the wrong description of updateFunczsxwing2014-11-191-9/+7
* [SPARK-4482][Streaming] Disable ReceivedBlockTracker's write ahead log by def...Tathagata Das2014-11-191-12/+25
* [SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...jerryshao2014-11-142-9/+54
* [SPARK-3660][STREAMING] Initial RDD for updateStateByKey transformationSoumitra Kumar2014-11-123-32/+106
* [Streaming][Minor]Replace some 'if-else' in Clockhuangzhaowei2014-11-111-13/+2
* [SPARK-3954][Streaming] Optimization to FileInputDStreamsurq2014-11-101-3/+4
* [SPARK-4301] StreamingContext should not allow start() to be called after cal...Josh Rosen2014-11-081-17/+21
* [SPARK-4029][Streaming] Update streaming driver to reliably save and recover ...Tathagata Das2014-11-055-78/+343
* [SPARK-4027][Streaming] WriteAheadLogBackedBlockRDD to read received either f...Tathagata Das2014-10-302-3/+130
* [SPARK-4028][Streaming] ReceivedBlockHandler interface to abstract the functi...Tathagata Das2014-10-309-57/+324
* [SPARK-4080] Only throw IOException from [write|read][Object|External]Josh Rosen2014-10-245-11/+14
* [SPARK-4026][Streaming] Write ahead log managementHari Shreedharan2014-10-246-0/+535
* replace awaitTransformation with awaitTermination in scaladoc/javadocHolden Karau2014-10-212-2/+2
* [SPARK-2377] Python API for Streaminggiwa2014-10-122-1/+317
* [SPARK-3762] clear reference of SparkEnv after stopDavies Liu2014-10-073-3/+0
* SPARK-2932 [STREAMING] Move MasterFailureTest out of "main" source directorySean Owen2014-09-251-428/+0
* [SPARK-546] Add full outer join to RDD and DStream.Aaron Staple2014-09-242-4/+86
* [SPARK-1853] Show Streaming application code context (file, line number) in S...Mubarak Seyed2014-09-232-36/+64
* SPARK-2745 [STREAMING] Add Java friendly methods to Duration classSean Owen2014-09-232-2/+57
* SPARK-3470 [CORE] [STREAMING] Add Closeable / close() to Java context objectsSean Owen2014-09-121-2/+5
* [Spark-3490] Disable SparkUI for testsAndrew Or2014-09-113-9/+29
* [Docs] actorStream storageLevel default is MEMORY_AND_DISK_SER_2Mario Pastorelli2014-09-091-1/+1
* [SPARK-2886] Use more specific actor system name than "spark"Andrew Or2014-08-251-5/+5
* [SPARK-2169] Don't copy appName / basePath everywhere.Marcelo Vanzin2014-08-182-6/+3
* [SPARK-2924] remove default args to overloaded methodsAnand Avati2014-08-151-1/+7
* Minor cleanup of metrics.SourceReynold Xin2014-08-141-3/+3
* [SPARK-2454] Do not ship spark home to WorkersAndrew Or2014-08-021-1/+0
* [SPARK-2379] Fix the bug that streaming's receiver may fall into a dead loopjoyyoj2014-08-011-1/+1
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-09 10:41:24 +0000