我正在使用Spark1.6并尝试使用
线程"main“org.apache.spark.sql.AnalysisException中的异常:未定义函数collect_list；at org.apache.spark.sql.catalyst.analysis.SimpleFunctionRegistry
浏览 2提问于2016-02-10得票数 5
回答已采纳
$$anonfun$4.apply(HiveContext.scala:235) at org.apache.spark.sql.hive.HiveContext.x$3(HiveContext.scalaat org.apac
浏览 3提问于2015-03-24得票数 2
我正在尝试比较spark sql和hive上下文，我可以知道有什么不同吗? hivecontext sql使用hive查询，而spark sql使用spark查询吗？下面是我的代码：sqlContext = HiveContext(sc)
sqlContext.sql('select * from table')
浏览 11提问于2018-08-21得票数 0
(HiveContext.scala:231) at org.apache.spark.sql.hive.HiveContext.x$3(HiveContext.scala:229) at org.apache.spark.sql.hive.HiveContext.hiveconf$lzycompute(HiveContext.scala:229) at org.apache.spark.sql.h
浏览 2提问于2015-12-22得票数 0
回答已采纳
2回答
我正试图在火花壳中执行这段代码：sqlContext.sql("show(HiveContext.scala:305)，org.apache.spark.sql.hive.HiveContext.runSqlHive(HiveContext.scala:272)，org.apache.spa
浏览 3提问于2015-01-07得票数 0
回答已采纳
1回答
现在我安装了spark，我正在对hive表进行一些查询，就像这样(在scala中)：result = hiveContext.sql("SELECT * FROM USERS");你知道如何配置spark来显示查询的执行时间吗？
浏览 2提问于2016-04-04得票数 2
1回答
我在ApacheSpark1.3中使用HiveContext，因为我需要它更好的查询支持(vs1.3的SQLContext)。 at org.apache.spark.sql.hive.HiveContext$QueryExecution.<init>(HiveContext.scala:385)
at org.apache.spark.s
浏览 3提问于2015-10-14得票数 2
1回答
我有以下scala代码来从Spark中拉取数据： import org.apache.spark.sql.types{StringType, StructType, TimestampType}
import org.apache.spark.sql." %% "spark-sql" %
浏览 65提问于2019-04-11得票数 0
回答已采纳
我不能从文档中确定当使用Spark中的HiveContext创建Hive表时，它是使用Spark引擎还是标准Hive mapreduce作业来执行任务？val sc = new SparkContext() CREATE TABLE db.new_table
浏览 0提问于2018-07-13得票数 0
2回答
$$anonfun$4.apply(HiveContext.scala:235) at org.apache.spark.sql.hive.HiveContext.x$3(HiveContext.scalaat org.apac
浏览 3提问于2015-02-02得票数 1
回答已采纳
3回答
但是我需要HiveContext，因为我使用的是一个函数collect_list，它不是SparkContext支持的，而是由HiveContext支持的。因为HiveContext是SparkContext的超类，所以它应该能工作，但它不是。
如何使用Spark 在Scala中初始化HiveContext
浏览 4提问于2016-07-04得票数 1
回答已采纳
当我尝试在齐柏林飞艇中手动加载hiveContext时：import org.apache.spark.sql.hive.HiveContext(HiveContext.scala:327)
at org.apache.spark.sql.hive.HiveContext.metadataHive(HiveContext
浏览 0提问于2017-08-02得票数 3
2回答
16/03/23 05:52:43 ERROR ApplicationMaster: User class threw exception:org.apache.spark.sql.AnalysisExceptionNote that, using window functions currently requires a HiveContext;
org.apache.spark.sql.AnalysisExceptionNote that, using window functio
浏览 1提问于2016-03-23得票数 3
回答已采纳
val query = """SELECT *, ROW_NUMBER() OVER (ORDER BY employee_id) row_number FROM d_f"""但是接下来的问题。
浏览 1提问于2015-08-03得票数 10
根据的说法，collect_set和collect_list函数应该在Spark SQL中可用。但是，我不能让它工作。我正在使用运行Spark 1.6.0。我正尝试在Scala中做到这一点： .agg(collect_set("column2")) 并在运行时收到以下错误：
Exception in threa
浏览 7提问于2016-02-21得票数 16
回答已采纳
我使用的是CDH5.4.2的火花(独立的)
org.apache.spark.sql.hive.HiveContext@6c6f3a15 scala> hiveContext =新的org.apache.spark.sql.hive.HiveContext(sc)；hiveCo
浏览 8提问于2016-07-26得票数 0
:554) at org.apache.spark.sql.hive.HiveContext(HiveContext.scala:539)
at org.apache.spark.sql.hive.HiveContext.metad
浏览 2提问于2017-01-05得票数 2
回答已采纳
这些类型的表不会实现自身，因此当通过SQL删除该表或从Databricks tables UI中删除该表时，不会丢失数据。
浏览 2提问于2016-04-29得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
