There was an error while loading. Please reload this page.
1 parent 185eb99 commit 3461a95Copy full SHA for 3461a95
bigframes/core/local_data.py
@@ -274,10 +274,11 @@ def _(
274
sub_generators[field_name] = iter_array(array.field(field_name), dtype)
275
276
keys = list(sub_generators.keys())
277
- row_values_iter = zip(*sub_generators.values())
278
- is_null_iter = array.is_null()
+ is_null_generator = iter_array(array.is_null(), bigframes.dtypes.BOOL_DTYPE)
279
280
- for is_row_null, row_values in zip(is_null_iter, row_values_iter):
+ for values in zip(is_null_generator, *sub_generators.values()):
+ is_row_null = values[0]
281
+ row_values = values[1:]
282
if not is_row_null:
283
yield {key: value for key, value in zip(keys, row_values)}
284
else:
0 commit comments