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
Commit message (
Expand
)
Author
Age
Files
Lines
*
Fixed differences in APIs of StreamingContext and JavaStreamingContext. Chang...
Tathagata Das
2013-02-23
5
-26
/
+232
*
Merge branch 'mesos-streaming' into streaming
Tathagata Das
2013-02-22
8
-8
/
+313
|
\
|
*
Fixed resolver for akka-zeromq
Tathagata Das
2013-02-22
1
-0
/
+3
|
*
Merge pull request #480 from MLnick/streaming-eg-algebird
Tathagata Das
2013-02-22
5
-5
/
+179
|
|
\
|
|
*
Adding documentation for HLL and CMS examples. More efficient and clear use o...
Nick Pentreath
2013-02-21
2
-12
/
+36
|
|
*
Bumping Algebird to 0.1.9
Nick Pentreath
2013-02-21
2
-2
/
+2
|
|
*
Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird
Nick Pentreath
2013-02-21
115
-922
/
+1528
|
|
|
\
|
|
*
|
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
3
-21
/
+24
|
|
*
|
Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird
Nick Pentreath
2013-02-19
55
-1138
/
+2543
|
|
|
\
\
|
|
*
|
|
Adding streaming HyperLogLog example using Algebird
Nick Pentreath
2013-02-19
3
-1
/
+69
|
*
|
|
|
Merge pull request #479 from ScrapCodes/zeromq-streaming
Tathagata Das
2013-02-22
4
-3
/
+131
|
|
\
\
\
\
|
|
|
_
|
_
|
/
|
|
/
|
|
|
|
|
*
|
|
removed document on zeromq
Prashant Sharma
2013-02-20
1
-59
/
+0
|
|
*
|
|
fixes corresponding to review feedback at pull request #479
Prashant Sharma
2013-02-20
3
-6
/
+9
|
|
*
|
|
example for demonstrating ZeroMQ stream
Prashant Sharma
2013-02-19
2
-8
/
+77
|
|
*
|
|
ZeroMQ stream as receiver
Prashant Sharma
2013-02-19
4
-0
/
+115
|
|
|
|
/
|
|
|
/
|
|
*
|
|
Merge pull request #487 from tdas/streaming
Tathagata Das
2013-02-20
113
-903
/
+1387
|
|
\
\
\
*
|
|
|
|
Fixed condition in InputDStream isTimeValid.
Tathagata Das
2013-02-21
1
-1
/
+1
|
|
/
/
/
|
/
|
|
|
*
|
|
|
Merge branch 'mesos-streaming' into streaming
Tathagata Das
2013-02-20
7
-50
/
+103
|
\
|
|
|
|
*
|
|
Merge pull request #486 from ScrapCodes/akka-example-bug-fix
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 pull request #481 from pwendell/stream-rdd-type-streaming
Tathagata Das
2013-02-19
6
-19
/
+146
|
|
\
\
\
|
|
|
/
/
|
|
/
|
|
|
|
*
|
Small changes that were missing in merge
Patrick Wendell
2013-02-19
2
-0
/
+2
|
|
*
|
Use RDD type for `slice` operator in Java.
Patrick Wendell
2013-02-19
1
-2
/
+2
|
|
*
|
Use RDD type for `transform` operator in Java.
Patrick Wendell
2013-02-19
2
-7
/
+122
|
|
*
|
Use RDD type for `foreach` operator in Java.
Patrick Wendell
2013-02-19
6
-11
/
+21
|
|
/
/
|
*
|
Merge pull request #476 from tdas/streaming
Tathagata Das
2013-02-19
52
-862
/
+2142
|
|
\
\
*
|
|
|
Fixed bug in CheckpointSuite
Tathagata Das
2013-02-20
2
-6
/
+6
*
|
|
|
Merge branch 'mesos-master' into streaming
Tathagata Das
2013-02-20
6
-8
/
+51
|
\
\
\
\
|
*
\
\
\
Merge pull request #482 from woggling/shutdown-exceptions
Matei Zaharia
2013-02-19
3
-7
/
+37
|
|
\
\
\
\
|
|
*
|
|
|
Pull detection of being in a shutdown hook into utility function.
Charles Reiss
2013-02-19
2
-14
/
+23
|
|
*
|
|
|
Catch/log errors deleting temp dirs
Charles Reiss
2013-02-19
1
-1
/
+5
|
|
*
|
|
|
Paranoid uncaught exception handling for exceptions during shutdown
Charles Reiss
2013-02-19
1
-6
/
+23
|
*
|
|
|
|
Merge pull request #484 from andyk/master
Matei Zaharia
2013-02-19
2
-1
/
+2
|
|
\
\
\
\
\
|
|
*
|
|
|
|
Fixes link to issue tracker in documentation page "Contributing to Spark".
Andy Konwinski
2013-02-19
2
-1
/
+2
|
|
|
/
/
/
/
|
*
|
|
|
|
Merge pull request #483 from rxin/splitpruningrdd2
Matei Zaharia
2013-02-19
1
-0
/
+12
|
|
\
\
\
\
\
|
|
|
/
/
/
/
|
|
/
|
|
|
|
|
|
*
|
|
|
Added a method to create PartitionPruningRDD.
Reynold Xin
2013-02-19
1
-0
/
+12
|
|
/
/
/
/
*
|
|
/
/
Merge branch 'mesos-master' into streaming
Tathagata Das
2013-02-20
109
-893
/
+1408
|
\
|
|
|
|
|
|
_
|
/
/
|
/
|
|
|
|
*
|
|
Merge pull request #477 from shivaram/ganglia-port-change
Matei Zaharia
2013-02-18
1
-1
/
+8
|
|
\
\
\
|
|
*
|
|
Print cluster url after setup completes
Shivaram Venkataraman
2013-02-18
1
-0
/
+5
|
|
*
|
|
Print ganglia url after setup
Shivaram Venkataraman
2013-02-18
1
-0
/
+2
|
|
*
|
|
Use port 5080 for httpd/ganglia
Shivaram Venkataraman
2013-02-18
1
-1
/
+1
|
|
/
/
/
|
*
|
|
Rename "jobs" to "applications" in the standalone cluster
Matei Zaharia
2013-02-17
34
-295
/
+299
|
*
|
|
Renamed "splits" to "partitions"
Matei Zaharia
2013-02-17
48
-390
/
+405
|
*
|
|
Clean up EC2 script options a bit
Matei Zaharia
2013-02-17
1
-9
/
+12
|
*
|
|
Change EC2 script to use 0.6 AMIs by default, for now
Matei Zaharia
2013-02-17
1
-5
/
+5
|
*
|
|
Merge pull request #421 from shivaram/spark-ec2-change
Matei Zaharia
2013-02-17
2
-15
/
+59
|
|
\
\
\
|
|
*
|
|
Turn on ganglia by default
Shivaram Venkataraman
2013-01-31
1
-1
/
+1
|
|
*
|
|
Add an option to use the old scripts
Shivaram Venkataraman
2013-01-28
1
-13
/
+30
|
|
*
|
|
Add option to start ganglia. Also enable Hadoop ports even if cluster type is
Shivaram Venkataraman
2013-01-27
1
-8
/
+15
[next]