q10 update r2 rather than v1, duckdb rollfun

duckdblabs · Jul 30, 2023 · 3b60271 · 3b60271
1 parent 657cee0
commit 3b60271
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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