我们能从一个spark会话连接到bigtable和hive吗?

bvuwiixz  于 2021-06-24  发布在  Hive
关注(0)|答案(1)|浏览(304)

下面是我的例子https://github.com/googlecloudplatform/cloud-bigtable-examples/tree/master/scala/bigtable-shc 从使用spark的scala应用程序连接到bigtable。我们在地面军事系统中有一些数据,我们使用hive连接到这些数据。我们需要能够连接到hive并获取数据并将其写入bigtable。
我在hbase-site.xml文件中添加了bigtable的配置。我在启动spark会话时向配置中添加了配置单元属性。spark会话能否同时连接到两个不同的数据源?

jhdbpxl9

jhdbpxl91#

我可以连接到Hive和大table。我不得不使用下面的配置。

val spark = SparkSession
    .builder
    .appName(appName)
    .config("spark.sql.warehouse.dir","gs://<bucket-name>/user/hive/warehouse/")
    .enableHiveSupport()
    .getOrCreate

相关问题