From 214ce77d8f7d0dfd15540e2c4f167c0108d42886 Mon Sep 17 00:00:00 2001
From: Daniel Tomlinson <dtomlinson@panaetius.co.uk>
Date: Sat, 25 Sep 2021 16:47:08 +0100
Subject: [PATCH] adding debug.py

---
 analyse_properties/debug.py | 24 ++++++++++++++++++++++++
 1 file changed, 24 insertions(+)
 create mode 100644 analyse_properties/debug.py

diff --git a/analyse_properties/debug.py b/analyse_properties/debug.py
new file mode 100644
index 0000000..ab44457
--- /dev/null
+++ b/analyse_properties/debug.py
@@ -0,0 +1,24 @@
+import apache_beam as beam
+
+
+class DebugShowEmptyColumn(beam.DoFn):
+    def __init__(self, index):
+        self.index = index
+
+    def process(self, element):
+        column = element[self.index]
+        if len(column) == 0:
+            yield element
+        return None
+
+
+class DebugShowColumnWithValueIn(beam.DoFn):
+    def __init__(self, index, value):
+        self.index = index
+        self.value = value
+
+    def process(self, element):
+        column = element[self.index]
+        if self.value in column:
+            yield element
+        return None