robertwb commented on a change in pull request #12971:
URL: https://github.com/apache/beam/pull/12971#discussion_r502090932
##
File path: sdks/python/apache_beam/dataframe/transforms.py
##
@@ -166,16 +173,40 @@ def expand(self, pcolls):
partitioned_pcoll = next(pcoll
robertwb commented on a change in pull request #12971:
URL: https://github.com/apache/beam/pull/12971#discussion_r502090932
##
File path: sdks/python/apache_beam/dataframe/transforms.py
##
@@ -166,16 +173,40 @@ def expand(self, pcolls):
partitioned_pcoll = next(pcoll