withOutFuture.scala

import com.example.core.common.ConfigLoader
import com.example.core.common.DeltaWriter._

object Demo extends App {

  if (args.length < 2) {
    logger.error("No Environment type or Network ID are provided as a argument while running spark job")
    System.exit(1)
  }

  val envType = args(0)
  val NETWORK_ID = Some(args(1))
  val CLIENT_SCHEMA = Some(args(2))
  val APP_NAME: String = s"Demo-${NETWORK_ID.get}"

  val spark = getSparkSession(APP_NAME)

  val configUtility = new ConfigLoader(envType, NETWORK_ID.get.toInt, CLIENT_SCHEMA.get)

  val tableList = List(
      "EXAMPLE_EXCHANGE_RATE_DAILY",
      "EXAMPLE_SETTING",
      "EXAMPLE_HISTORY",
      "EXAMPLE"
  )

  tableList.foreach(t => deltaTableWriteToSQLServer(
    spark, envType, NETWORK_ID.get.toInt, configUtility.CONSUMABLE_DATA,
    CLIENT_SCHEMA.get, t
  ))

}