2017-08-07 7 views
0

カラム値が定義済みの文字列で始まる条件に基づいてデータフレームをフィルタリングする必要があります。Sparkデータフレーム検索列(文字列で始まる)

私がしようとしています次:

val domainConfigJSON = sqlContext.read 
    .jdbc(url, "CONFIG", prop) 
    .select("DID", "CONF", "KEY").filter("key like 'config.*'") 

となっ例外:com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException:

によって引き起こさ あなたのSQL構文でエラーが発生しています; が 近い「KEY = 『設定を使用する権利構文についてはMariaDBサーバのバージョンに対応していること取扱説明書をご確認ください。*』」行では、1

Using spark: 1.6.1 
+0

KEYもMariaDBの予約語です。 – philantrovert

答えて

2

あなたは列クラスのstartsWith機能の存在を使用することができます。

myDataFrame.filter(col("columnName").startsWith("PREFIX")) 
+0

ありがとう、それは完全に働いた。 – Anush