We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a2253c1 commit 794ec58Copy full SHA for 794ec58
1 file changed
pkg/result/result.go
@@ -163,16 +163,16 @@ func FromAvro(uri string) (*Result, error) {
163
if !ok {
164
return nil, fmt.Errorf("failed to parse record. unexpected type: %T", recordObject)
165
}
166
- for _, c := range r.Columns {
167
- val := record[c.Name]
168
- if m, ok := val.(map[string]any); ok && len(m) == 1 {
169
- val = extractUnionValue(m, c)
170
- }
171
- if c.IsDecimal() {
172
- val = decodeDecimal(val, c.Scale)
+ for _, c := range r.Columns {
+ val := record[c.Name]
+ if m, ok := val.(map[string]any); ok && len(m) == 1 {
+ val = extractUnionValue(m, c)
+ }
+ if c.IsDecimal() {
+ val = decodeDecimal(val, c.Scale)
173
174
+ row = append(row, val)
175
- row = append(row, val)
176
r.Data = append(r.Data, row)
177
178
0 commit comments