в Apache искре, я не могу использовать фразы c в Scala

Question

scala> val streamingDataFrame = spark.readStream.
     schema(staticSchema).
     option("maxFilesPerTrigger", 1).
     format("csv").
     option("header", "true").
     load("/home/server/spark/data/csv/example/*.csv")

: 24: ошибка: не найдена: значение staticSchema схема (staticSchema).

введите описание изображения здесь ^

Answer 1

:24: error: not found: value staticSchema schema(staticSchema).

вышеприведенная ошибка возникает, потому что вы не объявили staticSchema, сначала объявите его и используйте.

И проблема, описанная в Image, отличается, что означает, что "error: not found: value staticDataFrame"

выдает ошибку, потому что вы не использовали val ключевое слово перед staticDataFrame.