Method createTableMtcars

spark/src/test/java/io/ddf/spark/BaseTest.java:111–119

()

    }

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

        manager.sql("CREATE TABLE mtcars ("
            + "mpg double, cyl int, disp double, hp int, drat double, wt double, qsec double, vs int, am int, gear int, carb int"
            + ") ROW FORMAT DELIMITED FIELDS TERMINATED BY ' '", "SparkSQL");

        manager.sql("load data local inpath '../resources/test/mtcars' into table mtcars", "SparkSQL");
    }
    
    public void createTableCarOwner() throws DDFException {
      manager.sql("drop table if exists carowner", "SparkSQL");