address feedback

snowplow · Aug 18, 2023 · 802338a · 802338a
1 parent b784ed5
commit 802338a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...s/core/src/main/scala/com.snowplowanalytics/iglu.schemaddl/redshift/ShredModelEntry.scala b/...s/core/src/main/scala/com.snowplowanalytics/iglu.schemaddl/redshift/ShredModelEntry.scala
@@ -88,7 +88,7 @@ object ShredModelEntry {
     if (s == NullCharacter) "\\\\N"
     else s.replace('\t', ' ').replace('\n', ' ')
 
-  val extraCols = List(
+  private val extraCols = List(
     (""""schema_vendor"""", "VARCHAR(128)", "ENCODE ZSTD", "NOT NULL"),
     (""""schema_name"""", "VARCHAR(128)", "ENCODE ZSTD", "NOT NULL"),
     (""""schema_format"""", "VARCHAR(128)", "ENCODE ZSTD", "NOT NULL"),
@@ -100,6 +100,9 @@ object ShredModelEntry {
     (""""ref_parent"""", "VARCHAR(255)", "ENCODE ZSTD", "NOT NULL")
   )
 
+  /** List of column names common across all shredded tables */
+  val commonColumnNames: List[String] = extraCols.map(_._1.replaceAll(""""""", ""))
+
   sealed trait ColumnType
 
   implicit val showProps: Show[List[ShredModelEntry]] = Show.show(props => {