()
| 105 | } |
| 106 | |
| 107 | func ingestDataForDataSet() { |
| 108 | dataSetName := viper.GetString(dataSetKeyName) |
| 109 | dataFileDir := fmt.Sprintf("./%s/%s", dataSetName, dataDir) |
| 110 | dataFiles, err := ioutil.ReadDir(dataFileDir) |
| 111 | panicIfErr(err) |
| 112 | |
| 113 | cfg := client.ConnectorConfig{ |
| 114 | Address: fmt.Sprintf("%s:%d", viper.GetString(hostKeyName), viper.GetInt(portKeyName)), |
| 115 | } |
| 116 | |
| 117 | connector := cfg.NewConnector(logger, tally.NoopScope) |
| 118 | |
| 119 | for _, dataFileInfo := range dataFiles { |
| 120 | baseName := dataFileInfo.Name() |
| 121 | dataFilePath := fmt.Sprintf("./%s/%s/%s", dataSetName, dataDir, baseName) |
| 122 | tableName := strings.TrimSuffix(baseName, filepath.Ext(baseName)) |
| 123 | ingestDataForTable(connector, tableName, dataFilePath) |
| 124 | } |
| 125 | } |
| 126 | |
| 127 | func makeQuery(queryName, queryType, queryPath string) { |
| 128 | var err error |
no test coverage detected