EventhubScheduleJob.scala

object EventhubScheduleJob {
  @transient lazy private val logger = Logger.getLogger(getClass.getName)

  def main(args: Array[String]): Unit = {
    
    // One-time initialization
    val spark = SparkSession.builder()
      .appName(AppName)
      .config(SparkMaster, Local)
      .getOrCreate()

    while(true) {
      try {
        // do something
      } catch {
        // log for investigation
      } finally {
        Thread.sleep(60000) // 1 minute
      }
    }
  }
}