Function transformRecord

plugins/destination/sqlite/client/transformer.go:49–60

(record arrow.RecordBatch)

}

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