0

をマージフィールドを持つことで私は5行のデータフレーム持っている:私は達成するためにwan't何Scalaのスパークデータフレームのグループ

[user,sun,MainTest2,end,false] 
[user,sun,MainTest2,start,false] 
[user,sun,MainTest,end,true] 
[user,sun,MainTest,start,true] 
[user,sun,MainTest,start,true] 

をテキストと2つの集計行が4フィールドにマージされます:

[user,sun,MainTest2,end#some_union_symbol#start,false] 
[user,sun,MainTest,end#some_union_symbol#start#some_union_symbol#start,true] 

私は減らすことについて何かする必要があるとは思いますが、あまりよく分かりません。 ありがとうございました!

答えて

0

私の1.4.1スパークを見つけて動作させることができるすべてのスタックから1つだけAnswer

申し訳ありませんが、ダブルポストの場合

関連する問題