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