diff options
| -rw-r--r-- | weed/mq/schema/write_parquet_test.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/mq/schema/write_parquet_test.go b/weed/mq/schema/write_parquet_test.go index 2b1fabdfd..d3ec547ab 100644 --- a/weed/mq/schema/write_parquet_test.go +++ b/weed/mq/schema/write_parquet_test.go @@ -18,7 +18,10 @@ func TestWriteParquet(t *testing.T) { AddRecordField("Person", NewRecordTypeBuilder(). AddStringField("zName"). AddListField("emails", TypeString)). - AddStringField("Company").Build() + AddStringField("Company"). + AddRecordField("zAddress", NewRecordTypeBuilder(). + AddStringField("Street"). + AddStringField("City")).Build() fmt.Printf("RecordType: %v\n", recordType) // create a parquet schema |