diff options
| author | chrislu <chris.lu@gmail.com> | 2024-04-25 08:54:57 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-04-25 08:54:57 -0700 |
| commit | 313097aca08c5c98e4ad5e50c890a3d7fffd9020 (patch) | |
| tree | 9fade7fc79f216a43509d3a7c2fd7547f463630b | |
| parent | 827e2930105e61a5bb751b46838deea6d27d2f2f (diff) | |
| download | seaweedfs-313097aca08c5c98e4ad5e50c890a3d7fffd9020.tar.xz seaweedfs-313097aca08c5c98e4ad5e50c890a3d7fffd9020.zip | |
printout test values
| -rw-r--r-- | weed/mq/schema/write_parquet_test.go | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/weed/mq/schema/write_parquet_test.go b/weed/mq/schema/write_parquet_test.go index d3ec547ab..454b6cdc4 100644 --- a/weed/mq/schema/write_parquet_test.go +++ b/weed/mq/schema/write_parquet_test.go @@ -10,7 +10,7 @@ import ( "testing" ) -func TestWriteParquet(t *testing.T) { +func TestWriteReadParquet(t *testing.T) { // create a schema_pb.RecordType recordType := NewRecordTypeBuilder(). AddLongField("ID"). @@ -19,7 +19,7 @@ func TestWriteParquet(t *testing.T) { AddStringField("zName"). AddListField("emails", TypeString)). AddStringField("Company"). - AddRecordField("zAddress", NewRecordTypeBuilder(). + AddRecordField("Address", NewRecordTypeBuilder(). AddStringField("Street"). AddStringField("City")).Build() fmt.Printf("RecordType: %v\n", recordType) @@ -77,11 +77,15 @@ func testWritingParquetFile(t *testing.T, count int, filename string, parquetSch AddStringValue("Company", fmt.Sprintf("company_%d", i)).Build() AddRecordValue(rowBuilder, recordType, recordValue) - // fmt.Printf("RecordValue: %v\n", recordValue) + if count < 10 { + fmt.Printf("RecordValue: %v\n", recordValue) + } row := rowBuilder.Row() - // fmt.Printf("Row: %+v\n", row) + if count < 10 { + fmt.Printf("Row: %+v\n", row) + } if err != nil { t.Fatalf("rowBuilder.Build failed: %v", err) |