Function transformRecord

plugins/destination/duckdb/client/transform.go:10–21

(sc *arrow.Schema, rec arrow.RecordBatch)

)

func transformRecord(sc *arrow.Schema, rec arrow.RecordBatch) arrow.RecordBatch {
	cols := make([]arrow.Array, rec.NumCols())
	for i := 0; i < int(rec.NumCols()); i++ {
		col := rec.Column(i)
		if _, isList := col.DataType().(arrow.ListLikeType); isList && sc.Field(i).Type.ID() == arrow.STRING {
			cols[i] = transformToStringArray(col)
			continue
		}
		cols[i] = transformArray(col)
	}
	return array.NewRecordBatch(sc, cols, rec.NumRows())
}

func transformArray(arr arrow.Array) arrow.Array {
	if arrow.TypeEqual(arr.DataType(), transformTypeForWriting(arr.DataType())) {