2017-08-09 4 views
-1

私はscalaの初心者であり、カラムvalueに基づいてテーブルrowsをフィルタリングしようとしています。スパークのためのスカラ - カラム上のテーブルの行をフィルタリングする

私はdataframe火花)持っている:私は、構文は次のようなものでなければなりません考え出し

+---+-----+ 
|id |value| 
+---+-----+ 
|3 |0 | 
|3 |0 | 
|4 |0 | 
|4 |0 | 
+---+-----+ 

+---+-----+ 
|id |value| 
+---+-----+ 
|3 |0 | 
|3 |1 | 
|3 |0 | 
|4 |1 | 
|4 |0 | 
|4 |0 | 
+---+-----+ 

私はvalue!=0ですべてrowsを削除する新しいdataframeを作成したいがそれを正しく得ることができませんでした:

val newDataFrame = OldDataFrame.filter($"value"==0) 

答えて

0

正しい方法は次のとおりです。あなたはちょうど=記号を追加するのを忘れました

0

彼らはあなたがフィルタリングを行うことができる様々な方法です。

  1. ヴァルnewDataFrame = OldDataFrame.filter($ "値" === 0)

  2. ヴァルnewDataFrame = OldDataFrame.filter(OldDataFrame( "値")=== 0)

  3. ヴァルnewDataFrame = OldDataFrame.filter( "値=== 0")

あなたはどこの機能だけでなく代わりのフィルタを使用することができます。

これが役に立ちます。

よろしく、

Neeraj

関連する問題