Thanks, that helped. And I needed SchemaRDD.as() to provide an alias for
the RDD.
-Jerry
On 17/12/14 12:12 pm, Tobias Pfeiffer wrote:
Jerry,
On Wed, Dec 17, 2014 at 3:35 PM, Jerry Raj <[email protected]
<mailto:[email protected]>> wrote:
Another problem with the DSL:
t1.where('term == "dmin").count() returns zero.
Looks like you need ===:
https://spark.apache.org/docs/1.1.0/api/scala/index.html#org.apache.spark.sql.SchemaRDD
Tobias
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
