Skip to content
Snippets Groups Projects
  1. Feb 24, 2014
  2. Feb 22, 2014
  3. Feb 19, 2014
  4. Feb 18, 2014
  5. Feb 17, 2014
    • Andrew Or's avatar
      Fix typos in Spark Streaming programming guide · 767e3ae1
      Andrew Or authored
      Author: Andrew Or <andrewor14@gmail.com>
      
      Closes #536 from andrewor14/streaming-typos and squashes the following commits:
      
      a05faa6 [Andrew Or] Fix broken link and wording
      bc2e4bc [Andrew Or] Merge github.com:apache/incubator-spark into streaming-typos
      d5515b4 [Andrew Or] TD's comments
      767ef12 [Andrew Or] Fix broken links
      8f4c731 [Andrew Or] Fix typos in programming guide
      767e3ae1
  6. Feb 14, 2014
    • Andrew Ash's avatar
      Typo: Standlone -> Standalone · eec4bd1a
      Andrew Ash authored
      Author: Andrew Ash <andrew@andrewash.com>
      
      Closes #601 from ash211/typo and squashes the following commits:
      
      9cd43ac [Andrew Ash] Change docs references to metrics.properties, not metrics.conf
      3813ff1 [Andrew Ash] Typo: mulitcast -> multicast
      873bd2f [Andrew Ash] Typo: Standlone -> Standalone
      eec4bd1a
  7. Feb 11, 2014
    • Henry Saputra's avatar
      Merge pull request #577 from hsaputra/fix_simple_streaming_doc. · ba38d989
      Henry Saputra authored
      SPARK-1075 Fix doc in the Spark Streaming custom receiver closing bracket in the class constructor
      
      The closing parentheses in the constructor in the first code block example is reversed:
      diff --git a/docs/streaming-custom-receivers.md b/docs/streaming-custom-receivers.md
      index 4e27d65..3fb540c 100644
      — a/docs/streaming-custom-receivers.md
      +++ b/docs/streaming-custom-receivers.md
      @@ -14,7 +14,7 @@ This starts with implementing NetworkReceiver(api/streaming/index.html#org.apa
      The following is a simple socket text-stream receiver.
      {% highlight scala %}
      class SocketTextStreamReceiver(host: String, port: Int(
      + class SocketTextStreamReceiver(host: String, port: Int)
      extends NetworkReceiverString
      {
      protected lazy val blocksGenerator: BlockGenerator =
      
      Author: Henry Saputra <henry@platfora.com>
      
      Closes #577 and squashes the following commits:
      
      6508341 [Henry Saputra] SPARK-1075 Fix doc in the Spark Streaming custom receiver.
      ba38d989
    • Chen Chao's avatar
      Merge pull request #579 from CrazyJvm/patch-1. · 4afe6ccf
      Chen Chao authored
      "in the source DStream" rather than "int the source DStream"
      
      "flatMap is a one-to-many DStream operation that creates a new DStream by generating multiple new records from each record int the source DStream."
      
      Author: Chen Chao <crazyjvm@gmail.com>
      
      Closes #579 and squashes the following commits:
      
      4abcae3 [Chen Chao] in the source DStream
      4afe6ccf
  8. Feb 09, 2014
    • Martin Jaggi's avatar
      Merge pull request #566 from martinjaggi/copy-MLlib-d. · 2182aa3c
      Martin Jaggi authored
      new MLlib documentation for optimization, regression and classification
      
      new documentation with tex formulas, hopefully improving usability and reproducibility of the offered MLlib methods.
      also did some minor changes in the code for consistency. scala tests pass.
      
      this is the rebased branch, i deleted the old PR
      
      jira:
      https://spark-project.atlassian.net/browse/MLLIB-19
      
      Author: Martin Jaggi <m.jaggi@gmail.com>
      
      Closes #566 and squashes the following commits:
      
      5f0f31e [Martin Jaggi] line wrap at 100 chars
      4e094fb [Martin Jaggi] better description of GradientDescent
      1d6965d [Martin Jaggi] remove broken url
      ea569c3 [Martin Jaggi] telling what updater actually does
      964732b [Martin Jaggi] lambda R() in documentation
      a6c6228 [Martin Jaggi] better comments in SGD code for regression
      b32224a [Martin Jaggi] new optimization documentation
      d5dfef7 [Martin Jaggi] new classification and regression documentation
      b07ead6 [Martin Jaggi] correct scaling for MSE loss
      ba6158c [Martin Jaggi] use d for the number of features
      bab2ed2 [Martin Jaggi] renaming LeastSquaresGradient
      2182aa3c
  9. Feb 08, 2014
    • Mark Hamstra's avatar
      Merge pull request #542 from markhamstra/versionBump. Closes #542. · c2341c92
      Mark Hamstra authored
      Version number to 1.0.0-SNAPSHOT
      
      Since 0.9.0-incubating is done and out the door, we shouldn't be building 0.9.0-incubating-SNAPSHOT anymore.
      
      @pwendell
      
      Author: Mark Hamstra <markhamstra@gmail.com>
      
      == Merge branch commits ==
      
      commit 1b00a8a7c1a7f251b4bb3774b84b9e64758eaa71
      Author: Mark Hamstra <markhamstra@gmail.com>
      Date:   Wed Feb 5 09:30:32 2014 -0800
      
          Version number to 1.0.0-SNAPSHOT
      c2341c92
    • Martin Jaggi's avatar
      Merge pull request #552 from martinjaggi/master. Closes #552. · fabf1749
      Martin Jaggi authored
      tex formulas in the documentation
      
      using mathjax.
      and spliting the MLlib documentation by techniques
      
      see jira
      https://spark-project.atlassian.net/browse/MLLIB-19
      and
      https://github.com/shivaram/spark/compare/mathjax
      
      Author: Martin Jaggi <m.jaggi@gmail.com>
      
      == Merge branch commits ==
      
      commit 0364bfabbfc347f917216057a20c39b631842481
      Author: Martin Jaggi <m.jaggi@gmail.com>
      Date:   Fri Feb 7 03:19:38 2014 +0100
      
          minor polishing, as suggested by @pwendell
      
      commit dcd2142c164b2f602bf472bb152ad55bae82d31a
      Author: Martin Jaggi <m.jaggi@gmail.com>
      Date:   Thu Feb 6 18:04:26 2014 +0100
      
          enabling inline latex formulas with $.$
      
          same mathjax configuration as used in math.stackexchange.com
      
          sample usage in the linear algebra (SVD) documentation
      
      commit bbafafd2b497a5acaa03a140bb9de1fbb7d67ffa
      Author: Martin Jaggi <m.jaggi@gmail.com>
      Date:   Thu Feb 6 17:31:29 2014 +0100
      
          split MLlib documentation by techniques
      
          and linked from the main mllib-guide.md site
      
      commit d1c5212b93c67436543c2d8ddbbf610fdf0a26eb
      Author: Martin Jaggi <m.jaggi@gmail.com>
      Date:   Thu Feb 6 16:59:43 2014 +0100
      
          enable mathjax formula in the .md documentation files
      
          code by @shivaram
      
      commit d73948db0d9bc36296054e79fec5b1a657b4eab4
      Author: Martin Jaggi <m.jaggi@gmail.com>
      Date:   Thu Feb 6 16:57:23 2014 +0100
      
          minor update on how to compile the documentation
      fabf1749
  10. Feb 07, 2014
    • Andrew Or's avatar
      Merge pull request #533 from andrewor14/master. Closes #533. · 1896c6e7
      Andrew Or authored
      External spilling - generalize batching logic
      
      The existing implementation consists of a hack for Kryo specifically and only works for LZF compression. Introducing an intermediate batch-level stream takes care of pre-fetching and other arbitrary behavior of higher level streams in a more general way.
      
      Author: Andrew Or <andrewor14@gmail.com>
      
      == Merge branch commits ==
      
      commit 3ddeb7ef89a0af2b685fb5d071aa0f71c975cc82
      Author: Andrew Or <andrewor14@gmail.com>
      Date:   Wed Feb 5 12:09:32 2014 -0800
      
          Also privatize fields
      
      commit 090544a87a0767effd0c835a53952f72fc8d24f0
      Author: Andrew Or <andrewor14@gmail.com>
      Date:   Wed Feb 5 10:58:23 2014 -0800
      
          Privatize methods
      
      commit 13920c918efe22e66a1760b14beceb17a61fd8cc
      Author: Andrew Or <andrewor14@gmail.com>
      Date:   Tue Feb 4 16:34:15 2014 -0800
      
          Update docs
      
      commit bd5a1d7350467ed3dc19c2de9b2c9f531f0e6aa3
      Author: Andrew Or <andrewor14@gmail.com>
      Date:   Tue Feb 4 13:44:24 2014 -0800
      
          Typo: phyiscal -> physical
      
      commit 287ef44e593ad72f7434b759be3170d9ee2723d2
      Author: Andrew Or <andrewor14@gmail.com>
      Date:   Tue Feb 4 13:38:32 2014 -0800
      
          Avoid reading the entire batch into memory; also simplify streaming logic
      
          Additionally, address formatting comments.
      
      commit 3df700509955f7074821e9aab1e74cb53c58b5a5
      Merge: a531d2e 164489d
      Author: Andrew Or <andrewor14@gmail.com>
      Date:   Mon Feb 3 18:27:49 2014 -0800
      
          Merge branch 'master' of github.com:andrewor14/incubator-spark
      
      commit a531d2e347acdcecf2d0ab72cd4f965ab5e145d8
      Author: Andrew Or <andrewor14@gmail.com>
      Date:   Mon Feb 3 18:18:04 2014 -0800
      
          Relax assumptions on compressors and serializers when batching
      
          This commit introduces an intermediate layer of an input stream on the batch level.
          This guards against interference from higher level streams (i.e. compression and
          deserialization streams), especially pre-fetching, without specifically targeting
          particular libraries (Kryo) and forcing shuffle spill compression to use LZF.
      
      commit 164489d6f176bdecfa9dabec2dfce5504d1ee8af
      Author: Andrew Or <andrewor14@gmail.com>
      Date:   Mon Feb 3 18:18:04 2014 -0800
      
          Relax assumptions on compressors and serializers when batching
      
          This commit introduces an intermediate layer of an input stream on the batch level.
          This guards against interference from higher level streams (i.e. compression and
          deserialization streams), especially pre-fetching, without specifically targeting
          particular libraries (Kryo) and forcing shuffle spill compression to use LZF.
      1896c6e7
  11. Jan 30, 2014
    • Reynold Xin's avatar
      Merge pull request #524 from rxin/doc · ac712e48
      Reynold Xin authored
      Added spark.shuffle.file.buffer.kb to configuration doc.
      
      Author: Reynold Xin <rxin@apache.org>
      
      == Merge branch commits ==
      
      commit 0eea1d761ff772ff89be234e1e28035d54e5a7de
      Author: Reynold Xin <rxin@apache.org>
      Date:   Wed Jan 29 14:40:48 2014 -0800
      
          Added spark.shuffle.file.buffer.kb to configuration doc.
      ac712e48
  12. Jan 28, 2014
    • Tathagata Das's avatar
      Merge pull request #497 from tdas/docs-update · 79302096
      Tathagata Das authored
      Updated Spark Streaming Programming Guide
      
      Here is the updated version of the Spark Streaming Programming Guide. This is still a work in progress, but the major changes are in place. So feedback is most welcome.
      
      In general, I have tried to make the guide to easier to understand even if the reader does not know much about Spark. The updated website is hosted here -
      
      http://www.eecs.berkeley.edu/~tdas/spark_docs/streaming-programming-guide.html
      
      The major changes are:
      - Overview illustrates the usecases of Spark Streaming - various input sources and various output sources
      - An example right after overview to quickly give an idea of what Spark Streaming program looks like
      - Made Java API and examples a first class citizen like Scala by using tabs to show both Scala and Java examples (similar to AMPCamp tutorial's code tabs)
      - Highlighted the DStream operations updateStateByKey and transform because of their powerful nature
      - Updated driver node failure recovery text to highlight automatic recovery in Spark standalone mode
      - Added information about linking and using the external input sources like Kafka and Flume
      - In general, reorganized the sections to better show the Basic section and the more advanced sections like Tuning and Recovery.
      
      Todos:
      - Links to the docs of external Kafka, Flume, etc
      - Illustrate window operation with figure as well as example.
      
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      
      == Merge branch commits ==
      
      commit 18ff10556570b39d672beeb0a32075215cfcc944
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Tue Jan 28 21:49:30 2014 -0800
      
          Fixed a lot of broken links.
      
      commit 34a5a6008dac2e107624c7ff0db0824ee5bae45f
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Tue Jan 28 18:02:28 2014 -0800
      
          Updated github url to use SPARK_GITHUB_URL variable.
      
      commit f338a60ae8069e0a382d2cb170227e5757cc0b7a
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Mon Jan 27 22:42:42 2014 -0800
      
          More updates based on Patrick and Harvey's comments.
      
      commit 89a81ff25726bf6d26163e0dd938290a79582c0f
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Mon Jan 27 13:08:34 2014 -0800
      
          Updated docs based on Patricks PR comments.
      
      commit d5b6196b532b5746e019b959a79ea0cc013a8fc3
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Sun Jan 26 20:15:58 2014 -0800
      
          Added spark.streaming.unpersist config and info on StreamingListener interface.
      
      commit e3dcb46ab83d7071f611d9b5008ba6bc16c9f951
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Sun Jan 26 18:41:12 2014 -0800
      
          Fixed docs on StreamingContext.getOrCreate.
      
      commit 6c29524639463f11eec721e4d17a9d7159f2944b
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Thu Jan 23 18:49:39 2014 -0800
      
          Added example and figure for window operations, and links to Kafka and Flume API docs.
      
      commit f06b964a51bb3b21cde2ff8bdea7d9785f6ce3a9
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Wed Jan 22 22:49:12 2014 -0800
      
          Fixed missing endhighlight tag in the MLlib guide.
      
      commit 036a7d46187ea3f2a0fb8349ef78f10d6c0b43a9
      Merge: eab351d a1cd1851
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Wed Jan 22 22:17:42 2014 -0800
      
          Merge remote-tracking branch 'apache/master' into docs-update
      
      commit eab351d05c0baef1d4b549e1581310087158d78d
      Author: Tathagata Das <tathagata.das1565@gmail.com>
      Date:   Wed Jan 22 22:17:15 2014 -0800
      
          Update Spark Streaming Programming Guide.
      79302096
  13. Jan 23, 2014
  14. Jan 21, 2014
  15. Jan 20, 2014
  16. Jan 18, 2014
  17. Jan 17, 2014
  18. Jan 15, 2014
  19. Jan 14, 2014
Loading