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
Commit message (
Expand
)
Author
Age
Files
Lines
...
|
*
|
Better equality test (thanks Josh)
Patrick Wendell
2013-01-14
1
-4
/
+3
|
*
|
Remving main method from tests
Patrick Wendell
2013-01-14
1
-27
/
+0
|
*
|
Adding some initial tests to streaming API.
Patrick Wendell
2013-01-14
3
-3
/
+79
|
*
|
A very rough, early cut at some Java functionality for Streaming.
Patrick Wendell
2013-01-14
3
-0
/
+188
*
|
|
Fixed issue https://spark-project.atlassian.net/browse/STREAMING-29, along wi...
Tathagata Das
2013-01-19
1
-1
/
+7
|
|
/
|
/
|
*
|
Fixed updateStateByKey to work with primitive types.
Tathagata Das
2013-01-14
3
-8
/
+8
|
/
*
Minor name fix
Tathagata Das
2013-01-13
1
-2
/
+2
*
Fixed bug
Tathagata Das
2013-01-13
1
-1
/
+3
*
Added documentation for PairDStreamFunctions.
Tathagata Das
2013-01-13
3
-27
/
+303
*
Removed stream id from the constructor of NetworkReceiver to make it easier f...
Tathagata Das
2013-01-13
6
-30
/
+68
*
Changed variable name form ***Time to ***Duration to keep things consistent.
Tathagata Das
2013-01-09
26
-186
/
+176
*
Split Time to Time (absolute instant of time) and Duration (duration of time).
Tathagata Das
2013-01-09
25
-152
/
+174
*
Moved Twitter example to the where the other examples are.
Tathagata Das
2013-01-07
2
-104
/
+0
*
Merge branch 'streaming-merge' into dev-merge
Tathagata Das
2013-01-07
2
-0
/
+104
|
\
|
*
Merge pull request #8 from radlab/twitter-example
Patrick Wendell
2012-12-29
2
-0
/
+104
|
|
\
|
|
*
Minor changes after review and general cleanup.
Patrick Wendell
2012-12-21
2
-11
/
+19
|
|
*
Adding a Twitter InputDStream with an example
Patrick Wendell
2012-12-21
2
-0
/
+96
*
|
|
Merge branch 'dev' into dev-merge
Tathagata Das
2013-01-07
16
-639
/
+37
|
\
\
\
|
*
|
|
Changed locations for unit test logs.
Tathagata Das
2013-01-07
1
-2
/
+2
|
*
|
|
Fixed bug
Tathagata Das
2013-01-07
1
-1
/
+1
|
*
|
|
Renamed examples and added documentation.
Tathagata Das
2013-01-07
3
-21
/
+35
|
*
|
|
Moved Spark Streaming examples to examples sub-project.
Tathagata Das
2013-01-06
12
-616
/
+0
*
|
|
|
BufferingBlockCreator -> NetworkReceiver.BlockGenerator
Patrick Wendell
2013-01-02
5
-94
/
+89
*
|
|
|
Merge branch 'dev-merge' into datahandler-fix
Patrick Wendell
2013-01-02
46
-507
/
+721
|
\
|
|
|
|
*
|
|
Updated Streaming Programming Guide.
Tathagata Das
2013-01-01
1
-0
/
+1
|
*
|
|
More classes made private[streaming] to hide from scala docs.
Tathagata Das
2012-12-30
17
-52
/
+135
|
*
|
|
Refactored a whole lot to push all DStreams into the spark.streaming.dstream ...
Tathagata Das
2012-12-30
40
-333
/
+401
|
*
|
|
Improved jekyll and scala docs. Made many classes and method private to remov...
Tathagata Das
2012-12-29
16
-139
/
+201
*
|
|
|
Several code-quality improvements to DataHandler.
Patrick Wendell
2013-01-02
5
-88
/
+84
|
/
/
/
*
|
|
Modifications to make sure LocalScheduler terminate cleanly without errors wh...
Tathagata Das
2012-12-27
1
-5
/
+8
*
|
|
Merge branch 'dev' of github.com:radlab/spark into dev-checkpoint
Tathagata Das
2012-12-20
14
-110
/
+683
|
\
|
|
|
*
|
Changes in response to TD's review.
Patrick Wendell
2012-12-07
6
-15
/
+29
|
*
|
Adding Flume InputDStream
Patrick Wendell
2012-12-07
8
-6
/
+246
|
|
/
|
*
Added kafka JAR
Denny
2012-12-05
1
-0
/
+0
|
*
Adjust Kafka code to work with new streaming changes.
Denny
2012-12-05
2
-4
/
+5
|
*
Merge branch 'dev' into kafka
Denny
2012-12-05
22
-109
/
+139
|
|
\
|
*
|
Added Kafka Wordcount producer
Denny
2012-11-19
2
-25
/
+52
|
*
|
Comment out code for fault-tolerance.
Denny
2012-11-19
1
-17
/
+18
|
*
|
Merge branch 'dev' into kafka
Denny
2012-11-19
4
-3
/
+173
|
|
\
\
|
*
\
\
Merge branch 'dev' into kafka
Denny
2012-11-13
9
-123
/
+155
|
|
\
\
\
|
*
|
|
|
change import for example function
Denny
2012-11-13
1
-1
/
+1
|
*
|
|
|
Merge branch 'dev' into kafka
Denny
2012-11-12
26
-2055
/
+331
|
|
\
\
\
\
|
*
|
|
|
|
Updated comment.
Denny
2012-11-11
1
-1
/
+1
|
*
|
|
|
|
Add comment.
Denny
2012-11-11
1
-0
/
+2
|
*
|
|
|
|
Kafka Stream comments.
Denny
2012-11-11
5
-53
/
+99
|
*
|
|
|
|
Merge branch 'dev' of github.com:radlab/spark into kafka
Denny
2012-11-09
8
-50
/
+263
|
|
\
\
\
\
\
|
*
|
|
|
|
|
Kafka Stream.
Denny
2012-11-09
9
-161
/
+245
|
*
|
|
|
|
|
Merge branch 'dev' of github.com:radlab/spark into kafka
Denny
2012-11-06
16
-237
/
+545
|
|
\
\
\
\
\
\
|
*
|
|
|
|
|
|
Working on kafka.
Denny
2012-11-06
3
-0
/
+159
*
|
|
|
|
|
|
|
Made checkpoint data in RDDs optional to further reduce serialized size.
Tathagata Das
2012-12-11
1
-3
/
+1
[prev]
[next]