From dffc6aa553815aa3eb5f0e09b5fef8a7ec514837 Mon Sep 17 00:00:00 2001 From: Daniel Tomlinson Date: Mon, 27 Sep 2021 21:17:49 +0100 Subject: [PATCH] adding debug print --- analyse_properties/debug.py | 6 ++++++ 1 file changed, 6 insertions(+) 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