0
我是Spark和Spark SQL的新手,但瞭解Java和SQL。Spark和Spark的Java新手與Java
我該如何使用Spark SQL來專門獲取一組使用Spark SQL轉換爲Spark的Oracle存儲過程。請舉例。
我是Spark和Spark SQL的新手,但瞭解Java和SQL。Spark和Spark的Java新手與Java
我該如何使用Spark SQL來專門獲取一組使用Spark SQL轉換爲Spark的Oracle存儲過程。請舉例。
以下代碼是示例Spark SQL;你能問我嗎?
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;
public class SparkSQL {
public static void main(String[] args) {
SparkSession sparkSession = SparkSession.builder().master("local").getOrCreate();
Dataset<Row> peopleDS = sparkSession.read().json("C:\\people.json");
peopleDS.createOrReplaceTempView("people");
Dataset<Row> sql = sparkSession.sql("select city,avg(age) from people group by city");
sql.show();
}
}