Apache Spark SQL是否支持与Oracle的MERGE SQL子句类似的MERGE子句? MERGE into <table> using (
select * from <table1>
when matched then update...
DELETE WHERE...
when not matched then insert...
)
我需要实施星火下面的SQL逻辑DataFrame SELECT KEY,
CASE WHEN tc in ('a','b') THEN 'Y'
WHEN tc in ('a') AND amt > 0 THEN 'N'
ELSE NULL END REASON,
FROM dataset1;
我输入DataFrame是如下: val dataset1 = S
我想以编程方式给出一定数量的字段,并且对于某些字段,选择一个列并将该字段传递给另一个函数,该函数将返回一个字符串case类,字符串。到目前为止,我有 val myList = Seq(("a", "b", "c", "d"), ("aa", "bb", "cc","dd"))
val df = myList.toDF("col1","col2","col3","col4")
val fie