Method createTableAirline

spark/src/test/java/io/ddf/spark/BaseTest.java:30–45

()

    }

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

        manager.sql("create table airline (Year int,Month int,DayofMonth int,"
            + "DayOfWeek int,DepTime int,CRSDepTime int,ArrTime int,"
            + "CRSArrTime int,UniqueCarrier string, FlightNum int, "
            + "TailNum string, ActualElapsedTime int, CRSElapsedTime int, "
            + "AirTime int, ArrDelay int, DepDelay int, Origin string, "
            + "Dest string, Distance int, TaxiIn int, TaxiOut int, Cancelled int, "
            + "CancellationCode string, Diverted string, CarrierDelay int, "
            + "WeatherDelay int, NASDelay int, SecurityDelay int, LateAircraftDelay int ) "
            + "ROW FORMAT DELIMITED FIELDS TERMINATED BY ','", "SparkSQL");

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

    }

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