Open ighack opened 3 years ago
Can I use this
sparkSession.sql( """CREATE TEMPORARY VIEW es (JIANG_CD STRING) | USING org.apache.spark.sql.redis OPTIONS (table 'es',spark.redis.host '10.3.87.33',spark.redis.port '6379') |""".stripMargin)
and Can I use where like this sparkSession.sql("SELECT * FROM es where JIANG_CD = '1' ")
Can I use this
and Can I use where like this sparkSession.sql("SELECT * FROM es where JIANG_CD = '1' ")