Method createTableMovie

spark/src/test/java/io/ddf/spark/BaseTest.java:90–100

()

    }

    public void createTableMovie() throws DDFException {
        manager.sql("drop table if exists movie", "SparkSQL");

        manager.sql("create table movie (" +
            "idx string,title string,year int,length int,budget double,rating double,votes int," +
            "r1 double,r2 double,r3 double,r4 double,r5 double,r6 double,r7 double,r8 double,r9 double,r10 double," +
            "mpaa string,Action int,Animation int,Comedy int,Drama int,Documentary int,Romance int,Short int" +
            ") ROW FORMAT DELIMITED FIELDS TERMINATED BY ','", "SparkSQL");

        manager.sql("load data local inpath '../resources/test/movies.csv' into table movie", "SparkSQL");
    }

    public void createTableRatings() throws DDFException {
        manager.sql("drop table if exists ratings", "SparkSQL");