Changeset: c8d1b6eefc1e for MonetDB
URL: https://dev.monetdb.org/hg/MonetDB/rev/c8d1b6eefc1e
Modified Files:
sql/backends/monet5/vaults/parquet/parquet.c
sql/backends/monet5/vaults/parquet/parquet.h
Branch: parquet
Log Message:
implement parquet open_file
diffs (47 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
@@ -0,0 +1,25 @@
+#include "parquet.h"
+
+#include <stdio.h>
+
+#include <parquet-glib/parquet-glib.h>
+#include <parquet-glib/arrow-file-reader.h>
+#include <arrow-glib/arrow-glib.h>
+#include <parquet-glib/metadata.h>
+
+struct parquet_file open_file(char* filename) {
+ GParquetArrowFileReader *reader;
+ GError *error;
+
+ reader = gparquet_arrow_file_reader_new_path(filename, &error);
+
+ if(!reader) {
+ printf("%s", error->message);
+ /* TODO: Throw a SQLState Error. */
+ reader = NULL;
+ }
+
+ struct parquet_file file = { filename, reader };
+
+ return file;
+}
diff --git a/sql/backends/monet5/vaults/parquet/parquet.h
b/sql/backends/monet5/vaults/parquet/parquet.h
--- a/sql/backends/monet5/vaults/parquet/parquet.h
+++ b/sql/backends/monet5/vaults/parquet/parquet.h
@@ -0,0 +1,14 @@
+#ifndef MONET_PARQUET
+#define MONET_PARQUET
+
+#include <parquet-glib/arrow-file-reader.h>
+
+struct parquet_file {
+ char* filename;
+ GParquetArrowFileReader *reader;
+};
+
+/* Opens the file, and returns a struct containing the reader. */
+struct parquet_file open_file(char* filename);
+
+#endif
_______________________________________________
checkin-list mailing list -- [email protected]
To unsubscribe send an email to [email protected]
