xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

feat: add the number of threads in mode

This commit is contained in:
Yaming Pei 2025-03-03 20:07:09 +08:00
parent cd958c9f17
commit 56ac7c9ef4
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tools/taos-tools/src/benchCsv.c
View File

@ -385,7 +385,7 @@ int csvGenCreateStbSql(SDataBase* db, SSuperTable* stb, char* buf, int size) {
if (pos <= 0 || pos >= size) return -1;
}
pos += snprintf(buf + pos, size - pos, "\n");
pos += snprintf(buf + pos, size - pos, ";\n");
if (pos <= 0 || pos >= size) return -1;
// infoPrint("create stable: <%s>.\n", buf);
@ -488,14 +488,14 @@ static int csvInitWriteMeta(SDataBase* db, SSuperTable* stb, CsvWriteMeta* write
break;
}
case CSV_NAMING_B_THREAD: {
(void)snprintf(write_meta->mode, sizeof(write_meta->mode), "batch|no-time-slice");
write_meta->total_threads = MIN(g_arguments->nthreads, stb->childTblCount);
(void)snprintf(write_meta->mode, sizeof(write_meta->mode), "batch[%zu]|no-time-slice", write_meta->total_threads);
csvGenThreadFormatter(write_meta);
break;
}
case CSV_NAMING_B_THREAD_TIME_SLICE: {
(void)snprintf(write_meta->mode, sizeof(write_meta->mode), "batch|time-slice");
write_meta->total_threads = MIN(g_arguments->nthreads, stb->childTblCount);
(void)snprintf(write_meta->mode, sizeof(write_meta->mode), "batch[%zu]|time-slice", write_meta->total_threads);
csvGenThreadFormatter(write_meta);
csvCalcTimestampStep(write_meta);
break;