You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/19 19:30:04 UTC

[2/2] git commit: Merge pull request #458 from tdas/docs-update

Merge pull request #458 from tdas/docs-update

Updated java API docs for streaming, along with very minor changes in the code examples.

Docs updated for:
Scala: StreamingContext, DStream, PairDStreamFunctions
Java: JavaStreamingContext, JavaDStream, JavaPairDStream

Example updated:
JavaQueueStream: Not use deprecated method
ActorWordCount: Use the public interface the right way.


Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/256a3553
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/256a3553
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/256a3553

Branch: refs/heads/master
Commit: 256a3553c447db0865ea8807a8fdbccb66a97b28
Parents: fe8a354 11e6534
Author: Patrick Wendell <pw...@gmail.com>
Authored: Sun Jan 19 10:29:54 2014 -0800
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Sun Jan 19 10:29:54 2014 -0800

----------------------------------------------------------------------
 .../streaming/examples/JavaQueueStream.java     |  3 +-
 .../streaming/examples/ActorWordCount.scala     |  2 +-
 .../spark/streaming/StreamingContext.scala      | 17 ++++--
 .../spark/streaming/api/java/JavaDStream.scala  | 22 +++-----
 .../streaming/api/java/JavaPairDStream.scala    |  4 ++
 .../api/java/JavaStreamingContext.scala         | 55 ++++++++++----------
 .../spark/streaming/dstream/DStream.scala       |  6 +--
 .../dstream/PairDStreamFunctions.scala          | 11 ++--
 .../streaming/receivers/ActorReceiver.scala     | 35 ++++++++-----
 9 files changed, 79 insertions(+), 76 deletions(-)
----------------------------------------------------------------------