Changeset: fc32068f3d3a for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/fc32068f3d3a
Modified Files:
        sql/backends/monet5/vaults/parquet/parquet.c
        sql/server/rel_select.c
Branch: parquet
Log Message:

add parquet to compilation


diffs (86 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
@@ -7,6 +7,15 @@
 #include "rel_file_loader.h"
 
 #include "parquet.h"
+#include "mal_instruction.h"
+#include "mal_interpreter.h"
+#include "mal_runtime.h"
+#include "mal_parser.h"
+#include "mal_builder.h"
+#include "mal_namespace.h"
+#include "mal_debugger.h"
+#include "mal_linker.h"
+#include "mal_utils.h"
 
 parquet_file *parquet_open_file(char* filename) {
     GParquetArrowFileReader *reader;
@@ -61,8 +70,38 @@ parquet_load(sql_subfunc *f, char *filen
        return 0;
 }
 
-void
-parquet_init(void)
+static str
+Parquetprelude(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci)
+{
+    (void)cntxt;
+    (void)mb;
+    (void)stk;
+    (void)pci;
+       fl_register("parquet", &parquet_add_types, &parquet_load);
+    return MAL_SUCCEED;
+}
+
+static str
+Parquetepilogue(void *ret)
 {
-       fl_register("parquet", &parquet_add_types, &parquet_load);
+    (void)ret;
+    return MAL_SUCCEED;
 }
+
+#include "sql_scenario.h"
+#include "mel.h"
+
+static mel_func parquet_init_funcs[] = {
+ pattern("parquet", "prelude", Parquetprelude, false, "", noargs),
+ command("parquet", "epilogue", Parquetepilogue, false, "", noargs),
+{ .imp=NULL }
+};
+
+
+#include "mal_import.h"
+#ifdef _MSC_VER
+#undef read
+#pragma section(".CRT$XCU",read)
+#endif
+LIB_STARTUP_FUNC(init_parquet_mal)
+{ mal_module("parquet", NULL, parquet_init_funcs); }
\ No newline at end of file
diff --git a/sql/server/rel_select.c b/sql/server/rel_select.c
--- a/sql/server/rel_select.c
+++ b/sql/server/rel_select.c
@@ -554,13 +554,13 @@ file_loader_add_table_column_types(sql_s
        }
 
        /* below stuff needs to be in the parquet backend code */
-//#include "../backends/monet5/vaults/parquet/parquet.h"
-
-//     parquet_file *file = open_file(filename);
-
-//     if(file->error) {
-//             return file->error;
-//     }
+       // #include "../backends/monet5/vaults/parquet/parquet.h"
+
+       // parquet_file *file = parquet_open_file(filename);
+
+//     if(file->error) {
+//             return file->error;
+//     }
 
 //     get_table_metadata(file);
 
_______________________________________________
checkin-list mailing list -- checkin-list@monetdb.org
To unsubscribe send an email to checkin-list-le...@monetdb.org

Reply via email to