Changeset: c57dcd272e8f for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/c57dcd272e8f
Modified Files:
sql/backends/monet5/vaults/parquet/parquet.c
sql/server/rel_file_loader.c
Branch: parquet
Log Message:
todo: handle reregistering of file_loader
small cleanup in parquet add
diffs (36 lines):
diff --git a/sql/backends/monet5/vaults/parquet/parquet.c
b/sql/backends/monet5/vaults/parquet/parquet.c
--- a/sql/backends/monet5/vaults/parquet/parquet.c
+++ b/sql/backends/monet5/vaults/parquet/parquet.c
@@ -145,7 +145,6 @@ parquet_add_types(mvc *sql, sql_subfunc
guint n_columns = garrow_table_get_n_columns(table);
list *types = sa_list(sql->sa);
- list *col_names = sa_list(sql->sa);
if (!tname)
tname = "parquet";
@@ -172,7 +171,6 @@ parquet_add_types(mvc *sql, sql_subfunc
(void)table;
/* cleanup tbl */
f->res = types;
- f->colnames = col_names;
/* close file */
GDKfree(file);
diff --git a/sql/server/rel_file_loader.c b/sql/server/rel_file_loader.c
--- a/sql/server/rel_file_loader.c
+++ b/sql/server/rel_file_loader.c
@@ -17,6 +17,13 @@ fl_exit(void)
int
fl_register(char *name, fl_add_types_fptr add_types, fl_load_fptr load)
{
+ file_loader_t *fl = fl_find(name);
+
+ if (fl) {
+ printf("re-registering %s\n", name);
+ GDKfree(fl->name);
+ fl->name = NULL;
+ }
for (int i = 0; i<NR_FILE_LOADERS; i++) {
if (file_loaders[i].name == NULL) {
file_loaders[i].name = GDKstrdup(name);
_______________________________________________
checkin-list mailing list -- [email protected]
To unsubscribe send an email to [email protected]
