From 1cc819708133014a3ad3fbffc0146cf49d10fc03 Mon Sep 17 00:00:00 2001 From: Rokhaya Gueye Date: Tue, 17 Jun 2025 18:53:38 +0100 Subject: [PATCH 1/2] Fix: default tempdir to be an hsym --- code/processes/tickerlogreplay.q | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/code/processes/tickerlogreplay.q b/code/processes/tickerlogreplay.q index 298ad6730..e0accae7f 100644 --- a/code/processes/tickerlogreplay.q +++ b/code/processes/tickerlogreplay.q @@ -27,7 +27,7 @@ clean:@[value;`clean;1b] // clean sortcsv:@[value;`sortcsv;hsym first .proc.getconfigfile["sort.csv"]] // location of sort csv file compression:@[value;`compression;()]; // specify the compress level, empty list if no required partandmerge:@[value;`partandmerge;0b]; // setting to do a replay where the data is partitioned and then merged on disk -tempdir:@[value;`tempdir;`:tempmergedir]; // location to save data for partandmerge replay +tempdir:hsym @[value;`tempdir;`:tempmergedir]; // location to save data for partandmerge replay mergenumrows:@[value;`mergenumrows;10000000]; // default number of rows for merge process mergenumtab:@[value;`mergenumtab;`quote`trade!10000 50000]; // specify number of rows per table for merge process mergenumbytes:@[value;`mergenumbytes;500000000]; // default number of bytes for merge process @@ -107,6 +107,7 @@ if[partandmerge and sortafterreplay;(sortafterreplay:0b; .lg.o[`replayinit;"Sett \d .replay .lg.o[`replayinit;"hdb directory is set to ",string hdbdir:hsym hdbdir]; +.lg.o[`replayinit;"tempdir directory is set to ",string tempdir:hsym tempdir]; // the path to the table to save pathtotable:{[h;p;t] `$(string .Q.par[h;partitiontype$p;t]),"/"} From ae94bd285397054cc656a4e1997ba8cdb866e57b Mon Sep 17 00:00:00 2001 From: Rokhaya Gueye Date: Wed, 18 Jun 2025 15:15:32 +0100 Subject: [PATCH 2/2] modified hsym from tempdir --- code/processes/tickerlogreplay.q | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/code/processes/tickerlogreplay.q b/code/processes/tickerlogreplay.q index e0accae7f..03a841e13 100644 --- a/code/processes/tickerlogreplay.q +++ b/code/processes/tickerlogreplay.q @@ -27,7 +27,7 @@ clean:@[value;`clean;1b] // clean sortcsv:@[value;`sortcsv;hsym first .proc.getconfigfile["sort.csv"]] // location of sort csv file compression:@[value;`compression;()]; // specify the compress level, empty list if no required partandmerge:@[value;`partandmerge;0b]; // setting to do a replay where the data is partitioned and then merged on disk -tempdir:hsym @[value;`tempdir;`:tempmergedir]; // location to save data for partandmerge replay +tempdir:@[value;`tempdir;`:tempmergedir]; // location to save data for partandmerge replay mergenumrows:@[value;`mergenumrows;10000000]; // default number of rows for merge process mergenumtab:@[value;`mergenumtab;`quote`trade!10000 50000]; // specify number of rows per table for merge process mergenumbytes:@[value;`mergenumbytes;500000000]; // default number of bytes for merge process