aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-6428][Streaming] Added explicit types for all public methods.Reynold Xin2015-03-2438-114/+127
* [SPARK-4012] stop SparkContext when the exception is thrown from an infinite ...CodingCat2015-03-181-1/+1
* [SPARK-6222][Streaming] Dont delete checkpoint data when doing pre-batch-star...Tathagata Das2015-03-192-12/+20
* [SPARK-3266] Use intermediate abstract classes to fix type erasure issues in ...Josh Rosen2015-03-173-2/+11
* [SPARK-6331] Load new master URL if present when recovering streaming context...Tathagata Das2015-03-172-3/+6
* [SPARK-6077] Remove streaming tab while stopping StreamingContextlisurprise2015-03-163-2/+7
* [Minor] Resolve sbt warnings: postfix operator second should be enabledGuoQiang Li2015-03-061-0/+1
* SPARK-4682 [CORE] Consolidate various 'Clock' classesSean Owen2015-02-198-106/+25
* [SPARK-5826][Streaming] Fix Configuration not serializable problemjerryshao2015-02-171-2/+4
* SPARK-5795 [STREAMING] api.java.JavaPairDStream.saveAsNewAPIHadoopFiles may n...Sean Owen2015-02-161-10/+10
* [SPARK-5831][Streaming]When checkpoint file size is bigger than 10, then dele...Xutingjun2015-02-161-1/+1
* [Minor] Fix incorrect warning logLiang-Chi Hsieh2015-02-041-1/+1
* [SPARK-5379][Streaming] Add awaitTerminationOrTimeoutzsxwing2015-02-042-0/+26
* [SPARK-4969][STREAMING][PYTHON] Add binaryRecords to streamingfreeman2015-02-033-5/+123
* [STREAMING] SPARK-4986 Wait for receivers to deregister and receiver job to t...Jesper Lundgren2015-02-032-4/+17
* Spark 3883: SSL support for HttpServer and AkkaJacek Lewandowski2015-02-021-2/+6
* [SPARK-4859][Core][Streaming] Refactor LiveListenerBus and StreamingListenerBuszsxwing2015-02-012-71/+27
* [SPARK-5315][Streaming] Fix reduceByWindow Java API not work bugjerryshao2015-01-221-0/+20
* [SPARK-5233][Streaming] Fix error replaying of WAL introduced bugjerryshao2015-01-222-9/+21
* [SPARK-5147][Streaming] Delete the received data WAL log periodicallyTathagata Das2015-01-218-19/+46
* [SPARK-5297][Streaming] Fix Java file stream type erasure problemjerryshao2015-01-201-10/+43
* [SPARK-4803] [streaming] Remove duplicate RegisterReceiver messageIlayaperumal Gopinathan2015-01-201-7/+0
* [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
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-15 00:26:32 +0000