diff options
| author | chrislu <chris.lu@gmail.com> | 2024-04-24 23:28:20 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-04-24 23:28:20 -0700 |
| commit | f91484ca07757482c18e00b4e5ee811d021aed0b (patch) | |
| tree | f8b8321f7172502dc7d4fc3c4cb4bdd790f19062 | |
| parent | f93c4cf48cc48fa76905b3a2e6e5ac15e6af5a1e (diff) | |
| download | seaweedfs-f91484ca07757482c18e00b4e5ee811d021aed0b.tar.xz seaweedfs-f91484ca07757482c18e00b4e5ee811d021aed0b.zip | |
add some notes
| -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) |