スパークデータフレームのキー値に基づくフィルタリング

Question

データベース/データフレームにキー値のペアである列があります。私は特定の値に基づいてデータをフィルタリングしたい。 キー 'ddd'の値が 'DDD'の行のみを表示します。 これはspark/spark sqlでどのように実現できますか？

"{'aaa': 'AAA', 'bbb': 'BBB', 'ccc': 'CCC', 'ddd': 'DDD', 'eee': 'EEE', 'fff': 'FFF', 'ggg': 'GGG'}" 
"{'aaa': 'AAA1', 'bbb': 'BBB1', 'ccc': 'CCC1', 'ddd': 'DDD1', 'eee': 'EEE1', 'fff': 'FFF1', 'ggg': 'GGG1'}" 

Answer 1

私たちは、フィルタ機能

 DataFrame inputDf= //read from database 

    DataFrame filteredDf=inputDf.filter("ddd='DDD'");