你可以傳遞參數/參數通過編程方式創建SQL語句的SQL字符串使用Scala / Python並將其傳遞給sqlContext.sql(字符串)。
這裏有一個例子使用Scala中的字符串格式:val參數= 100
sqlContext。sql (s”“”從表1,參數選擇* = $ param”" ")注意前麵的“s”第一”“”。這使您能夠替代美元參數在一個Scala的字符串。
這裏有一個例子使用Python中的字符串格式:
param = 100
從表查詢= " SELECT *參數= {}”.format(參數)sqlContext.sql(查詢)你可以傳遞參數/參數通過編程方式創建SQL語句的SQL字符串使用Scala / Python並將其傳遞給sqlContext.sql(字符串)。
這裏有一個例子使用Scala中的字符串格式:val參數= 100
sqlContext。sql (s”“”從表1,參數選擇* = $ param”" ")注意前麵的“s”第一”“”。這使您能夠替代美元參數在一個Scala的字符串。
這裏有一個例子使用Python中的字符串格式:
param = 100
從表查詢= " SELECT *參數= {}”.format(參數)sqlContext.sql(查詢)我試著像下麵一樣插入查詢
val = 1207 val b = " amit " val c = 20 sqlContext。sql (s”“插入表employee選擇t。*從(選擇美元,美元b, c)美元t”“”)
但是,我得到以下錯誤
異常的線程org.apache.spark.sql“主要”。AnalysisException:不能解決“阿米特”給定的輸入列;
我們如何通過參數在python spark-sql日期嗎
在我的場景。謝謝你!