-
- Downloads
Fixed streaming examples docs to use run-example instead of spark-submit
Pretty self-explanatory Author: Tathagata Das <tathagata.das1565@gmail.com> Closes #722 from tdas/example-fix and squashes the following commits: 7839979 [Tathagata Das] Minor changes. 0673441 [Tathagata Das] Fixed java docs of java streaming example e687123 [Tathagata Das] Fixed scala style errors. 9b8d112 [Tathagata Das] Fixed streaming examples docs to use run-example instead of spark-submit.
Showing
- examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java 6 additions, 7 deletions...g/apache/spark/examples/streaming/JavaCustomReceiver.java
- examples/src/main/java/org/apache/spark/examples/streaming/JavaFlumeEventCount.java 4 additions, 2 deletions.../apache/spark/examples/streaming/JavaFlumeEventCount.java
- examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java 3 additions, 3 deletions...g/apache/spark/examples/streaming/JavaKafkaWordCount.java
- examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java 8 additions, 5 deletions...apache/spark/examples/streaming/JavaNetworkWordCount.java
- examples/src/main/scala/org/apache/spark/examples/streaming/ActorWordCount.scala 2 additions, 4 deletions.../org/apache/spark/examples/streaming/ActorWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/CustomReceiver.scala 7 additions, 12 deletions.../org/apache/spark/examples/streaming/CustomReceiver.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/FlumeEventCount.scala 6 additions, 3 deletions...org/apache/spark/examples/streaming/FlumeEventCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/HdfsWordCount.scala 3 additions, 2 deletions...a/org/apache/spark/examples/streaming/HdfsWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala 3 additions, 3 deletions.../org/apache/spark/examples/streaming/KafkaWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/MQTTWordCount.scala 5 additions, 5 deletions...a/org/apache/spark/examples/streaming/MQTTWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/NetworkWordCount.scala 8 additions, 6 deletions...rg/apache/spark/examples/streaming/NetworkWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/RecoverableNetworkWordCount.scala 3 additions, 4 deletions...park/examples/streaming/RecoverableNetworkWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/StatefulNetworkWordCount.scala 3 additions, 3 deletions...e/spark/examples/streaming/StatefulNetworkWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/TwitterPopularTags.scala 19 additions, 3 deletions.../apache/spark/examples/streaming/TwitterPopularTags.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/ZeroMQWordCount.scala 4 additions, 4 deletions...org/apache/spark/examples/streaming/ZeroMQWordCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewGenerator.scala 6 additions, 4 deletions...rk/examples/streaming/clickstream/PageViewGenerator.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewStream.scala 5 additions, 2 deletions...spark/examples/streaming/clickstream/PageViewStream.scala
- external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala 35 additions, 23 deletions.../apache/spark/streaming/twitter/TwitterInputDStream.scala
Loading
Please register or sign in to comment