aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-2886] Use more specific actor system name than "spark"Andrew Or2014-08-251-5/+5
* [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
* 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-1777] Prevent OOMs from single partitionsAndrew Or2014-07-271-3/+2
* 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-1341] [Streaming] Throttle BlockGenerator to limit rate of data consum...Issac Buenrostro2014-07-102-1/+71
* [STREAMING] SPARK-2343: Fix QueueInputDStream with oneAtATime falseManuel Laflamme2014-07-091-1/+1
* [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-111-0/+1
* [SPARK-1942] Stop clearing spark.driver.port in unit testsSyed Hashmi2014-06-031-1/+0
* SPARK-1878: Fix the incorrect initialization orderzsxwing2014-05-191-3/+3
* Package docsPrashant Sharma2014-05-144-0/+89
* SPARK-1798. Tests should clean up temp filesSean Owen2014-05-121-0/+3
* SPARK-1637: Clean up examples for 1.0Sandeep2014-05-061-2/+1
* [SPARK-1504], [SPARK-1505], [SPARK-1558] Updated Spark Streaming guideTathagata Das2014-05-051-2/+4
* SPARK-1663. (Addendum) Fix signature of one version of JavaPairRDDStream.redu...Sean Owen2014-05-041-1/+1
* [SPARK-1633][Streaming] Java API unit test and example for custom streaming r...Tathagata Das2014-04-282-27/+65
* [Spark-1382] Fix NPE in DStream.slice (updated version of #365)zsxwing2014-04-251-10/+12
* [SPARK-1617] and [SPARK-1618] Improvements to streaming ui and bug fix to soc...Tathagata Das2014-04-2412-93/+202
* [SPARK-1510] Spark Streaming metrics source for metrics systemjerryshao2014-04-243-1/+79
* [SPARK-1592][streaming] Automatically remove streaming input blocksTathagata Das2014-04-242-4/+14
* Fix Scala StyleSandeep2014-04-241-2/+1
* SPARK-1488. Squash more language feature warnings in new commits by importing...Sean Owen2014-04-244-0/+5
* [SPARK-1540] Add an optional Ordering parameter to PairRDDFunctions.Matei Zaharia2014-04-233-14/+19
* [streaming][SPARK-1578] Removed requirement for TTL in StreamingContext.Tathagata Das2014-04-221-14/+1
* SPARK-1496: Have jarOfClass return Option[String]Patrick Wendell2014-04-221-1/+1
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-2128-541/+1311
* Update ReducedWindowedDStream.scalabaishuo(白硕)2014-04-161-1/+1
* SPARK-1488. Resolve scalac feature warnings during buildSean Owen2014-04-146-0/+6
* [SPARK-1386] Web UI for Spark StreamingTathagata Das2014-04-1113-84/+527
* SPARK-1057 (alternative) Remove fastutilSean Owen2014-04-112-14/+12
* Update WindowedDStream.scalabaishuo(白硕)2014-04-111-1/+1
* Remove Unnecessary Whitespace'sSandeep2014-04-1010-46/+46
* Revert "SPARK-729: Closures not always serialized at capture time"Patrick Wendell2014-04-101-4/+4
* SPARK-729: Closures not always serialized at capture timeWilliam Benton2014-04-091-4/+4
* Spark 1271: Co-Group and Group-By should pass Iterable[X]Holden Karau2014-04-083-39/+45
* [SPARK-1331] Added graceful shutdown to Spark StreamingTathagata Das2014-04-0811-188/+441
* [SPARK-1103] Automatic garbage collection of RDD, shuffle and broadcast dataTathagata Das2014-04-071-1/+3
* SPARK-1096, a space after comment start style checker.Prashant Sharma2014-03-285-9/+7
* Spark 1095 : Adding explicit return types to all public methodsNirmalReddy2014-03-265-15/+33
* SPARK-1316. Remove use of Commons IOSean Owen2014-03-251-3/+3
* SPARK-1251 Support for optimizing and executing structured queriesMichael Armbrust2014-03-202-3/+3
* [java8API] SPARK-964 Investigate the potential for using JDK 8 lambda express...Prashant Sharma2014-03-034-128/+98
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-13 22:17:11 +0000