scala-код spark в scala ide не показывает запуск приложения scala

Question

Я разработчик Scala, но столкнулся с какой-то странной проблемой.когда я пытался выполнить код Scala с помощью метода main, он не показывал мне возможность запуска в качестве приложения Scala.

Я был совершенно не в курсе, потому что обычно это происходит, когда нет метода main, но возникает проблемаосновной метод также там.

код, как показано ниже.

package org.apache.spark.examples.sql

import org.apache.spark.sql.{Encoder, Encoders, SparkSession}
import org.apache.spark.sql.expressions.Aggregator

// scalastyle:off println
object SimpleTypedAggregator {

  def main(args: Array[String]): Unit = {
    val spark = SparkSession
      .builder
      .master("local[*]")
      .appName("common typed aggregator implementations")
      .getOrCreate()
      spark.sparkContext.setLogLevel("ERROR")

    import spark.implicits._
    val ds = spark.range(20).select(('id % 3).as("key"), 'id).as[(Long, Long)]
    println("input data:")
    ds.show()

Answer 1

Объявление пакета, которое я делал, было неверным. Удивлен !!!! Eclipse не показывает неправильный пакет.

Но это дает проблему, о которой я упоминал выше.

В любом случае это поможет всем, если у них возникнет такая же проблема, как у меня. И им не нужно тратить время, как я, чтобы найти глупость.

Спасибо всем за то, что вы сделали, чтобы решить эту проблему. :)

Answer 2

Вы используете IntelliJ IDEA?Добавьте поддержку FrameWork .., затем установите флажок Scala