aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main/scala/org
Commit message (Expand)AuthorAgeFilesLines
* [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-191-14/+8
* [SPARK-14676] Wrap and re-throw Await.result exceptions in order to capture f...Josh Rosen2016-04-192-5/+6
* [SPARK-14719] WriteAheadLogBasedBlockHandler should ignore BlockManager put e...Josh Rosen2016-04-181-8/+14
* [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-14508][BUILD] Add a new ScalaStyle Rule `OmitBracesInCase`Dongjoon Hyun2016-04-124-24/+11
* [SPARK-14475] Propagate user-defined context from driver to executorsEric Liang2016-04-113-7/+15
* [SPARK-14455][STREAMING] Fix NPE in allocatedExecutors when calling in receiv...jerryshao2016-04-091-3/+9
* [SPARK-12133][STREAMING] Streaming dynamic allocationTathagata Das2016-04-064-3/+270
* [SPARK-13211][STREAMING] StreamingContext throws NoSuchElementException when ...Sean Owen2016-04-052-9/+5
* [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-011-1/+2
* [SPARK-14075] Refactor MemoryStore to be testable independent of BlockManagerJosh Rosen2016-03-233-4/+7
* [SPARK-13990] Automatically pick serializer when caching RDDsJosh Rosen2016-03-211-1/+2
* [SPARK-13921] Store serialized blocks as multiple chunks in MemoryStoreJosh Rosen2016-03-172-7/+13
* [SPARK-13928] Move org.apache.spark.Logging into org.apache.spark.internal.Lo...Wenchen Fan2016-03-1727-25/+41
* [MINOR][DOCS] Fix more typos in comments/strings.Dongjoon Hyun2016-03-148-9/+9
* [SPARK-13823][CORE][STREAMING][SQL] Always specify Charset in String <-> byte...Sean Owen2016-03-131-1/+3
* [STREAMING][MINOR] Fix a duplicate "be" in commentsLiwei Lin2016-03-111-2/+1
* [SPARK-3854][BUILD] Scala style: require spaces before `{`.Dongjoon Hyun2016-03-102-2/+2
* [SPARK-13398][STREAMING] Move away from thread pool task support to forkjoinHolden Karau2016-03-041-11/+12
* [SPARK-13583][CORE][STREAMING] Remove unused imports and add checkstyle ruleDongjoon Hyun2016-03-0316-22/+7
* [SPARK-13423][WIP][CORE][SQL][STREAMING] Static analysis fixes for 2.xSean Owen2016-03-0311-15/+15
* [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-13186][STREAMING] migrate away from SynchronizedMapHuaxin Gao2016-02-221-14/+16
* [SPARK-13248][STREAMING] Remove deprecated Streaming APIs.Luciano Resende2016-02-215-223/+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
* [SPARK-13280][STREAMING] Use a better logger name for FileBasedWriteAheadLog.Marcelo Vanzin2016-02-161-5/+15
* [SPARK-13172][CORE][SQL] Stop using RichException.getStackTrace it is deprecatedSean Owen2016-02-131-2/+2
* [SPARK-13170][STREAMING] Investigate replacing SynchronizedQueue as it is dep...Sean Owen2016-02-092-7/+10
* [SPARK-13165][STREAMING] Replace deprecated synchronizedBuffer in streamingHolden Karau2016-02-094-19/+23
* [SPARK-13195][STREAMING] Fix NoSuchElementException when a state is not set b...Shixiong Zhu2016-02-041-1/+2
* [SPARK-12739][STREAMING] Details of batch in Streaming tab uses two Duration ...Mario Briggs2016-02-031-2/+2
* [SPARK-13121][STREAMING] java mapWithState mishandles scala OptionGabriele Nizzoli2016-02-021-1/+1
* [SPARK-6847][CORE][STREAMING] Fix stack overflow issue when updateStateByKey ...Shixiong Zhu2016-02-012-2/+10
* [SPARK-3369][CORE][STREAMING] Java mapPartitions Iterator->Iterable is incons...Sean Owen2016-01-263-8/+6
* [STREAMING][MINOR] Scaladoc + logsJacek Laskowski2016-01-234-6/+5
* [SPARK-11137][STREAMING] Make StreamingContext.stop() exception-safejayadevanmurali2016-01-231-4/+12
* [SPARK-12859][STREAMING][WEB UI] Names of input streams with receivers don't ...Alex Bozarth2016-01-231-1/+1
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-22 13:33:27 +0000