Skip to content

GitLab

Explore

Sign in

Primary navigation

Project

S

spark
- Activity
- Members
- Labels
- Issues
- Issue boards
- Milestones
- Wiki
- Releases
- Model registry
- Environments
- Incidents

Snippets Groups Projects

11e6534d

Commit 11e6534d authored 11 years ago by Tathagata Das

Downloads
- Patches
- Plain Diff

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

parent c06a307c

No related branches found

No related tags found

No related merge requests found

Changes 9

Hide whitespace changes

Inline Side-by-side

Showing

examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java 1 addition, 2 deletions

.../org/apache/spark/streaming/examples/JavaQueueStream.java
examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala 1 addition, 1 deletion

.../org/apache/spark/streaming/examples/ActorWordCount.scala
streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 12 additions, 5 deletions

...n/scala/org/apache/spark/streaming/StreamingContext.scala
streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStream.scala 6 additions, 16 deletions

...ala/org/apache/spark/streaming/api/java/JavaDStream.scala
streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala 4 additions, 0 deletions

...org/apache/spark/streaming/api/java/JavaPairDStream.scala
streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 27 additions, 28 deletions

...pache/spark/streaming/api/java/JavaStreamingContext.scala
streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala 3 additions, 3 deletions

...in/scala/org/apache/spark/streaming/dstream/DStream.scala
streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala 4 additions, 7 deletions

...apache/spark/streaming/dstream/PairDStreamFunctions.scala
streaming/src/main/scala/org/apache/spark/streaming/receivers/ActorReceiver.scala 21 additions, 14 deletions

.../org/apache/spark/streaming/receivers/ActorReceiver.scala

with 79 additions and 76 deletions

Loading

0% Loading or .

You are about to add 0 people to the discussion. Proceed with caution.

Finish editing this message first!

Please register or sign in to comment