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
/
examples
Commit message (
Expand
)
Author
Age
Files
Lines
*
Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird
Nick Pentreath
2013-02-21
2
-1
/
+67
|
\
|
*
Merge branch 'mesos-streaming' into streaming
Tathagata Das
2013-02-20
1
-1
/
+1
|
|
\
|
|
*
A bug fix post merge, following changes to AkkaUtils
Prashant Sharma
2013-02-20
1
-1
/
+1
|
*
|
Merge branch 'mesos-master' into streaming
Tathagata Das
2013-02-20
1
-0
/
+66
|
|
\
\
|
|
|
/
|
|
/
|
|
|
*
Fixing to match Spark styleguide
Patrick Wendell
2013-02-05
1
-8
/
+8
|
|
*
Adding an example with an OLAP roll-up
Patrick Wendell
2013-02-04
1
-0
/
+66
*
|
|
Streaming example using Twitter Algebird's Count Min Sketch monoid
Nick Pentreath
2013-02-19
1
-0
/
+78
*
|
|
Dependencies and refactoring for streaming HLL example, and using context.twi...
Nick Pentreath
2013-02-19
2
-21
/
+14
*
|
|
Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird
Nick Pentreath
2013-02-19
10
-108
/
+200
|
\
|
|
|
*
|
Added comment to the KafkaWordCount, given by Sean McNamara.
Tathagata Das
2013-02-19
1
-0
/
+12
|
*
|
Merge branch 'streaming' into ScrapCodes-streaming-actor
Tathagata Das
2013-02-19
9
-119
/
+46
|
|
\
\
|
|
*
|
Changed networkStream to socketStream and pluggableNetworkStream to become ne...
Tathagata Das
2013-02-18
4
-9
/
+9
|
|
*
|
Merge branch 'streaming' into ScrapCode-streaming
Tathagata Das
2013-02-18
10
-145
/
+64
|
|
|
\
\
|
|
|
*
|
Moved Java streaming examples to examples/src/main/java/spark/streaming/... a...
Tathagata Das
2013-02-14
3
-0
/
+0
|
|
|
*
|
Added TwitterInputDStream from example to StreamingContext. Renamed example T...
Tathagata Das
2013-02-14
2
-91
/
+13
|
|
|
*
|
Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWind...
Tathagata Das
2013-02-14
1
-6
/
+5
|
|
|
*
|
Merge branch 'mesos-master' into streaming
Tathagata Das
2013-02-07
1
-11
/
+17
|
|
|
|
\
|
|
|
|
*
|
Merge pull request #372 from Reinvigorate/sm-kafka
Tathagata Das
2013-02-07
1
-8
/
+8
|
|
|
|
\
\
|
|
|
|
*
|
kafkaStream API cleanup. A quorum of zookeepers can now be specified
seanm
2013-01-18
1
-8
/
+8
|
|
*
|
|
|
Plug in actor as stream receiver API
Prashant Sharma
2013-01-19
2
-0
/
+143
|
|
*
|
|
|
Changed method name of createReceiver to getReceiver as it is not intended to...
Prashant Sharma
2013-01-19
1
-1
/
+1
|
*
|
|
|
|
Taking FeederActor out as seperate program
Prashant Sharma
2013-02-08
1
-22
/
+44
|
*
|
|
|
|
Improved document comment in example
Prashant Sharma
2013-01-25
1
-1
/
+7
|
*
|
|
|
|
actor as receiver
Prashant Sharma
2013-01-22
1
-0
/
+130
|
*
|
|
|
|
Changed method name of createReceiver to getReceiver as it is not intended to...
Prashant Sharma
2013-01-21
1
-1
/
+1
|
|
|
/
/
/
|
|
/
|
|
|
*
|
|
|
|
Adding streaming HyperLogLog example using Algebird
Nick Pentreath
2013-02-19
2
-0
/
+67
|
|
_
|
_
|
/
|
/
|
|
|
*
|
|
|
Remove activation of profiles by default
Mikhail Bautin
2013-01-31
1
-11
/
+0
*
|
|
|
Add Maven build file for streaming, and fix some issues in SBT file
Matei Zaharia
2013-01-20
1
-0
/
+17
|
/
/
/
*
|
|
Merge branch 'master' into streaming
Matei Zaharia
2013-01-20
1
-39
/
+20
|
\
\
\
|
*
|
|
Minor formatting fixes
Matei Zaharia
2013-01-20
1
-2
/
+2
|
*
|
|
Use only one update function and pass in transpose of ratings matrix where ap...
Nick Pentreath
2013-01-17
1
-29
/
+3
|
*
|
|
Fixed index error missing first argument
Nick Pentreath
2013-01-17
1
-1
/
+1
|
*
|
|
Adding default command line args to SparkALS
Nick Pentreath
2013-01-17
1
-10
/
+17
*
|
|
|
Merge branch 'mesos-streaming' into streaming
Tathagata Das
2013-01-20
4
-1
/
+175
|
\
\
\
\
|
|
|
/
/
|
|
/
|
|
|
*
|
|
NetworkWordCount example
Patrick Wendell
2013-01-17
2
-1
/
+63
|
*
|
|
Adding queueStream and some slight refactoring
Patrick Wendell
2013-01-17
1
-0
/
+62
|
*
|
|
Small doc fix
Patrick Wendell
2013-01-17
1
-1
/
+1
|
*
|
|
Two changes:
Patrick Wendell
2013-01-14
1
-2
/
+2
|
*
|
|
Flume example and bug fix
Patrick Wendell
2013-01-14
1
-0
/
+50
|
|
|
/
|
|
/
|
*
|
|
Merge branch 'master' into streaming
Tathagata Das
2013-01-15
2
-1
/
+12
|
\
\
\
|
|
/
/
|
/
|
/
|
|
/
|
*
Update examples/src/main/scala/spark/examples/LocalLR.scala
Eric Zhang
2013-01-13
1
-1
/
+1
|
*
Rename environment variable for hadoop profiles to hadoopVersion
Shivaram Venkataraman
2013-01-12
1
-2
/
+2
|
*
Activate hadoop2 profile in pom.xml with -Dhadoop=2
Shivaram Venkataraman
2013-01-10
1
-0
/
+6
|
*
Activate hadoop1 if property hadoop is missing. hadoop2 can be activated now
Shivaram Venkataraman
2013-01-08
1
-1
/
+3
|
*
Activate hadoop1 profile by default for maven builds
Shivaram Venkataraman
2013-01-07
1
-0
/
+3
*
|
Removed stream id from the constructor of NetworkReceiver to make it easier f...
Tathagata Das
2013-01-13
1
-7
/
+8
*
|
Making the Twitter example distributed.
Patrick Wendell
2013-01-07
2
-37
/
+62
*
|
Moved Twitter example to the where the other examples are.
Tathagata Das
2013-01-07
2
-0
/
+105
*
|
Renamed examples and added documentation.
Tathagata Das
2013-01-07
10
-274
/
+97
*
|
Moved Spark Streaming examples to examples sub-project.
Tathagata Das
2013-01-06
12
-0
/
+615
|
/
[next]