def getDefaultConn()

in src/main/scala/com/aliyun/emr/example/spark/streaming/SparkHBaseDemo.scala [36:44]

• 9 lines of code
• 3 McCabe index (conditional complexity)

  def getDefaultConn(quorum: String): Connection = {
    if (conf == null && connection == null) {
      conf = HBaseConfiguration.create()
      conf.set(HConstants.ZOOKEEPER_QUORUM, quorum)
      conf.set(HConstants.ZOOKEEPER_ZNODE_PARENT, "/hbase")
      connection = ConnectionFactory.createConnection(conf)
    }
    connection
  }