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