我看到從
python
來sql
是創建一個臨時觀點,然後從sql訪問,dataframe,細胞在sql。
現在的問題是,我怎麼能有一個
%的sql
細胞與選擇
聲明,這個聲明的結果分配給一個dataframe變量可以使用在未來python
細胞?
編輯:我知道,我可以在python運行一個SQL查詢並將結果存儲在一個dataframe。但事實上是我開發的SQL代碼
%的sql
細胞,一旦工作我必須查詢剪切和粘貼回一個python細胞並把它放到引號和寬鬆的高亮顯示。經常發生這種情況,當我在做一些數據分析,我的大多數代碼包含一些SQL查詢。
對我來說,是有意義的一個選項添加到
選擇
聲明如到dataframe_name
,然後注冊dataframe在python空間,沒有實際運行查詢。
@adrin它可能不是一個參數來選擇,而不是在一個sql語句,但它是可能的不用複製粘貼:
df1 =火花。創建DataFrame([(None, None), (1, None), (None, 2)], ("a", "b")) display(df1)
df1.createOrReplaceTempView(表1)
% sql創建或替換臨時視圖作為SELECT * FROM table1表二
從表二sql SELECT * %
df2 = spark.table(表二)顯示(df2)
@adrin它可能不是一個參數來選擇,而不是在一個sql語句,但它是可能的不用複製粘貼:
df1 =火花。創建DataFrame([(None, None), (1, None), (None, 2)], ("a", "b")) display(df1)
df1.createOrReplaceTempView(表1)
% sql創建或替換臨時視圖作為SELECT * FROM table1表二
從表二sql SELECT * %
df2 = spark.table(表二)顯示(df2)