Xin Ren created SPARK-17628:

             Summary: Name of "object StreamingExamples" should be more 
                 Key: SPARK-17628
             Project: Spark
          Issue Type: Bug
          Components: Examples, Streaming
    Affects Versions: 2.0.0
            Reporter: Xin Ren
            Priority: Minor

`object StreamingExamples` is more of a utility object, and the name is too 
general and I thought it's an actual streaming example at the very beginning.

/** Utility functions for Spark Streaming examples. */
object StreamingExamples extends Logging {

  /** Set reasonable logging levels for streaming if the user has not 
configured log4j. */
  def setStreamingLogLevels() {
    val log4jInitialized = Logger.getRootLogger.getAllAppenders.hasMoreElements
    if (!log4jInitialized) {
      // We first log something to initialize Spark's default logging, then we 
override the
      // logging level.
      logInfo("Setting log level to [WARN] for streaming example." +
        " To override add a custom to the classpath.")

This message was sent by Atlassian JIRA

To unsubscribe, e-mail:
For additional commands, e-mail:

Reply via email to