UDF注冊(cè):
1、spark sql 注冊(cè)方式 (只能對(duì)sql() 可見(jiàn))
2、DataFrame注冊(cè)方式(對(duì)外部可見(jiàn))
1、spark sql 注冊(cè)方式 (只能對(duì)sql() 可見(jiàn))
2、DataFrame注冊(cè)方式(對(duì)外部可見(jiàn))
2019-09-18
full out join例子:
df_1.join(df_2,
df_1("uid") === df_2("u_id"),
"full"
).show
df_1.join(df_2,
df_1("uid") === df_2("u_id"),
"full"
).show
2019-09-18
df.withColumn("op_phone",concat(lit("廣州",col("op_phone").show
2019-09-18