Use reflection to convert RDD to dataframe

Java：

package cn.spark.sql;

import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.api.java.function.Function;
import org.apache.spark.sql.DataFrame;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SQLContext;

import java.util.List;

public class RDD2DataFrameReflection {
    public static void main(String[] args){
        SparkConf conf = new SparkConf().setAppName("RDD2DataFrameReflection")
        .setMaster("local");
        JavaSparkContext sc = new JavaSparkContext(conf);
        SQLContext sqlContext = new SQLContext(sc);

        JavaRDD<String> lines = sc.textFile("C://Users//Desktop//students.txt");

        JavaRDD<Student> students = lines.map(
                new Function<String, Student>() {
                    private static final long serialVersionUID = 1L;
            @Override
            public Student call(String s) throws Exception {
                String[] lineSplit = s.split(",");
                Student stu = new Student();
                stu.setID(Integer.valueOf(lineSplit[0].trim()));
                stu.setName(lineSplit[1]);
                stu.setAge(Integer.valueOf(lineSplit[2].trim()));
                return stu;


            }
        });

        /*
        *  Use reflection   take RDD Convert to DataFrame
        *  take Student.class  Put it in   In fact, it is created by reflection DataFrame
        *  Because the bottom layer passes Student class  On reflection   To get some of the field
        *  requirement  javabean We need to implement serializable  Interface 
        * */
        DataFrame studentDF = sqlContext.createDataFrame(
                students,Student.class);
        // To get a DataFrame  after   You can register a temporary table 
        studentDF.registerTempTable("students");
        DataFrame teengerDF = sqlContext.sql("select * from students where age <= 18");

        // Will find out DataFrame  Convert again to RDD
        JavaRDD<Row> teengerRDD = teengerDF.javaRDD();


        // take EDD Data in   mapping   It maps to student
        JavaRDD<Student> teengerStudentRDD = teengerRDD.map(new Function<Row, Student>() {
            @Override
            public Student call(Row row) throws Exception {
                Student stu = new Student();
                stu.setAge(row.getInt(0));
                stu.setID(row.getInt(1));
                stu.setName(row.getString(2));
                return stu;
            }
        });
        List<Student> studentList = teengerStudentRDD.collect();
        for (Student stu : studentList){
            System.out.println(stu);
        }
    }
}

test ：