func SerializeObjectToBigQuery()

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
}