aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test/java/org/apache
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-6752] [STREAMING] [REVISED] Allow StreamingContext to be recreated fro...Tathagata Das2015-05-131-22/+3
* [SPARK-7530] [STREAMING] Added StreamingContext.getState() to expose the curr...Tathagata Das2015-05-112-0/+15
* [SPARK-6752] [STREAMING] [REOPENED] Allow StreamingContext to be recreated fr...Tathagata Das2015-04-291-37/+108
* [SPARK-7056] [STREAMING] Make the Write Ahead Log pluggableTathagata Das2015-04-291-0/+129
* Revert "[SPARK-6752][Streaming] Allow StreamingContext to be recreated from c...Patrick Wendell2015-04-251-108/+37
* [SPARK-6752][Streaming] Allow StreamingContext to be recreated from checkpoin...Tathagata Das2015-04-231-37/+108
* SPARK-6225 [CORE] [SQL] [STREAMING] Resolve most build warnings, 1.3.0 editionSean Owen2015-03-111-0/+4
* SPARK-4682 [CORE] Consolidate various 'Clock' classesSean Owen2015-02-191-1/+1
* SPARK-5795 [STREAMING] api.java.JavaPairDStream.saveAsNewAPIHadoopFiles may n...Sean Owen2015-02-161-0/+18
* Make sure only owner can read / write to directories created for the job.Marcelo Vanzin2015-02-021-2/+2
* [SPARK-5315][Streaming] Fix reduceByWindow Java API not work bugjerryshao2015-01-221-2/+18
* [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
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-28 20:31:07 +0000