Was ist das Scala-Funkenäquivalent der Teilmenge von R

Question

Angenommen, ich habe einen Datenrahmen df in Funken, mit der Struktur so.

Eingang:

amount city 
10000 la 
12145 ng 
14000 wy 
18000 la 

Wie der Datenrahmen für Menge Teilmenge kann> 10000

Erwartete Ausgabe:

amount city 
12145 ng 
14000 wy 
18000 la 

In R i so etwas tun kann:

df1 <- df[df$amount > 10000 ,] 

Ich weiß, dass ich SQL Funken verwenden kann, das gleiche zu tun, aber was ist der Schritt, der oben

Answer 1

Aus der Dokumentation ähnelt:

http://spark.apache.org/docs/latest/sql-programming-guide.html#untyped-dataset-operations-aka-dataframe-operations

val df1 = df.filter($"amount" > 10000)