aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test/java/org
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-5297][Streaming] Fix Java file stream type erasure problemjerryshao2015-01-201-5/+65
* [SPARK-1010] Clean up uses of System.setProperty in unit testsJosh Rosen2014-12-301-2/+6
* SPARK-4297 [BUILD] Build warning fixes omnibusSean Owen2014-12-241-8/+8
* [SPARK-3660][STREAMING] Initial RDD for updateStateByKey transformationSoumitra Kumar2014-11-121-4/+49
* SPARK-2745 [STREAMING] Add Java friendly methods to Duration classSean Owen2014-09-232-0/+147
* [SPARK-1942] Stop clearing spark.driver.port in unit testsSyed Hashmi2014-06-031-4/+0
* SPARK-1878: Fix the incorrect initialization orderzsxwing2014-05-191-0/+4
* SPARK-1798. Tests should clean up temp filesSean Owen2014-05-121-1/+4
* [SPARK-1633][Streaming] Java API unit test and example for custom streaming r...Tathagata Das2014-04-282-2/+146
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-211-6/+3
* Remove Unnecessary Whitespace'sSandeep2014-04-101-1/+1
* Spark 1271: Co-Group and Group-By should pass Iterable[X]Holden Karau2014-04-081-9/+49
* [java8API] SPARK-964 Investigate the potential for using JDK 8 lambda express...Prashant Sharma2014-03-031-30/+32
* SPARK 1084.1 (resubmitted)Sean Owen2014-02-271-37/+87
* Made some classes private[stremaing] and deprecated a method in JavaStreaming...Tathagata Das2014-01-151-3/+3
* Removed StreamingContext.registerInputStream and registerOutputStream - they ...Tathagata Das2014-01-131-2/+1
* Removing mentions in testsPatrick Wendell2014-01-121-2/+0
* Fix wonky imports from mergeAndrew Or2014-01-091-8/+1
* Merge github.com:apache/incubator-sparkAndrew Or2014-01-092-90/+55
|\
| * Merge remote-tracking branch 'apache/master' into project-refactorTathagata Das2014-01-061-1/+3
| |\
| * | Removed unnecessary comments.Tathagata Das2013-12-311-26/+0
| * | Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-302-70/+56
* | | Merge remote-tracking branch 'spark/master'Andrew Or2014-01-021-3/+7
|\ \ \ | | |/ | |/|
| * | Fix other failing testsMatei Zaharia2013-12-281-3/+6
| * | Fix test failures due to setting / clearing clock type in StreamingMatei Zaharia2013-12-281-3/+4
| |/
* | Address Aaron's commentsAndrew Or2013-12-291-4/+4
* | Fix streaming JavaAPISuite againAndrew Or2013-12-261-8/+12
* | Fix streaming JavaAPISuite that depended on orderAaron Davidson2013-12-261-11/+16
|/
* Merge branch 'master' into scala-2.10Raymond Liu2013-11-132-28/+433
|\
| * Merge branch 'apache-master' into transformTathagata Das2013-10-252-7/+62
| |\
| | * Style fixesPatrick Wendell2013-10-241-9/+9
| | * Spacing fixPatrick Wendell2013-10-241-4/+4
| | * Small spacing fixPatrick Wendell2013-10-241-2/+2
| | * Adding Java versions and associated testsPatrick Wendell2013-10-242-0/+56
| | * Some clean-up of testsPatrick Wendell2013-10-241-2/+1
| * | Fixed accidental bug.Tathagata Das2013-10-241-1/+1
| * | Added JavaStreamingContext.transformTathagata Das2013-10-241-30/+102
| * | Merge branch 'apache-master' into transformTathagata Das2013-10-221-5/+11
| |\|
| | * Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streamingjerryshao2013-10-121-5/+11
| * | Fixed bug in Java transformWith, added more Java testcases for transform and ...Tathagata Das2013-10-221-15/+204
| * | Updated TransformDStream to allow n-ary DStream transform. Added transformWit...Tathagata Das2013-10-211-3/+86
| |/
* | fixed some warningsMartin Weindel2013-10-051-46/+48
* | Akka 2.2 migrationPrashant Sharma2013-09-221-1/+1
* | Merged with masterPrashant Sharma2013-09-061-8/+10
|/
* Initial work to rename package to org.apache.sparkMatei Zaharia2013-09-012-0/+1389
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-10 04:59:29 +0000