Add ingestion workflow logic

pipeline/spanner/pom.xml

@@ -76,4 +76,15 @@
             <scope>test</scope>
         </dependency>
     </dependencies>
+
+    <build>
+        <resources>
+            <resource>
+                <directory>../workflow/ingestion-helper</directory>
+                <includes>
+                    <include>schema.sql</include>
+                </includes>
+            </resource>
+        </resources>
+    </build>
 </project>

pipeline/spanner/src/main/java/org/datacommons/ingestion/spanner/SpannerClient.java

@@ -231,17 +231,17 @@ public void validateOrInitializeDatabase() {
     }
   }
 
-  /** Reads DDL statements from the spanner_schema.sql file in the resources directory. */
+  /** Reads DDL statements from the schema.sql file in the resources directory. */
   List<String> readDdlStatements() {
-    InputStream inputStream = getClass().getClassLoader().getResourceAsStream("spanner_schema.sql");
+    InputStream inputStream = getClass().getClassLoader().getResourceAsStream("schema.sql");
     if (inputStream == null) {
-      throw new IllegalStateException("Could not find spanner_schema.sql in resources.");
+      throw new IllegalStateException("Could not find schema.sql in resources.");
     }
     try (BufferedReader reader =
         new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8))) {
       return parseDdlStatements(reader);
     } catch (IOException e) {
-      throw new IllegalStateException("Failed to read spanner_schema.sql", e);
+      throw new IllegalStateException("Failed to read schema.sql", e);
     }
   }