()
| 92 | } |
| 93 | |
| 94 | func createTablesForDataSet() { |
| 95 | dataSetName := viper.GetString(dataSetKeyName) |
| 96 | dataSetSchemaDir := fmt.Sprintf("%s/%s", dataSetName, schemaDir) |
| 97 | schemaDirInfo, err := ioutil.ReadDir(dataSetSchemaDir) |
| 98 | panicIfErr(err) |
| 99 | for _, schemaInfo := range schemaDirInfo { |
| 100 | baseName := schemaInfo.Name() |
| 101 | tableName := strings.TrimSuffix(baseName, filepath.Ext(baseName)) |
| 102 | tableSchemaPath := fmt.Sprintf("%s/%s/%s", dataSetName, schemaDir, baseName) |
| 103 | createTable(tableName, tableSchemaPath) |
| 104 | } |
| 105 | } |
| 106 | |
| 107 | func ingestDataForDataSet() { |
| 108 | dataSetName := viper.GetString(dataSetKeyName) |
no test coverage detected