lib/impala/cursor.rb in impala-0.3.0 vs lib/impala/cursor.rb in impala-0.3.1
- old
+ new
@@ -97,10 +97,10 @@
def parse_row(raw)
row = {}
fields = raw.split(metadata.delim)
- fields.zip(metadata.schema.fieldSchemas).each do |raw_value, schema|
+ metadata.schema.fieldSchemas.zip(fields).each do |schema, raw_value|
value = convert_raw_value(raw_value, schema)
row[schema.name.to_sym] = value
end
row