Почему это ошибка компилятора, но она запускается в Spark-shell? - PullRequest
0 голосов
/ 03 октября 2019

Команда

println(  sql( "SELECT date_format(now(),'yyyyMMdd')" ).as[String].first )

отлично работает на Spark-shell (используя Spark v2.2), но строка

 val databaseNow = spark.sql( "SELECT date_format(now(),'yyyyMMdd')" ).as[String].first

не компилируется. Я пробую много вариантов импорта и проблема сохраняется. Я пробую варианты синтаксиса как df.first.toString, но это не решение ([x] не x).

1 Ответ

2 голосов
/ 03 октября 2019

Просто включите включенные кодировщики, такие как:

val spark: SparkSession =
  SparkSession
    .builder()
    .appName("test")
    .getOrCreate()

import spark.implicits._

val databaseNow = spark.sql( "SELECT date_format(now(),'yyyyMMdd')" ).as[String].first
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...