hivecontext

    0熱度

    1回答

    我想使用pyspark sql在Hive Table(表名:'sample')上構建查詢。 以下是簡單pyspark代碼我在pyspark殼 From pyspark.sql import HiveContext sqlContext = HiveContext(sc) sqlContext.sql("SELECT * FROM sample").collect() 下面編譯是我遇到的錯誤

    1熱度

    1回答

    在bluemix火花我想用HiveContext HqlContext = HiveContext(sc) //some code df = HqlContext.read.parquet("swift://notebook.spark/file.parquet") Py4JJavaError: An error occurred while calling o45.parquet. :

    0熱度

    1回答

    我已經從本地系統連接到Hive(在集羣中),並在scala IDE中使用spark,最後放置了我的配置單元站點。 xml正確地在Spark/conf文件夾和類路徑中,並且能夠連接到Metastore,但無法訪問配置單元表。 如何更改用戶的HiveContext 15/12/22 10時28分42秒INFO ParseDriver:解析命令:show表 15/12/22 10點28分43秒INFO

    0熱度

    1回答

    案後,查看蜂房表的數據: 我有一個表HiveTest這是一個ORC表和交易設置真,火花shell加載和查看數據 var rdd= objHiveContext.sql("select * from HiveTest") rdd.show() --- 能夠查看數據 現在我去了我的蜂房殼或ambari更新的表,例如現在,當 hive> update HiveTest set name='test