aboutsummaryrefslogtreecommitdiff
path: root/examples/src
Commit message (Collapse)AuthorAgeFilesLines
* Merge pull request #577 from skumargithub/masterMatei Zaharia2013-06-291-0/+50
|\ | | | | Example of cumulative counting using updateStateByKey
| * Removed unused code, clarified intent of the program, batch size to 1 secondunknown2013-05-061-5/+3
| |
| * Modified as per TD's suggestionsunknown2013-04-301-17/+6
| |
| * Examaple of cumulative counting using updateStateByKeyunknown2013-04-221-0/+63
| |
* | Merge remote-tracking branch 'mrpotes/master'Matei Zaharia2013-06-293-15/+12
|\ \
| * | Fix usage and parameter extractionJames Phillpotts2013-06-253-12/+9
| | |
| * | Include a default OAuth implementation, and update examples and ↵James Phillpotts2013-06-253-3/+3
| | | | | | | | | | | | JavaStreamingContext
* | | Merge branch 'master' into streamingTathagata Das2013-06-2440-164/+734
|\| | | | | | | | | | | | | | Conflicts: .gitignore
| * | Merge remote-tracking branch 'milliondreams/casdemo'Matei Zaharia2013-06-181-0/+196
| |\ \ | | | | | | | | | | | | | | | | Conflicts: project/SparkBuild.scala
| | * | Fixing the style as per feedbackRohit Rai2013-06-131-35/+37
| | | |
| | * | Example to write the output to cassandraRohit Rai2013-06-031-5/+43
| | | |
| | * | A better way to read column value if you are sure the column exists in every ↵Rohit Rai2013-06-031-2/+4
| | | | | | | | | | | | | | | | row.
| | * | Removing infix callRohit Rai2013-06-021-3/+3
| | | |
| | * | Adding example to make Spark RDD from CassandraRohit Rai2013-06-011-0/+154
| | | |
| * | | Add hBase exampleEthan Jewett2013-05-091-0/+35
| | | |
| * | | Revert "Merge pull request #596 from esjewett/master" because theReynold Xin2013-05-091-35/+0
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | dependency on hbase introduces netty-3.2.2 which conflicts with netty-3.5.3 already in Spark. This caused multiple test failures. This reverts commit 0f1b7a06e1f6782711170234f105f1b277e3b04c, reversing changes made to aacca1b8a85bd073ce185a06d6470b070761b2f4.
| * | | Switch to using SparkContext method to create RDDEthan Jewett2013-05-071-2/+2
| | | |
| * | | Fix indents and mention other configuration optionsEthan Jewett2013-05-041-2/+5
| | | |
| * | | Remove unnecessary column family configEthan Jewett2013-05-041-4/+2
| | | |
| * | | HBase exampleEthan Jewett2013-05-041-0/+34
| |/ /
| * | Attempt at fixing merge conflictMridul Muralidharan2013-04-245-77/+77
| |\|
| | * Uniform whitespace across scala examplesAndrew Ash2013-04-094-76/+76
| | |
| | * Corrected order of CountMinSketchMonoid argumentsErik van oosten2013-04-021-1/+1
| | |
| * | Fix review comments, add a new api to SparkHadoopUtil to create appropriate ↵Mridul Muralidharan2013-04-221-2/+8
| |/ | | | | | | Configuration. Modify an example to show how to use SplitInfo
| * Java indentation 4 --> 2 spacesNick Pentreath2013-03-203-200/+200
| |
| * A few cosmetic changes for JavaKMeansNick Pentreath2013-03-191-1/+4
| |
| * Adding Java K-Means exampleNick Pentreath2013-03-192-0/+112
| |
| * Changes to more closely match line length limit styleNick Pentreath2013-03-171-3/+5
| |
| * Adding Java versions of Pi and LogQueryNick Pentreath2013-03-153-0/+161
| |
| * Pass a code JAR to SparkContext in our examples. Fixes SPARK-594.Matei Zaharia2013-02-2535-82/+137
| |
| * Fix compile errorMatei Zaharia2013-02-252-2/+2
| |
| * Use public method sparkContext instead of protected sc in streaming examplesMatei Zaharia2013-02-253-4/+4
| |
* | Surfacing decoders on KafkaInputDStreamseanm2013-04-161-1/+1
|/
* Fixed bugs in examples.Tathagata Das2013-02-243-4/+3
|
* Fixed differences in APIs of StreamingContext and JavaStreamingContext. ↵Tathagata Das2013-02-231-1/+1
| | | | Change rawNetworkStream to rawSocketStream, and added twitter, actor, zeroMQ streams to JavaStreamingContext. Also added them to JavaAPISuite.
* Merge pull request #480 from MLnick/streaming-eg-algebirdTathagata Das2013-02-222-0/+164
|\ | | | | [Streaming] Examples using Twitter's Algebird library
| * Adding documentation for HLL and CMS examples. More efficient and clear use ↵Nick Pentreath2013-02-212-12/+36
| | | | | | | | of the monoids.
| * Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebirdNick Pentreath2013-02-212-1/+67
| |\
| * | Streaming example using Twitter Algebird's Count Min Sketch monoidNick Pentreath2013-02-191-0/+78
| | |
| * | Dependencies and refactoring for streaming HLL example, and using ↵Nick Pentreath2013-02-191-15/+14
| | | | | | | | | | | | context.twitterStream method
| * | Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebirdNick Pentreath2013-02-1910-108/+200
| |\ \ | | | | | | | | | | | | | | | | Conflicts: project/SparkBuild.scala
| * | | Adding streaming HyperLogLog example using AlgebirdNick Pentreath2013-02-191-0/+62
| | | |
* | | | Merge pull request #479 from ScrapCodes/zeromq-streamingTathagata Das2013-02-221-0/+73
|\ \ \ \ | |_|_|/ |/| | | Zeromq streaming
| * | | fixes corresponding to review feedback at pull request #479Prashant Sharma2013-02-201-3/+6
| | | |
| * | | example for demonstrating ZeroMQ streamPrashant Sharma2013-02-191-0/+70
| | |/ | |/|
* | | Merge branch 'mesos-streaming' into streamingTathagata Das2013-02-201-1/+1
|\ \ \ | | | | | | | | | | | | | | | | Conflicts: streaming/src/test/java/spark/streaming/JavaAPISuite.java
| * | | A bug fix post merge, following changes to AkkaUtilsPrashant Sharma2013-02-201-1/+1
| |/ /
* | | Merge branch 'mesos-master' into streamingTathagata Das2013-02-201-0/+66
|\ \ \ | |/ / |/| | | | | | | | | | | Conflicts: core/src/main/scala/spark/rdd/CheckpointRDD.scala streaming/src/main/scala/spark/streaming/dstream/ReducedWindowedDStream.scala
| * | Fixing to match Spark styleguidePatrick Wendell2013-02-051-8/+8
| | |
| * | Adding an example with an OLAP roll-upPatrick Wendell2013-02-041-0/+66
| |/
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-13 08:06:17 +0000