commit fc0a83927d9db65d421b7080d4fe5d4286e7a58b Author: Vihang Karajgaonkar Date: Thu May 3 10:25:16 2018 -0700 HIVE-19041 : Thrift deserialization of Partition objects should intern fields diff --git a/standalone-metastore/pom.xml b/standalone-metastore/pom.xml index c9eec9ddbc7fb1d843589efb0df36302cf802fdf..13e7d7a43d68bda226546c91cf6c103450c3c808 100644 --- a/standalone-metastore/pom.xml +++ b/standalone-metastore/pom.xml @@ -399,6 +399,12 @@ Partition.java SerDeInfo.java StorageDescriptor.java + AddPartitionsRequest.java + DropPartitionsRequest.java + PartitionsStatsRequest.java + AddDynamicPartitions.java + ColumnStatisticsDesc.java + ColumnStatisticsObj.java ${basedir}/src/main/resources/thrift-replacements.txt true diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java index dd3a127013af7d13fa5b2345dfda80e47bb88403..2e44d483e2dce1659f1d1cb2b023cbe993f5daa3 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java @@ -168,8 +168,8 @@ public AddPartitionsRequest( boolean ifNotExists) { this(); - this.dbName = dbName; - this.tblName = tblName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tblName); this.parts = parts; this.ifNotExists = ifNotExists; setIfNotExistsIsSet(true); @@ -181,10 +181,10 @@ public AddPartitionsRequest( public AddPartitionsRequest(AddPartitionsRequest other) { __isset_bitfield = other.__isset_bitfield; if (other.isSetDbName()) { - this.dbName = other.dbName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.dbName); } if (other.isSetTblName()) { - this.tblName = other.tblName; + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.tblName); } if (other.isSetParts()) { List __this__parts = new ArrayList(other.parts.size()); @@ -196,7 +196,7 @@ public AddPartitionsRequest(AddPartitionsRequest other) { this.ifNotExists = other.ifNotExists; this.needResult = other.needResult; if (other.isSetCatName()) { - this.catName = other.catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.catName); } } @@ -221,7 +221,7 @@ public String getDbName() { } public void setDbName(String dbName) { - this.dbName = dbName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); } public void unsetDbName() { @@ -244,7 +244,7 @@ public String getTblName() { } public void setTblName(String tblName) { - this.tblName = tblName; + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tblName); } public void unsetTblName() { @@ -349,7 +349,7 @@ public String getCatName() { } public void setCatName(String catName) { - this.catName = catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(catName); } public void unsetCatName() { @@ -768,7 +768,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, AddPartitionsReques switch (schemeField.id) { case 1: // DB_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -776,7 +776,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, AddPartitionsReques break; case 2: // TBL_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.tblName = iprot.readString(); + struct.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTblNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -819,7 +819,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, AddPartitionsReques break; case 6: // CAT_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -921,9 +921,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, AddPartitionsReques @Override public void read(org.apache.thrift.protocol.TProtocol prot, AddPartitionsRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); - struct.tblName = iprot.readString(); + struct.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTblNameIsSet(true); { org.apache.thrift.protocol.TList _list487 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); @@ -945,7 +945,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, AddPartitionsRequest struct.setNeedResultIsSet(true); } if (incoming.get(1)) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } } diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java index 0e7075878655895b8b7d17d8357629f186e81c08..44a57f234f89559740525d8fdbff9994b23514aa 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java @@ -166,8 +166,8 @@ public ColumnStatisticsDesc( this(); this.isTblLevel = isTblLevel; setIsTblLevelIsSet(true); - this.dbName = dbName; - this.tableName = tableName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); + this.tableName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tableName); } /** @@ -177,17 +177,17 @@ public ColumnStatisticsDesc(ColumnStatisticsDesc other) { __isset_bitfield = other.__isset_bitfield; this.isTblLevel = other.isTblLevel; if (other.isSetDbName()) { - this.dbName = other.dbName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.dbName); } if (other.isSetTableName()) { - this.tableName = other.tableName; + this.tableName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.tableName); } if (other.isSetPartName()) { this.partName = other.partName; } this.lastAnalyzed = other.lastAnalyzed; if (other.isSetCatName()) { - this.catName = other.catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.catName); } } @@ -234,7 +234,7 @@ public String getDbName() { } public void setDbName(String dbName) { - this.dbName = dbName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); } public void unsetDbName() { @@ -257,7 +257,7 @@ public String getTableName() { } public void setTableName(String tableName) { - this.tableName = tableName; + this.tableName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tableName); } public void unsetTableName() { @@ -325,7 +325,7 @@ public String getCatName() { } public void setCatName(String catName) { - this.catName = catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(catName); } public void unsetCatName() { @@ -750,7 +750,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatisticsDes break; case 2: // DB_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -758,7 +758,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatisticsDes break; case 3: // TABLE_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.tableName = iprot.readString(); + struct.tableName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTableNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -782,7 +782,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatisticsDes break; case 6: // CAT_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -880,9 +880,9 @@ public void read(org.apache.thrift.protocol.TProtocol prot, ColumnStatisticsDesc TTupleProtocol iprot = (TTupleProtocol) prot; struct.isTblLevel = iprot.readBool(); struct.setIsTblLevelIsSet(true); - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); - struct.tableName = iprot.readString(); + struct.tableName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTableNameIsSet(true); BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { @@ -894,7 +894,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, ColumnStatisticsDesc struct.setLastAnalyzedIsSet(true); } if (incoming.get(2)) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } } diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java index 9762478b2d885cd3ae65e5416c09c97acfe7329d..6f9a57fe53fbc7bd09961c42cb8c66b1a57fd431 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java @@ -139,8 +139,8 @@ public ColumnStatisticsObj( ColumnStatisticsData statsData) { this(); - this.colName = colName; - this.colType = colType; + this.colName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(colName); + this.colType = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(colType); this.statsData = statsData; } @@ -149,10 +149,10 @@ public ColumnStatisticsObj( */ public ColumnStatisticsObj(ColumnStatisticsObj other) { if (other.isSetColName()) { - this.colName = other.colName; + this.colName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.colName); } if (other.isSetColType()) { - this.colType = other.colType; + this.colType = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.colType); } if (other.isSetStatsData()) { this.statsData = new ColumnStatisticsData(other.statsData); @@ -175,7 +175,7 @@ public String getColName() { } public void setColName(String colName) { - this.colName = colName; + this.colName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(colName); } public void unsetColName() { @@ -198,7 +198,7 @@ public String getColType() { } public void setColType(String colType) { - this.colType = colType; + this.colType = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(colType); } public void unsetColType() { @@ -503,7 +503,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatisticsObj switch (schemeField.id) { case 1: // COL_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.colName = iprot.readString(); + struct.colName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setColNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -511,7 +511,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, ColumnStatisticsObj break; case 2: // COL_TYPE if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.colType = iprot.readString(); + struct.colType = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setColTypeIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -579,9 +579,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, ColumnStatisticsObj @Override public void read(org.apache.thrift.protocol.TProtocol prot, ColumnStatisticsObj struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - struct.colName = iprot.readString(); + struct.colName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setColNameIsSet(true); - struct.colType = iprot.readString(); + struct.colType = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setColTypeIsSet(true); struct.statsData = new ColumnStatisticsData(); struct.statsData.read(iprot); diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsRequest.java index 443f08e277446d6a7e06e8f664e7341441dd95ba..565a6d076ab7b31c0a40e6559b54886976666e52 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsRequest.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsRequest.java @@ -191,8 +191,8 @@ public DropPartitionsRequest( RequestPartsSpec parts) { this(); - this.dbName = dbName; - this.tblName = tblName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tblName); this.parts = parts; } @@ -202,10 +202,10 @@ public DropPartitionsRequest( public DropPartitionsRequest(DropPartitionsRequest other) { __isset_bitfield = other.__isset_bitfield; if (other.isSetDbName()) { - this.dbName = other.dbName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.dbName); } if (other.isSetTblName()) { - this.tblName = other.tblName; + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.tblName); } if (other.isSetParts()) { this.parts = new RequestPartsSpec(other.parts); @@ -218,7 +218,7 @@ public DropPartitionsRequest(DropPartitionsRequest other) { } this.needResult = other.needResult; if (other.isSetCatName()) { - this.catName = other.catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.catName); } } @@ -248,7 +248,7 @@ public String getDbName() { } public void setDbName(String dbName) { - this.dbName = dbName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); } public void unsetDbName() { @@ -271,7 +271,7 @@ public String getTblName() { } public void setTblName(String tblName) { - this.tblName = tblName; + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tblName); } public void unsetTblName() { @@ -428,7 +428,7 @@ public String getCatName() { } public void setCatName(String catName) { - this.catName = catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(catName); } public void unsetCatName() { @@ -981,7 +981,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, DropPartitionsReque switch (schemeField.id) { case 1: // DB_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -989,7 +989,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, DropPartitionsReque break; case 2: // TBL_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.tblName = iprot.readString(); + struct.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTblNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1047,7 +1047,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, DropPartitionsReque break; case 9: // CAT_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1178,9 +1178,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, DropPartitionsReque @Override public void read(org.apache.thrift.protocol.TProtocol prot, DropPartitionsRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); - struct.tblName = iprot.readString(); + struct.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTblNameIsSet(true); struct.parts = new RequestPartsSpec(); struct.parts.read(iprot); @@ -1208,7 +1208,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, DropPartitionsReques struct.setNeedResultIsSet(true); } if (incoming.get(5)) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } } diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java index ff634081db8e6f0f9752c74fafd7f3ce81dbd312..8f00fbdd246aff755f1071fd2048626ff0a5b50d 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java @@ -491,7 +491,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, FieldSchema struct) switch (schemeField.id) { case 1: // NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.name = iprot.readString(); + struct.name = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -499,7 +499,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, FieldSchema struct) break; case 2: // TYPE if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.type = iprot.readString(); + struct.type = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTypeIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -507,7 +507,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, FieldSchema struct) break; case 3: // COMMENT if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.comment = iprot.readString(); + struct.comment = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCommentIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -585,15 +585,15 @@ public void read(org.apache.thrift.protocol.TProtocol prot, FieldSchema struct) TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { - struct.name = iprot.readString(); + struct.name = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setNameIsSet(true); } if (incoming.get(1)) { - struct.type = iprot.readString(); + struct.type = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTypeIsSet(true); } if (incoming.get(2)) { - struct.comment = iprot.readString(); + struct.comment = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCommentIsSet(true); } } diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java index c58e1cb7d93d2db13ee7e2d7ceddd62f1d8b81ff..51f809a0f8d483d48b69a5a0e75b1c141bc7a716 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java @@ -231,7 +231,7 @@ public Partition(Partition other) { this.privileges = new PrincipalPrivilegeSet(other.privileges); } if (other.isSetCatName()) { - this.catName = other.catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.catName); } } @@ -467,7 +467,7 @@ public String getCatName() { } public void setCatName(String catName) { - this.catName = catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(catName); } public void unsetCatName() { @@ -1029,7 +1029,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Partition struct) t break; case 2: // DB_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1037,7 +1037,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Partition struct) t break; case 3: // TABLE_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.tableName = iprot.readString(); + struct.tableName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTableNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1099,7 +1099,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, Partition struct) t break; case 9: // CAT_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1284,11 +1284,11 @@ public void read(org.apache.thrift.protocol.TProtocol prot, Partition struct) th struct.setValuesIsSet(true); } if (incoming.get(1)) { - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); } if (incoming.get(2)) { - struct.tableName = iprot.readString(); + struct.tableName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTableNameIsSet(true); } if (incoming.get(3)) { @@ -1325,7 +1325,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, Partition struct) th struct.setPrivilegesIsSet(true); } if (incoming.get(8)) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } } diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java index 91cf567e746c9da1c2db39ea1bf229b5f219b1ef..b24a6dd3810282b19c1a9d698d2f73d97ec9d343 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java @@ -157,8 +157,8 @@ public PartitionsStatsRequest( List partNames) { this(); - this.dbName = dbName; - this.tblName = tblName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tblName); this.colNames = colNames; this.partNames = partNames; } @@ -168,10 +168,10 @@ public PartitionsStatsRequest( */ public PartitionsStatsRequest(PartitionsStatsRequest other) { if (other.isSetDbName()) { - this.dbName = other.dbName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.dbName); } if (other.isSetTblName()) { - this.tblName = other.tblName; + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.tblName); } if (other.isSetColNames()) { List __this__colNames = new ArrayList(other.colNames); @@ -182,7 +182,7 @@ public PartitionsStatsRequest(PartitionsStatsRequest other) { this.partNames = __this__partNames; } if (other.isSetCatName()) { - this.catName = other.catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.catName); } } @@ -204,7 +204,7 @@ public String getDbName() { } public void setDbName(String dbName) { - this.dbName = dbName; + this.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); } public void unsetDbName() { @@ -227,7 +227,7 @@ public String getTblName() { } public void setTblName(String tblName) { - this.tblName = tblName; + this.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tblName); } public void unsetTblName() { @@ -326,7 +326,7 @@ public String getCatName() { } public void setCatName(String catName) { - this.catName = catName; + this.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(catName); } public void unsetCatName() { @@ -704,7 +704,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionsStatsRequ switch (schemeField.id) { case 1: // DB_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -712,7 +712,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionsStatsRequ break; case 2: // TBL_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.tblName = iprot.readString(); + struct.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTblNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -756,7 +756,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, PartitionsStatsRequ break; case 5: // CAT_NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -862,9 +862,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsRequ @Override public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - struct.dbName = iprot.readString(); + struct.dbName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDbNameIsSet(true); - struct.tblName = iprot.readString(); + struct.tblName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setTblNameIsSet(true); { org.apache.thrift.protocol.TList _list468 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); @@ -890,7 +890,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsReque struct.setPartNamesIsSet(true); BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { - struct.catName = iprot.readString(); + struct.catName = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setCatNameIsSet(true); } } diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SerDeInfo.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SerDeInfo.java index 71957f79f27927410899c9c6ef83b20fb507371b..671c43efb3353a577b881d1a6327adaf662cb1f7 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SerDeInfo.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SerDeInfo.java @@ -197,10 +197,10 @@ public SerDeInfo(SerDeInfo other) { this.description = other.description; } if (other.isSetSerializerClass()) { - this.serializerClass = other.serializerClass; + this.serializerClass = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.serializerClass); } if (other.isSetDeserializerClass()) { - this.deserializerClass = other.deserializerClass; + this.deserializerClass = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.deserializerClass); } if (other.isSetSerdeType()) { this.serdeType = other.serdeType; @@ -330,7 +330,7 @@ public String getSerializerClass() { } public void setSerializerClass(String serializerClass) { - this.serializerClass = serializerClass; + this.serializerClass = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(serializerClass); } public void unsetSerializerClass() { @@ -353,7 +353,7 @@ public String getDeserializerClass() { } public void setDeserializerClass(String deserializerClass) { - this.deserializerClass = deserializerClass; + this.deserializerClass = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(deserializerClass); } public void unsetDeserializerClass() { @@ -842,7 +842,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, SerDeInfo struct) t switch (schemeField.id) { case 1: // NAME if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.name = iprot.readString(); + struct.name = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setNameIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -850,7 +850,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, SerDeInfo struct) t break; case 2: // SERIALIZATION_LIB if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.serializationLib = iprot.readString(); + struct.serializationLib = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setSerializationLibIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -886,7 +886,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, SerDeInfo struct) t break; case 5: // SERIALIZER_CLASS if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.serializerClass = iprot.readString(); + struct.serializerClass = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setSerializerClassIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -894,7 +894,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, SerDeInfo struct) t break; case 6: // DESERIALIZER_CLASS if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.deserializerClass = iprot.readString(); + struct.deserializerClass = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDeserializerClassIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1047,11 +1047,11 @@ public void read(org.apache.thrift.protocol.TProtocol prot, SerDeInfo struct) th TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(7); if (incoming.get(0)) { - struct.name = iprot.readString(); + struct.name = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setNameIsSet(true); } if (incoming.get(1)) { - struct.serializationLib = iprot.readString(); + struct.serializationLib = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setSerializationLibIsSet(true); } if (incoming.get(2)) { @@ -1074,11 +1074,11 @@ public void read(org.apache.thrift.protocol.TProtocol prot, SerDeInfo struct) th struct.setDescriptionIsSet(true); } if (incoming.get(4)) { - struct.serializerClass = iprot.readString(); + struct.serializerClass = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setSerializerClassIsSet(true); } if (incoming.get(5)) { - struct.deserializerClass = iprot.readString(); + struct.deserializerClass = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setDeserializerClassIsSet(true); } if (incoming.get(6)) { diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java index 00e60417ffedab9666f6fafe67a09c2ee299fed5..3cfa765fc1a57ddbec27153336c0515360c94e5f 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java @@ -1308,7 +1308,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, StorageDescriptor s break; case 2: // LOCATION if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.location = iprot.readString(); + struct.location = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setLocationIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1316,7 +1316,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, StorageDescriptor s break; case 3: // INPUT_FORMAT if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.inputFormat = iprot.readString(); + struct.inputFormat = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setInputFormatIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1324,7 +1324,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, StorageDescriptor s break; case 4: // OUTPUT_FORMAT if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.outputFormat = iprot.readString(); + struct.outputFormat = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setOutputFormatIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); @@ -1368,7 +1368,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, StorageDescriptor s } iprot.readListEnd(); } - struct.setBucketColsIsSet(true); + struct.bucketCols = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(struct.bucketCols); struct.setBucketColsIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -1666,15 +1666,15 @@ public void read(org.apache.thrift.protocol.TProtocol prot, StorageDescriptor st struct.setColsIsSet(true); } if (incoming.get(1)) { - struct.location = iprot.readString(); + struct.location = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setLocationIsSet(true); } if (incoming.get(2)) { - struct.inputFormat = iprot.readString(); + struct.inputFormat = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setInputFormatIsSet(true); } if (incoming.get(3)) { - struct.outputFormat = iprot.readString(); + struct.outputFormat = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot.readString()); struct.setOutputFormatIsSet(true); } if (incoming.get(4)) { @@ -1701,7 +1701,7 @@ public void read(org.apache.thrift.protocol.TProtocol prot, StorageDescriptor st struct.bucketCols.add(_elem189); } } - struct.setBucketColsIsSet(true); + struct.bucketCols = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(struct.bucketCols); struct.setBucketColsIsSet(true); } if (incoming.get(8)) { { diff --git a/standalone-metastore/src/main/resources/thrift-replacements.txt b/standalone-metastore/src/main/resources/thrift-replacements.txt index 01ee71a5b10f30d0514ad4cf41c2c767c1f86e5a..06343ecfa33c2312bd0cbfa883a74583048cf288 100644 --- a/standalone-metastore/src/main/resources/thrift-replacements.txt +++ b/standalone-metastore/src/main/resources/thrift-replacements.txt @@ -35,6 +35,12 @@ this\.inputFormat\ \=\ inputFormat;=this.inputFormat\ \=\ org.apache.hadoop.hive this\.outputFormat\ \=\ outputFormat;=this.outputFormat\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(outputFormat); this\.dbName\ \=\ dbName;=this.dbName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(dbName); this\.tableName\ \=\ tableName;=this.tableName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tableName); +this\.tblName\ \=\ tblName;=this\.tblName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(tblName); +this\.catName\ \=\ catName;=this\.catName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(catName); +this\.serializerClass\ \=\ serializerClass;=this\.serializerClass\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(serializerClass); +this\.deserializerClass\ \=\ deserializerClass;=this\.deserializerClass\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(deserializerClass); +this\.colName\ \=\ colName;=this\.colName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(colName); +this\.colType\ \=\ colType;=this\.colType\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(colType); # Fix constructors and setters of List instance fields @@ -55,6 +61,12 @@ this\.inputFormat\ \=\ other\.inputFormat;=this.inputFormat\ \=\ org.apache.hado this\.outputFormat\ \=\ other\.outputFormat;=this.outputFormat\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.outputFormat); this\.dbName\ \=\ other\.dbName;=this.dbName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.dbName); this\.tableName\ \=\ other\.tableName;=this.tableName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.tableName); +this\.tblName\ \=\ other\.tblName;=this\.tblName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.tblName); +this\.catName\ \=\ other\.catName;=this\.catName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.catName); +this\.serializerClass\ \=\ other\.serializerClass;=this\.serializerClass\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.serializerClass); +this\.deserializerClass\ \=\ other\.deserializerClass;=this\.deserializerClass\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.deserializerClass); +this\.colName\ \=\ other\.colName;=this\.colName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.colName); +this\.colType\ \=\ other\.colType;=this\.colType\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other.colType); __this__parameters_copy_key\ \=\ other_element_key;=__this__parameters_copy_key\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other_element_key); __this__parameters_copy_value\ \=\ other_element_value;=__this__parameters_copy_value\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(other_element_value); @@ -67,3 +79,33 @@ this\.parameters\.put\(key,\ val\);=this.parameters.put(org.apache.hadoop.hive.m # Fix the deserialization methods in Partitions.java: intern parameters after it's deserialized struct\.setParametersIsSet\(true\);=struct.parameters\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(struct.parameters);\ struct.setParametersIsSet(true); + +# Fix the StandardScheme read method which deserializes the fields into the thrift objects + +# PartitionStandardScheme - parameters are already interned above +struct\.dbName\ \=\ iprot\.readString\(\);=struct\.dbName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.tableName\ \=\ iprot\.readString\(\);=struct\.tableName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.catName\ \=\ iprot\.readString\(\);=struct\.catName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); + +# StorageDescriptorStandardScheme - parameters are already interned above +struct\.location\ \=\ iprot\.readString\(\);=struct\.location\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.inputFormat\ \=\ iprot\.readString\(\);=struct\.inputFormat\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.outputFormat\ \=\ iprot\.readString\(\);=struct\.outputFormat\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.setBucketColsIsSet\(true\);=struct\.bucketCols\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(struct.bucketCols);\ struct.setBucketColsIsSet(true); + +# SerDeInfoStandardScheme - parameters are already interned above +struct\.name\ \=\ iprot\.readString\(\);=struct\.name\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.serializationLib\ \=\ iprot\.readString\(\);=struct\.serializationLib\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.serializerClass\ \=\ iprot\.readString\(\);=struct\.serializerClass\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.deserializerClass\ \=\ iprot\.readString\(\);=struct\.deserializerClass\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); + +# FieldSchemaStandardScheme - name field gets automatically handled above +struct\.type\ \=\ iprot\.readString\(\);=struct\.type\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.comment\ \=\ iprot\.readString\(\);=struct\.comment\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); + +# AddPartitionsRequestStandardScheme - other fields are taken care of above +struct\.tblName\ \=\ iprot\.readString\(\);=struct\.tblName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); + +# ColumnStatisticsObjStandardScheme +struct\.colName\ \=\ iprot\.readString\(\);=struct\.colName\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); +struct\.colType\ \=\ iprot\.readString\(\);=struct\.colType\ \=\ org.apache.hadoop.hive.metastore.utils.StringUtils.intern(iprot\.readString\(\)); \ No newline at end of file