diff --git a/analyse_properties/debug.py b/analyse_properties/debug.py index ab44457..ae59b79 100644 --- a/analyse_properties/debug.py +++ b/analyse_properties/debug.py @@ -22,3 +22,9 @@ class DebugShowColumnWithValueIn(beam.DoFn): if self.value in column: yield element return None + + +class DebugPrint(beam.DoFn): + def process(self, element): + print(element) + yield element