您的位置:首页 > 其它

spark 2.0.0与HIVE结合的测试

2016-09-12 20:30 232 查看
spark 2.0.0中,对hive的结合开发是否进行了改变,于是进行了如下测试。

最大的变化就是没有什么HiveContext了。直接就是一个SparkSession。

val spark = SparkSession

      .builder()

      .master("local[*]")

      .appName("Spark Hive Example")

      .config("spark.sql.warehouse.dir", warehouseLocation)

      .enableHiveSupport()

      .getOrCreate()

其中有个命令就是:enableHiveSupport,提供了对HIVE的支持。非常方便。

于是进行测试,剩下的套路和以前都是一样的。顺利通过。

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  spark 2.0 hive 测试