aboutsummaryrefslogtreecommitdiff
path: root/streaming/src
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-6765] Fix test code style for streaming.Reynold Xin2015-04-0816-58/+96
* [SPARK-6602][Core] Replace direct use of Akka with Spark RPC interface - part 1zsxwing2015-04-041-14/+11
* [SPARK-6428] Turn on explicit type checking for public methods.Reynold Xin2015-04-035-12/+16
* [SPARK-6428][Streaming] Added explicit types for all public methods.Reynold Xin2015-03-2438-114/+127
* SPARK-6338 [CORE] Use standard temp dir mechanisms in tests to avoid orphane...Sean Owen2015-03-205-27/+14
* [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-193-12/+153
* [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-174-7/+25
* [SPARK-6077] Remove streaming tab while stopping StreamingContextlisurprise2015-03-165-57/+102
* SPARK-6225 [CORE] [SQL] [STREAMING] Resolve most build warnings, 1.3.0 editionSean Owen2015-03-111-0/+4
* [Minor] Resolve sbt warnings: postfix operator second should be enabledGuoQiang Li2015-03-061-0/+1
* [SPARK-5943][Streaming] Update the test to use new API to reduce the warningSaisai Shao2015-02-232-6/+6
* SPARK-4682 [CORE] Consolidate various 'Clock' classesSean Owen2015-02-1916-171/+82
* [SPARK-5826][Streaming] Fix Configuration not serializable problemjerryshao2015-02-171-2/+4
* SPARK-5795 [STREAMING] api.java.JavaPairDStream.saveAsNewAPIHadoopFiles may n...Sean Owen2015-02-162-10/+28
* [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-043-0/+50
* [SPARK-4969][STREAMING][PYTHON] Add binaryRecords to streamingfreeman2015-02-034-5/+174
* [STREAMING] SPARK-4986 Wait for receivers to deregister and receiver job to t...Jesper Lundgren2015-02-033-4/+75
* Spark 3883: SSL support for HttpServer and AkkaJacek Lewandowski2015-02-021-2/+6
* Make sure only owner can read / write to directories created for the job.Marcelo Vanzin2015-02-021-2/+2
* [SPARK-4859][Core][Streaming] Refactor LiveListenerBus and StreamingListenerBuszsxwing2015-02-012-71/+27
* SPARK-4430 [STREAMING] [TEST] Apache RAT Checks fail spuriously on test filesSean Owen2015-01-251-7/+2
* [SPARK-5315][Streaming] Fix reduceByWindow Java API not work bugjerryshao2015-01-222-2/+38
* [SPARK-5233][Streaming] Fix error replaying of WAL introduced bugjerryshao2015-01-223-19/+31
* [SPARK-5147][Streaming] Delete the received data WAL log periodicallyTathagata Das2015-01-219-50/+172
* [SPARK-5297][Streaming] Fix Java file stream type erasure problemjerryshao2015-01-202-15/+108
* [SPARK-4803] [streaming] Remove duplicate RegisterReceiver messageIlayaperumal Gopinathan2015-01-202-9/+2
* [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-4159 [CORE] Maven build doesn't run JUnit test suitesSean Owen2015-01-061-3/+2
* [SPARK-1600] Refactor FileInputStream tests to remove Thread.sleep() calls an...Josh Rosen2015-01-066-136/+251
* [SPARK-4835] Disable validateOutputSpecs for Spark Streaming jobsJosh Rosen2015-01-044-4/+55
* [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-317-16/+42
* [SPARK-1010] Clean up uses of System.setProperty in unit testsJosh Rosen2014-12-301-2/+6
* [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-2511-21/+58
* [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-4297 [BUILD] Build warning fixes omnibusSean Owen2014-12-241-8/+8
* [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-4826] Fix generation of temp file names in WAL testsJosh Rosen2014-12-152-17/+20
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-24 17:34:36 +0000