-
- Downloads
Merge pull request #363 from pwendell/streaming-logs
Set default logging to WARN for Spark streaming examples. This programatically sets the log level to WARN by default for streaming tests. If the user has already specified a log4j.properties file, the user's file will take precedence over this default.
No related branches found
No related tags found
Showing
- examples/src/main/java/org/apache/spark/streaming/examples/JavaFlumeEventCount.java 2 additions, 0 deletions.../apache/spark/streaming/examples/JavaFlumeEventCount.java
- examples/src/main/java/org/apache/spark/streaming/examples/JavaKafkaWordCount.java 2 additions, 0 deletions...g/apache/spark/streaming/examples/JavaKafkaWordCount.java
- examples/src/main/java/org/apache/spark/streaming/examples/JavaNetworkWordCount.java 3 additions, 1 deletion...apache/spark/streaming/examples/JavaNetworkWordCount.java
- examples/src/main/java/org/apache/spark/streaming/examples/JavaQueueStream.java 2 additions, 0 deletions.../org/apache/spark/streaming/examples/JavaQueueStream.java
- examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala 5 additions, 7 deletions.../org/apache/spark/streaming/examples/ActorWordCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/FlumeEventCount.scala 3 additions, 1 deletion...org/apache/spark/streaming/examples/FlumeEventCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/HdfsWordCount.scala 2 additions, 1 deletion...a/org/apache/spark/streaming/examples/HdfsWordCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala 3 additions, 2 deletions.../org/apache/spark/streaming/examples/KafkaWordCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/MQTTWordCount.scala 3 additions, 5 deletions...a/org/apache/spark/streaming/examples/MQTTWordCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/NetworkWordCount.scala 2 additions, 0 deletions...rg/apache/spark/streaming/examples/NetworkWordCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/QueueStream.scala 5 additions, 3 deletions...ala/org/apache/spark/streaming/examples/QueueStream.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/RawNetworkGrep.scala 3 additions, 2 deletions.../org/apache/spark/streaming/examples/RawNetworkGrep.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/StatefulNetworkWordCount.scala 2 additions, 0 deletions...e/spark/streaming/examples/StatefulNetworkWordCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/StreamingExamples.scala 21 additions, 0 deletions...g/apache/spark/streaming/examples/StreamingExamples.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterAlgebirdCMS.scala 6 additions, 4 deletions.../apache/spark/streaming/examples/TwitterAlgebirdCMS.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterAlgebirdHLL.scala 6 additions, 3 deletions.../apache/spark/streaming/examples/TwitterAlgebirdHLL.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterPopularTags.scala 2 additions, 0 deletions.../apache/spark/streaming/examples/TwitterPopularTags.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/ZeroMQWordCount.scala 1 addition, 0 deletions...org/apache/spark/streaming/examples/ZeroMQWordCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/clickstream/PageViewStream.scala 3 additions, 1 deletion...spark/streaming/examples/clickstream/PageViewStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStream.scala 1 addition, 1 deletion...g/src/main/scala/org/apache/spark/streaming/DStream.scala
Loading
Please register or sign in to comment