start implementation language codes

src/main/resources/app.yml

@@ -3,6 +3,7 @@ app:
   documentTypeLabelsPath: "/home/swissbib/environment/code/repositories/memoriav/gitlab/services/postprocessing/rico-edm-transformer/configs/document_types/labels.csv"
   accessTermLabelsPath: "/home/swissbib/environment/code/repositories/memoriav/gitlab/services/postprocessing/rico-edm-transformer/configs/access_terms/labels.csv"
   reuseStatementLabelsPath: "/home/swissbib/environment/code/repositories/memoriav/gitlab/services/postprocessing/rico-edm-transformer/configs/reuse_statements/labels.csv"
+  isocodemapping: "/home/swissbib/environment/code/repositories/memoriav/gitlab/services/postprocessing/rico-edm-transformer/configs/isocode-693-mapping/labels.csv"
 
 
 

src/main/scala/ch/memobase/rico2edm/KafkaTopology.scala

@@ -26,6 +26,7 @@ import org.apache.kafka.streams.scala.kstream.KStream
 import org.apache.kafka.streams.scala.{StreamsBuilder, _}
 import org.apache.logging.log4j.scala.Logging
 
+import java.util.Properties
 import scala.util.Try
 
 class KafkaTopology extends Logging {
@@ -40,7 +41,8 @@ class KafkaTopology extends Logging {
   def build(
              topicIn: String,
              topicOut: String,
-             reportingTopic: String
+             reportingTopic: String,
+             appSettings: Properties
            ): Topology = {
     val builder = new StreamsBuilder
     val edmBuilder = new EDM
@@ -98,6 +100,8 @@ class KafkaTopology extends Logging {
 
      */
 
+
+
     builder.build()
   }
 

src/main/scala/ch/memobase/rico2edm/Main.scala

@@ -41,19 +41,20 @@ object Main extends Logging {
       "accessTermLabelsPath",
       "reuseStatementLabelsPath"
     ).asJava,*/
-    List().asJava,
+    List("isocodemapping").asJava,
     "app.yml",
     false,
     true,
     false,
     false
   )
-
   val streams = new KafkaStreams(
     topology.build(
       settings.getInputTopic,
       settings.getOutputTopic,
-      settings.getProcessReportTopic
+      settings.getProcessReportTopic,
+      settings.getAppSettings
+
     ),
     settings.getKafkaStreamsSettings
   )