o Adding a MQTT consumer that stores the parsed record in Cassandra.

1 files changed, 12 insertions, 1 deletions

diff --git a/README.md b/README.md
index 91681e4..5d39e63 100644
--- a/README.md
+++ b/README.md
@@ -1,4 +1,4 @@
-# Schema
+# Soil Moisture Schema
 
     CREATE TABLE sm_by_day (
         device text,
@@ -11,6 +11,17 @@
         )
     );
 
+# Raw Schema
+
+    CREATE TABLE raw_record (
+        day text,
+        timestamp timestamp,
+        records list<frozen<tuple<text, text>>>,
+        PRIMARY KEY (
+            (day), 
+            timestamp
+        )
+    );
 
 # Create Schema