add env support for sqoop jobs

razorpay · Dec 19, 2024 · d7a22a1 · d7a22a1
1 parent b4f1c26
commit d7a22a1
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/sql-delta-import/src/main/scala/com/razorpay/spark/jdbc/common/Constants.scala b/sql-delta-import/src/main/scala/com/razorpay/spark/jdbc/common/Constants.scala
@@ -1,5 +1,7 @@
 package com.razorpay.spark.jdbc.common
 
+import scala.io.Source
+
 object Constants {
   final val HUDI_DB_PREFIX = "realtime_"
 
@@ -12,7 +14,10 @@ object Constants {
   // seconds
   final val QUERY_TIMEOUT = 10800
 
-  final val CREDSTASH_TABLE_NAME = "credstash-prod-emr-sqoop"
+  val env_file_path = "/opt/env"
+  val env = Source.fromFile(env_file_path).getLines().mkString
+
+  final val CREDSTASH_TABLE_NAME = s"credstash-$env-emr-sqoop"
 
   final val CREATED_DATE = "created_date"
   final val CREATED_AT = "created_at"