如何为SparkSQL添加hive中支持的而SparkSQL暂未支持的命令

Partition1: (ds=‘2008-04-08‘, hr=11)
Partition2: (ds=‘2008-04-08‘, hr=12)
Partition3: (ds=‘2008-04-09‘, hr=11)
Partition4: (ds=‘2008-04-09‘, hr=12)

ANALYZE TABLE Table1 PARTITION(ds=‘2008-04-09‘, hr=11) COMPUTE STATISTICS;

ANALYZE TABLE Table1 PARTITION(ds=‘2008-04-09‘, hr) COMPUTE STATISTICS;

ANALYZE TABLE Table1 PARTITION(ds, hr) COMPUTE STATISTICS;

ANALYZE TABLE Table1 COMPUTE STATISTICS;

private[hive] case class AnalyzeTable(tableName: String) extends Command

private[hive] object HiveQl {
　　val tree = getAst(sql)
　　if (nativeCommands contains tree.getText) {
　　　　NativeCommand(sql)
　　} else {
　　　　ifExists) =>
　　　　val tableName = tableNameParts.map { case Token(p, Nil) => p }.mkString(".")
　　　　DropTable(tableName, ifExists.nonEmpty)
    
　　　　// Support "ANALYZE TABLE tableNmae COMPUTE STATISTICS noscan"
　　　　case Token("TOK_ANALYZE",
            Token("TOK_TAB", Token("TOK_TABNAME", tableNameParts) :: partitionSpec) ::
            isNoscan) =>
      
 
　　　　// Reference: https://cwiki.apache.org/confluence/display/Hive/StatsDev#StatsDev-ExistingTables
　　　　if (partitionSpec.nonEmpty) {
       　　// Analyze partitions will be treated as a Hive native command.
        　　NativePlaceholder
　　　　} else if (isNoscan.isEmpty) {
       　　// If users do not specify "noscan", it will be treated as a Hive native command.
        　　NativePlaceholder
　　　　} else {
        　　val tableName = tableNameParts.map { case Token(p, Nil) => p }.mkString(".")
  　　　　　 AnalyzeTable(tableName)
　　　　}
}

case DropTable(tableName, ifExists) => execution.DropTable(tableName, ifExists) :: Nil
case AnalyzeTable(tableName) => execution.AnalyzeTable(tableName) :: Nil
case describe: logical.DescribeCommand =>
    val resolvedTable = context.executePlan(describe.table).analyzed
    resolvedTable match {

/**
 * :: DeveloperApi ::
 * Analyzes the given table in the current database to generate statistics, which will be
 * used in query optimizations.
 *
 * Right now, it only supports Hive tables and it only updates the size of a Hive table
 * in the Hive metastore.
 */
@DeveloperApi
case class AnalyzeTable(tableName: String) extends LeafNode with Command {

　　def hiveContext = sqlContext.asInstanceOf[HiveContext]

　　def output = Seq.empty

　　override protected[sql] lazy val sideEffectResult = {
　　　　hiveContext.analyze(tableName)
　　　　Seq.empty[Any]
　　}

　　override def execute(): RDD[Row] = {
　　　　sideEffectResult
　　　　sparkContext.emptyRDD[Row]
　　}
}

ANALYZE TABLE tableNmae COMPUTE STATISTICS noscan