Re: [PR] Add imdb SQL benchmark [datafusion]

via GitHub Mon, 01 Jun 2026 18:34:48 -0700


Copilot commented on code in PR #22680:
URL: https://github.com/apache/datafusion/pull/22680#discussion_r3338091927



##########
benchmarks/sql_benchmarks/imdb/init/cleanup.sql:
##########
@@ -0,0 +1,41 @@
+DROP TABLE aka_name;
+
+DROP TABLE aka_title;
+
+DROP TABLE cast_info;
+
+DROP TABLE char_name;
+
+DROP TABLE comp_cast_type;
+
+DROP TABLE company_name;
+
+DROP TABLE company_type;
+
+DROP TABLE complete_cast;
+
+DROP TABLE info_type;
+
+DROP TABLE keyword;
+
+DROP TABLE kind_type;
+
+DROP TABLE link_type;
+
+DROP TABLE movie_companies;
+
+DROP TABLE movie_info;
+
+DROP TABLE movie_info_idx;
+
+DROP TABLE movie_keyword;
+
+DROP TABLE movie_link;
+
+DROP TABLE name;
+
+DROP TABLE person_info;
+
+DROP TABLE role_type;
+
+DROP TABLE title;

Review Comment:
   Cleanup uses `DROP TABLE` without `IF EXISTS`. This can cause cleanup to 
fail if tables are already dropped / were never created. Prefer `DROP TABLE IF 
EXISTS` (matches other benchmark cleanups).



##########
benchmarks/sql_benchmarks/imdb/benchmarks/08b.benchmark:
##########
@@ -0,0 +1,46 @@
+name Q08b
+group imdb
+
+echo Loading imdb tables
+
+load sql_benchmarks/imdb/init/load_${IMDB_FILE_TYPE:-parquet}.sql
+
+assert I
+SELECT COUNT(*) > 0 from title;
+----
+true
+
+run
+SELECT MIN(an.name) AS acress_pseudonym,

Review Comment:
   Spelling: column alias `acress_pseudonym` looks like a typo. Fixing it makes 
result schemas easier to read/compare.



##########
benchmarks/sql_benchmarks/imdb/benchmarks/01a.benchmark:
##########
@@ -0,0 +1,35 @@
+name Q01a
+group imdb
+
+echo Loading imdb tables
+
+load sql_benchmarks/imdb/init/load_${IMDB_FILE_TYPE:-parquet}.sql
+
+assert I
+SELECT COUNT(*) > 0 from title;
+----
+true
+
+run
+SELECT MIN(mc.note) AS production_note,
+       MIN(t.title) AS movie_title,
+       MIN(t.production_year) AS movie_year
+FROM company_type AS ct,
+     info_type AS it,
+     movie_companies AS mc,
+     movie_info_idx AS mi_idx,
+     title AS t
+WHERE ct.kind = 'production companies'
+  AND it.info = 'top 250 rank'
+  AND mc.note NOT LIKE '%(as Metro-Goldwyn-Mayer Pictures)%'
+  AND (mc.note LIKE '%(co-production)%'
+       OR mc.note LIKE '%(presents)%')
+  AND ct.id = mc.company_type_id
+  AND t.id = mc.movie_id
+  AND t.id = mi_idx.movie_id
+  AND mc.movie_id = mi_idx.movie_id
+  AND it.id = mi_idx.info_type_id;
+
+result sql_benchmarks/imdb/results/01a.csv

Review Comment:
   All IMDB benchmark files reference expected result CSVs under 
