在 Spark SQL 中,可以使用 createOrReplaceTempView()
方法來創建臨時表。該方法接受兩個參數,第一個參數是表名,第二個參數是一個 DataFrame 對象。以下是一個使用 createOrReplaceTempView()
方法創建臨時表的示例代碼:
val df = spark.read.format("csv").option("header", "true").load("path/to/file.csv")
df.createOrReplaceTempView("temp_table")
在上述示例中,首先使用 read()
方法讀取 CSV 文件并加載為 DataFrame 對象,然后使用 createOrReplaceTempView()
方法將 DataFrame 對象注冊為名為 “temp_table” 的臨時表。創建臨時表后,可以使用 SQL 語句對該臨時表進行查詢。