File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
tensorflow_transform/beam Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -4049,7 +4049,7 @@ def _extract_outputs(self, sums):
40494049 def expand (self , pcoll : beam .PCollection [Tuple [np .ndarray , np .ndarray ]]):
40504050 self .base_temp_dir_in_expand = self .base_temp_dir
40514051 return (pcoll
4052- | beam .FlatMap (lambda baches : list (zip (* baches )))
4052+ | beam .FlatMap (lambda batches : list (zip (* batches )))
40534053 |
40544054 beam .CombineGlobally (lambda values : np .sum (list (values ), axis = 0 ))
40554055 | beam .FlatMap (self ._extract_outputs ).with_outputs ('0' , '1' ))
@@ -4096,7 +4096,7 @@ class _SimpleSumCombiner(tft_beam.experimental.PTransformAnalyzer):
40964096 def expand (self , pcoll : beam .PCollection [Tuple [np .ndarray , np .ndarray ]]):
40974097 return (
40984098 pcoll
4099- | beam .FlatMap (lambda baches : list (zip (* baches )))
4099+ | beam .FlatMap (lambda batches : list (zip (* batches )))
41004100 | beam .CombineGlobally (lambda values : np .sum (list (values ), axis = 0 ))
41014101 | beam .combiners .ToList ()
41024102 | beam .Map (output_fn ))
You can’t perform that action at this time.
0 commit comments