`sql_benchmarks/imdb/results/`, but that directory/files are not present in 
this change. As a result, `BENCH_VALIDATE=1` / `SqlBenchmark::verify` won't be 
able to load expected results. Add the expected result CSVs (or switch to 
inline `result_query` blocks / remove `result` directives if validation isn't 
supported yet).



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(8000) NOT NULL,
+    note varchar(387)
+) STORED AS CSV LOCATION 'data/imdb/movie_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info_idx (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(10) NOT NULL,
+    note varchar(1)
+) STORED AS CSV LOCATION 'data/imdb/movie_info_idx.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_keyword (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    keyword_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_link (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    linked_movie_id integer NOT NULL,
+    link_type_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_link.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE name (
+    id integer unsigned NOT NULL,
+    name varchar(106) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    gender varchar(1),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/name.csv' OPTIONS ('has_header' 'false', 
'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE person_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info text NOT NULL,
+    note varchar(430)
+) STORED AS CSV LOCATION 'data/imdb/person_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(8000) NOT NULL,
+    note varchar(387)
+) STORED AS CSV LOCATION 'data/imdb/movie_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info_idx (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(10) NOT NULL,
+    note varchar(1)
+) STORED AS CSV LOCATION 'data/imdb/movie_info_idx.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_keyword (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    keyword_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_link (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    linked_movie_id integer NOT NULL,
+    link_type_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_link.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE name (
+    id integer unsigned NOT NULL,
+    name varchar(106) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    gender varchar(1),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/name.csv' OPTIONS ('has_header' 'false', 
'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(8000) NOT NULL,
+    note varchar(387)
+) STORED AS CSV LOCATION 'data/imdb/movie_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info_idx (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(10) NOT NULL,
+    note varchar(1)
+) STORED AS CSV LOCATION 'data/imdb/movie_info_idx.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_keyword (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    keyword_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_link (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    linked_movie_id integer NOT NULL,
+    link_type_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_link.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE name (
+    id integer unsigned NOT NULL,
+    name varchar(106) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    gender varchar(1),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/name.csv' OPTIONS ('has_header' 'false', 
'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE person_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info text NOT NULL,
+    note varchar(430)
+) STORED AS CSV LOCATION 'data/imdb/person_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE role_type (
+    id integer unsigned NOT NULL,
+    role varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/role_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE title (
+    id integer unsigned NOT NULL,
+    title varchar(334) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    imdb_id integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    series_years varchar(49),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/title.csv' OPTIONS ('has_header' 'false', 
'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/cleanup.sql:
##########
@@ -0,0 +1,41 @@
+DROP TABLE aka_name;
+
+DROP TABLE aka_title;
+
+DROP TABLE cast_info;
+
+DROP TABLE char_name;
+
+DROP TABLE comp_cast_type;
+
+DROP TABLE company_name;
+
+DROP TABLE company_type;
+
+DROP TABLE complete_cast;
+
+DROP TABLE info_type;
+
+DROP TABLE keyword;
+
+DROP TABLE kind_type;

Review Comment:
   Cleanup uses `DROP TABLE` without `IF EXISTS`. This is inconsistent with 
other SQL benchmarks (e.g. TPCH) and can cause cleanup to fail if a prior step 
didn't create a table (or if cleanup is run repeatedly). Prefer `DROP TABLE IF 
EXISTS` for resilience.



##########
benchmarks/sql_benchmarks/imdb/benchmarks/12b.benchmark:
##########
@@ -0,0 +1,46 @@
+name Q12b
+group imdb
+
+echo Loading imdb tables
+
+load sql_benchmarks/imdb/init/load_${IMDB_FILE_TYPE:-parquet}.sql
+
+assert I
+SELECT COUNT(*) > 0 from title;
+----
+true
+
+run
+SELECT MIN(mi.info) AS budget,
+       MIN(t.title) AS unsuccsessful_movie

Review Comment:
   Spelling: column alias `unsuccsessful_movie` looks like a typo. Fixing it 
makes result schemas easier to read/compare.



##########
benchmarks/benches/sql.rs:
##########
@@ -82,7 +82,7 @@ struct EnvParser {
     subgroup: Option<String>,
 
     #[arg(env = "BENCH_QUERY")]
-    query: Option<i32>,
+    query: Option<String>,

Review Comment:
   Changing `BENCH_QUERY` from `Option<i32>` to `Option<String>` means query 
ids may include suffixes (e.g. `6a`, `16c`) or even a leading `Q`. The 
downstream filtering logic in `filter_benchmarks` currently formats 
`Q{query:0>2}` which will not match files like `Q06a` when `BENCH_QUERY=6a`, 
and will produce `QQ..` if a `Q` prefix is provided. Update `filter_benchmarks` 
to normalize the string (strip optional `Q/q` prefix and pad only the numeric 
prefix) so IMDB queries can be selected reliably.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   DataFusion SQL string literals treat backslashes as escape sequences (e.g. 
`\n`, `\t`, `\\`). A trailing backslash (`'\'`) is not a valid escape sequence 
and will fail to parse. Use `'\\'` to represent a single backslash for 
`format.escape`.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(8000) NOT NULL,
+    note varchar(387)
+) STORED AS CSV LOCATION 'data/imdb/movie_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info_idx (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(10) NOT NULL,
+    note varchar(1)
+) STORED AS CSV LOCATION 'data/imdb/movie_info_idx.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_keyword (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    keyword_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(8000) NOT NULL,
+    note varchar(387)
+) STORED AS CSV LOCATION 'data/imdb/movie_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info_idx (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(10) NOT NULL,
+    note varchar(1)
+) STORED AS CSV LOCATION 'data/imdb/movie_info_idx.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(8000) NOT NULL,
+    note varchar(387)
+) STORED AS CSV LOCATION 'data/imdb/movie_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info_idx (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(10) NOT NULL,
+    note varchar(1)
+) STORED AS CSV LOCATION 'data/imdb/movie_info_idx.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_keyword (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    keyword_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_link (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    linked_movie_id integer NOT NULL,
+    link_type_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_link.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(8000) NOT NULL,
+    note varchar(387)
+) STORED AS CSV LOCATION 'data/imdb/movie_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



