object ConnectionInstance {

private var conn: Connection =null

  def getConnection(conf: Configuration): Connection = {

if (conn ==null ||conn.isClosed) {

conn = ConnectionFactory.createConnection(conf);

}

conn

  }

}