Hi,
I have a short question regarding the compute() of an SchemaRDD.
For SchemaRDD the actual queryExecution seems to be triggered via
collect(), while the compute  triggers only the compute() of the parent and
copies the data (Please correct me if I am wrong!).

Is this compute() triggered at all when I do something like:
*val schemaRDD2 = schemaRDD.where(...)*
*schemaRDD2.collect() *

And if not when is the compute function triggered/ what is the intend
behind it?

Sorry if this is a trivial question, just getting started with spark
(SQL)....
Thanks,
Joerg

Reply via email to