From f91484ca07757482c18e00b4e5ee811d021aed0b Mon Sep 17 00:00:00 2001 From: chrislu Date: Wed, 24 Apr 2024 23:28:20 -0700 Subject: [PATCH] add some notes --- weed/mq/schema/to_schema_value.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/weed/mq/schema/to_schema_value.go b/weed/mq/schema/to_schema_value.go index 5dbab91f4..95cfdcb33 100644 --- a/weed/mq/schema/to_schema_value.go +++ b/weed/mq/schema/to_schema_value.go @@ -6,6 +6,9 @@ import ( "github.com/seaweedfs/seaweedfs/weed/pb/schema_pb" ) +// ToRecordValue converts a parquet.Row to a schema_pb.RecordValue +// This does not work or did not test with nested structures. +// Using this may fail to convert the parquet.Row to schema_pb.RecordValue func ToRecordValue(recordType *schema_pb.RecordType, row parquet.Row) (*schema_pb.RecordValue, error) { values := []parquet.Value(row) recordValue, _, _, err := toRecordValue(recordType, values, 0, 0)