2017-11-08 14 views
0

私はSparksessionをハイブテーブルで使用しようとしました。私は次のコードを使用していました。 val spark = SparkSession.builder()。appName( "spark")。master( "local")。enableHiveSupport()。getOrCreate() spark.sql( "select * from data") .show()spark session with hivecontext

表が見つかりませんが、表はハイブに存在します。これで私を助けてください。

+0

はあなたが火花confの中でハイブ-site.xmlのを追加しましたか? –

答えて

0

こんにちは、あなたは次のように、倉庫のパスを提供する必要があります。詳細については

// warehouseLocation points to the default location for managed databases and tables 
val warehouseLocation = new File("spark-warehouse").getAbsolutePath 

val spark = SparkSession 
    .builder() 
    .appName("Spark Hive Example") 
    .config("spark.sql.warehouse.dir", warehouseLocation) 
    .enableHiveSupport() 
    .getOrCreate() 

、あなたはここで見ることができます:Hive Tables with Spark