I’m trying to create a Temporary View with Schema and can’t seem to do so. My query is so far:

spark.sql("""CREATE OR REPLACE TEMPORARY VIEW my_table (id IntegerType, name StringType""")

Error:

226 converted = convert_exception(e.java_exception)
227 if not isinstance(converted, UnknownException):
228     # Hide where the exception came from that shows a non-Pythonic
229     # JVM exception message.

–> 230 raise converted from None

But it fails. Is this wrong?

Thanks for your help.