----------+-------------------+----------+---------+--------------------+dayofweek count2 -> 343 (Tuesday)如有任何帮助，非常感谢！
浏览 1提问于2016-12-27得票数 1
回答已采纳
1回答
我在配置单元0.13中有键/值表(键和值都是avro类型)。当我尝试在Spark SQL 1.1中运行查询时，我得到了以下错误(在配置单元中它是有效的)...
key struct<constructtypespark-sql> select key.constructtype, count(*) from construct
浏览 4提问于2014-09-16得票数 1
2回答
在选择我正在使用的多个元素代码的sql spark中，是否有按表分组的方法：df.createOrReplaceTempView("GETBYID")val sqlDF = spark.sql(
"SELECT count(customerId) FROM GETBYID group by cust
浏览 7提问于2017-01-02得票数 2
回答已采纳
我有一个Dataframe，从它创建一个临时视图以运行sql查询。经过几个sql查询之后，我想将sql查询的输出转换为一个新的Dataframe。因此，问题是:将sql查询输出转换为Dataframe的正确方法是什么？下面是我到目前为止掌握的代码：//read data from Azure blobvar df = spark.read.parquet(some_path)
SELECT
d
浏览 0提问于2022-07-20得票数 3
回答已采纳
edf.select("x").distinct.show()显示edf DataFrame的x列中的不同值。
是否有一种有效的方法也可以显示这些不同值在数据帧中发生的次数？(计算每个不同的值)
浏览 15提问于2016-06-21得票数 38
回答已采纳
2回答
我需要找到单词(而不是子字符串)，如果它旁边有标点符号，我也需要计算它，例如： id group text2 c no you can8 c no&a 2c 0
d 1 我试过这个： sql_q = spark.sql("select group,
浏览 23提问于2020-06-20得票数 1
df.select("state").distinct().count() spark.sql("SELECT distri
浏览 0提问于2018-10-31得票数 2
| Patients250 | 3725 | 1 我尝试使用如下查询： select distinct drug_ndc as NDC, countpatient_id as Patientsgroup by 1
order by 1 但我一直收到错误。我尝试过使用和不使用别名，但都无济于事。
浏览 43提问于2019-09-13得票数 0
回答已采纳
我想用Java从Google BigQuery中的一个表中读取数据。我如何在Java中做到这一点，我需要什么依赖项，以及最终的Datatype是什么？
浏览 2提问于2019-11-02得票数 1
回答已采纳
我试图在spark (scala)中创建一个表，然后从两个现有的数据帧中插入值，但我得到了以下经验： Exception in thread "main" org.apache.spark.sql.AnalysisException.builder() .config("spark.sql.warehouse.dir"
浏览 9提问于2019-03-03得票数 1
3回答
如何使用group By子句将列添加到具有行数的DF中？()) type mismatch; (which expands to) org.apache.spark.sql.Dataset[org.apache.spark.sql.Row]然后
浏览 46提问于2019-11-25得票数 2
回答已采纳
as b group by b.pidimport org.apache.spark.sql.(data), schme) df.createOrReplaceTempView("tab_tmp")
spark.sql("select storeid,orderid,combox_pid,pid,count
浏览 0提问于2020-02-10得票数 0
我有以下涉及UNION的Spark (2.4.0)查询。现在，我试图限制优化器从其查询的物理计划中排除特定规则，以便Spark只为这两个查询创建一个Exchange。SET "spark.sql.optimizer.excludeRules" = org.apache.spark.sql.catalyst.optimizer.PushDownPredicate;select a, count(*) as cnt<e
浏览 1提问于2020-07-20得票数 0
回答已采纳
我使用spark提供的sql方法运行以下sql语句。val maxDateDF = spark.sql("SELECT name, max(birthDate) maxDate FROM people group by name")
import org.apache.spark.sql</e
浏览 22提问于2021-03-10得票数 0
回答已采纳
如何以编程方式从星火sql中的日期中减去天数？val date = "2019-10-01"
select id, my_tablegroup</e
浏览 4提问于2020-01-20得票数 0
回答已采纳
我有一个简单的DataFrame，它的模式是：process_time: timestamp .groupBy( ).count()
如何使用Spark SQL的语法将此代码移植到SQL？
浏览 57提问于2018-07-24得票数 -1
回答已采纳
1回答
我很少看到关于缓存sql表的问题，但它们似乎都没有完全回答我的问题。import org.apache.spark.sql._
val df2 =
浏览 3提问于2017-11-17得票数 2
回答已采纳
假设我试图对一些由对(a和b值)组成的样本数据做一些统计。有些对存在多次，另一些则不存在。(''' COUNT(*) as countGROUP BY a, b输出：spark.sql('''
SELECT a,
浏览 1提问于2018-11-27得票数 2
回答已采纳
我见过来自数据仓库和SQL背景的人正在使用SQL实现聚合和其他转换逻辑(where spark is the sparkSession object) 使用spark.sql()：
CITY_CENSUS.createOrReplaceTempView("CITY
浏览 1提问于2019-05-05得票数 0
1回答
我是斯派克和斯卡拉的新手。((df.groupBy("id","start_time_formated","l2_c","l3_c",
"l4_c","l2_s","l3_s","l4_s"
浏览 3提问于2016-04-19得票数 0
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号