aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* SPARK-3470 [CORE] [STREAMING] Add Closeable / close() to Java context objectsSean Owen2014-09-121-2/+5
* SPARK-2482: Resolve sbt warnings during buildwitgo2014-09-114-5/+0
* [Spark-3490] Disable SparkUI for testsAndrew Or2014-09-114-13/+41
* [Docs] actorStream storageLevel default is MEMORY_AND_DISK_SER_2Mario Pastorelli2014-09-091-1/+1
* [SPARK-3397] Bump pom.xml version number of master branch to 1.2.0-SNAPSHOTGuoQiang Li2014-09-061-1/+1
* [SPARK-3285] [examples] Using values.sum is easier to understand than using v...Yadong Qi2014-08-282-3/+3
* [SPARK-2886] Use more specific actor system name than "spark"Andrew Or2014-08-251-5/+5
* [HOTFIX][Streaming][MLlib] use temp folder for checkpointXiangrui Meng2014-08-191-6/+11
* [SPARK-3128][MLLIB] Use streaming test suite for StreamingLRfreeman2014-08-191-1/+3
* [SPARK-2169] Don't copy appName / basePath everywhere.Marcelo Vanzin2014-08-182-6/+3
* [SPARK-2924] remove default args to overloaded methodsAnand Avati2014-08-151-1/+7
* SPARK-2955 [BUILD] Test code fails to compile with "mvn compile" without "ins...Sean Owen2014-08-141-4/+4
* Minor cleanup of metrics.SourceReynold Xin2014-08-141-3/+3
* [SPARK-2454] Do not ship spark home to WorkersAndrew Or2014-08-021-1/+0
* [SPARK-2379] Fix the bug that streaming's receiver may fall into a dead loopjoyyoj2014-08-011-1/+1
* SPARK-2749 [BUILD]. Spark SQL Java tests aren't compiling in Jenkins' Maven b...Sean Owen2014-07-301-0/+5
* [SPARK-2410][SQL] Merging Hive Thrift/JDBC server (with Maven profile fix)Cheng Lian2014-07-281-1/+1
* Revert "[SPARK-2410][SQL] Merging Hive Thrift/JDBC server"Patrick Wendell2014-07-271-1/+1
* [SPARK-1777] Prevent OOMs from single partitionsAndrew Or2014-07-271-3/+2
* [SPARK-2410][SQL] Merging Hive Thrift/JDBC serverCheng Lian2014-07-271-1/+1
* Revert "[SPARK-2410][SQL] Merging Hive Thrift/JDBC server"Michael Armbrust2014-07-251-1/+1
* [SPARK-2410][SQL] Merging Hive Thrift/JDBC serverCheng Lian2014-07-251-1/+1
* replace println to log4jfireflyc2014-07-251-5/+7
* SPARK-2657 Use more compact data structures than ArrayBuffer in groupBy & cog...Matei Zaharia2014-07-251-7/+8
* fix compile error of streaming projectJames Z.M. Gao2014-07-161-1/+2
* [SPARK-2517] Remove some compiler warnings.Reynold Xin2014-07-161-1/+4
* [SPARK-1341] [Streaming] Throttle BlockGenerator to limit rate of data consum...Issac Buenrostro2014-07-103-1/+109
* [SPARK-1776] Have Spark's SBT build read dependencies from Maven.Prashant Sharma2014-07-101-0/+3
* [STREAMING] SPARK-2343: Fix QueueInputDStream with oneAtATime falseManuel Laflamme2014-07-092-2/+92
* [SPARK-2362] Fix for newFilesOnly logic in file DStreamGabriele Nizzoli2014-07-081-1/+1
* SPARK-897: preemptively serialize closuresWilliam Benton2014-06-291-5/+20
* [STREAMING] SPARK-2009 Key not found exception when slow receiver startsVadim Chekan2014-06-171-1/+1
* SPARK-2113: awaitTermination() after stop() will hang in Spark StremaingLars Albertsson2014-06-112-0/+13
* Resolve scalatest warnings during buildwitgo2014-06-102-3/+2
* [SPARK-1841]: update scalatest to version 2.1.5witgo2014-06-061-6/+6
* [SPARK-2029] Bump pom.xml version number of master branch to 1.1.0-SNAPSHOT.Takuya UESHIN2014-06-051-1/+1
* [SPARK-1942] Stop clearing spark.driver.port in unit testsSyed Hashmi2014-06-034-8/+0
* SPARK-1878: Fix the incorrect initialization orderzsxwing2014-05-192-3/+7
* Package docsPrashant Sharma2014-05-144-0/+89
* SPARK-1798. Tests should clean up temp filesSean Owen2014-05-125-2/+11
* SPARK-1637: Clean up examples for 1.0Sandeep2014-05-061-2/+1
* [SPARK-1504], [SPARK-1505], [SPARK-1558] Updated Spark Streaming guideTathagata Das2014-05-052-2/+5
* SPARK-1663. (Addendum) Fix signature of one version of JavaPairRDDStream.redu...Sean Owen2014-05-041-1/+1
* Improved build configurationwitgo2014-04-281-14/+0
* [SPARK-1633][Streaming] Java API unit test and example for custom streaming r...Tathagata Das2014-04-287-31/+215
* [Spark-1382] Fix NPE in DStream.slice (updated version of #365)zsxwing2014-04-252-11/+23
* [SPARK-1617] and [SPARK-1618] Improvements to streaming ui and bug fix to soc...Tathagata Das2014-04-2414-102/+216
* [SPARK-1510] Spark Streaming metrics source for metrics systemjerryshao2014-04-243-1/+79
* [SPARK-1592][streaming] Automatically remove streaming input blocksTathagata Das2014-04-245-18/+90
* Fix Scala StyleSandeep2014-04-241-2/+1