updated api usage

Author: ramitg254

hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/TestHCatMultiOutputFormat.java

@@ -374,7 +374,7 @@ private List<String> getTableData(String table, String database) throws Exceptio
     Hive hive = Hive.get(conf);
     org.apache.hadoop.hive.ql.metadata.Table tbl = hive.getTable(database, table);
     FetchWork work;
-    if (!tbl.getSupportedPartCols().isEmpty()) {
+    if (!tbl.getPartCols().isEmpty()) {
       List<Partition> partitions = hive.getPartitions(tbl);
       List<PartitionDesc> partDesc = new ArrayList<PartitionDesc>();
       List<Path> partLocs = new ArrayList<Path>();

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/AlterTableUtils.java

@@ -75,7 +75,7 @@ public static boolean isSchemaEvolutionEnabled(Table table, Configuration conf)
   }
 
   public static boolean isFullPartitionSpec(Table table, Map<String, String> partitionSpec) {
-    for (FieldSchema partitionCol : table.getNativePartCols()) {
+    for (FieldSchema partitionCol : table.getPartCols()) {
       if (partitionSpec.get(partitionCol.getName()) == null) {
         return false;
       }

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/create/like/CreateTableLikeOperation.java

@@ -100,7 +100,7 @@ private Table createViewLikeTable(Table oldTable) throws HiveException {
     setUserSpecifiedLocation(table);
 
     table.setFields(oldTable.getCols());
-    table.setPartCols(oldTable.getNativePartCols());
+    table.setPartCols(oldTable.getPartCols());
 
     if (desc.getDefaultSerdeProps() != null) {
       for (Map.Entry<String, String> e : desc.getDefaultSerdeProps().entrySet()) {

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/info/desc/DescTableOperation.java

@@ -131,7 +131,7 @@ private void getColumnsNoColumnPath(Table table, Partition partition, List<Field
     cols.addAll(partition == null || table.getTableType() == TableType.VIRTUAL_VIEW ?
         table.getCols() : partition.getCols());
     if (!desc.isFormatted()) {
-      cols.addAll(table.getNativePartCols());
+      cols.addAll(table.getPartCols());
     }
 
     // Fetch partition statistics only for describe extended or formatted.

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/info/show/status/formatter/JsonShowTableStatusFormatter.java

@@ -69,7 +69,7 @@ private Map<String, Object> makeOneTableStatus(Table table, Hive db, HiveConf co
 
     builder.put("partitioned", table.isPartitioned());
     if (table.isPartitioned()) {
-      builder.put("partitionColumns", JsonDescTableFormatter.createColumnsInfo(table.getSupportedPartCols(),
+      builder.put("partitionColumns", JsonDescTableFormatter.createColumnsInfo(table.getPartCols(),
           Collections.emptyList()));
     }
 

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/info/show/status/formatter/TextShowTableStatusFormatter.java

@@ -73,7 +73,7 @@ private void writeStorageInfo(DataOutputStream out, Partition partition, Table t
   private void writeColumnsInfo(DataOutputStream out, Table table) throws IOException, UnsupportedEncodingException {
     String columns = MetaStoreUtils.getDDLFromFieldSchema("columns", table.getCols());
     String partitionColumns = table.isPartitioned() ?
-        MetaStoreUtils.getDDLFromFieldSchema("partition_columns", table.getSupportedPartCols()) : "";
+        MetaStoreUtils.getDDLFromFieldSchema("partition_columns", table.getPartCols()) : "";
 
     out.write(Utilities.newLineCode);
     out.write(("columns:" + columns).getBytes(StandardCharsets.UTF_8));

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/partition/PartitionUtils.java

@@ -23,7 +23,6 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import java.util.Map.Entry;
 
 import org.apache.hadoop.hive.conf.HiveConf;
 import org.apache.hadoop.hive.conf.HiveConf.ConfVars;
@@ -150,7 +149,7 @@ public static List<Partition> getPartitionsWithSpecs(Hive db, Table table, GetPa
   }
 
   private static String tablePartitionColNames(Table table) {
-    List<FieldSchema> partCols = table.getNativePartCols();
+    List<FieldSchema> partCols = table.getPartCols();
     return String.join("/", partCols.toString());
   }
 

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/partition/exchange/AlterTableExchangePartitionAnalyzer.java

@@ -84,7 +84,7 @@ protected void analyzeCommand(TableName tableName, Map<String, String> partition
     if (AcidUtils.isTransactionalTable(sourceTable) || AcidUtils.isTransactionalTable(destTable)) {
       throw new SemanticException(ErrorMsg.EXCHANGE_PARTITION_NOT_ALLOWED_WITH_TRANSACTIONAL_TABLES.getMsg());
     }
-    List<String> sourceProjectFilters = MetaStoreUtils.getPvals(sourceTable.getNativePartCols(), partitionSpecs);
+    List<String> sourceProjectFilters = MetaStoreUtils.getPvals(sourceTable.getPartCols(), partitionSpecs);
 
     // check if source partition exists
     GetPartitionsFilterSpec sourcePartitionsFilterSpec = new GetPartitionsFilterSpec();
@@ -106,7 +106,7 @@ protected void analyzeCommand(TableName tableName, Map<String, String> partition
       throw new SemanticException(ErrorMsg.PARTITION_VALUE_NOT_CONTINUOUS.getMsg(partitionSpecs.toString()));
     }
 
-    List<String> destProjectFilters = MetaStoreUtils.getPvals(destTable.getNativePartCols(), partitionSpecs);
+    List<String> destProjectFilters = MetaStoreUtils.getPvals(destTable.getPartCols(), partitionSpecs);
 
     // check if dest partition exists
     GetPartitionsFilterSpec getDestPartitionsFilterSpec = new GetPartitionsFilterSpec();

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/partition/show/ShowPartitionAnalyzer.java

@@ -102,7 +102,7 @@ ExprNodeDesc getShowPartitionsFilter(Table table, ASTNode command) throws Semant
       if (astChild.getType() == HiveParser.TOK_WHERE) {
         RowResolver rwsch = new RowResolver();
         Map<String, String> colTypes = new HashMap<String, String>();
-        for (FieldSchema fs : table.getSupportedPartCols()) {
+        for (FieldSchema fs : table.getPartCols()) {
           rwsch.put(table.getTableName(), fs.getName(), new ColumnInfo(fs.getName(),
               TypeInfoFactory.stringTypeInfo, null, true));
           colTypes.put(fs.getName().toLowerCase(), fs.getType());
@@ -202,8 +202,8 @@ private String getShowPartitionsOrder(Table table, ASTNode command) throws Seman
       if (astChild.getType() == HiveParser.TOK_ORDERBY) {
         Map<String,  Integer> poses = new HashMap<String, Integer>();
         RowResolver rwsch = new RowResolver();
-        for (int i = 0; i < table.getSupportedPartCols().size(); i++) {
-          FieldSchema fs = table.getSupportedPartCols().get(i);
+        for (int i = 0; i < table.getPartCols().size(); i++) {
+          FieldSchema fs = table.getPartCols().get(i);
           rwsch.put(table.getTableName(), fs.getName(), new ColumnInfo(fs.getName(),
               TypeInfoFactory.getPrimitiveTypeInfo(fs.getType()), null, true));
           poses.put(fs.getName().toLowerCase(), i);

ql/src/java/org/apache/hadoop/hive/ql/ddl/table/storage/archive/AlterTableArchiveOperation.java

@@ -129,7 +129,7 @@ private Path getOriginalDir(Table table, PartSpecInfo partitionSpecInfo, List<Pa
     // in full partition specification case we allow custom locations to keep backward compatibility
     if (partitions.isEmpty()) {
       throw new HiveException("No partition matches the specification");
-    } else if (partitionSpecInfo.values.size() != table.getNativePartCols().size()) {
+    } else if (partitionSpecInfo.values.size() != table.getPartCols().size()) {
       // for partial specifications we need partitions to follow the scheme
       for (Partition partition : partitions) {
         if (AlterTableArchiveUtils.partitionInCustomLocation(table, partition)) {