aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test/java
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-14011][CORE][SQL] Enable `LineLength` Java checkstyle ruleDongjoon Hyun2016-03-212-38/+81
* [SPARK-13823][CORE][STREAMING][SQL] Always specify Charset in String <-> byte...Sean Owen2016-03-132-4/+7
* [SPARK-13165][STREAMING] Replace deprecated synchronizedBuffer in streamingHolden Karau2016-02-091-2/+2
* [SPARK-3369][CORE][STREAMING] Java mapPartitions Iterator->Iterable is incons...Sean Owen2016-01-261-10/+10
* [SPARK-4819] Remove Guava's "Optional" from public APISean Owen2016-01-082-3/+3
* [SPARK-12618][CORE][STREAMING][SQL] Clean up build warnings: 2.0.0 editionSean Owen2016-01-083-49/+33
* [SPARK-12244][SPARK-12245][STREAMING] Rename trackStateByKey to mapWithState ...Tathagata Das2015-12-091-24/+24
* [SPARK-12084][CORE] Fix codes that uses ByteBuffer.array incorrectlyShixiong Zhu2015-12-041-8/+7
* [SPARK-6990][BUILD] Add Java linting script; fix minor warningsDmitry Erastov2015-12-042-3/+3
* [SPARK-11495] Fix potential socket / file handle leaks that were found via st...Josh Rosen2015-11-181-7/+13
* [SPARK-4557][STREAMING] Spark Streaming foreachRDD Java API method should acc...Bryan Cutler2015-11-181-1/+40
* [SPARK-11731][STREAMING] Enable batching on Driver WriteAheadLog by defaultBurak Yavuz2015-11-161-0/+1
* [SPARK-11663][STREAMING] Add Java API for trackStateByKeyShixiong Zhu2015-11-121-0/+210
* [SPARK-11333][STREAMING] Add executorId to ReceiverInfo and display it in UIShixiong Zhu2015-11-092-2/+9
* [SPARK-11462][STREAMING] Add JavaStreamingListenerzsxwing2015-11-092-0/+375
* [SPARK-10547] [TEST] Streamline / improve style of Java API testsSean Owen2015-09-122-425/+413
* [SPARK-9613] [CORE] Ban use of JavaConversions and migrate all existing uses ...Sean Owen2015-08-251-17/+7
* [SPARK-9534] [BUILD] Enable javac lint for scalac parity; fix a lot of build ...Sean Owen2015-08-041-30/+32
* [SPARK-9479] [STREAMING] [TESTS] Fix ReceiverTrackerSuite failure for maven b...zsxwing2015-07-301-0/+1
* [SPARK-8630] [STREAMING] Prevent from checkpointing QueueInputDStreamzsxwing2015-06-301-0/+8
* [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
|\
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-07 00:41:27 +0000