Function transformRecord

plugins/destination/mysql/client/transformer.go:65–79

(record arrow.RecordBatch)

}

func transformRecord(record arrow.RecordBatch) ([][]any, error) {
	res := make([][]any, record.NumRows())
	var err error
	for i := int64(0); i < record.NumRows(); i++ {
		row := make([]any, record.NumCols())
		for j := 0; int64(j) < record.NumCols(); j++ {
			row[j], err = getValue(record.Column(j), int(i))
			if err != nil {
				return nil, err
			}
		}
		res[i] = row
	}
	return res, nil
}