We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 560aa8d commit 31b469bCopy full SHA for 31b469b
1 file changed
sdks/python/apache_beam/io/filebasedio_perf_test.py
@@ -73,6 +73,9 @@ class SyntheticRecordToStrFn(beam.DoFn):
73
"""
74
A DoFn that convert key-value bytes from synthetic source to string record.
75
76
+ It uses base64 to convert random bytes emitted from the synthetic source.
77
+ Therefore, every 3 bytes give 4 bytes long ascii characters.
78
+
79
Output length = 4(ceil[len(key)/3] + ceil[len(value)/3]) + 1
80
81
def process(self, element):
0 commit comments