From c2aaf24632551dca7ba411aa1070ac9f908f7254 Mon Sep 17 00:00:00 2001 From: Craig Swank Date: Sun, 8 Sep 2019 07:51:34 -0600 Subject: [PATCH] Use struct tags when generating via parquet --- examples/via_parquet/main.go | 4 ---- internal/structs/structs.go | 2 +- 2 files changed, 1 insertion(+), 5 deletions(-) diff --git a/examples/via_parquet/main.go b/examples/via_parquet/main.go index 78a5201..2b48138 100644 --- a/examples/via_parquet/main.go +++ b/examples/via_parquet/main.go @@ -26,8 +26,4 @@ func main() { r.Scan(&p) enc.Encode(p) } - - if err := r.Error(); err != nil { - log.Fatal(err) - } } diff --git a/internal/structs/structs.go b/internal/structs/structs.go index db01cb4..4065549 100644 --- a/internal/structs/structs.go +++ b/internal/structs/structs.go @@ -53,7 +53,7 @@ func field(elem *sch.SchemaElement) string { if elem.RepetitionType != nil && *elem.RepetitionType == sch.FieldRepetitionType_OPTIONAL { ptr = "*" } - return fmt.Sprintf("%s %s%s", n, ptr, t) + return fmt.Sprintf("%s %s%s `parquet:\"%s\"`", n, ptr, t, elem.Name) } func getType(t string) string {