Color", "Shape", "Range","Size").map(Tuple1.apply).toDF("color")
我想再写一个WHEN条件，在上面where size > 10和Shap
浏览 13提问于2017-02-21得票数 5
1回答
我正面临一个问题，在Hive中有一个过滤条件，其中包含了CASE WHEN子句。以下是语句和错误：select day where case when length(day) <> '19' then substr(day,1,19) else day end
org.apache.spark.sql.AnalysisException:过滤表达式‘大小写时(非
浏览 0提问于2019-01-06得票数 0
我知道如何使用Scala在SPARK中实现一个简单的CASE-WHEN-然后子句。我使用的是1.6.2版本。但是，我需要在CASE- the子句中指定多个列的条件。如何使用Scala在星星之火中实现这一目标？select sd.standardizationId,
case when sd.numberOfShares =
浏览 8提问于2016-11-10得票数 2
回答已采纳
4回答
因此，据我所知，Apache没有模仿update SQL命令的功能。例如，我可以在给定条件的列中更改单个值。唯一的解决办法是使用以下命令(在Stackoverflow中)：withColumn(columnName, where('condition', value));
但是，条件应该是column类型，这意味着我必须使用Apache内置的列过滤函数(equalTo、isin、lt、gt等等)。
浏览 5提问于2017-08-08得票数 6
回答已采纳
4回答
在我的MS SQL Server数据库中，我根据一列中的各种不同代码来提取事务数据。更有效的做法是：我们有如此多的查询每秒
浏览 5提问于2009-06-16得票数 9
回答已采纳
3回答
是否可以在case子句中为when语句写入子查询CASE WHEN (SELECT colA FROM tab2 WHERE tab2.colA = tab1.colA) THEN '1' WHEN colC = '1' THEN ( select colR FROM...),
WH
浏览 0提问于2010-07-02得票数 6
回答已采纳
在scala中，我已经与此进行了一段时间的斗争，我似乎无法找到一个明确的解决方案。val joined = Companies.as("Companies") .withColumn
浏览 1提问于2019-11-11得票数 0
回答已采纳
3回答
def stringToBinary(stringValue: String): Int = { case "yes" => return1 case "present" => return 1
浏览 5提问于2017-07-19得票数 3
回答已采纳
我的目标是将列添加到现有的DataFrame中，并使用DF中现有列的转换填充这些列。<console>:33: error: type mismatch;
found : org.apache.spark.sql.ColumnName&qu
浏览 1提问于2018-04-03得票数 2
回答已采纳
-+|b |1 |2 |3 |1 |+---+---+---+---+---+ ("c", 0, 1, 0)))
.toDF("nm", "ca",
浏览 5提问于2017-10-08得票数 0
回答已采纳
3回答
如何命名聚合列？
、、
我在Scala中使用Spark，并且我的聚合列是匿名的。有没有一种方便的方法来重命名数据集中的多个列？我考虑过使用as来强加一个模式，但是键列是一个结构(由于groupBy操作)，并且我不知道如何在其中定义一个包含StructType的case class。])org.apache.spark.sql.types.StructType <and>
(fields: java.util.List[org.apac
浏览 0提问于2016-07-26得票数 18
回答已采纳
2回答
我可以在UPDATE子句中使用多个WHEN条件来更新单个列吗？下面的查询是否正确？UPDATE TABLE WHEN id IN (2, 3, 4) THEN 1 WHEN id IN(9, 7) THEN 6
WHERE
浏览 1提问于2010-10-07得票数 2
spark.sql("select case when type = 'KEY' then case when length(key)>0 and key not rlike '^[0-9]+@.*'then '' else case when key rlike '^[0-9]+@.*' then regexp_extract(key, '^[^@]+'
浏览 3提问于2021-09-01得票数 1
回答已采纳
我希望在Order By子句中使用Case，但希望对多个列的结果集进行排序。当我使用以下语法时，我得到语法错误。Select * From MyTable CASE END Desc
浏览 2提问于2011-12-27得票数 2
回答已采纳
3回答
运行Spark 1.6 WHEN evt_acct_app_id > '0' THEN '001' END不断得到这个错误:得到这个未知的异常：
org
浏览 0提问于2017-04-09得票数 0
我对Spark非常陌生，每次我需要从一个数据模型传递到另一个数据模型(特别是从RDDs到数据集和Dataframes)时，我都会陷入困境。有人能解释一下我是怎么做的吗？举个例子，现在我有了一个RDD[org.apache.spark.ml.linalg.Vector]，我需要将它传递给我的机器学习算法，例如一个KMeans (火花DataSet MLlib)。因此，我需要将其转换为包含向量类型行的单一列“功能”的Dataset。我该怎么做？
浏览 1提问于2018-06-04得票数 2
回答已采纳
3回答
给定表1的字符串类型为一列"x“。我希望创建表2，其中列"y“是"x”中给出的日期字符串的整数表示形式。root |-- y: integer (nullable = true)val extractDateAsInt = udf[Int, String]
浏览 4提问于2015-09-02得票数 33
回答已采纳
2回答
我有一个复杂的查询，它跨多个列执行多个匹配，然后根据相关性进行排序。然后返回一个空的结果集。SELECT *, CASE WHEN companyName = 'gfdgfs' THEN 2 ELSE 0 END
+ CASE WHEN companyName LIKE '%gfdgfs%'THEN 1 ELSE 0 END
浏览 1提问于2015-12-24得票数 4
回答已采纳
4回答
我正在试图在IN子句中写一个case语句。 WHERE tbl.Channel IN (select <e
浏览 0提问于2014-11-04得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
