我尝试使用pyspark中的current_timestamp方法获取当前时间戳和时区。但是得到“SQLException:不支持的类型TIMESTAMP_WITH_TIMEZONE”
val connection_properties = Map(
"url" -> CONNECTION_URL,
"user" -> USER,
"password" -> PASSWORD,
"driver" -> DRIVER_CLASSNAME
)
val source_df=spark.read.format("jdbc").options(connection_properties)
val test=source_df.option("query","select current_timestamp as create_ts, AB.emp_id, AB.emp_name from EMPLOYEE AB" ).load()
但是我期望create_ts的值类似于2023-03-09 23:09:50.379 +0530。有人能帮我解决这个问题吗?
1条答案
按热度按时间hs1ihplo1#
不要在查询中使用
current_timestamp
。请尝试使用DataFrame获取它。加