##########
benchmarks/sql_benchmarks/imdb/init/load_csv.sql:
##########
@@ -0,0 +1,170 @@
+CREATE EXTERNAL TABLE aka_name (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    name varchar(218) NOT NULL,
+    imdb_index varchar(12),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE aka_title (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    title varchar(553) NOT NULL,
+    imdb_index varchar(12),
+    kind_id integer NOT NULL,
+    production_year integer,
+    phonetic_code varchar(5),
+    episode_of_id integer,
+    season_nr integer,
+    episode_nr integer,
+    note varchar(72),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/aka_title.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE cast_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    movie_id integer NOT NULL,
+    person_role_id integer,
+    note varchar(992),
+    nr_order integer,
+    role_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/cast_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE char_name (
+    id integer unsigned NOT NULL,
+    name varchar(478) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/char_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE comp_cast_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/comp_cast_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_name (
+    id integer unsigned NOT NULL,
+    name varchar(200) NOT NULL,
+    country_code varchar(255),
+    imdb_id integer,
+    name_pcode_nf varchar(5),
+    name_pcode_sf varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/company_name.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE company_type (
+    id integer unsigned NOT NULL,
+    kind varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/company_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE complete_cast (
+    id integer unsigned NOT NULL,
+    movie_id integer,
+    subject_id integer NOT NULL,
+    status_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/complete_cast.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE info_type (
+    id integer unsigned NOT NULL,
+    info varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/info_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE keyword (
+    id integer unsigned NOT NULL,
+    keyword varchar(74) NOT NULL,
+    phonetic_code varchar(5)
+) STORED AS CSV LOCATION 'data/imdb/keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE kind_type (
+    id integer unsigned NOT NULL,
+    kind varchar(15) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/kind_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE link_type (
+    id integer unsigned NOT NULL,
+    link varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/link_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_companies (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    company_id integer NOT NULL,
+    company_type_id integer NOT NULL,
+    note varchar(208)
+) STORED AS CSV LOCATION 'data/imdb/movie_companies.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(8000) NOT NULL,
+    note varchar(387)
+) STORED AS CSV LOCATION 'data/imdb/movie_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_info_idx (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info varchar(10) NOT NULL,
+    note varchar(1)
+) STORED AS CSV LOCATION 'data/imdb/movie_info_idx.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_keyword (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    keyword_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_keyword.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE movie_link (
+    id integer unsigned NOT NULL,
+    movie_id integer NOT NULL,
+    linked_movie_id integer NOT NULL,
+    link_type_id integer NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/movie_link.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE name (
+    id integer unsigned NOT NULL,
+    name varchar(106) NOT NULL,
+    imdb_index varchar(12),
+    imdb_id integer,
+    gender varchar(1),
+    name_pcode_cf varchar(5),
+    name_pcode_nf varchar(5),
+    surname_pcode varchar(5),
+    md5sum varchar(32)
+) STORED AS CSV LOCATION 'data/imdb/name.csv' OPTIONS ('has_header' 'false', 
'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE person_info (
+    id integer unsigned NOT NULL,
+    person_id integer NOT NULL,
+    info_type_id integer NOT NULL,
+    info text NOT NULL,
+    note varchar(430)
+) STORED AS CSV LOCATION 'data/imdb/person_info.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');
+
+CREATE EXTERNAL TABLE role_type (
+    id integer unsigned NOT NULL,
+    role varchar(32) NOT NULL
+) STORED AS CSV LOCATION 'data/imdb/role_type.csv' OPTIONS ('has_header' 
'false', 'format.delimiter' ',', 'format.escape' '\');

Review Comment:
   `format.escape` value `'\'` is an invalid trailing escape in DataFusion SQL 
string literals. Use `'\\'` to represent a single backslash.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Re: [PR] Add imdb SQL benchmark [datafusion]

Reply via email to