From 3b60271904ed6e04e0ecd3ac09170f144aad8b6f Mon Sep 17 00:00:00 2001 From: Jan Gorecki Date: Sun, 30 Jul 2023 08:45:41 +0200 Subject: [PATCH] q10 update r2 rather than v1, duckdb rollfun --- duckdb-latest/rollfun-duckdb-latest.R | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/duckdb-latest/rollfun-duckdb-latest.R b/duckdb-latest/rollfun-duckdb-latest.R index 0cd25780..a202d878 100755 --- a/duckdb-latest/rollfun-duckdb-latest.R +++ b/duckdb-latest/rollfun-duckdb-latest.R @@ -275,7 +275,7 @@ t = system.time({ print(c(nr<-dbGetQuery(con, "SELECT count(*) AS cnt FROM ans")$cnt, nc<-ncol(dbGetQuery(con, "SELECT * FROM ans LIMIT 0")))) })[["elapsed"]] m = memory_usage() -invisible(dbSendQuery(con, sprintf("UPDATE ans SET v1 = NULL WHERE ROWID < %d", w-1))) +invisible(dbSendQuery(con, sprintf("UPDATE ans SET r2 = NULL WHERE ROWID < %d", w-1))) chkt = system.time(chk<-dbGetQuery(con, "SELECT sum(r2) AS r2 FROM ans"))[["elapsed"]] write.log(run=1L, task=task, data=data_name, in_rows=in_nr, question=question, out_rows=nr, out_cols=nc, solution=solution, version=ver, git=git, fun=fun, time_sec=t, mem_gb=m, cache=cache, chk=make_chk(chk), chk_time_sec=chkt, on_disk=on_disk) invisible(dbExecute(con, "DROP TABLE IF EXISTS ans")) @@ -284,7 +284,7 @@ t = system.time({ print(c(nr<-dbGetQuery(con, "SELECT count(*) AS cnt FROM ans")$cnt, nc<-ncol(dbGetQuery(con, "SELECT * FROM ans LIMIT 0")))) })[["elapsed"]] m = memory_usage() -invisible(dbSendQuery(con, sprintf("UPDATE ans SET v1 = NULL WHERE ROWID < %d", w-1))) +invisible(dbSendQuery(con, sprintf("UPDATE ans SET r2 = NULL WHERE ROWID < %d", w-1))) chkt = system.time(chk<-dbGetQuery(con, "SELECT sum(r2) AS r2 FROM ans"))[["elapsed"]] write.log(run=2L, task=task, data=data_name, in_rows=in_nr, question=question, out_rows=nr, out_cols=nc, solution=solution, version=ver, git=git, fun=fun, time_sec=t, mem_gb=m, cache=cache, chk=make_chk(chk), chk_time_sec=chkt, on_disk=on_disk) print(dbGetQuery(con, "SELECT * FROM ans LIMIT 3")) ## head