aboutsummaryrefslogtreecommitdiff
path: root/examples/src
Commit message (Expand)AuthorAgeFilesLines
* Changed JavaStreamingContextWith*** to ***Function in streaming.api.java.*** ...Tathagata Das2014-01-062-6/+6
* Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-306-13/+20
* Refactored streaming project to separate out the twitter functionality.Tathagata Das2013-12-263-1/+4
* Fixed job name in the java streaming example.azuryyu2013-12-241-1/+1
* Merge branch 'master' of github.com:apache/incubator-spark into scala-2.10-tempPrashant Sharma2013-11-216-16/+19
|\
| * Merge branch 'master' into removesemicolonscalaHenry Saputra2013-11-192-11/+14
| |\
| | * Enable the Broadcast examples to work in a cluster settingAaron Davidson2013-11-182-11/+14
| * | Remove the semicolons at the end of Scala code to make it more pure Scala code.Henry Saputra2013-11-194-5/+5
| |/
* | Merge branch 'scala210-master' of github.com:colorant/incubator-spark into sc...Prashant Sharma2013-11-218-24/+244
|\ \
| * | Merge branch 'master' into scala-2.10Raymond Liu2013-11-138-24/+244
| |\|
| | * fix sparkhdfs lr testtgravescs2013-10-291-1/+2
| | * Makes Spark SIMR ready.Ali Ghodsi2013-10-241-1/+1
| | * Merge pull request #64 from prabeesh/masterMatei Zaharia2013-10-231-0/+107
| | |\
| | | * Update MQTTWordCount.scalaPrabeesh K2013-10-221-6/+1
| | | * Update MQTTWordCount.scalaPrabeesh K2013-10-221-3/+4
| | | * Update MQTTWordCount.scalaPrabeesh K2013-10-181-15/+14
| | | * added mqtt adapter wordcount exampleprabeesh2013-10-161-0/+112
| | * | Merge pull request #56 from jerryshao/kafka-0.8-devMatei Zaharia2013-10-212-13/+113
| | |\ \
| | | * | Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streamingjerryshao2013-10-122-13/+113
| | * | | BroadcastTest2 --> BroadcastTestMosharaf Chowdhury2013-10-162-62/+12
| | * | | Default blockSize is 4MB.Mosharaf Chowdhury2013-10-161-0/+59
| | * | | Fixing spark streaming example and a bug in examples build.Patrick Wendell2013-10-151-4/+9
| | |/ /
| | * / Remove unnecessary mutable importsNeal Wiggins2013-10-111-2/+0
| | |/
* | / Remove deprecated actorFor and use actorSelection everywhere.Prashant Sharma2013-11-121-1/+1
|/ /
* | fixed some warningsMartin Weindel2013-10-054-5/+3
* | Akka 2.2 migrationPrashant Sharma2013-09-222-4/+6
* | Merged with masterPrashant Sharma2013-09-0658-324/+1946
|\|
| * Add missing license headers found with RATMatei Zaharia2013-09-021-0/+17
| * Move some classes to more appropriate packages:Matei Zaharia2013-09-015-13/+11
| * Initial work to rename package to org.apache.sparkMatei Zaharia2013-09-0152-213/+213
| * Fix finding of assembly JAR, as well as some pointers to ./runMatei Zaharia2013-08-298-13/+13
| * Change build and run instructions to use assembliesMatei Zaharia2013-08-293-0/+447
| * make SparkHadoopUtil a member of SparkEnvJey Kottalam2013-08-151-2/+1
| * Merge pull request #762 from shivaram/sgd-cleanupEvan Sparks2013-08-111-0/+85
| |\
| | * Add setters for optimizer, gradient in SGD.Shivaram Venkataraman2013-08-081-1/+1
| | * Merge branch 'master' of git://github.com/mesos/spark into sgd-cleanupShivaram Venkataraman2013-08-061-0/+116
| | |\
| | * | Refactor GLM algorithms and add Java testsShivaram Venkataraman2013-08-061-0/+85
| * | | Fixed path to JavaALS.java and JavaKMeans.java, fixed hadoop2-yarn profileAlexander Pivovarov2013-08-102-0/+0
| * | | Optimize Scala PageRank to use reduceByKeyMatei Zaharia2013-08-101-8/+4
| * | | Merge pull request #789 from MLnick/masterMatei Zaharia2013-08-101-0/+50
| |\ \ \
| | * | | Style changes as per Matei's commentsNick Pentreath2013-08-081-9/+8
| | * | | Adding Scala version of PageRank exampleNick Pentreath2013-08-071-0/+51
| | | |/ | | |/|
| * | | Merge pull request #786 from shivaram/mllib-javaMatei Zaharia2013-08-092-0/+168
| |\ \ \
| | * | | Remove Java-specific constructor for Rating.Shivaram Venkataraman2013-08-081-3/+3
| | * | | Java examples, tests for KMeans and ALSShivaram Venkataraman2013-08-062-0/+168
| | |/ /
| * / / Optimize JavaPageRank to use reduceByKey instead of groupByKeyMatei Zaharia2013-08-081-9/+8
| |/ /
| * | Got rid of unnecessary map functionstayhf2013-08-061-6/+2
| * | changes as reviewer requestedstayhf2013-08-061-10/+1
| * | Updated code with reviewer's suggestionsstayhf2013-08-051-47/+47
| * | Simple PageRank algorithm implementation in Java for SPARK-760stayhf2013-08-031-0/+129
| |/