aboutsummaryrefslogtreecommitdiff
path: root/streaming/src
Commit message (Expand)AuthorAgeFilesLines
* Resolve scalatest warnings during buildwitgo2014-06-102-3/+2
* [SPARK-1841]: update scalatest to version 2.1.5witgo2014-06-061-6/+6
* [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
* [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
* SPARK-1488. Squash more language feature warnings in new commits by importing...Sean Owen2014-04-246-0/+7
* [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-224-49/+14
* 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-2133-585/+1670
* HOTFIX: Ignore streaming UI testPatrick Wendell2014-04-171-1/+2
* Update ReducedWindowedDStream.scalabaishuo(白硕)2014-04-161-1/+1
* SPARK-1488. Resolve scalac feature warnings during buildSean Owen2014-04-148-0/+9
* [SPARK-1386] Web UI for Spark StreamingTathagata Das2014-04-1116-88/+576
* SPARK-1057 (alternative) Remove fastutilSean Owen2014-04-112-14/+12
* Update WindowedDStream.scalabaishuo(白硕)2014-04-111-1/+1
* Remove Unnecessary Whitespace'sSandeep2014-04-1011-47/+47
* 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-085-50/+96
* [SPARK-1331] Added graceful shutdown to Spark StreamingTathagata Das2014-04-0814-204/+539
* [SPARK-1103] Automatic garbage collection of RDD, shuffle and broadcast dataTathagata Das2014-04-071-1/+3
* HOTFIX: Disable actor input stream test.Patrick Wendell2014-04-071-2/+2
* SPARK-1365 [HOTFIX] Fix RateLimitedOutputStream testPatrick Wendell2014-03-311-2/+3
* SPARK-1096, a space after comment start style checker.Prashant Sharma2014-03-287-11/+10
* Spark 1095 : Adding explicit return types to all public methodsNirmalReddy2014-03-265-15/+33
* SPARK-1316. Remove use of Commons IOSean Owen2014-03-254-31/+27
* 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-035-158/+130
* SPARK-1158: Fix flaky RateLimitedOutputStreamSuite.Reynold Xin2014-03-032-20/+32
* Ignore RateLimitedOutputStreamSuite for now.Reynold Xin2014-03-021-1/+1
* SPARK 1084.1 (resubmitted)Sean Owen2014-02-274-55/+105
* Merge pull request #567 from ScrapCodes/style2.Prashant Sharma2014-02-0918-65/+108
* Merge pull request #557 from ScrapCodes/style. Closes #557.Patrick Wendell2014-02-091-7/+10
* Merge pull request #529 from hsaputra/cleanup_right_arrowop_scalaHenry Saputra2014-02-021-8/+8
* Fix ClassCastException in JavaPairRDD.collectAsMap() (SPARK-1040)Josh Rosen2014-01-252-3/+3
* Updated java API docs for streaming, along with very minor changes in the cod...Tathagata Das2014-01-167-73/+77
* Made some classes private[stremaing] and deprecated a method in JavaStreaming...Tathagata Das2014-01-155-4/+11
* Merge remote-tracking branch 'apache/master' into filestream-fixTathagata Das2014-01-141-0/+17
|\
| * Add missing header filesPatrick Wendell2014-01-141-0/+17