MonetDB: parquet - implement get_metadata

[Mitchell Weggemans]

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

implement get_metadata


diffs (46 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
@@ -23,3 +23,24 @@ struct parquet_file open_file(char* file
 
     return file;
 }
+
+
+struct parquet_table_metadata get_table_metadata(struct parquet_file file) {
+    /* This shouldn't be possible, but check it for good measure */
+    if(file.reader == NULL) {
+        /* Throw error */
+    }
+
+    GError *table_error;
+    GArrowTable *table = gparquet_arrow_file_reader_read_table(file.reader, 
&table_error);
+
+    if(table_error) {
+        printf("%s", table_error->message);
+    }
+
+    guint64 n_rows = garrow_table_get_n_rows(table);
+
+    struct parquet_table_metadata metadata = {"foo", n_rows};
+
+    return metadata;
+}
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
@@ -8,7 +8,14 @@ struct parquet_file {
     GParquetArrowFileReader *reader;
 };
 
+struct parquet_table_metadata {
+    char* table_name;
+    int n_row;
+};
+
 /* Opens the file, and returns a struct containing the reader. */
 struct parquet_file open_file(char* filename);
 
+struct parquet_table_metadata get_table_metadata(struct parquet_file file);
+
 #endif
_______________________________________________
checkin-list mailing list -- checkin-list@monetdb.org
To unsubscribe send an email to checkin-list-le...@monetdb.org