diff --git a/oonipipeline/src/oonipipeline/analysis/detector.py b/oonipipeline/src/oonipipeline/analysis/detector.py
index 2f5f9df7..bb1c1eb9 100644
--- a/oonipipeline/src/oonipipeline/analysis/detector.py
+++ b/oonipipeline/src/oonipipeline/analysis/detector.py
@@ -205,6 +205,7 @@ def run(self, df: pd.DataFrame, col: str, count_col: str):
                 row["s_neg"] = self.s_neg
                 row["current_mean"] = self.current_mean
                 row["h"] = self.h
+                row["block_type"] = col
                 changepoints.append(row)
                 self._reset()
 
diff --git a/oonipipeline/src/oonipipeline/db/create_tables.py b/oonipipeline/src/oonipipeline/db/create_tables.py
index 0e47f6b5..ffba1422 100644
--- a/oonipipeline/src/oonipipeline/db/create_tables.py
+++ b/oonipipeline/src/oonipipeline/db/create_tables.py
@@ -244,7 +244,8 @@ def make_create_queries():
             `s_pos` Nullable(float),
             `s_neg` Nullable(float),
             `current_mean` Nullable(float),
-            `h` Nullable(float)
+            `h` Nullable(float),
+            `block_type` String
         )
         ENGINE = ReplacingMergeTree
         ORDER BY (probe_asn, probe_cc, ts, domain);