org.apache.spark.sql.AnalysisException: Detected implicit cartesian product

2019-09-05 Thread kyunam
n logical plans SELECT * FROM LHS left join RHS on LHS.R = RHS.R The above happens in both Spark 2.3.3 and 2.4.4. Thanks, Kyunam -- Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ - To unsubscribe e-mail: user-unsubscr...@spark.apache.org

How to query StructField's metadata in spark sql?

2019-09-05 Thread kyunam
Using SQL, is it possible to query a column's metadata? Thanks, Kyunam -- Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ - To unsubscribe e-mail: user-unsubscr...@spark.apache.org

Possible to specify returnType: DataType in UDFRegistration.register()?

2019-06-01 Thread kyunam
ring,f: org.apache.spark.sql.api.java.UDF21[_, _, _, _, _, _, _, _, _, _, _, _, _, _, _, _, _, _, _, _, _, _],returnType: org.apache.spark.sql.types.DataType)Unit Why can't I pass in returnType?Thanks,Kyunam -- Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/

how to call database specific function when reading writing thru jdbc

2018-06-07 Thread Kyunam Kim
o, this doesn't work. .as("shape") Also when writing, I want to be able to call a built-in function: STGeomFromText like this: INSERT INTO SpatialTable (GeomCol1) VALUES (geometry::STGeomFromText('POLYGON ((0 0, 150 0, 150 150, 0 150, 0 0))', 0)); How would go about doing this? Thanks, Kyunam