| 62 | } |
| 63 | |
| 64 | public void createTableSmiths2() throws DDFException { |
| 65 | manager.sql("drop table if exists smiths2", "SparkSQL"); |
| 66 | |
| 67 | manager.sql("create table smiths2 (subject string, variable string, value double) " |
| 68 | + "ROW FORMAT DELIMITED FIELDS TERMINATED BY ','", "SparkSQL"); |
| 69 | |
| 70 | manager.sql("load data local inpath '../resources/test/smiths2' into table smiths2", "SparkSQL"); |
| 71 | |
| 72 | } |
| 73 | |
| 74 | public void createTableAirlineWithNA() throws DDFException { |
| 75 | manager.sql("drop table if exists airline", "SparkSQL"); |