Guest User

Untitled

a guest
Nov 27th, 2017
63
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.96 KB | None | 0 0
  1. object GeneralLogger {
  2.  
  3. val newLogger = LoggerFactory.getLogger(super.getClass)
  4. val configFile: Config = ConfigFactory.load()
  5.  
  6. def SparkLogger(event: ErrorEvent) : Unit = {
  7.  
  8. val sparkAppName: String = configFile.getString("spark.appName")
  9. val sparkMaster: String = configFile.getString("spark.master")
  10. val sparkCrossJoin: String = configFile.getString("spark.crossJoin")
  11. val sparkSqlWarehouse: String = configFile.getString("spark.sqlWarehouse")
  12. val sparkExecutorMemory: String = configFile.getString("spark.sparkExecutorMemory")
  13.  
  14. newLogger.info("--- Spark Parameters ---")
  15. newLogger.info("sparkAppName: " + sparkAppName.toString)
  16. newLogger.info("sparkMaster: " + sparkMaster.toString)
  17. newLogger.info("sparkCrossJoin: " + sparkCrossJoin.toString)
  18. newLogger.info("sparkSqlWarehouse: " + sparkSqlWarehouse.toString)
  19. newLogger.info("sparkExecutorMemory: " + sparkExecutorMemory.toString)
  20.  
  21. }
  22.  
  23. def CassandraLogger() : Unit = {
  24.  
  25. val cassandraHost: util.List[String] = configFile.getStringList("cassandra.host")
  26. val cassandraUser: String = configFile.getString("cassandra.username")
  27. val cassandraKeyspace: String = configFile.getString("cassandra.keyspaces.test")
  28. val cassandraPassword: String = configFile.getString("cassandra.password")
  29.  
  30. newLogger.info("--- Cassandra Parameters ---")
  31. newLogger.info("cassandraHost: " + cassandraHost.toString)
  32. newLogger.info("cassandraUser: " + cassandraUser.toString)
  33. newLogger.info("cassandraKeyspace: " + cassandraKeyspace.toString)
  34. newLogger.info("cassandraPassword: " + cassandraPassword.toString)
  35.  
  36. }
  37.  
  38. 2375 [main] INFO c.g.bank.core.utils.GeneralLogger$ - --- Spark Parameters ---
  39. 2449 [main] INFO c.g.bank.core.utils.GeneralLogger$ - sparkAppName: Flap
  40.  
  41. 2375 [main] INFO c.g.bank.core.utils.IncomeNotifier$ - --- Spark Parameters ---
  42. 2449 [main] INFO c.g.bank.core.utils.IncomeNotifier$ - sparkAppName: Flap
Add Comment
Please, Sign In to add comment