Hi

I would like to know where exactly(which class/function) spark sql will
apply the operators on dataset / dataframe rows.
For example by applying the following filter or groupby which class is
responsible for? And will iterate over the rows to do its operation?

Kind regards
Ehsan Shams

val df1 = sqlContext.read.format("csv").option("header",
"true").load("src/main/resources/Names.csv")
val df11 = df1.filter("County='Hessen'")
val df12 = df1.groupBy("County")

Reply via email to