我想获取数据帧中每个id的第一行，但是它返回一个错误：代码是：
WindowSpec window = Window.pa
浏览 18提问于2016-09-09得票数 1
1回答
created_at"))))
当运行代码时，我得到了这个错误：现在我得到了错误：
Exception in thread "main" org.apache
浏览 65提问于2019-04-11得票数 0
回答已采纳
1回答
窗口函数不适用于Pyspark。
、、、、
我有一个数据框架，我想将数据汇总到7天，并对其中的一些函数进行一些聚合。|2013-04-16| 1| 9| 1| 1| 1| 1| 1| 250.0|0.0| .rangeBetween(-(days(7)), 0)
现在，我想执行一些聚合，即应用一些windows函数</em
浏览 2提问于2016-03-15得票数 0
回答已采纳
val query = """SELECT *, ROW_NUMBER() OVER (ORDER BY employee_id) row_number FROM d_f"""
val result = Spark.getSqlContext
浏览 1提问于2015-08-03得票数 10
我们正在尝试使用hivecontext(1.6.0)运行配置单元查询，但获得了“AnalysisException”。81368), 'yyyyMMdd'), '000000'), 'yyyyMMddHHmmss'), 81368) ) endCaused by: org.apache.spark.sql.AnalysisExceptionAdd to group by or wrap in first() (or fi
浏览 6提问于2017-01-26得票数 1
回答已采纳
1回答
将HiveQL转换为Scala
、、、、
我想把带有窗口功能的HiveQL查询转换成.但我经常收到同样的例外。原始查询(工作正常)： SELECT category, product,result.withColumn("seqNum", w).where(col("seqNum") <= 10).drop("
浏览 0提问于2019-01-17得票数 1
回答已采纳
我正在使用SparkSQL SELECT artist, count(distinct(song))
FROM user_log_table：org.apache.spark.sql.AnalysisException:分组表达式序列为空，“user_log_table.artist”不是聚合函数。如果您不关心得到哪个值，则在窗口函数中将‘( user_log_table.song)计数为“coun
浏览 2提问于2021-06-08得票数 0
我知道sqlContext不支持窗口函数，但是HiveContext支持。hiveContext = HiveContext(sc)visit_number = hiveContext.sql("select store_numberstore_number order by visit_date) visit_number "
浏览 3提问于2016-04-07得票数 2
软件包com.databricks:spark csv_2.11:1.2.0.使用SQLContext 1.导入org.apache.spark.sql.SQLContext 2. val sqlctx$$anonfun$2.apply(FunctionRegistry.scala:65)：未定义函数percentile_approx；在org.apache.spark.sql.catalyst.analysis.SimpleFunctionRegistry$$anonfun$2.apply(FunctionRegistr
浏览 15提问于2018-01-10得票数 0
我遇到了一个spark.sql错误，我无法用堆栈溢出的答案来解决这个错误，重点是我尝试了"first_value，collected_list“，他们没有解决错误，如果我用这个列逻辑按数据分组将是错误的%spark03.sql date_key,where date_key >= 20220101 a
浏览 7提问于2022-03-29得票数 0
回答已采纳
3回答
| 2 2 | 2015-09-01 | 1这是我可以通过窗口功能实现的Window.partitionBy("id").orderBy("date")不幸的是，Spark1.4.1不支持常规数据格式的窗口功能：
org.apa
浏览 4提问于2015-09-04得票数 10
回答已采纳
这是我的密码：import org.apache.spark.sql.expressions._
val windowSpec诊断: User类抛出异常: org.apache.spark.sql.AnalysisException:分组表达式序列为空，“mytable.product_pk”不是聚合函数。在窗口函数中将'(max(mytable.stock)包装为_w0‘)，
浏览 2提问于2017-11-20得票数 1
回答已采纳
我一直用scala中的spark从本地系统连接到Hive (它在集群中)，最后将我的hive-site.xml正确地放置在Spark/conf文件夹和类路径中，并且能够连接到转移，但无法访问蜂窝表。如何更改HiveContext的用户
15/12/22 10:28:42 INFO ParseDriver:解析命令:显示表15/12/22 10:28:43 INFO ParseDriver: ParseDriver:解析完成15/
浏览 2提问于2015-12-22得票数 0
回答已采纳
2回答
在选择我正在使用的多个元素代码的sql spark中，是否有按表分组的方法：df.createOrReplaceTempView("GETBYID")val sqlDF = spark.sql(但当我尝试：
val sqlDF = <e
浏览 7提问于2017-01-02得票数 2
回答已采纳
1回答
我使用的代码是val training = sqlContext.createDataFrame(Seq(
(10)
浏览 3提问于2016-10-11得票数 2
回答已采纳
我需要使用窗口函数，该函数由2列进行解析，并在第3列和第4列上进行不同的计数。我可以算出任何问题，但使用不同的计数会抛出异常-
rg.apache.spark.sql.AnalysisException: Distinct window functions are not supported
浏览 2提问于2020-03-11得票数 4
回答已采纳
1回答
但我想从spark执行它。我已经创建了一个spark-sql-hive上下文，如下所示scala> val sqlHContext = new org.apache.spark.sql.hive.HiveContext(sc)
sqlHContext: org.apache.spark.sql.hive.HiveContext = org.apache.spark.sql.hive.HiveContext@71138de5COL_DATET
浏览 1提问于2015-05-20得票数 1
1回答
我无法配置Spark以使我能够访问中的Hive表(不使用JDBC，而是从Spark本地访问)hc = HiveContext(sc)
hc.sql('show tables')
浏览 0提问于2019-01-14得票数 0
我试过在星火数据框架中这样做：但我发现了一个错误：
线程“主”org.apache.spark.sql.AnalysisException中的异常:分组表达式序列为空，而'score‘不是聚合函数。在窗口函数中将“((score-min(score))”包装为“logged_score”，如果您不关心得到哪个值，
浏览 2提问于2018-01-04得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
