diff options
| -rw-r--r-- | weed/mq/schema/to_schema_value.go | 3 |
1 files changed, 3 insertions, 0 deletions
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) |