Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- object GeneralLogger {
- val newLogger = LoggerFactory.getLogger(super.getClass)
- val configFile: Config = ConfigFactory.load()
- def SparkLogger(event: ErrorEvent) : Unit = {
- val sparkAppName: String = configFile.getString("spark.appName")
- val sparkMaster: String = configFile.getString("spark.master")
- val sparkCrossJoin: String = configFile.getString("spark.crossJoin")
- val sparkSqlWarehouse: String = configFile.getString("spark.sqlWarehouse")
- val sparkExecutorMemory: String = configFile.getString("spark.sparkExecutorMemory")
- newLogger.info("--- Spark Parameters ---")
- newLogger.info("sparkAppName: " + sparkAppName.toString)
- newLogger.info("sparkMaster: " + sparkMaster.toString)
- newLogger.info("sparkCrossJoin: " + sparkCrossJoin.toString)
- newLogger.info("sparkSqlWarehouse: " + sparkSqlWarehouse.toString)
- newLogger.info("sparkExecutorMemory: " + sparkExecutorMemory.toString)
- }
- def CassandraLogger() : Unit = {
- val cassandraHost: util.List[String] = configFile.getStringList("cassandra.host")
- val cassandraUser: String = configFile.getString("cassandra.username")
- val cassandraKeyspace: String = configFile.getString("cassandra.keyspaces.test")
- val cassandraPassword: String = configFile.getString("cassandra.password")
- newLogger.info("--- Cassandra Parameters ---")
- newLogger.info("cassandraHost: " + cassandraHost.toString)
- newLogger.info("cassandraUser: " + cassandraUser.toString)
- newLogger.info("cassandraKeyspace: " + cassandraKeyspace.toString)
- newLogger.info("cassandraPassword: " + cassandraPassword.toString)
- }
- 2375 [main] INFO c.g.bank.core.utils.GeneralLogger$ - --- Spark Parameters ---
- 2449 [main] INFO c.g.bank.core.utils.GeneralLogger$ - sparkAppName: Flap
- 2375 [main] INFO c.g.bank.core.utils.IncomeNotifier$ - --- Spark Parameters ---
- 2449 [main] INFO c.g.bank.core.utils.IncomeNotifier$ - sparkAppName: Flap
Add Comment
Please, Sign In to add comment