Hi spark. is there anything in the works for a typesafe HQL like API for building spark queries from case classes ? i.e. where, given a domain object "Product" with a "cost" associated with it , we can do something like:
query.select(Product).filter({ _.cost > 50.00f
}).join(ProductMetaData).by(product,meta=>product.id=meta.id). toSchemaRDD ?
I know the above snippet is totally wacky but, you get the idea :)
--
jay vyas
