Standard verwenden SqlContext

Question

Ich habe den folgenden Code, der Funke sagen sollte die Standard-Datenbankschema zu verwenden:

sqlContext.sql(s"use default") 

Wenn ich diesen Code laufen lasse, erhalte ich die folgende Fehlermeldung auf der oberen Zeile:

[1.1] failure: ``with'' expected but identifier use found 

use default 
^ 
java.lang.RuntimeException: [1.1] failure: ``with'' expected but identifier use found 

use default 
^ 

Was bedeutet das? Warum erwartet es with?

Answer 1

Datenbank-Befehle sind nur sinnvoll für o.a.s.sql.hive.HiveContex (Spark-< 2.0.0) oder o.a.s.sql.SparkSession mit Hive Unterstützung (Spark-2.0.0+) initialisiert, aber es sieht aus wie Ihr Standard o.a.s.sql.SQLContext verwendet, die Datenbanken nicht unterstützt.

Mit anderen Worten:

• Funken Binärdateien mit Hive Unterstützung gebaut.
• Initialisieren SQLContext mit HiveContext.