Skip to content

Commit 9800df2

Browse files
author
maxence
committed
fix: remove batch concurrency support
1 parent 70f3557 commit 9800df2

File tree

4 files changed

+2
-8
lines changed

4 files changed

+2
-8
lines changed

src/parsers/command-options.lisp

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -73,13 +73,10 @@
7373
(bind (((_ _ _ val) batch-size))
7474
(cons :batch-size val))))
7575

76-
;;; deprecated, but still accept it in the parsing
77-
(defrule option-prefetch-rows (and (or (and kw-batch kw-concurrency)
78-
(and kw-prefetch kw-rows))
79-
equal-sign
76+
(defrule option-prefetch-rows (and kw-prefetch kw-rows equal-sign
8077
(+ (digit-char-p character)))
8178
(:lambda (prefetch-rows)
82-
(bind (((_ _ nb) prefetch-rows))
79+
(bind (((_ _ _ nb) prefetch-rows))
8380
(cons :prefetch-rows (parse-integer (text nb))))))
8481

8582
(defrule option-rows-per-range (and kw-rows kw-per kw-range

test/csv-districts-env.load

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@ LOAD CSV
3535
skip header = 1,
3636
batch rows = 200,
3737
batch size = 1024 kB,
38-
batch concurrency = 3,
3938
fields terminated by '\t'
4039

4140
BEFORE LOAD DO

test/csv-districts-stdin.load

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ LOAD CSV
3030
skip header = 1,
3131
batch rows = 200,
3232
batch size = 1024 kB,
33-
batch concurrency = 3,
3433
fields terminated by '\t'
3534

3635
BEFORE LOAD DO

test/csv-districts.load

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,6 @@ LOAD CSV
3434
skip header = 1,
3535
batch rows = 200,
3636
batch size = 1024 kB,
37-
batch concurrency = 3,
3837
fields terminated by '\t'
3938

4039
BEFORE LOAD DO

0 commit comments

Comments
 (0)