关于一些技术点的随笔记录（二）

create table A (
     table_code string,
     data_dt string,
     update_dt string)
     clustered by (table_code) into 1 buckets
     row format delimited fields terminated by '33'
     stored as orc -- orc格式
     tablproperties('transactional'='true');

insert into table A values('1','2','3');

FAILED: SemanticException [Error 10265]: This command is not allowed on an ACID table default.a with a non-ACID transaction manager. Failed command: null

val list = List(1, 2, 3, 4, 5, 6)

list match {
    //right其实就代表了一个集合，元素为3，4，5，6
    case List(_, _, right@_*) => println(right)
    case _ =>
}

list match {
    //这种写法错误
    //case l:List(_, _, _*) => println(right)

    //正确写法，下面两种输出结果一致
    case list@ List(_,_, _*) => println(list)
    case list: List[_] => println(list)
}

private def yarn(): Unit = {
    val yarnConf = new YarnConfiguration()
    val yarnClient = YarnClient.createYarnClient()

    yarnClient.init(yarnConf)
    yarnClient.start()

    try {
      import scala.collection.JavaConversions._
      //YarnApplicationState有应用不同的运行状态，如RUNNING、FINISHED
      val applicationReports = yarnClient.getApplications(util.EnumSet.of(YarnApplicationState.RUNNING))

      applicationReports.foreach { ar =>
        //应用ID，spark.app.id
        println(s"appId ==> ${ar.getApplicationId}")
        //应用名字，spark.app.name
        println(s"name ==> ${ar.getName}")
        //应用所处队列，spark.yarn.queue
        println(s"queue ==> ${ar.getQueue}")
        //应用的用户
        println(s"user ==> ${ar.getUser}")
      }

    } catch {
      case e: Exception => e.printStackTrace()
    }

    yarnClient.stop()
 }