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
...
*
|
|
|
commit opt for grep scalibility test.
haoyuan
2012-09-07
3
-31
/
+45
|
|
/
/
|
/
|
|
*
|
|
Less warmup in word count
root
2012-09-06
1
-1
/
+1
*
|
|
Merge branch 'dev' of github.com:radlab/spark into dev
root
2012-09-05
1
-1
/
+1
|
\
\
\
|
*
|
|
Merge branch 'dev' of github.com:radlab/spark into dev
root
2012-09-05
6
-56
/
+201
|
|
\
|
|
|
*
|
|
Some changes to make important log output visible even if we set the logging ...
root
2012-09-05
1
-1
/
+1
*
|
|
|
Tuning Akka for more connections
root
2012-09-05
1
-5
/
+5
|
|
/
/
|
/
|
|
*
|
|
Merge branch 'dev' of github.com:radlab/spark into dev
Tathagata Das
2012-09-04
4
-2
/
+229
|
\
\
\
|
*
|
|
fix the compile error in TopKWordCountRaw.scala
haoyuan
2012-09-04
1
-6
/
+6
|
*
|
|
add TopKWordCountRaw.scala
haoyuan
2012-09-04
1
-0
/
+86
|
|
/
/
|
*
|
Merge branch 'dev' of github.com:radlab/spark into dev
root
2012-09-04
7
-97
/
+345
|
|
\
|
|
*
|
Various test programs
root
2012-09-04
3
-2
/
+143
*
|
|
Changed DStream member access permissions from private to protected. Updated...
Tathagata Das
2012-09-04
4
-35
/
+80
*
|
|
Updated the return types of PairDStreamFunctions to return DStreams instead o...
Tathagata Das
2012-09-04
1
-21
/
+35
|
|
/
|
/
|
*
|
Merge branch 'dev' of github.com:radlab/spark into dev
Tathagata Das
2012-09-02
15
-70
/
+368
|
\
|
|
*
tweaks
root
2012-09-01
1
-1
/
+1
|
*
More raw network receiver programs
root
2012-09-01
3
-1
/
+76
|
*
Make batch size configurable in RawCount
root
2012-09-01
1
-6
/
+6
|
*
Further fixes to raw text sender, plus an app that uses it
root
2012-09-01
7
-5
/
+56
|
*
Bug fixes to RateLimitedOutputStream
Matei Zaharia
2012-09-01
1
-1
/
+3
|
*
First work towards a RawInputDStream and a sender program for it.
Matei Zaharia
2012-09-01
8
-50
/
+218
|
*
Bug fix
Matei Zaharia
2012-08-31
1
-1
/
+1
|
*
Bug fix
Matei Zaharia
2012-08-31
1
-1
/
+1
|
*
Better output messages for streaming job duration
Matei Zaharia
2012-08-31
2
-5
/
+3
|
*
WordCount tweaks
root
2012-08-31
1
-7
/
+10
|
*
Make checkpoint interval configurable in WordCount2
root
2012-08-31
1
-7
/
+8
*
|
Added transformRDD DStream operation and TransformedDStream. Added sbt assemb...
Tathagata Das
2012-09-02
3
-19
/
+46
*
|
Added StateDStream, corresponding stateful stream operations, and testcases. ...
Tathagata Das
2012-08-31
7
-82
/
+303
|
/
*
Compile fixes
root
2012-08-29
2
-4
/
+4
*
Merge branch 'dev' of github.com/radlab/spark into dev
Tathagata Das
2012-08-28
8
-55
/
+143
|
\
|
*
Made WordCount2 even more configurable
root
2012-08-27
1
-5
/
+7
|
*
Merge branch 'dev' of github.com:radlab/spark into dev
root
2012-08-27
1
-14
/
+12
|
|
\
|
|
*
Code style
Matei Zaharia
2012-08-26
1
-14
/
+12
|
*
|
Tweaks to WordCount2
root
2012-08-27
1
-6
/
+13
|
|
/
|
*
Made Time and Interval immutable
Matei Zaharia
2012-08-26
5
-51
/
+13
|
*
Merge branch 'dev' of github.com:radlab/spark into dev
Matei Zaharia
2012-08-26
3
-4
/
+106
|
|
\
|
|
*
Added sliding word count, and some fixes to reduce window DStream
root
2012-08-26
3
-4
/
+106
|
*
|
Add equals and hashCode to Time
Matei Zaharia
2012-08-26
1
-0
/
+8
|
|
/
|
*
Make Time serializable
Matei Zaharia
2012-08-26
1
-1
/
+1
|
*
Reduce log4j verbosity for streaming
Matei Zaharia
2012-08-24
1
-0
/
+8
|
*
Fix WordCount job name
Matei Zaharia
2012-08-24
1
-1
/
+1
*
|
Added capabllity to take streaming input from network. Renamed SparkStreamCon...
Tathagata Das
2012-08-28
19
-142
/
+502
|
/
*
Added new Clock interface that is used by RecurringTimer to scheduler events ...
Tathagata Das
2012-08-06
6
-30
/
+130
*
Renamed RDS to DStream, plus minor style fixes
Matei Zaharia
2012-08-02
16
-185
/
+183
*
Added an RDS that repeatedly returns the same input
Matei Zaharia
2012-08-02
1
-0
/
+18
*
Added a WordCount for external data and fixed bugs in file streams
Matei Zaharia
2012-08-02
3
-7
/
+33
*
Moved streaming files not immediately necessary to spark.streaming.util.
Tathagata Das
2012-08-01
9
-19
/
+14
*
1. Refactored SparkStreamContext, Scheduler, InputRDS, FileInputRDS and a few...
Tathagata Das
2012-08-01
46
-2432
/
+796
*
Restructured file locations to separate examples and other programs from core...
Tathagata Das
2012-07-30
28
-159
/
+27
*
Renamed stream package to streaming
Matei Zaharia
2012-07-29
46
-50
/
+50
*
Added the Spark Streaing code, ported to Akka 2
Matei Zaharia
2012-07-28
46
-0
/
+5081
[prev]