spark sql加载avro

 1         SparkConf sparkConf = new SparkConf().setAppName("Spark job");
 2         JavaSparkContext javaSparkContext = new JavaSparkContext(sparkConf);
 3 
 4         SQLContext sqlContext = new SQLContext(javaSparkContext);
 5 
 6         String FORMAT_CLASS = "com.databricks.spark.avro";
 7 
 8         // avro 在hdfs上的路径
 9         String path = "/sqoopdb/pcdas/*.avro";
10         DataFrame tblarticleautoDf = sqlContext.read().format(FORMAT_CLASS)
11                 .load(path);
12         tblarticleautoDf.registerTempTable("tableName");
13 
14         String sql = "select * from tableName";
15         DataFrame queryDf = sqlContext.sql(sql);
16         System.out.println(queryDf.count());
17         System.out.println(queryDf.first());