如何使用"when“语句填充Spark上的空值
在Spark中，可以使用"when"语句来填充空值。"when"语句是Spark SQL中的条件表达式，可以根据条件进行不同的操作。
下面是使用"when"语句填充Spark上的空值的步骤：
- 导入必要的Spark库和函数：
import org.apache.spark.sql.functions._- 使用"when"语句填充空值：
val filledDF = originalDF.withColumn("column_name", when(col("column_name").isNull, "填充值").otherwise(col("column_name")))其中，"column_name"是需要填充空值的列名，"填充值"是你希望填充的具体值。
- 如果需要填充多个列的空值，可以按照上述步骤对每个列进行填充。
- 如果需要填充的值是根据其他列的值进行计算得出的，可以在"when"语句中使用其他列的值进行计算。
下面是一个完整的示例代码：
import org.apache.spark.sql.functions._
val originalDF = spark.read.format("csv").option("header", "true").load("path_to_file.csv")
val filledDF = originalDF.withColumn("column_name", when(col("column_name").isNull, "填充值").otherwise(col("column_name")))
filledDF.show()在这个示例中，我们首先导入了必要的Spark库和函数。然后，使用"spark.read.format"方法加载了一个CSV文件，并将其保存到一个DataFrame中。接下来，使用"withColumn"方法和"when"语句对指定的列进行空值填充。最后，使用"show"方法展示填充后的DataFrame。
需要注意的是，以上示例中的代码是使用Scala语言编写的，如果你使用其他编程语言如Python，可以相应地调整代码。
推荐的腾讯云相关产品：腾讯云云服务器（CVM）、腾讯云云数据库MySQL、腾讯云云原生容器服务（TKE）等。你可以通过腾讯云官方网站获取更详细的产品介绍和相关文档。
腾讯云产品介绍链接地址：
相关·内容
输入数据
val ds = Seq((1,"play Framwork"),
(2,"Spark framework"),
(3,"spring framework")).toDF("id","subject")
预期数据
val ds = Seq((1,""),
(2,"Spark framework"),
(3,"spring framework")).toDF("id","subject")
这里，如果我的play
浏览 2提问于2018-07-02得票数 1
回答已采纳
有人能给我解释一下字符串和空值之间的比较行为吗？
DataFrame：
import pyspark.sql.functions as F
df = spark.createDataFrame([
["text_1,","text_1"],
["text_1,","text_2"],
["text_1,",None]
]).toDF("col1", "col2")
df1 = df.withColumn("equal", F.when(F.col("co
浏览 13提问于2021-02-23得票数 2
回答已采纳
1回答
当我试图用空值填充一个DataFrame来替换其中的其他值时，我得到了错误的Caused by: scala.MatchError: Null (of class scala.reflect.internal.Types$ClassNoArgsTypeRef)。我如何使用Scala Spark 2.1来做这件事？
浏览 28提问于2017-03-17得票数 0
回答已采纳
我有一个在多个列中有Nulls的PySpark数据帧。我正在尝试用相应列的最大数字+ 1填充空值。这个想法是，在为每个数字分类列创建“缺失”类别时，在尝试模拟SAS中的一个热编码过程时，返回并在一次热编码后将这些值标记为“无”。
例如，male中的“null”应为“3”。因此，公列的最大数目+1= 3。然后是4，其他列的最大数目是6。
示例数据：
+----------------+------+-----+-----+
| MS| male| rate|level|
+----------------+------+-----+-----+-
|
浏览 0提问于2019-08-22得票数 1
2回答
我想用过去的随机日期或空值来填充表中的一列。我想设置两个日期之间的随机日期，1920年1月1日和2018年12月1日，或空值。
我遇到了一些令人困惑的代码，它们可能是在特定时间段生成随机日期的解决方案，但它不能满足空值的要求。
INSERT INTO `FootballPlayers` VALUES (SELECT timestamp('2010-04-30') - INTERVAL FLOOR( RAND( ) * 366) DAY);
我希望表的列有类似这样的内容。
+----------------+
| Date of Death |
+---------------
浏览 2提问于2019-11-06得票数 0
我有一个tableA，它有一个名为funny VARCHAR(4)的列，它用'YES'和'NO'字符串填充。
我有一个也有funny TINYINT(1)列的tableB，它是空的。
假设两个表都有相应的id列，那么我可以从工作台运行的MySQL查询将从tableA获取所有内容并将其转换为tableB中正确的整数值
浏览 1提问于2015-12-11得票数 0
1回答
我在执行枢轴命令。我的行标签是日期字段。我的列是像NY、TX等位置。源数据中的一些值是空的，但是一旦它被旋转，我想用日期顺序“填充”这些空值。
也就是说，如果NY列的值为1/1/2010，而1/2/2010为null，则我希望将该值从1/1/2010填充到1/2/2010，以及以下任何其他空日期，直到另一个值已经存在为止。因此，基本上，我用相同的数据填充空空白，为每个列都有数据的关闭日期。
我目前拥有的枢轴查询的一个例子是：
SELECT ReadingDate, [NY],[TX],[WI]
FROM
(SELECT NAME As 'NodeName',
浏览 0提问于2015-10-22得票数 1
回答已采纳
1回答
在星火中，文字列在添加时是不可空的：
from pyspark.sql import SparkSession, functions as F
spark = SparkSession.builder.getOrCreate()
df = spark.createDataFrame([(1,)], ['c1'])
df = df.withColumn('c2', F.lit('a'))
df.printSchema()
# root
# |-- c1: long (nullable = true)
# |-- c2: string
浏览 3提问于2021-07-29得票数 4
回答已采纳
2回答
我正在尝试使用mongoose将来自mongoDB数据库的记录填充到数组中。当我试图填满记录的时候。它在函数外部显示了一个空数组，即使我在函数外部声明了。下面是代码。
var saveMessageToVariable = function(){
var records = [];
var spark_ids = [];
var obj = new Object();
Message.find().distinct("spark_id").exec(function(err,data) {
data.forEach(functio
浏览 5提问于2017-01-07得票数 0
2回答
我正在从Crystal迁移一个报告，在那里我可以创建一个列并使用这个公式进行填充...
if ({@SD Profile}="null") and ({@HD Profile 2}="null")
then ""
else
if ({@HD Profile 2}="null")
then "SD only"
else
if ({@SD Profile}="null")
then "HD only"
else
浏览 3提问于2015-07-21得票数 1
我得到的代码来自这个链接：https://johnpaton.net/posts/forward-fill-spark/它有一些我想要完成的任务的背景。 from pyspark.sql import Window
from pyspark.sql.functions import last
# define the window
window = Window.partitionBy('location')\
.orderBy('time')\
.rowsBetween(-sys.maxsize,
浏览 13提问于2020-04-28得票数 1
回答已采纳
我有两个数据格式：df_1和df_2
rdd = spark.sparkContext.parallelize([
(1, '', '5647-0394'),
(2, '', '6748-9384'),
(3, '', '9485-9484')])
df_1 = spark.createDataFrame(rdd, schema=['ID', 'UPDATED_MESSAGE', 'ZIP_CODE'])
# +---+----
浏览 26提问于2022-11-03得票数 0
回答已采纳
我正在尝试对我拥有的一些参数运行多层反馈。我没有得到我想要的空值。我想知道如何做一个多部分的ELSE语句，其中我可以说ELSE send 'N‘或NULL。下面是我的代码的一个简短示例。我知道它在没有OR部分的情况下是有效的，但如果没有OR部分，我就得不到有NULL的值。我知道其混乱的数据和业务应该总是有一个Y或N填充，但我们都知道情况并非如此。
DECLARE @par1 char(1)
DECLARE @par2 char(1)
DECLARE @par3 char(1)
DECLARE @needs char(1)
SET @needs = 'C'
SET @
浏览 0提问于2019-08-20得票数 0
3回答
我有以下spark数据框架- +----+----+
|col1|col2|
+----+----+
| a| 1|
| b|null|
| c| 3|
+----+----+ 在spark API中有没有一种方法来检测col2中是否包含3？请注意，答案应该只是一个指标值- yes/no -而不是在col2中具有3的记录集。
浏览 6提问于2021-09-03得票数 2
我有一个数据集，其中包含在特定时间点的观察值，但这些时间点(以及它们之间的时间长度)因组而异。我正在尝试“填充”数据，以便将现有的观察结果带到丢失的单元格中。但我只想在原始观察后的特定行数内执行此操作。例如，我可以有一个如下所示的数据集：
对于A组，我想用2001的值填充2002的值，用2003的值填充2004，依此类推。我根本不想填充2000，因为我没有前面的值。我也不想填写2011年的值，因为"cyclelength“变量告诉我，A组的观测应该每两年进行一次，所以我不想将数据向前推进到超过这个值。2011只是一个真正缺失的价值。
类似地，在B组中，我希望将2000的值前移
浏览 1提问于2014-12-16得票数 0
回答已采纳
我有一个查询，我正在拉入一个部门字段，但是，在某个日期之后，我希望这个字段填充为空。 例如，下面是代码 Select T6.Segment2 as 'Old Department Code' 我确实希望此字段能够引入适当的值，但是在某个日期(2019年4月1日)之后，我希望此字段显示空值。 这个是可能的吗？
浏览 12提问于2019-04-12得票数 0
回答已采纳
4回答
我在这里之前已经看到了这个问题，我已经从中吸取了教训。然而，我不确定为什么当我觉得它应该工作的时候，我会得到一个错误。
我想通过一些规则在现有的Spark DataFrame中创建一个新的列。这是我写的。iris_spark是具有分类变量iris_spark的数据框，具有三个不同的类别。
from pyspark.sql import functions as F
iris_spark_df = iris_spark.withColumn(
"Class",
F.when(iris_spark.iris_class == 'Iris-setosa
浏览 1提问于2016-08-20得票数 30
几天来，我一直在研究如何完成以下工作:我有一张有备用地址的桌子，但我只需要把这座城市拉出来。然而，这座城市可能位于field5、field4或field3。我想要做的，并不幸地失败了，是填充另一个名为city的字段，通过计算<> NULL的三个字段所找到的值。
到目前为止，这就是我所拥有的，虽然我没有收到任何错误，但唯一出现的值是field4，因为field5是null或'‘。但是，如果field4也是空的，则城市字段为空。由于某些原因，我的查询没有查看field3，如果存在值，则该值不会填充。救命啊！
这是第一次尝试:当altcity='Y‘和(field5为空或
浏览 2提问于2015-04-30得票数 0
回答已采纳
2回答
我有一个MS数据库。
在我的一个字段LotNumber上，我将默认值设置为，它是一个标量值函数，它接受当前日期并创建一个朱利安日期格式化的批号。
当我使用SSMS将值插入到表中时，将正确地填充该值，用LotNumber替换空值。
我试图为visual 2010中的数据库创建一个前端。我设置了我的数据源，将一个详细信息视图拖到了一个表单上，我可以看到数据，对数据进行编辑，并删除数据。但是，当我尝试插入新数据时，它会使用NULL填充LotNumber字段。
当从我的winForms应用程序中输入数据时，我不理解为什么MS不使用默认值而不是空值。我的印象是，在SQL模式中设置默认值的目的是用默认值替
浏览 3提问于2014-08-29得票数 0
回答已采纳
5回答
表中有2位列活动，而活动列已经包含值，但挂起的列仍然为空。
如何用与活动相反的值填充挂起的字段？
我被困在这个密码里..。
Declare @suspended bit;
--some conditions
Update Users_mock
Set Suspended = @Suspended;
浏览 2提问于2012-12-19得票数 0
回答已采纳
1回答
我正在尝试清理MySQL中的一些数据，但我不确定修复以下问题的最有效方法。我有三列A、B和C，它们经常具有相同的值。如果A和B相同，或者A和C相同，那么如果可能的话，我想用非空值填充另一个选项。B&C不影响A的值。例如：
-------------------
|A |B |C |
-------------------
|1 |2 |3 |
|1 |2 |NULL |
|2 |5 |8 |
|2 |NULL |8 |
|3 |NULL |9 |
|3 |NULL |NULL |
-----
浏览 2提问于2014-02-18得票数 4
我有下面的数据集，它包含一些空值，需要在spark中使用fillna替换空值。
DataFrame：
df = spark.read.format("com.databricks.spark.csv").option("header","true").load("/sample.csv")
>>> df.printSchema();
root
|-- Age: string (nullable = true)
|-- Height: string (nullable = true)
|-- Nam
浏览 1提问于2016-11-03得票数 20
回答已采纳
1回答
Spark的.NET正向填充
、、、、
我正在研究.NET (C#)中的Spark DataFrame的窗口函数。 我有一个包含年、月、日、小时、分钟、ID、类型和值的DataFrame df： | 2021 | 3 | 4 | 8 | 9 | 87 | Type1 | 380.5 |
| 2021 | 3 | 4 | 8 | 10 | null | null | null |
| 2021 | 3 | 4 | 8 | 11 | null | null | null |
| 2021 | 3 | 4 | 8 | 12 | null
浏览 24提问于2021-03-23得票数 3
回答已采纳
在spark中，当集合为空时将视图模型发送到视图中会导致一些令人头疼的问题，例如：
<input value="model.addresses[0].street" />
其中"model.addresses“可以是空的，因此给出一个NRE。
除了在呈现之前填充集合之外，有没有其他方法来处理这个问题。这有点麻烦，因为它需要一些自定义处理来确保它们被填充。我在想spark条件属性会起作用：
<input value="model.addresses[0] != null?model.addresses.street" />
但我觉得
浏览 0提问于2009-11-26得票数 0
回答已采纳
1回答
我需要将"dep“列分成两个不同的列，一个是”已记录“，另一个是”未记录“。“未记录”列将包含当天"dep“为空或null的条目的时间总和。"recorded“列需要显示"dep”列不为空或空的那一天的时间总和。
到目前为止，这就是我所拥有的
SELECT Cast(Start_Time AS DATE) AS Date, dep,
sum(time) as "Total Time"
FROM A6K_Events
Group By Cast(Start_Time AS DATE), dep
它会产生这样的结果
+----------
浏览 0提问于2018-06-30得票数 0
我对更新查询有问题。
下面是我尝试用于更新另一个名为BOARD_CALLS的表的摘录
表: BOARD_TASKS
CHAR(8) BIGINT INT INT CHAR(8) INT
+-----------+----------+----------+----------+-------------------+--------------+
| REF_CALL | NUM_TASK | IS_PHONE | IS_EMAIL | IS_DUPLICATE_WITH | IS_DUPLICATE |
+-
浏览 2提问于2019-12-16得票数 0
回答已采纳
我的数据库在MySQL中
我有一个表，假设有4列。我想知道是否可能，以及如何实现以下内容:根据第2列和第3列的值填充第4列
在Excel中我有一个公式，让我们举个例子:如果column2值设置为“灰色”，而column3值设置为“汽车”，那么第四列的值应该设置为“超级”。
我只是举个例子。
我在Excel中的实际公式如下：=IF(K4=4;"Maximal";IF(K4>4;"Maximal";IF(K4=3;"Important";IF(K4>3;"Important";IF(K4=2;"Limited
浏览 0提问于2016-07-20得票数 0
1回答
我正在尝试为数据质量报告编写一个SQL查询，该报告将多个列中的数据质量失败值显示到一列中。请参考下面的示例
事实表
Ac_Nm INAmt Ast Rcs
123 100 5000 NA
456 200 -200 Yes
789 -300 1000 No
所需输出(填充VAL列)
Ac_Nm Is_Clm Val
123 RCS NA
456 Ast -200
789 InAmt -300
如何编写SQL查询来填充Val列？我已经写好了其余的数据质量报告查询。
在上面
浏览 3提问于2014-11-06得票数 0
我的sql查询有问题，不知道如何解决：
输出表由以下内容组成。
1. SERIALNR VARCHAR(26) NOT NULL
2. LP_BASIC VARCHAR(20) NOT NULL
3. LP_NEW VARCHAR(20)
4. SCORE NUMBER(20) NOT NULL
5. CURRENT_LP VARCHAR(20)
查询本身运行良好，不包含错误。
LP_BASIC列总是填充，而LP_NEW是可选字段。CURRENT_LP应该始终显示LP_NEW (如果不是空的话)，否则显示LP_BASIC (从不为空)。
问题是，“ problem
浏览 3提问于2016-11-02得票数 2
2回答
我正在使用spark sql开发一个SPARK应用程序，我的工作之一是从两个表中选择值，并将其插入到一个空表中，这就是我的结果。但为此，我正在尝试使用spark创建一个空表，我已经创建了一个空数据框，但无法将其注册为表。下面是我的情况代码
from pyspark import SQLContext
from pyspark.sql.types import StructType,StructField,StringType,DateType,IntegerType
sqlc=SQLContext(sc)
schema= StructType([StructField("Name&#
浏览 2提问于2016-08-03得票数 0
回答已采纳
如何将变量传递给Spark数据帧筛选器和for IF条件。
我正在从Spark dataframe填充值
val data=sqlContext.sql("Select Col from Tables1")
我想将这个变量数据传递到dataframe filter选项中。
我尝试了下面的一个，但它是空值。
val df=df1.filter($"Column1"===data) and
val df=df1.filter($"Column1"===$data)
两种方法都不起作用。
我试着在IF语句中使用。
if $data="Strin
浏览 26提问于2017-03-16得票数 0
我有一个列(例如col )，它具有布尔值，现在取决于Col A有0还是1，我必须将另一列(例如Col B)的值写入两个不同的列。
(例如，如果Col A为0，则B列的值必须写在C列中，D列的值必须为空，如果为1，则必须将B列的值写在D栏中，而C列的值必须为空)。
在查询中甚至可以包含吗？或者我必须在文件中导入查询结果并在其上运行脚本？
浏览 9提问于2016-09-16得票数 0
回答已采纳
我有一种情况，我的数据帧有3列，在这3列之外，column3中有可能存在空值。此DF中的总记录为200万条。我需要通过mysql数据库中的一个值来填充这个空值(基本上调用一个返回值的函数)。我可以考虑遍历每一行，但考虑到数据量，这可能会耗费更多的时间。我如何实现这一点，我知道如何用静态值填充空值，但这是完全动态的。谢谢你的问候，罗宾
浏览 26提问于2018-09-08得票数 2
回答已采纳
1回答
我有这个示例数据帧： id | A | B | C | D
1 |NULL | 1 | 1 |NULL
2 | 1 | 1 | 1 | 1
3 | 1 |NULL |NULL |NULL 我想改成这样的格式： id | newColumn
1 | {"B", "C"}
2 | {"A","B","C","D"}
3 | {"A"} 换句话说，我想创建一个新列，其中包含行值不为空的列名。 我如何使用Scala在Spark中做到这一点
浏览 19提问于2019-03-19得票数 0
2回答
我想把数据从熊猫转换为火花，我正在使用spark_context.createDataFrame()方法来创建数据。我还将在createDataFrame()方法中指定模式。
我想知道的是如何处理特殊情况。例如，熊猫中的NaN，当转换为Spark时，最终会变成字符串"NaN“。我在寻找如何获得实际的空值而不是"NaN“的方法。
浏览 3提问于2017-07-19得票数 11
回答已采纳
我有一个由person、transaction_id和is_successful组成的数据帧。数据帧由具有不同transaction_ids的person的重复值组成，并且每个事务的is_successful将为True/False。 我想要派生一个新的数据帧，它将为每个人都有一条记录，其中包含该人的最新transaction_id，并且仅当他的任何事务成功时才填充True。 val input_df = sc.parallelize(Seq((1,1, "True"), (1,2, "False"), (2,1, "False"), (2,2
浏览 19提问于2021-08-07得票数 1
1回答
我正在尝试用以前的非空值(如果存在)填充我的Spark dataframe中缺少的值。我在Python/Pandas中做过这种事情，但是我的数据对于Pandas (在一个小集群上)来说太大了，我是Spark noob。这是Spark可以做到的吗？它可以对多个列执行此操作吗？如果是这样的话，是怎么做的？如果没有，在谁的Hadoop工具套件中有任何替代方法的建议吗？
谢谢!
浏览 0提问于2016-07-01得票数 8
我有一个数据帧(mydf)，如下所示：
+---+---+---+---+
| F1| F2| F3| F4|
+---+---+---+---+
| t| y4| 5|1.0|
| x| y| 1|0.5|
| x| y| 1|0.5|
| x| z| 2|1.0|
| x| b| 5|1.0|
| t| y2| 6|1.0|
| t| y3| 3|1.0|
| x| a| 4|1.0|
+---+---+---+---+
我想在"withColumn“中做一个条件聚合，如下所示：
mydf.withColumn("myVar"
浏览 0提问于2018-11-07得票数 6
回答已采纳
2回答
我在SQL Server2008中有一条case语句，它使用以下语法
case
when [Phone1] = 'Cell' then [CellNumber]
when [Phone1] = 'Home' then [HomeNumber]
when [Phone1] = 'Work' then [WorkNumber]
when [Phone2] = 'Cell' then [CellNumber2]
when [Phone2] = 'Home' then [HomeNu
浏览 6提问于2016-08-30得票数 0
回答已采纳
我正在尝试用数据帧中某列的第一个不为空的值填充该列的空值。 我想要填充的数据帧如下所示，我希望'id_book‘列的所有行都具有相同的编号 ? 我尝试了以下方法，但仍然显示空值 w = Window.partitionBy('id_book').orderBy('id_book', 'date').rowsBetween(0,sys.maxsize)
filled_column = first(spark_df['id_book'], ignorenulls=True).over(w)
spark_df_fill
浏览 55提问于2021-03-16得票数 0
我找了又找，但我找不到答案。
我有一个函数，它本质上将列(根据它们的名称和数据类型)排序为我的公司在将DataFrames保存到SQL之前所需的特定顺序。我知道这个功能起作用。它所做的就是输出一个列列表(在源DataFrame中找到)。我调用这个排序列名列表col_list，并使用它作为df.select()的参数。
这种方法几个月来一直行之有效。但是，在一个特定的项目中，当我试图通过以下方法将排序应用于数据访问时：
df = df.select(*col_list)
...I得到了以下错误：
org.apache.spark.SparkException: Job aborted due t
浏览 11提问于2022-04-13得票数 0
我有一个特定的要求，其中我需要检查空的DataFrame。如果为空，则填充默认值。这是我尝试过的，但没有得到我想要的。
def checkNotEmpty(df: org.apache.spark.sql.DataFrame, col: String):org.apache.spark.sql.DataFrame =
{
if (!df.rdd.isEmpty()) df
else
df.na.fill(0, Seq(col))
}
val age = checkNotEmpty(w_feature_md.filter("age='22'"
浏览 4提问于2016-09-16得票数 2
1回答
在E.Capriolo等人编写的Hive的第168页上，它声明："...in的Java原语不是对象，不能为空。“因此，对于简单的Hive UDF：
public class ConvertToCelcius extends UDF {
public double evaluate(double value) {
return (value - 32) / 1.8;
}
}
如果遇到空行值，会发生什么情况？
另外，如何使用Java原语测试是否将null传递给我们的UDF？
想必，我们可以将上述内容改写为：
public class ConvertToC
浏览 2提问于2017-11-06得票数 1
回答已采纳
我正在使用Oracle，并试图实现以下逻辑:在PS_EMPLOYEES上，如果ADDRESS3不是null且不等于“”，则使用ADDRESS2 On填充该字段，用ADDRESS1填充该字段。
我能够让下面的部分工作，但是如何确保它也不是空的呢？
, ADDRESS_LINE1 =
SELECT (CASE WHEN t2.ADDRESS3 != ' ' THEN substr(t2.ADDRESS2, 1, 30) ELSE substr(t2.ADDRESS1, 1, 30) END)
FROM PS_EMPLOYEES t2
WHERE t2.EM
浏览 2提问于2014-08-15得票数 0
回答已采纳
1回答
可以试一下火花壳吗？
case class Employee(id: Int, name: String, department: String, salary: Option[Double])
import org.apache.spark.sql.functions._
import spark.implicits._
case class Employee(id: Int, name: String, department: String, salary: Option[Double])
val data = List(Employee(1, "XYZ", "d
浏览 2提问于2020-01-31得票数 2
回答已采纳
3回答
有一个dataset推断say，其中我想将性别列中的空值随机替换为男性或女性。
imputedcsv.groupBy("Gender").count.show()
+------+-----+
|Gender|count|
+------+-----+
| null| 24|
|Female| 240|
| Male| 242|
+------+-----+
其中一个用单个值填充空值，但是如何从一组值随机填充列的空值，比如{Male,Female}。
imputedcsv.na.fill("Male", Seq("Gender"))
浏览 2提问于2017-11-21得票数 1
回答已采纳
无法将下面的the查询部件ISNULL(名称，'N/A')转换为Spark等效项
选择ID，ISNULL(名称，'N/A')作为名称，公司从TEST到
将下面的the查询部分ISNULL(名称，'N/A')转换为Spark等效项
选择ID，ISNULL(名称，'N/A')作为名称，公司从测试
浏览 13提问于2022-11-23得票数 0
回答已采纳
3回答
我正试图将数据格式插入卡桑德拉：
result.rdd.saveToCassandra(keyspaceName, tableName)
然而，一些列值是空的，因此我得到了异常：
java.lang.NumberFormatException: empty String
at sun.misc.FloatingDecimal.readJavaFormatString(FloatingDecimal.java:1842)
at sun.misc.FloatingDecimal.parseFloat(FloatingDecimal.java:122)
at java.lang.Float.pars
浏览 7提问于2017-05-08得票数 2
回答已采纳
当我们获得预期的值时，下面的代码可以正常工作
case Criteria
when ''Security_Agent'' then substring(criteriavalue,charindex(''['',criteriavalue,8)+1,charindex('']'',criteriavalue,14)-charindex(''['',criteriavalue,8)-1)
when ''Agent'&#
浏览 3提问于2018-10-17得票数 0
它目前正在按预期工作，但我不希望它使用序列中的下一个值填充加号，如果它是null的话。我的问题是，在我的FROM最后一个表中尝试下一个if语句时。它一点也不喜欢。这是一个语法问题，我在googled上搜索了一下，但没有效果。
CREATE SEQUENCE acct_seq
START WITH 1
INCREMENT BY 1
NO MAXVALUE
NO CYCLE
CACHE 24
;
SELECT accntnum AS new_acct, old_acct
FROM FINAL TABLE (
UPDATE accounts INCLUDE(old_acct INT)
SET a
浏览 5提问于2013-08-21得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
