aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* [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
* [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
* [STREAMING][TEST] Fix flaky streaming.FailureSuiteTathagata Das2016-02-112-2/+6
* [SPARK-13170][STREAMING] Investigate replacing SynchronizedQueue as it is dep...Sean Owen2016-02-093-20/+34
* [SPARK-13165][STREAMING] Replace deprecated synchronizedBuffer in streamingHolden Karau2016-02-0915-176/+188
* [SPARK-13195][STREAMING] Fix NoSuchElementException when a state is not set b...Shixiong Zhu2016-02-042-1/+7
* [SPARK-12739][STREAMING] Details of batch in Streaming tab uses two Duration ...Mario Briggs2016-02-032-4/+5
* [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-013-2/+79
* [SPARK-6363][BUILD] Make Scala 2.11 the default Scala versionJosh Rosen2016-01-301-2/+2
* [SPARK-3369][CORE][STREAMING] Java mapPartitions Iterator->Iterable is incons...Sean Owen2016-01-264-18/+16
* [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
* [SPARK-7997][CORE] Remove Akka from Spark Core and StreamingShixiong Zhu2016-01-221-1/+0
* [SPARK-7799][SPARK-12786][STREAMING] Add "streaming-akka" projectShixiong Zhu2016-01-203-332/+1
* [SPARK-12847][CORE][STREAMING] Remove StreamingListenerBus and post all Strea...Shixiong Zhu2016-01-206-25/+83
* [SPARK-10985][CORE] Avoid passing evicted blocks throughout BlockManagerJosh Rosen2016-01-181-4/+4
* [SPARK-12652][PYSPARK] Upgrade Py4J to 0.9.1Shixiong Zhu2016-01-121-10/+0
* [SPARK-12692][BUILD][STREAMING] Scala style: Fix the style violation (Space b...Kousuke Saruta2016-01-1121-67/+67
* [SPARK-3873][BUILD] Enable import ordering error checking.Marcelo Vanzin2016-01-103-5/+4
* [SPARK-4819] Remove Guava's "Optional" from public APISean Owen2016-01-084-10/+11
* [SPARK-12618][CORE][STREAMING][SQL] Clean up build warnings: 2.0.0 editionSean Owen2016-01-083-49/+33
* [SPARK-12591][STREAMING] Register OpenHashMapBasedStateMap for KryoShixiong Zhu2016-01-072-34/+133
* [SPARK-12510][STREAMING] Refactor ActorReceiver to support JavaShixiong Zhu2016-01-072-12/+56
* [STREAMING][MINOR] More contextual information in logs + minor code i…Jacek Laskowski2016-01-078-66/+61
* [SPARK-7689] Remove TTL-based metadata cleaning in Spark 2.0Josh Rosen2016-01-063-24/+12
* [SPARK-12604][CORE] Java count(AprroxDistinct)ByKey methods return Scala Long...Sean Owen2016-01-062-12/+13
* Revert "[SPARK-12672][STREAMING][UI] Use the uiRoot function instead of defau...Shixiong Zhu2016-01-061-3/+2
* [SPARK-12672][STREAMING][UI] Use the uiRoot function instead of default root ...huangzhaowei2016-01-061-2/+3
* [SPARK-3873][TESTS] Import ordering fixes.Marcelo Vanzin2016-01-0517-48/+46
* [SPARK-12511] [PYSPARK] [STREAMING] Make sure PythonDStream.registerSerialize...Shixiong Zhu2016-01-051-0/+12
* [SPARK-12608][STREAMING] Remove submitJobThreadPool since submitJob doesn't c...Shixiong Zhu2016-01-041-6/+1
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-29 18:39:28 +0000