Javaを使ってApache SparkプログラムでHiveのメタストアを指定する方法は？

Question

私はHiveでSparkSQLを実行するためのJavaコードを書いています。私はプログラムに私のハイブのmetastoreの道を与えようとしていますが、まったく働いていません。
は、プログラムを参照してください：

String warehouseLocation = "file:${system:user.dir}/spark-warehouse"; 

SparkSession spark = SparkSession 
      .builder() 
      .appName("Java Spark Hive Example") 
      .master("local[*]") 
      .config("spark.sql.warehouse.dir", warehouseLocation) 
      .enableHiveSupport() 
      .getOrCreate(); 
try 
{ 
     spark.sql("select count(*) from health1 ").show(); 
} 
catch (Exception AnalysisException) 
{ 
    System.out.print("\nTable is not found\n"); 
} 

私metastore_dbは場所にあります。/home/aims/hadoop/hadoop/hive/var/lib/metastore_db 私はSparkSQLを使用してやろうとしています任意の操作はHIVEでのHadoopに反映されるべきであるとします。そのためには、metastore_dbをMavenプログラムに接続する必要があります。
どうすればいいですか？ configを使って私のhive-site.xmlパスをプログラムに与える方法はありますか？

Answer 1

以下のようにHive Metastore Serverを実行できます。

hive --service metastore & 

今、あなたは、私は日食を使用してそれを行うことができますどのようにhive.metastore.uris

SparkSession spark = SparkSession 
    .builder() 
    .appName("Java Spark Hive Example") 
    .master("local[*]") 
    .config("hive.metastore.uris", "thrift://localhost:9083") 
    .enableHiveSupport() 
    .getOrCreate(); 

spark.sql("select count(*) from health1").show(); 

Answer 2

core-site.xmlとhive-site.xmlをresourcesフォルダに配置すると、Sparkはこれらのファイルを自動的に検索し、Hive用のメタストアを初期化します。また、Hiveメタストアに関する情報を表示するには、ログレベルをINFOに設定します。