From 313097aca08c5c98e4ad5e50c890a3d7fffd9020 Mon Sep 17 00:00:00 2001 From: chrislu Date: Thu, 25 Apr 2024 08:54:57 -0700 Subject: [PATCH] printout test values --- weed/mq/schema/write_parquet_test.go | 12 ++++++++---- 1 file 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)