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 -- [email protected]
To unsubscribe send an email to [email protected]
