Spark2.0SQL語句執行過程

simba.sql("Select * from b") 調用SparkSession.scala的sql()方法： sql def sql(sqlText: String): DataFrame = { Dataset.ofRows(self, sessionState.sqlParser.parsePlan(sqlText)) }Dataset.ofRows()方法:  def o

>>阅读原文<<