http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SerDeInfo.java ---------------------------------------------------------------------- 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 a7aba9f..71957f7 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 @@ -859,15 +859,15 @@ import org.slf4j.LoggerFactory; case 3: // PARAMETERS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map104 = iprot.readMapBegin(); - struct.parameters = new HashMap<String,String>(2*_map104.size); - String _key105; - String _val106; - for (int _i107 = 0; _i107 < _map104.size; ++_i107) + org.apache.thrift.protocol.TMap _map112 = iprot.readMapBegin(); + struct.parameters = new HashMap<String,String>(2*_map112.size); + String _key113; + String _val114; + for (int _i115 = 0; _i115 < _map112.size; ++_i115) { - _key105 = iprot.readString(); - _val106 = iprot.readString(); - struct.parameters.put(_key105, _val106); + _key113 = iprot.readString(); + _val114 = iprot.readString(); + struct.parameters.put(_key113, _val114); } iprot.readMapEnd(); } @@ -935,10 +935,10 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(PARAMETERS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.parameters.size())); - for (Map.Entry<String, String> _iter108 : struct.parameters.entrySet()) + for (Map.Entry<String, String> _iter116 : struct.parameters.entrySet()) { - oprot.writeString(_iter108.getKey()); - oprot.writeString(_iter108.getValue()); + oprot.writeString(_iter116.getKey()); + oprot.writeString(_iter116.getValue()); } oprot.writeMapEnd(); } @@ -1021,10 +1021,10 @@ import org.slf4j.LoggerFactory; if (struct.isSetParameters()) { { oprot.writeI32(struct.parameters.size()); - for (Map.Entry<String, String> _iter109 : struct.parameters.entrySet()) + for (Map.Entry<String, String> _iter117 : struct.parameters.entrySet()) { - oprot.writeString(_iter109.getKey()); - oprot.writeString(_iter109.getValue()); + oprot.writeString(_iter117.getKey()); + oprot.writeString(_iter117.getValue()); } } } @@ -1056,15 +1056,15 @@ import org.slf4j.LoggerFactory; } if (incoming.get(2)) { { - org.apache.thrift.protocol.TMap _map110 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.parameters = new HashMap<String,String>(2*_map110.size); - String _key111; - String _val112; - for (int _i113 = 0; _i113 < _map110.size; ++_i113) + org.apache.thrift.protocol.TMap _map118 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.parameters = new HashMap<String,String>(2*_map118.size); + String _key119; + String _val120; + for (int _i121 = 0; _i121 < _map118.size; ++_i121) { - _key111 = iprot.readString(); - _val112 = iprot.readString(); - struct.parameters.put(_key111, _val112); + _key119 = iprot.readString(); + _val120 = iprot.readString(); + struct.parameters.put(_key119, _val120); } } struct.parameters = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(struct.parameters); struct.setParametersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java index dd95409..a0ae84e 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java @@ -435,14 +435,14 @@ import org.slf4j.LoggerFactory; case 1: // COL_STATS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list276 = iprot.readListBegin(); - struct.colStats = new ArrayList<ColumnStatistics>(_list276.size); - ColumnStatistics _elem277; - for (int _i278 = 0; _i278 < _list276.size; ++_i278) + org.apache.thrift.protocol.TList _list284 = iprot.readListBegin(); + struct.colStats = new ArrayList<ColumnStatistics>(_list284.size); + ColumnStatistics _elem285; + for (int _i286 = 0; _i286 < _list284.size; ++_i286) { - _elem277 = new ColumnStatistics(); - _elem277.read(iprot); - struct.colStats.add(_elem277); + _elem285 = new ColumnStatistics(); + _elem285.read(iprot); + struct.colStats.add(_elem285); } iprot.readListEnd(); } @@ -476,9 +476,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(COL_STATS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.colStats.size())); - for (ColumnStatistics _iter279 : struct.colStats) + for (ColumnStatistics _iter287 : struct.colStats) { - _iter279.write(oprot); + _iter287.write(oprot); } oprot.writeListEnd(); } @@ -508,9 +508,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.colStats.size()); - for (ColumnStatistics _iter280 : struct.colStats) + for (ColumnStatistics _iter288 : struct.colStats) { - _iter280.write(oprot); + _iter288.write(oprot); } } BitSet optionals = new BitSet(); @@ -527,14 +527,14 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, SetPartitionsStatsRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list281 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.colStats = new ArrayList<ColumnStatistics>(_list281.size); - ColumnStatistics _elem282; - for (int _i283 = 0; _i283 < _list281.size; ++_i283) + org.apache.thrift.protocol.TList _list289 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.colStats = new ArrayList<ColumnStatistics>(_list289.size); + ColumnStatistics _elem290; + for (int _i291 = 0; _i291 < _list289.size; ++_i291) { - _elem282 = new ColumnStatistics(); - _elem282.read(iprot); - struct.colStats.add(_elem282); + _elem290 = new ColumnStatistics(); + _elem290.read(iprot); + struct.colStats.add(_elem290); } } struct.setColStatsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java index dd1366b..35d6d24 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java @@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory; case 1: // COMPACTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list660 = iprot.readListBegin(); - struct.compacts = new ArrayList<ShowCompactResponseElement>(_list660.size); - ShowCompactResponseElement _elem661; - for (int _i662 = 0; _i662 < _list660.size; ++_i662) + org.apache.thrift.protocol.TList _list668 = iprot.readListBegin(); + struct.compacts = new ArrayList<ShowCompactResponseElement>(_list668.size); + ShowCompactResponseElement _elem669; + for (int _i670 = 0; _i670 < _list668.size; ++_i670) { - _elem661 = new ShowCompactResponseElement(); - _elem661.read(iprot); - struct.compacts.add(_elem661); + _elem669 = new ShowCompactResponseElement(); + _elem669.read(iprot); + struct.compacts.add(_elem669); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(COMPACTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size())); - for (ShowCompactResponseElement _iter663 : struct.compacts) + for (ShowCompactResponseElement _iter671 : struct.compacts) { - _iter663.write(oprot); + _iter671.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.compacts.size()); - for (ShowCompactResponseElement _iter664 : struct.compacts) + for (ShowCompactResponseElement _iter672 : struct.compacts) { - _iter664.write(oprot); + _iter672.write(oprot); } } } @@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list665 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.compacts = new ArrayList<ShowCompactResponseElement>(_list665.size); - ShowCompactResponseElement _elem666; - for (int _i667 = 0; _i667 < _list665.size; ++_i667) + org.apache.thrift.protocol.TList _list673 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.compacts = new ArrayList<ShowCompactResponseElement>(_list673.size); + ShowCompactResponseElement _elem674; + for (int _i675 = 0; _i675 < _list673.size; ++_i675) { - _elem666 = new ShowCompactResponseElement(); - _elem666.read(iprot); - struct.compacts.add(_elem666); + _elem674 = new ShowCompactResponseElement(); + _elem674.read(iprot); + struct.compacts.add(_elem674); } } struct.setCompactsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java index 941f756..c8fd20e 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java @@ -350,14 +350,14 @@ import org.slf4j.LoggerFactory; case 1: // LOCKS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list626 = iprot.readListBegin(); - struct.locks = new ArrayList<ShowLocksResponseElement>(_list626.size); - ShowLocksResponseElement _elem627; - for (int _i628 = 0; _i628 < _list626.size; ++_i628) + org.apache.thrift.protocol.TList _list634 = iprot.readListBegin(); + struct.locks = new ArrayList<ShowLocksResponseElement>(_list634.size); + ShowLocksResponseElement _elem635; + for (int _i636 = 0; _i636 < _list634.size; ++_i636) { - _elem627 = new ShowLocksResponseElement(); - _elem627.read(iprot); - struct.locks.add(_elem627); + _elem635 = new ShowLocksResponseElement(); + _elem635.read(iprot); + struct.locks.add(_elem635); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(LOCKS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.locks.size())); - for (ShowLocksResponseElement _iter629 : struct.locks) + for (ShowLocksResponseElement _iter637 : struct.locks) { - _iter629.write(oprot); + _iter637.write(oprot); } oprot.writeListEnd(); } @@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetLocks()) { { oprot.writeI32(struct.locks.size()); - for (ShowLocksResponseElement _iter630 : struct.locks) + for (ShowLocksResponseElement _iter638 : struct.locks) { - _iter630.write(oprot); + _iter638.write(oprot); } } } @@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.locks = new ArrayList<ShowLocksResponseElement>(_list631.size); - ShowLocksResponseElement _elem632; - for (int _i633 = 0; _i633 < _list631.size; ++_i633) + org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.locks = new ArrayList<ShowLocksResponseElement>(_list639.size); + ShowLocksResponseElement _elem640; + for (int _i641 = 0; _i641 < _list639.size; ++_i641) { - _elem632 = new ShowLocksResponseElement(); - _elem632.read(iprot); - struct.locks.add(_elem632); + _elem640 = new ShowLocksResponseElement(); + _elem640.read(iprot); + struct.locks.add(_elem640); } } struct.setLocksIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java index a391f94..89fe49a 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java @@ -557,13 +557,13 @@ import org.slf4j.LoggerFactory; case 1: // SKEWED_COL_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list114 = iprot.readListBegin(); - struct.skewedColNames = new ArrayList<String>(_list114.size); - String _elem115; - for (int _i116 = 0; _i116 < _list114.size; ++_i116) + org.apache.thrift.protocol.TList _list122 = iprot.readListBegin(); + struct.skewedColNames = new ArrayList<String>(_list122.size); + String _elem123; + for (int _i124 = 0; _i124 < _list122.size; ++_i124) { - _elem115 = iprot.readString(); - struct.skewedColNames.add(_elem115); + _elem123 = iprot.readString(); + struct.skewedColNames.add(_elem123); } iprot.readListEnd(); } @@ -575,23 +575,23 @@ import org.slf4j.LoggerFactory; case 2: // SKEWED_COL_VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list117 = iprot.readListBegin(); - struct.skewedColValues = new ArrayList<List<String>>(_list117.size); - List<String> _elem118; - for (int _i119 = 0; _i119 < _list117.size; ++_i119) + org.apache.thrift.protocol.TList _list125 = iprot.readListBegin(); + struct.skewedColValues = new ArrayList<List<String>>(_list125.size); + List<String> _elem126; + for (int _i127 = 0; _i127 < _list125.size; ++_i127) { { - org.apache.thrift.protocol.TList _list120 = iprot.readListBegin(); - _elem118 = new ArrayList<String>(_list120.size); - String _elem121; - for (int _i122 = 0; _i122 < _list120.size; ++_i122) + org.apache.thrift.protocol.TList _list128 = iprot.readListBegin(); + _elem126 = new ArrayList<String>(_list128.size); + String _elem129; + for (int _i130 = 0; _i130 < _list128.size; ++_i130) { - _elem121 = iprot.readString(); - _elem118.add(_elem121); + _elem129 = iprot.readString(); + _elem126.add(_elem129); } iprot.readListEnd(); } - struct.skewedColValues.add(_elem118); + struct.skewedColValues.add(_elem126); } iprot.readListEnd(); } @@ -603,25 +603,25 @@ import org.slf4j.LoggerFactory; case 3: // SKEWED_COL_VALUE_LOCATION_MAPS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map123 = iprot.readMapBegin(); - struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map123.size); - List<String> _key124; - String _val125; - for (int _i126 = 0; _i126 < _map123.size; ++_i126) + org.apache.thrift.protocol.TMap _map131 = iprot.readMapBegin(); + struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map131.size); + List<String> _key132; + String _val133; + for (int _i134 = 0; _i134 < _map131.size; ++_i134) { { - org.apache.thrift.protocol.TList _list127 = iprot.readListBegin(); - _key124 = new ArrayList<String>(_list127.size); - String _elem128; - for (int _i129 = 0; _i129 < _list127.size; ++_i129) + org.apache.thrift.protocol.TList _list135 = iprot.readListBegin(); + _key132 = new ArrayList<String>(_list135.size); + String _elem136; + for (int _i137 = 0; _i137 < _list135.size; ++_i137) { - _elem128 = iprot.readString(); - _key124.add(_elem128); + _elem136 = iprot.readString(); + _key132.add(_elem136); } iprot.readListEnd(); } - _val125 = iprot.readString(); - struct.skewedColValueLocationMaps.put(_key124, _val125); + _val133 = iprot.readString(); + struct.skewedColValueLocationMaps.put(_key132, _val133); } iprot.readMapEnd(); } @@ -647,9 +647,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(SKEWED_COL_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.skewedColNames.size())); - for (String _iter130 : struct.skewedColNames) + for (String _iter138 : struct.skewedColNames) { - oprot.writeString(_iter130); + oprot.writeString(_iter138); } oprot.writeListEnd(); } @@ -659,13 +659,13 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(SKEWED_COL_VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, struct.skewedColValues.size())); - for (List<String> _iter131 : struct.skewedColValues) + for (List<String> _iter139 : struct.skewedColValues) { { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter131.size())); - for (String _iter132 : _iter131) + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter139.size())); + for (String _iter140 : _iter139) { - oprot.writeString(_iter132); + oprot.writeString(_iter140); } oprot.writeListEnd(); } @@ -678,17 +678,17 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(SKEWED_COL_VALUE_LOCATION_MAPS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRING, struct.skewedColValueLocationMaps.size())); - for (Map.Entry<List<String>, String> _iter133 : struct.skewedColValueLocationMaps.entrySet()) + for (Map.Entry<List<String>, String> _iter141 : struct.skewedColValueLocationMaps.entrySet()) { { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter133.getKey().size())); - for (String _iter134 : _iter133.getKey()) + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, _iter141.getKey().size())); + for (String _iter142 : _iter141.getKey()) { - oprot.writeString(_iter134); + oprot.writeString(_iter142); } oprot.writeListEnd(); } - oprot.writeString(_iter133.getValue()); + oprot.writeString(_iter141.getValue()); } oprot.writeMapEnd(); } @@ -725,22 +725,22 @@ import org.slf4j.LoggerFactory; if (struct.isSetSkewedColNames()) { { oprot.writeI32(struct.skewedColNames.size()); - for (String _iter135 : struct.skewedColNames) + for (String _iter143 : struct.skewedColNames) { - oprot.writeString(_iter135); + oprot.writeString(_iter143); } } } if (struct.isSetSkewedColValues()) { { oprot.writeI32(struct.skewedColValues.size()); - for (List<String> _iter136 : struct.skewedColValues) + for (List<String> _iter144 : struct.skewedColValues) { { - oprot.writeI32(_iter136.size()); - for (String _iter137 : _iter136) + oprot.writeI32(_iter144.size()); + for (String _iter145 : _iter144) { - oprot.writeString(_iter137); + oprot.writeString(_iter145); } } } @@ -749,16 +749,16 @@ import org.slf4j.LoggerFactory; if (struct.isSetSkewedColValueLocationMaps()) { { oprot.writeI32(struct.skewedColValueLocationMaps.size()); - for (Map.Entry<List<String>, String> _iter138 : struct.skewedColValueLocationMaps.entrySet()) + for (Map.Entry<List<String>, String> _iter146 : struct.skewedColValueLocationMaps.entrySet()) { { - oprot.writeI32(_iter138.getKey().size()); - for (String _iter139 : _iter138.getKey()) + oprot.writeI32(_iter146.getKey().size()); + for (String _iter147 : _iter146.getKey()) { - oprot.writeString(_iter139); + oprot.writeString(_iter147); } } - oprot.writeString(_iter138.getValue()); + oprot.writeString(_iter146.getValue()); } } } @@ -770,59 +770,59 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(3); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list140 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.skewedColNames = new ArrayList<String>(_list140.size); - String _elem141; - for (int _i142 = 0; _i142 < _list140.size; ++_i142) + org.apache.thrift.protocol.TList _list148 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.skewedColNames = new ArrayList<String>(_list148.size); + String _elem149; + for (int _i150 = 0; _i150 < _list148.size; ++_i150) { - _elem141 = iprot.readString(); - struct.skewedColNames.add(_elem141); + _elem149 = iprot.readString(); + struct.skewedColNames.add(_elem149); } } struct.setSkewedColNamesIsSet(true); } if (incoming.get(1)) { { - org.apache.thrift.protocol.TList _list143 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, iprot.readI32()); - struct.skewedColValues = new ArrayList<List<String>>(_list143.size); - List<String> _elem144; - for (int _i145 = 0; _i145 < _list143.size; ++_i145) + org.apache.thrift.protocol.TList _list151 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.LIST, iprot.readI32()); + struct.skewedColValues = new ArrayList<List<String>>(_list151.size); + List<String> _elem152; + for (int _i153 = 0; _i153 < _list151.size; ++_i153) { { - org.apache.thrift.protocol.TList _list146 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - _elem144 = new ArrayList<String>(_list146.size); - String _elem147; - for (int _i148 = 0; _i148 < _list146.size; ++_i148) + org.apache.thrift.protocol.TList _list154 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + _elem152 = new ArrayList<String>(_list154.size); + String _elem155; + for (int _i156 = 0; _i156 < _list154.size; ++_i156) { - _elem147 = iprot.readString(); - _elem144.add(_elem147); + _elem155 = iprot.readString(); + _elem152.add(_elem155); } } - struct.skewedColValues.add(_elem144); + struct.skewedColValues.add(_elem152); } } struct.setSkewedColValuesIsSet(true); } if (incoming.get(2)) { { - org.apache.thrift.protocol.TMap _map149 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map149.size); - List<String> _key150; - String _val151; - for (int _i152 = 0; _i152 < _map149.size; ++_i152) + org.apache.thrift.protocol.TMap _map157 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.LIST, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map157.size); + List<String> _key158; + String _val159; + for (int _i160 = 0; _i160 < _map157.size; ++_i160) { { - org.apache.thrift.protocol.TList _list153 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - _key150 = new ArrayList<String>(_list153.size); - String _elem154; - for (int _i155 = 0; _i155 < _list153.size; ++_i155) + org.apache.thrift.protocol.TList _list161 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + _key158 = new ArrayList<String>(_list161.size); + String _elem162; + for (int _i163 = 0; _i163 < _list161.size; ++_i163) { - _elem154 = iprot.readString(); - _key150.add(_elem154); + _elem162 = iprot.readString(); + _key158.add(_elem162); } } - _val151 = iprot.readString(); - struct.skewedColValueLocationMaps.put(_key150, _val151); + _val159 = iprot.readString(); + struct.skewedColValueLocationMaps.put(_key158, _val159); } } struct.setSkewedColValueLocationMapsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java ---------------------------------------------------------------------- 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 385a015..00e6041 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 @@ -1290,14 +1290,14 @@ import org.slf4j.LoggerFactory; case 1: // COLS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list156 = iprot.readListBegin(); - struct.cols = new ArrayList<FieldSchema>(_list156.size); - FieldSchema _elem157; - for (int _i158 = 0; _i158 < _list156.size; ++_i158) + org.apache.thrift.protocol.TList _list164 = iprot.readListBegin(); + struct.cols = new ArrayList<FieldSchema>(_list164.size); + FieldSchema _elem165; + for (int _i166 = 0; _i166 < _list164.size; ++_i166) { - _elem157 = new FieldSchema(); - _elem157.read(iprot); - struct.cols.add(_elem157); + _elem165 = new FieldSchema(); + _elem165.read(iprot); + struct.cols.add(_elem165); } iprot.readListEnd(); } @@ -1358,13 +1358,13 @@ import org.slf4j.LoggerFactory; case 8: // BUCKET_COLS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list159 = iprot.readListBegin(); - struct.bucketCols = new ArrayList<String>(_list159.size); - String _elem160; - for (int _i161 = 0; _i161 < _list159.size; ++_i161) + org.apache.thrift.protocol.TList _list167 = iprot.readListBegin(); + struct.bucketCols = new ArrayList<String>(_list167.size); + String _elem168; + for (int _i169 = 0; _i169 < _list167.size; ++_i169) { - _elem160 = iprot.readString(); - struct.bucketCols.add(_elem160); + _elem168 = iprot.readString(); + struct.bucketCols.add(_elem168); } iprot.readListEnd(); } @@ -1376,14 +1376,14 @@ import org.slf4j.LoggerFactory; case 9: // SORT_COLS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list162 = iprot.readListBegin(); - struct.sortCols = new ArrayList<Order>(_list162.size); - Order _elem163; - for (int _i164 = 0; _i164 < _list162.size; ++_i164) + org.apache.thrift.protocol.TList _list170 = iprot.readListBegin(); + struct.sortCols = new ArrayList<Order>(_list170.size); + Order _elem171; + for (int _i172 = 0; _i172 < _list170.size; ++_i172) { - _elem163 = new Order(); - _elem163.read(iprot); - struct.sortCols.add(_elem163); + _elem171 = new Order(); + _elem171.read(iprot); + struct.sortCols.add(_elem171); } iprot.readListEnd(); } @@ -1395,15 +1395,15 @@ import org.slf4j.LoggerFactory; case 10: // PARAMETERS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map165 = iprot.readMapBegin(); - struct.parameters = new HashMap<String,String>(2*_map165.size); - String _key166; - String _val167; - for (int _i168 = 0; _i168 < _map165.size; ++_i168) + org.apache.thrift.protocol.TMap _map173 = iprot.readMapBegin(); + struct.parameters = new HashMap<String,String>(2*_map173.size); + String _key174; + String _val175; + for (int _i176 = 0; _i176 < _map173.size; ++_i176) { - _key166 = iprot.readString(); - _val167 = iprot.readString(); - struct.parameters.put(_key166, _val167); + _key174 = iprot.readString(); + _val175 = iprot.readString(); + struct.parameters.put(_key174, _val175); } iprot.readMapEnd(); } @@ -1446,9 +1446,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(COLS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.cols.size())); - for (FieldSchema _iter169 : struct.cols) + for (FieldSchema _iter177 : struct.cols) { - _iter169.write(oprot); + _iter177.write(oprot); } oprot.writeListEnd(); } @@ -1484,9 +1484,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(BUCKET_COLS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.bucketCols.size())); - for (String _iter170 : struct.bucketCols) + for (String _iter178 : struct.bucketCols) { - oprot.writeString(_iter170); + oprot.writeString(_iter178); } oprot.writeListEnd(); } @@ -1496,9 +1496,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(SORT_COLS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.sortCols.size())); - for (Order _iter171 : struct.sortCols) + for (Order _iter179 : struct.sortCols) { - _iter171.write(oprot); + _iter179.write(oprot); } oprot.writeListEnd(); } @@ -1508,10 +1508,10 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(PARAMETERS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.parameters.size())); - for (Map.Entry<String, String> _iter172 : struct.parameters.entrySet()) + for (Map.Entry<String, String> _iter180 : struct.parameters.entrySet()) { - oprot.writeString(_iter172.getKey()); - oprot.writeString(_iter172.getValue()); + oprot.writeString(_iter180.getKey()); + oprot.writeString(_iter180.getValue()); } oprot.writeMapEnd(); } @@ -1587,9 +1587,9 @@ import org.slf4j.LoggerFactory; if (struct.isSetCols()) { { oprot.writeI32(struct.cols.size()); - for (FieldSchema _iter173 : struct.cols) + for (FieldSchema _iter181 : struct.cols) { - _iter173.write(oprot); + _iter181.write(oprot); } } } @@ -1614,28 +1614,28 @@ import org.slf4j.LoggerFactory; if (struct.isSetBucketCols()) { { oprot.writeI32(struct.bucketCols.size()); - for (String _iter174 : struct.bucketCols) + for (String _iter182 : struct.bucketCols) { - oprot.writeString(_iter174); + oprot.writeString(_iter182); } } } if (struct.isSetSortCols()) { { oprot.writeI32(struct.sortCols.size()); - for (Order _iter175 : struct.sortCols) + for (Order _iter183 : struct.sortCols) { - _iter175.write(oprot); + _iter183.write(oprot); } } } if (struct.isSetParameters()) { { oprot.writeI32(struct.parameters.size()); - for (Map.Entry<String, String> _iter176 : struct.parameters.entrySet()) + for (Map.Entry<String, String> _iter184 : struct.parameters.entrySet()) { - oprot.writeString(_iter176.getKey()); - oprot.writeString(_iter176.getValue()); + oprot.writeString(_iter184.getKey()); + oprot.writeString(_iter184.getValue()); } } } @@ -1653,14 +1653,14 @@ import org.slf4j.LoggerFactory; BitSet incoming = iprot.readBitSet(12); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list177 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.cols = new ArrayList<FieldSchema>(_list177.size); - FieldSchema _elem178; - for (int _i179 = 0; _i179 < _list177.size; ++_i179) + org.apache.thrift.protocol.TList _list185 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.cols = new ArrayList<FieldSchema>(_list185.size); + FieldSchema _elem186; + for (int _i187 = 0; _i187 < _list185.size; ++_i187) { - _elem178 = new FieldSchema(); - _elem178.read(iprot); - struct.cols.add(_elem178); + _elem186 = new FieldSchema(); + _elem186.read(iprot); + struct.cols.add(_elem186); } } struct.setColsIsSet(true); @@ -1692,42 +1692,42 @@ import org.slf4j.LoggerFactory; } if (incoming.get(7)) { { - org.apache.thrift.protocol.TList _list180 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.bucketCols = new ArrayList<String>(_list180.size); - String _elem181; - for (int _i182 = 0; _i182 < _list180.size; ++_i182) + org.apache.thrift.protocol.TList _list188 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.bucketCols = new ArrayList<String>(_list188.size); + String _elem189; + for (int _i190 = 0; _i190 < _list188.size; ++_i190) { - _elem181 = iprot.readString(); - struct.bucketCols.add(_elem181); + _elem189 = iprot.readString(); + struct.bucketCols.add(_elem189); } } struct.setBucketColsIsSet(true); } if (incoming.get(8)) { { - org.apache.thrift.protocol.TList _list183 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.sortCols = new ArrayList<Order>(_list183.size); - Order _elem184; - for (int _i185 = 0; _i185 < _list183.size; ++_i185) + org.apache.thrift.protocol.TList _list191 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.sortCols = new ArrayList<Order>(_list191.size); + Order _elem192; + for (int _i193 = 0; _i193 < _list191.size; ++_i193) { - _elem184 = new Order(); - _elem184.read(iprot); - struct.sortCols.add(_elem184); + _elem192 = new Order(); + _elem192.read(iprot); + struct.sortCols.add(_elem192); } } struct.setSortColsIsSet(true); } if (incoming.get(9)) { { - org.apache.thrift.protocol.TMap _map186 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.parameters = new HashMap<String,String>(2*_map186.size); - String _key187; - String _val188; - for (int _i189 = 0; _i189 < _map186.size; ++_i189) + org.apache.thrift.protocol.TMap _map194 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.parameters = new HashMap<String,String>(2*_map194.size); + String _key195; + String _val196; + for (int _i197 = 0; _i197 < _map194.size; ++_i197) { - _key187 = iprot.readString(); - _val188 = iprot.readString(); - struct.parameters.put(_key187, _val188); + _key195 = iprot.readString(); + _val196 = iprot.readString(); + struct.parameters.put(_key195, _val196); } } struct.parameters = org.apache.hadoop.hive.metastore.utils.StringUtils.intern(struct.parameters); struct.setParametersIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java index a132e5e..8dfec98 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java @@ -54,6 +54,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField TEMPORARY_FIELD_DESC = new org.apache.thrift.protocol.TField("temporary", org.apache.thrift.protocol.TType.BOOL, (short)14); private static final org.apache.thrift.protocol.TField REWRITE_ENABLED_FIELD_DESC = new org.apache.thrift.protocol.TField("rewriteEnabled", org.apache.thrift.protocol.TType.BOOL, (short)15); private static final org.apache.thrift.protocol.TField CREATION_METADATA_FIELD_DESC = new org.apache.thrift.protocol.TField("creationMetadata", org.apache.thrift.protocol.TType.STRUCT, (short)16); + private static final org.apache.thrift.protocol.TField CAT_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("catName", org.apache.thrift.protocol.TType.STRING, (short)17); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -77,6 +78,7 @@ import org.slf4j.LoggerFactory; private boolean temporary; // optional private boolean rewriteEnabled; // optional private CreationMetadata creationMetadata; // optional + private String catName; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -95,7 +97,8 @@ import org.slf4j.LoggerFactory; PRIVILEGES((short)13, "privileges"), TEMPORARY((short)14, "temporary"), REWRITE_ENABLED((short)15, "rewriteEnabled"), - CREATION_METADATA((short)16, "creationMetadata"); + CREATION_METADATA((short)16, "creationMetadata"), + CAT_NAME((short)17, "catName"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -142,6 +145,8 @@ import org.slf4j.LoggerFactory; return REWRITE_ENABLED; case 16: // CREATION_METADATA return CREATION_METADATA; + case 17: // CAT_NAME + return CAT_NAME; default: return null; } @@ -188,7 +193,7 @@ import org.slf4j.LoggerFactory; private static final int __TEMPORARY_ISSET_ID = 3; private static final int __REWRITEENABLED_ISSET_ID = 4; private byte __isset_bitfield = 0; - private static final _Fields optionals[] = {_Fields.PRIVILEGES,_Fields.TEMPORARY,_Fields.REWRITE_ENABLED,_Fields.CREATION_METADATA}; + private static final _Fields optionals[] = {_Fields.PRIVILEGES,_Fields.TEMPORARY,_Fields.REWRITE_ENABLED,_Fields.CREATION_METADATA,_Fields.CAT_NAME}; public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); @@ -227,6 +232,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL))); tmpMap.put(_Fields.CREATION_METADATA, new org.apache.thrift.meta_data.FieldMetaData("creationMetadata", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT , "CreationMetadata"))); + tmpMap.put(_Fields.CAT_NAME, new org.apache.thrift.meta_data.FieldMetaData("catName", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Table.class, metaDataMap); } @@ -316,6 +323,9 @@ import org.slf4j.LoggerFactory; if (other.isSetCreationMetadata()) { this.creationMetadata = other.creationMetadata; } + if (other.isSetCatName()) { + this.catName = other.catName; + } } public Table deepCopy() { @@ -345,6 +355,7 @@ import org.slf4j.LoggerFactory; setRewriteEnabledIsSet(false); this.rewriteEnabled = false; this.creationMetadata = null; + this.catName = null; } public String getTableName() { @@ -736,6 +747,29 @@ import org.slf4j.LoggerFactory; } } + public String getCatName() { + return this.catName; + } + + public void setCatName(String catName) { + this.catName = catName; + } + + public void unsetCatName() { + this.catName = null; + } + + /** Returns true if field catName is set (has been assigned a value) and false otherwise */ + public boolean isSetCatName() { + return this.catName != null; + } + + public void setCatNameIsSet(boolean value) { + if (!value) { + this.catName = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case TABLE_NAME: @@ -866,6 +900,14 @@ import org.slf4j.LoggerFactory; } break; + case CAT_NAME: + if (value == null) { + unsetCatName(); + } else { + setCatName((String)value); + } + break; + } } @@ -919,6 +961,9 @@ import org.slf4j.LoggerFactory; case CREATION_METADATA: return getCreationMetadata(); + case CAT_NAME: + return getCatName(); + } throw new IllegalStateException(); } @@ -962,6 +1007,8 @@ import org.slf4j.LoggerFactory; return isSetRewriteEnabled(); case CREATION_METADATA: return isSetCreationMetadata(); + case CAT_NAME: + return isSetCatName(); } throw new IllegalStateException(); } @@ -1123,6 +1170,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_catName = true && this.isSetCatName(); + boolean that_present_catName = true && that.isSetCatName(); + if (this_present_catName || that_present_catName) { + if (!(this_present_catName && that_present_catName)) + return false; + if (!this.catName.equals(that.catName)) + return false; + } + return true; } @@ -1210,6 +1266,11 @@ import org.slf4j.LoggerFactory; if (present_creationMetadata) list.add(creationMetadata); + boolean present_catName = true && (isSetCatName()); + list.add(present_catName); + if (present_catName) + list.add(catName); + return list.hashCode(); } @@ -1381,6 +1442,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetCatName()).compareTo(other.isSetCatName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCatName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.catName, other.catName); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -1516,6 +1587,16 @@ import org.slf4j.LoggerFactory; } first = false; } + if (isSetCatName()) { + if (!first) sb.append(", "); + sb.append("catName:"); + if (this.catName == null) { + sb.append("null"); + } else { + sb.append(this.catName); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -1627,14 +1708,14 @@ import org.slf4j.LoggerFactory; case 8: // PARTITION_KEYS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list190 = iprot.readListBegin(); - struct.partitionKeys = new ArrayList<FieldSchema>(_list190.size); - FieldSchema _elem191; - for (int _i192 = 0; _i192 < _list190.size; ++_i192) + org.apache.thrift.protocol.TList _list198 = iprot.readListBegin(); + struct.partitionKeys = new ArrayList<FieldSchema>(_list198.size); + FieldSchema _elem199; + for (int _i200 = 0; _i200 < _list198.size; ++_i200) { - _elem191 = new FieldSchema(); - _elem191.read(iprot); - struct.partitionKeys.add(_elem191); + _elem199 = new FieldSchema(); + _elem199.read(iprot); + struct.partitionKeys.add(_elem199); } iprot.readListEnd(); } @@ -1646,15 +1727,15 @@ import org.slf4j.LoggerFactory; case 9: // PARAMETERS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map193 = iprot.readMapBegin(); - struct.parameters = new HashMap<String,String>(2*_map193.size); - String _key194; - String _val195; - for (int _i196 = 0; _i196 < _map193.size; ++_i196) + org.apache.thrift.protocol.TMap _map201 = iprot.readMapBegin(); + struct.parameters = new HashMap<String,String>(2*_map201.size); + String _key202; + String _val203; + for (int _i204 = 0; _i204 < _map201.size; ++_i204) { - _key194 = iprot.readString(); - _val195 = iprot.readString(); - struct.parameters.put(_key194, _val195); + _key202 = iprot.readString(); + _val203 = iprot.readString(); + struct.parameters.put(_key202, _val203); } iprot.readMapEnd(); } @@ -1721,6 +1802,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 17: // CAT_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.catName = iprot.readString(); + struct.setCatNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -1767,9 +1856,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(PARTITION_KEYS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitionKeys.size())); - for (FieldSchema _iter197 : struct.partitionKeys) + for (FieldSchema _iter205 : struct.partitionKeys) { - _iter197.write(oprot); + _iter205.write(oprot); } oprot.writeListEnd(); } @@ -1779,10 +1868,10 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(PARAMETERS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.parameters.size())); - for (Map.Entry<String, String> _iter198 : struct.parameters.entrySet()) + for (Map.Entry<String, String> _iter206 : struct.parameters.entrySet()) { - oprot.writeString(_iter198.getKey()); - oprot.writeString(_iter198.getValue()); + oprot.writeString(_iter206.getKey()); + oprot.writeString(_iter206.getValue()); } oprot.writeMapEnd(); } @@ -1827,6 +1916,13 @@ import org.slf4j.LoggerFactory; oprot.writeFieldEnd(); } } + if (struct.catName != null) { + if (struct.isSetCatName()) { + oprot.writeFieldBegin(CAT_NAME_FIELD_DESC); + oprot.writeString(struct.catName); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -1893,7 +1989,10 @@ import org.slf4j.LoggerFactory; if (struct.isSetCreationMetadata()) { optionals.set(15); } - oprot.writeBitSet(optionals, 16); + if (struct.isSetCatName()) { + optionals.set(16); + } + oprot.writeBitSet(optionals, 17); if (struct.isSetTableName()) { oprot.writeString(struct.tableName); } @@ -1918,19 +2017,19 @@ import org.slf4j.LoggerFactory; if (struct.isSetPartitionKeys()) { { oprot.writeI32(struct.partitionKeys.size()); - for (FieldSchema _iter199 : struct.partitionKeys) + for (FieldSchema _iter207 : struct.partitionKeys) { - _iter199.write(oprot); + _iter207.write(oprot); } } } if (struct.isSetParameters()) { { oprot.writeI32(struct.parameters.size()); - for (Map.Entry<String, String> _iter200 : struct.parameters.entrySet()) + for (Map.Entry<String, String> _iter208 : struct.parameters.entrySet()) { - oprot.writeString(_iter200.getKey()); - oprot.writeString(_iter200.getValue()); + oprot.writeString(_iter208.getKey()); + oprot.writeString(_iter208.getValue()); } } } @@ -1955,12 +2054,15 @@ import org.slf4j.LoggerFactory; if (struct.isSetCreationMetadata()) { struct.creationMetadata.write(oprot); } + if (struct.isSetCatName()) { + oprot.writeString(struct.catName); + } } @Override public void read(org.apache.thrift.protocol.TProtocol prot, Table struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; - BitSet incoming = iprot.readBitSet(16); + BitSet incoming = iprot.readBitSet(17); if (incoming.get(0)) { struct.tableName = iprot.readString(); struct.setTableNameIsSet(true); @@ -1992,29 +2094,29 @@ import org.slf4j.LoggerFactory; } if (incoming.get(7)) { { - org.apache.thrift.protocol.TList _list201 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.partitionKeys = new ArrayList<FieldSchema>(_list201.size); - FieldSchema _elem202; - for (int _i203 = 0; _i203 < _list201.size; ++_i203) + org.apache.thrift.protocol.TList _list209 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.partitionKeys = new ArrayList<FieldSchema>(_list209.size); + FieldSchema _elem210; + for (int _i211 = 0; _i211 < _list209.size; ++_i211) { - _elem202 = new FieldSchema(); - _elem202.read(iprot); - struct.partitionKeys.add(_elem202); + _elem210 = new FieldSchema(); + _elem210.read(iprot); + struct.partitionKeys.add(_elem210); } } struct.setPartitionKeysIsSet(true); } if (incoming.get(8)) { { - org.apache.thrift.protocol.TMap _map204 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.parameters = new HashMap<String,String>(2*_map204.size); - String _key205; - String _val206; - for (int _i207 = 0; _i207 < _map204.size; ++_i207) + org.apache.thrift.protocol.TMap _map212 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.parameters = new HashMap<String,String>(2*_map212.size); + String _key213; + String _val214; + for (int _i215 = 0; _i215 < _map212.size; ++_i215) { - _key205 = iprot.readString(); - _val206 = iprot.readString(); - struct.parameters.put(_key205, _val206); + _key213 = iprot.readString(); + _val214 = iprot.readString(); + struct.parameters.put(_key213, _val214); } } struct.setParametersIsSet(true); @@ -2049,6 +2151,10 @@ import org.slf4j.LoggerFactory; struct.creationMetadata.read(iprot); struct.setCreationMetadataIsSet(true); } + if (incoming.get(16)) { + struct.catName = iprot.readString(); + struct.setCatNameIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableMeta.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableMeta.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableMeta.java index cadbaaa..9e20f6f 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableMeta.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableMeta.java @@ -42,6 +42,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)2); private static final org.apache.thrift.protocol.TField TABLE_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("tableType", org.apache.thrift.protocol.TType.STRING, (short)3); private static final org.apache.thrift.protocol.TField COMMENTS_FIELD_DESC = new org.apache.thrift.protocol.TField("comments", org.apache.thrift.protocol.TType.STRING, (short)4); + private static final org.apache.thrift.protocol.TField CAT_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("catName", org.apache.thrift.protocol.TType.STRING, (short)5); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -53,13 +54,15 @@ import org.slf4j.LoggerFactory; private String tableName; // required private String tableType; // required private String comments; // optional + private String catName; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { DB_NAME((short)1, "dbName"), TABLE_NAME((short)2, "tableName"), TABLE_TYPE((short)3, "tableType"), - COMMENTS((short)4, "comments"); + COMMENTS((short)4, "comments"), + CAT_NAME((short)5, "catName"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -82,6 +85,8 @@ import org.slf4j.LoggerFactory; return TABLE_TYPE; case 4: // COMMENTS return COMMENTS; + case 5: // CAT_NAME + return CAT_NAME; default: return null; } @@ -122,7 +127,7 @@ import org.slf4j.LoggerFactory; } // isset id assignments - private static final _Fields optionals[] = {_Fields.COMMENTS}; + private static final _Fields optionals[] = {_Fields.COMMENTS,_Fields.CAT_NAME}; public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); @@ -134,6 +139,8 @@ import org.slf4j.LoggerFactory; new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); tmpMap.put(_Fields.COMMENTS, new org.apache.thrift.meta_data.FieldMetaData("comments", org.apache.thrift.TFieldRequirementType.OPTIONAL, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.CAT_NAME, new org.apache.thrift.meta_data.FieldMetaData("catName", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TableMeta.class, metaDataMap); } @@ -168,6 +175,9 @@ import org.slf4j.LoggerFactory; if (other.isSetComments()) { this.comments = other.comments; } + if (other.isSetCatName()) { + this.catName = other.catName; + } } public TableMeta deepCopy() { @@ -180,6 +190,7 @@ import org.slf4j.LoggerFactory; this.tableName = null; this.tableType = null; this.comments = null; + this.catName = null; } public String getDbName() { @@ -274,6 +285,29 @@ import org.slf4j.LoggerFactory; } } + public String getCatName() { + return this.catName; + } + + public void setCatName(String catName) { + this.catName = catName; + } + + public void unsetCatName() { + this.catName = null; + } + + /** Returns true if field catName is set (has been assigned a value) and false otherwise */ + public boolean isSetCatName() { + return this.catName != null; + } + + public void setCatNameIsSet(boolean value) { + if (!value) { + this.catName = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case DB_NAME: @@ -308,6 +342,14 @@ import org.slf4j.LoggerFactory; } break; + case CAT_NAME: + if (value == null) { + unsetCatName(); + } else { + setCatName((String)value); + } + break; + } } @@ -325,6 +367,9 @@ import org.slf4j.LoggerFactory; case COMMENTS: return getComments(); + case CAT_NAME: + return getCatName(); + } throw new IllegalStateException(); } @@ -344,6 +389,8 @@ import org.slf4j.LoggerFactory; return isSetTableType(); case COMMENTS: return isSetComments(); + case CAT_NAME: + return isSetCatName(); } throw new IllegalStateException(); } @@ -397,6 +444,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_catName = true && this.isSetCatName(); + boolean that_present_catName = true && that.isSetCatName(); + if (this_present_catName || that_present_catName) { + if (!(this_present_catName && that_present_catName)) + return false; + if (!this.catName.equals(that.catName)) + return false; + } + return true; } @@ -424,6 +480,11 @@ import org.slf4j.LoggerFactory; if (present_comments) list.add(comments); + boolean present_catName = true && (isSetCatName()); + list.add(present_catName); + if (present_catName) + list.add(catName); + return list.hashCode(); } @@ -475,6 +536,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetCatName()).compareTo(other.isSetCatName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCatName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.catName, other.catName); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -528,6 +599,16 @@ import org.slf4j.LoggerFactory; } first = false; } + if (isSetCatName()) { + if (!first) sb.append(", "); + sb.append("catName:"); + if (this.catName == null) { + sb.append("null"); + } else { + sb.append(this.catName); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -615,6 +696,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 5: // CAT_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.catName = iprot.readString(); + struct.setCatNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -650,6 +739,13 @@ import org.slf4j.LoggerFactory; oprot.writeFieldEnd(); } } + if (struct.catName != null) { + if (struct.isSetCatName()) { + oprot.writeFieldBegin(CAT_NAME_FIELD_DESC); + oprot.writeString(struct.catName); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -674,10 +770,16 @@ import org.slf4j.LoggerFactory; if (struct.isSetComments()) { optionals.set(0); } - oprot.writeBitSet(optionals, 1); + if (struct.isSetCatName()) { + optionals.set(1); + } + oprot.writeBitSet(optionals, 2); if (struct.isSetComments()) { oprot.writeString(struct.comments); } + if (struct.isSetCatName()) { + oprot.writeString(struct.catName); + } } @Override @@ -689,11 +791,15 @@ import org.slf4j.LoggerFactory; struct.setTableNameIsSet(true); struct.tableType = iprot.readString(); struct.setTableTypeIsSet(true); - BitSet incoming = iprot.readBitSet(1); + BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { struct.comments = iprot.readString(); struct.setCommentsIsSet(true); } + if (incoming.get(1)) { + struct.catName = iprot.readString(); + struct.setCatNameIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java index 6c7c9af..a663a64 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java @@ -41,6 +41,7 @@ import org.slf4j.LoggerFactory; private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbName", org.apache.thrift.protocol.TType.STRING, (short)1); private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tblName", org.apache.thrift.protocol.TType.STRING, (short)2); private static final org.apache.thrift.protocol.TField COL_NAMES_FIELD_DESC = new org.apache.thrift.protocol.TField("colNames", org.apache.thrift.protocol.TType.LIST, (short)3); + private static final org.apache.thrift.protocol.TField CAT_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("catName", org.apache.thrift.protocol.TType.STRING, (short)4); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -51,12 +52,14 @@ import org.slf4j.LoggerFactory; private String dbName; // required private String tblName; // required private List<String> colNames; // required + private String catName; // optional /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { DB_NAME((short)1, "dbName"), TBL_NAME((short)2, "tblName"), - COL_NAMES((short)3, "colNames"); + COL_NAMES((short)3, "colNames"), + CAT_NAME((short)4, "catName"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -77,6 +80,8 @@ import org.slf4j.LoggerFactory; return TBL_NAME; case 3: // COL_NAMES return COL_NAMES; + case 4: // CAT_NAME + return CAT_NAME; default: return null; } @@ -117,6 +122,7 @@ import org.slf4j.LoggerFactory; } // isset id assignments + private static final _Fields optionals[] = {_Fields.CAT_NAME}; public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; static { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); @@ -127,6 +133,8 @@ import org.slf4j.LoggerFactory; tmpMap.put(_Fields.COL_NAMES, new org.apache.thrift.meta_data.FieldMetaData("colNames", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)))); + tmpMap.put(_Fields.CAT_NAME, new org.apache.thrift.meta_data.FieldMetaData("catName", org.apache.thrift.TFieldRequirementType.OPTIONAL, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TableStatsRequest.class, metaDataMap); } @@ -159,6 +167,9 @@ import org.slf4j.LoggerFactory; List<String> __this__colNames = new ArrayList<String>(other.colNames); this.colNames = __this__colNames; } + if (other.isSetCatName()) { + this.catName = other.catName; + } } public TableStatsRequest deepCopy() { @@ -170,6 +181,7 @@ import org.slf4j.LoggerFactory; this.dbName = null; this.tblName = null; this.colNames = null; + this.catName = null; } public String getDbName() { @@ -256,6 +268,29 @@ import org.slf4j.LoggerFactory; } } + public String getCatName() { + return this.catName; + } + + public void setCatName(String catName) { + this.catName = catName; + } + + public void unsetCatName() { + this.catName = null; + } + + /** Returns true if field catName is set (has been assigned a value) and false otherwise */ + public boolean isSetCatName() { + return this.catName != null; + } + + public void setCatNameIsSet(boolean value) { + if (!value) { + this.catName = null; + } + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case DB_NAME: @@ -282,6 +317,14 @@ import org.slf4j.LoggerFactory; } break; + case CAT_NAME: + if (value == null) { + unsetCatName(); + } else { + setCatName((String)value); + } + break; + } } @@ -296,6 +339,9 @@ import org.slf4j.LoggerFactory; case COL_NAMES: return getColNames(); + case CAT_NAME: + return getCatName(); + } throw new IllegalStateException(); } @@ -313,6 +359,8 @@ import org.slf4j.LoggerFactory; return isSetTblName(); case COL_NAMES: return isSetColNames(); + case CAT_NAME: + return isSetCatName(); } throw new IllegalStateException(); } @@ -357,6 +405,15 @@ import org.slf4j.LoggerFactory; return false; } + boolean this_present_catName = true && this.isSetCatName(); + boolean that_present_catName = true && that.isSetCatName(); + if (this_present_catName || that_present_catName) { + if (!(this_present_catName && that_present_catName)) + return false; + if (!this.catName.equals(that.catName)) + return false; + } + return true; } @@ -379,6 +436,11 @@ import org.slf4j.LoggerFactory; if (present_colNames) list.add(colNames); + boolean present_catName = true && (isSetCatName()); + list.add(present_catName); + if (present_catName) + list.add(catName); + return list.hashCode(); } @@ -420,6 +482,16 @@ import org.slf4j.LoggerFactory; return lastComparison; } } + lastComparison = Boolean.valueOf(isSetCatName()).compareTo(other.isSetCatName()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetCatName()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.catName, other.catName); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -463,6 +535,16 @@ import org.slf4j.LoggerFactory; sb.append(this.colNames); } first = false; + if (isSetCatName()) { + if (!first) sb.append(", "); + sb.append("catName:"); + if (this.catName == null) { + sb.append("null"); + } else { + sb.append(this.catName); + } + first = false; + } sb.append(")"); return sb.toString(); } @@ -537,13 +619,13 @@ import org.slf4j.LoggerFactory; case 3: // COL_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list442 = iprot.readListBegin(); - struct.colNames = new ArrayList<String>(_list442.size); - String _elem443; - for (int _i444 = 0; _i444 < _list442.size; ++_i444) + org.apache.thrift.protocol.TList _list450 = iprot.readListBegin(); + struct.colNames = new ArrayList<String>(_list450.size); + String _elem451; + for (int _i452 = 0; _i452 < _list450.size; ++_i452) { - _elem443 = iprot.readString(); - struct.colNames.add(_elem443); + _elem451 = iprot.readString(); + struct.colNames.add(_elem451); } iprot.readListEnd(); } @@ -552,6 +634,14 @@ import org.slf4j.LoggerFactory; org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 4: // CAT_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.catName = iprot.readString(); + struct.setCatNameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -579,14 +669,21 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(COL_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.colNames.size())); - for (String _iter445 : struct.colNames) + for (String _iter453 : struct.colNames) { - oprot.writeString(_iter445); + oprot.writeString(_iter453); } oprot.writeListEnd(); } oprot.writeFieldEnd(); } + if (struct.catName != null) { + if (struct.isSetCatName()) { + oprot.writeFieldBegin(CAT_NAME_FIELD_DESC); + oprot.writeString(struct.catName); + oprot.writeFieldEnd(); + } + } oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -608,11 +705,19 @@ import org.slf4j.LoggerFactory; oprot.writeString(struct.tblName); { oprot.writeI32(struct.colNames.size()); - for (String _iter446 : struct.colNames) + for (String _iter454 : struct.colNames) { - oprot.writeString(_iter446); + oprot.writeString(_iter454); } } + BitSet optionals = new BitSet(); + if (struct.isSetCatName()) { + optionals.set(0); + } + oprot.writeBitSet(optionals, 1); + if (struct.isSetCatName()) { + oprot.writeString(struct.catName); + } } @Override @@ -623,16 +728,21 @@ import org.slf4j.LoggerFactory; struct.tblName = iprot.readString(); struct.setTblNameIsSet(true); { - org.apache.thrift.protocol.TList _list447 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.colNames = new ArrayList<String>(_list447.size); - String _elem448; - for (int _i449 = 0; _i449 < _list447.size; ++_i449) + org.apache.thrift.protocol.TList _list455 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.colNames = new ArrayList<String>(_list455.size); + String _elem456; + for (int _i457 = 0; _i457 < _list455.size; ++_i457) { - _elem448 = iprot.readString(); - struct.colNames.add(_elem448); + _elem456 = iprot.readString(); + struct.colNames.add(_elem456); } } struct.setColNamesIsSet(true); + BitSet incoming = iprot.readBitSet(1); + if (incoming.get(0)) { + struct.catName = iprot.readString(); + struct.setCatNameIsSet(true); + } } } http://git-wip-us.apache.org/repos/asf/hive/blob/ba8a99e1/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java index 789f91c..dff7d5c 100644 --- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java +++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java @@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory; case 1: // TABLE_STATS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list416 = iprot.readListBegin(); - struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list416.size); - ColumnStatisticsObj _elem417; - for (int _i418 = 0; _i418 < _list416.size; ++_i418) + org.apache.thrift.protocol.TList _list424 = iprot.readListBegin(); + struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list424.size); + ColumnStatisticsObj _elem425; + for (int _i426 = 0; _i426 < _list424.size; ++_i426) { - _elem417 = new ColumnStatisticsObj(); - _elem417.read(iprot); - struct.tableStats.add(_elem417); + _elem425 = new ColumnStatisticsObj(); + _elem425.read(iprot); + struct.tableStats.add(_elem425); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory; oprot.writeFieldBegin(TABLE_STATS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tableStats.size())); - for (ColumnStatisticsObj _iter419 : struct.tableStats) + for (ColumnStatisticsObj _iter427 : struct.tableStats) { - _iter419.write(oprot); + _iter427.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory; TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.tableStats.size()); - for (ColumnStatisticsObj _iter420 : struct.tableStats) + for (ColumnStatisticsObj _iter428 : struct.tableStats) { - _iter420.write(oprot); + _iter428.write(oprot); } } } @@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory; public void read(org.apache.thrift.protocol.TProtocol prot, TableStatsResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list421 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list421.size); - ColumnStatisticsObj _elem422; - for (int _i423 = 0; _i423 < _list421.size; ++_i423) + org.apache.thrift.protocol.TList _list429 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.tableStats = new ArrayList<ColumnStatisticsObj>(_list429.size); + ColumnStatisticsObj _elem430; + for (int _i431 = 0; _i431 < _list429.size; ++_i431) { - _elem422 = new ColumnStatisticsObj(); - _elem422.read(iprot); - struct.tableStats.add(_elem422); + _elem430 = new ColumnStatisticsObj(); + _elem430.read(iprot); + struct.tableStats.add(_elem430); } } struct.setTableStatsIsSet(true);
