2017-03-28 2 views
0

scalaでは、データフレーム内の複数の列を新しい列に結合できます。apache sparkで列を結合するときのscalaのconcatに相当するJava

var dataWithNewColumns = rawData.withColumn("day_and_time", concat(rawData("day"),lit("_"),rawData("time"))) 

私はJavaで同じことをしたいのですが、私は連結関数に任意の等価を見つけることができません。あなたは私を助けることができます?両方の列の組み合わせを実現する他のオプションも同様に歓迎されます。

ありがとうございます!

答えて

6

あなたが例えば、それを達成するために、あなたのクラスでfunctionsクラス(というか、それのstatic方法)をインポートする必要があります。

import static org.apache.spark.sql.functions.*; 

あなたがそれをインポートした後、このコードがどのように見えるかですlike:

Dataset<Row> data = //get data 
data.withColumn("new_Column", concat(data.col("col1"), lit("_"), data.col("col2"))); 
+0

ありがとうDarshan、これはまさに私が探していたものです。 – padmalcom

関連する問題