Nouveau sur Spark et Spark SQL avec Java

Question

Je suis nouveau sur Spark et Spark SQL mais je connais Java et SQL.

Comment utiliser Spark SQL spécifiquement pour convertir un ensemble de procédures stockées Oracle en Spark à l'aide de Spark SQL. Exemples s'il vous plaît.

Answer 1

Le code suivant est un exemple Spark SQL; Pouvez-vous me demander

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(); 



    } 

}