Method createTableRatings

spark/src/test/java/io/ddf/spark/BaseTest.java:102–109

()

    }

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

        manager.sql("create table ratings (userid int,movieid int,score double ) "
            + "ROW FORMAT DELIMITED FIELDS TERMINATED BY ','", "SparkSQL");

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

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