index
:
spark
2.12/build
SPARK-10001-hotfix
SPARK-10001-sigint
SPARK-14511-genjavadoc
SPARK-17647
WIP-SPARK-17647
escape
genjavadoc
macros
master
packages
scala-2.12
value-classes
Mirror of Apache Spark
about
summary
refs
log
tree
commit
diff
log msg
author
committer
range
path:
root
/
streaming
/
src
/
test
/
java
Commit message (
Expand
)
Author
Age
Files
Lines
*
[SPARK-14011][CORE][SQL] Enable `LineLength` Java checkstyle rule
Dongjoon Hyun
2016-03-21
2
-38
/
+81
*
[SPARK-13823][CORE][STREAMING][SQL] Always specify Charset in String <-> byte...
Sean Owen
2016-03-13
2
-4
/
+7
*
[SPARK-13165][STREAMING] Replace deprecated synchronizedBuffer in streaming
Holden Karau
2016-02-09
1
-2
/
+2
*
[SPARK-3369][CORE][STREAMING] Java mapPartitions Iterator->Iterable is incons...
Sean Owen
2016-01-26
1
-10
/
+10
*
[SPARK-4819] Remove Guava's "Optional" from public API
Sean Owen
2016-01-08
2
-3
/
+3
*
[SPARK-12618][CORE][STREAMING][SQL] Clean up build warnings: 2.0.0 edition
Sean Owen
2016-01-08
3
-49
/
+33
*
[SPARK-12244][SPARK-12245][STREAMING] Rename trackStateByKey to mapWithState ...
Tathagata Das
2015-12-09
1
-24
/
+24
*
[SPARK-12084][CORE] Fix codes that uses ByteBuffer.array incorrectly
Shixiong Zhu
2015-12-04
1
-8
/
+7
*
[SPARK-6990][BUILD] Add Java linting script; fix minor warnings
Dmitry Erastov
2015-12-04
2
-3
/
+3
*
[SPARK-11495] Fix potential socket / file handle leaks that were found via st...
Josh Rosen
2015-11-18
1
-7
/
+13
*
[SPARK-4557][STREAMING] Spark Streaming foreachRDD Java API method should acc...
Bryan Cutler
2015-11-18
1
-1
/
+40
*
[SPARK-11731][STREAMING] Enable batching on Driver WriteAheadLog by default
Burak Yavuz
2015-11-16
1
-0
/
+1
*
[SPARK-11663][STREAMING] Add Java API for trackStateByKey
Shixiong Zhu
2015-11-12
1
-0
/
+210
*
[SPARK-11333][STREAMING] Add executorId to ReceiverInfo and display it in UI
Shixiong Zhu
2015-11-09
2
-2
/
+9
*
[SPARK-11462][STREAMING] Add JavaStreamingListener
zsxwing
2015-11-09
2
-0
/
+375
*
[SPARK-10547] [TEST] Streamline / improve style of Java API tests
Sean Owen
2015-09-12
2
-425
/
+413
*
[SPARK-9613] [CORE] Ban use of JavaConversions and migrate all existing uses ...
Sean Owen
2015-08-25
1
-17
/
+7
*
[SPARK-9534] [BUILD] Enable javac lint for scalac parity; fix a lot of build ...
Sean Owen
2015-08-04
1
-30
/
+32
*
[SPARK-9479] [STREAMING] [TESTS] Fix ReceiverTrackerSuite failure for maven b...
zsxwing
2015-07-30
1
-0
/
+1
*
[SPARK-8630] [STREAMING] Prevent from checkpointing QueueInputDStream
zsxwing
2015-06-30
1
-0
/
+8
*
[SPARK-6752] [STREAMING] [REVISED] Allow StreamingContext to be recreated fro...
Tathagata Das
2015-05-13
1
-22
/
+3
*
[SPARK-7530] [STREAMING] Added StreamingContext.getState() to expose the curr...
Tathagata Das
2015-05-11
2
-0
/
+15
*
[SPARK-6752] [STREAMING] [REOPENED] Allow StreamingContext to be recreated fr...
Tathagata Das
2015-04-29
1
-37
/
+108
*
[SPARK-7056] [STREAMING] Make the Write Ahead Log pluggable
Tathagata Das
2015-04-29
1
-0
/
+129
*
Revert "[SPARK-6752][Streaming] Allow StreamingContext to be recreated from c...
Patrick Wendell
2015-04-25
1
-108
/
+37
*
[SPARK-6752][Streaming] Allow StreamingContext to be recreated from checkpoin...
Tathagata Das
2015-04-23
1
-37
/
+108
*
SPARK-6225 [CORE] [SQL] [STREAMING] Resolve most build warnings, 1.3.0 edition
Sean Owen
2015-03-11
1
-0
/
+4
*
SPARK-4682 [CORE] Consolidate various 'Clock' classes
Sean Owen
2015-02-19
1
-1
/
+1
*
SPARK-5795 [STREAMING] api.java.JavaPairDStream.saveAsNewAPIHadoopFiles may n...
Sean Owen
2015-02-16
1
-0
/
+18
*
Make sure only owner can read / write to directories created for the job.
Marcelo Vanzin
2015-02-02
1
-2
/
+2
*
[SPARK-5315][Streaming] Fix reduceByWindow Java API not work bug
jerryshao
2015-01-22
1
-2
/
+18
*
[SPARK-5297][Streaming] Fix Java file stream type erasure problem
jerryshao
2015-01-20
1
-5
/
+65
*
[SPARK-1010] Clean up uses of System.setProperty in unit tests
Josh Rosen
2014-12-30
1
-2
/
+6
*
SPARK-4297 [BUILD] Build warning fixes omnibus
Sean Owen
2014-12-24
1
-8
/
+8
*
[SPARK-3660][STREAMING] Initial RDD for updateStateByKey transformation
Soumitra Kumar
2014-11-12
1
-4
/
+49
*
SPARK-2745 [STREAMING] Add Java friendly methods to Duration class
Sean Owen
2014-09-23
2
-0
/
+147
*
[SPARK-1942] Stop clearing spark.driver.port in unit tests
Syed Hashmi
2014-06-03
1
-4
/
+0
*
SPARK-1878: Fix the incorrect initialization order
zsxwing
2014-05-19
1
-0
/
+4
*
SPARK-1798. Tests should clean up temp files
Sean Owen
2014-05-12
1
-1
/
+4
*
[SPARK-1633][Streaming] Java API unit test and example for custom streaming r...
Tathagata Das
2014-04-28
2
-2
/
+146
*
[SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...
Tathagata Das
2014-04-21
1
-6
/
+3
*
Remove Unnecessary Whitespace's
Sandeep
2014-04-10
1
-1
/
+1
*
Spark 1271: Co-Group and Group-By should pass Iterable[X]
Holden Karau
2014-04-08
1
-9
/
+49
*
[java8API] SPARK-964 Investigate the potential for using JDK 8 lambda express...
Prashant Sharma
2014-03-03
1
-30
/
+32
*
SPARK 1084.1 (resubmitted)
Sean Owen
2014-02-27
1
-37
/
+87
*
Made some classes private[stremaing] and deprecated a method in JavaStreaming...
Tathagata Das
2014-01-15
1
-3
/
+3
*
Removed StreamingContext.registerInputStream and registerOutputStream - they ...
Tathagata Das
2014-01-13
1
-2
/
+1
*
Removing mentions in tests
Patrick Wendell
2014-01-12
1
-2
/
+0
*
Fix wonky imports from merge
Andrew Or
2014-01-09
1
-8
/
+1
*
Merge github.com:apache/incubator-spark
Andrew Or
2014-01-09
2
-90
/
+55
|
\
[next]