adding debug print

This commit is contained in:
2021-09-27 21:17:49 +01:00
parent f9eeb8bfad
commit dffc6aa553

View File

@@ -22,3 +22,9 @@ class DebugShowColumnWithValueIn(beam.DoFn):
if self.value in column: if self.value in column:
yield element yield element
return None return None
class DebugPrint(beam.DoFn):
def process(self, element):
print(element)
yield element