@Dinu Sukumara:我承擔你的問題
如果你想保存時間戳值完全在源數據庫,沒有任何時區轉換,可以遵循以下步驟:
spark.conf.set (“spark.sql.session。時區”、“< source_timezone >”)
3所示。讀取數據從源:使用JDBC閱讀功能磚從源數據庫提取數據。
df = spark.read.format (jdbc)。選項(“url”,“< jdbc_url >”)。選項(“數據表”、“< table_name > ") .load ()