Set prefix for athena externa table if the table belongs to a namespace

metabolicdata · Mar 27, 2024 · 7932028 · 7932028
1 parent c5de1b1
commit 7932028
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/scala/com/metabolic/data/core/services/athena/AthenaAction.scala b/src/main/scala/com/metabolic/data/core/services/athena/AthenaAction.scala
@@ -15,9 +15,12 @@ class AthenaAction extends AfterAction with Logging {
 
     val options = config.environment
 
+    val s3Path = config.sink.asInstanceOf[FileSink].path
+      .replace("version=1/", "")
     val region = options.region
     val dbName = options.dbName
-    val tableName = ConfigUtilsService.getTableName(config)
+    val prefix = ConfigUtilsService.getTablePrefix(options.namespaces, s3Path)
+    val tableName = prefix+ConfigUtilsService.getTableName(config)
 
     val athena = new AthenaCatalogueService()(region)