Debug descriptor

snowplow-incubator · May 6, 2024 · a96e8a2 · a96e8a2
1 parent 9022980
commit a96e8a2
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/...c/main/scala/com.snowplowanalytics.snowplow.bigquery/processing/BigQuerySchemaUtils.scala b/...c/main/scala/com.snowplowanalytics.snowplow.bigquery/processing/BigQuerySchemaUtils.scala
@@ -144,7 +144,16 @@ object BigQuerySchemaUtils {
 
   def showDescriptor(descriptor: Descriptors.Descriptor): String =
     descriptor.getFields.asScala
-      .map(_.getName)
+      .map { field =>
+        val name      = field.getName
+        val fieldType = field.getType
+        if (field.getType == Descriptors.FieldDescriptor.Type.MESSAGE) {
+          val nested = showDescriptor(field.getMessageType)
+          s"$name : $fieldType - nested {$nested}"
+        } else {
+          s"$name : $fieldType"
+        }
+      }
       .mkString(", ")
 
 }