We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eaca17d commit 7fbd13bCopy full SHA for 7fbd13b
1 file changed
sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
@@ -170,6 +170,7 @@ def _bq_uuid(seed=None):
170
else:
171
return str(hashlib.md5(seed.encode('utf8')).hexdigest())
172
173
+
174
def _bq_uuid_list(list):
175
checksum = hashlib.sha256()
176
for item in list:
@@ -178,6 +179,7 @@ def _bq_uuid_list(list):
178
179
checksum.update(b'\x00')
180
return checksum.hexdigest()
181
182
183
class _ShardDestinations(beam.DoFn):
184
"""Adds a shard number to the key of the KV element.
185
0 commit comments