val df1 = sc.makeRDD(1 to 5).map(i => (i, i * 2)).toDF("single", "double") df1.where(df1.col("single").cast("string").equalTo("1"))
val df1 = sc.makeRDD(1 to 5).map(i => (i, i * 2)).toDF("single", "double") df1.where(df1.col("single").cast("string").equalTo("1"))