aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-14868][BUILD] Enable NewLineAtEofChecker in checkstyle and fix lint-ja...Dongjoon Hyun2016-04-242-2/+2
* [SPARK-14701][STREAMING] First stop the event loop, then stop the checkpoint ...Liwei Lin2016-04-221-2/+2
* [SPARK-6429] Implement hashCode and equals togetherJoan2016-04-221-3/+7
* [SPARK-8393][STREAMING] JavaStreamingContext#awaitTermination() throws non-de...Sean Owen2016-04-211-0/+2
* Revert "[SPARK-14719] WriteAheadLogBasedBlockHandler should ignore BlockManag...Josh Rosen2016-04-192-40/+31
* [SPARK-14676] Wrap and re-throw Await.result exceptions in order to capture f...Josh Rosen2016-04-193-7/+9
* [SPARK-14719] WriteAheadLogBasedBlockHandler should ignore BlockManager put e...Josh Rosen2016-04-182-31/+40
* [SPARK-14667] Remove HashShuffleManagerReynold Xin2016-04-181-2/+2
* [MINOR] Remove inappropriate type notation and extra anonymous closure within...hyukjinkwon2016-04-161-8/+8
* [SPARK-14630][BUILD][CORE][SQL][STREAMING] Code style: public abstract method...Liwei Lin2016-04-145-14/+14
* [MINOR][SQL] Remove extra anonymous closure within functional transformationshyukjinkwon2016-04-143-8/+8
* [SPARK-14544] [SQL] improve performance of SQL UI tabDavies Liu2016-04-121-2/+2
* [SPARK-14508][BUILD] Add a new ScalaStyle Rule `OmitBracesInCase`Dongjoon Hyun2016-04-127-32/+15
* [SPARK-14475] Propagate user-defined context from driver to executorsEric Liang2016-04-114-8/+24
* [SPARK-14455][STREAMING] Fix NPE in allocatedExecutors when calling in receiv...jerryshao2016-04-092-4/+31
* [SPARK-14437][CORE] Use the address that NettyBlockTransferService listens to...Shixiong Zhu2016-04-081-1/+1
* [SPARK-14134][CORE] Change the package name used for shading classes.Marcelo Vanzin2016-04-061-1/+1
* [SPARK-12133][STREAMING] Streaming dynamic allocationTathagata Das2016-04-065-3/+665
* [SPARK-13211][STREAMING] StreamingContext throws NoSuchElementException when ...Sean Owen2016-04-053-9/+10
* [SPARK-12425][STREAMING] DStream union optimisationGuillaume Poulin2016-04-052-11/+4
* [SPARK-14358] Change SparkListener from a trait to an abstract classReynold Xin2016-04-041-1/+1
* [MINOR][DOCS] Use multi-line JavaDoc comments in Scala code.Dongjoon Hyun2016-04-024-20/+24
* [MINOR] Typo fixesJacek Laskowski2016-04-029-36/+39
* [SPARK-12857][STREAMING] Standardize "records" and "events" on "records"Liwei Lin2016-04-014-40/+41
* [SPARK-13992] Add support for off-heap cachingJosh Rosen2016-04-012-2/+4
* [SPARK-14075] Refactor MemoryStore to be testable independent of BlockManagerJosh Rosen2016-03-235-12/+19
* [SPARK-13990] Automatically pick serializer when caching RDDsJosh Rosen2016-03-212-4/+7
* [SPARK-14011][CORE][SQL] Enable `LineLength` Java checkstyle ruleDongjoon Hyun2016-03-212-38/+81
* [SPARK-13921] Store serialized blocks as multiple chunks in MemoryStoreJosh Rosen2016-03-174-9/+15
* [SPARK-13928] Move org.apache.spark.Logging into org.apache.spark.internal.Lo...Wenchen Fan2016-03-1735-30/+51
* [SPARK-13823][SPARK-13397][SPARK-13395][CORE] More warnings, StandardCharset ...Sean Owen2016-03-162-2/+3
* [MINOR][DOCS] Fix more typos in comments/strings.Dongjoon Hyun2016-03-1414-17/+17
* [SPARK-13823][CORE][STREAMING][SQL] Always specify Charset in String <-> byte...Sean Owen2016-03-136-14/+19
* [STREAMING][MINOR] Fix a duplicate "be" in commentsLiwei Lin2016-03-111-2/+1
* [SPARK-3854][BUILD] Scala style: require spaces before `{`.Dongjoon Hyun2016-03-103-5/+5
* [SPARK-13696] Remove BlockStore class & simplify interfaces of mem. & disk st...Josh Rosen2016-03-101-2/+8
* [SPARK-7420][STREAMING][TESTS] Enable test: o.a.s.streaming.JobGeneratorSuite...proflin2016-03-091-2/+1
* [SPARK-13693][STREAMING][TESTS] Stop StreamingContext before deleting checkpo...Shixiong Zhu2016-03-051-1/+1
* [SPARK-13398][STREAMING] Move away from thread pool task support to forkjoinHolden Karau2016-03-042-14/+18
* [SPARK-13583][CORE][STREAMING] Remove unused imports and add checkstyle ruleDongjoon Hyun2016-03-0318-25/+8
* [SPARK-13423][WIP][CORE][SQL][STREAMING] Static analysis fixes for 2.xSean Owen2016-03-0315-25/+25
* [SPARK-12817] Add BlockManager.getOrElseUpdate and remove CacheManagerJosh Rosen2016-03-021-4/+0
* [MINOR][STREAMING] Fix a minor naming issue in JavaDStreamLikeLiwei Lin2016-02-261-0/+2
* [SPARK-12757] Add block-level read/write locks to BlockManagerJosh Rosen2016-02-251-0/+4
* [MINOR][DOCS] Fix all typos in markdown files of `doc` and similar patterns i...Dongjoon Hyun2016-02-221-1/+1
* [SPARK-13399][STREAMING] Fix checkpointsuite type erasure warningsHolden Karau2016-02-221-6/+13
* [SPARK-13186][STREAMING] migrate away from SynchronizedMapHuaxin Gao2016-02-223-18/+27
* [SPARK-13248][STREAMING] Remove deprecated Streaming APIs.Luciano Resende2016-02-216-230/+0
* [SPARK-13339][DOCS] Clarify commutative / associative operator requirements f...Sean Owen2016-02-194-22/+22
* [SPARK-11627] Add initial input rate limit for spark streaming backpressure m...junhao2016-02-161-1/+8
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-01 16:06:10 +0000