in tools/mc2bq/pkg/schema/schema.go [129:148]
func SerializeObjectToBigQuery(obj protoreflect.Message, root string, schema bigquery.Schema) ([]byte, error) {
serializedObj, err := normalizeToSchema(
obj,
&bigquery.FieldSchema{
Name: root,
Schema: schema,
Type: bigquery.RecordFieldType,
},
)
if err != nil {
return nil, err
}
res, err := json.Marshal(serializedObj)
if err != nil {
return nil, err
}
return append(res, '\n'), err
}