diff options
| author | chrislu <chris.lu@gmail.com> | 2024-04-24 23:33:11 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-04-24 23:33:11 -0700 |
| commit | 138a027a2e0056f474f8cf59c79f7fa203077006 (patch) | |
| tree | fb9bc5bc69ec0c2557f14521732683ba17c2c01e | |
| parent | 30b5aef62e216b62c47dec063388bbac58b0d0e3 (diff) | |
| download | seaweedfs-138a027a2e0056f474f8cf59c79f7fa203077006.tar.xz seaweedfs-138a027a2e0056f474f8cf59c79f7fa203077006.zip | |
add field types but without value
| -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 |