Modified: hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionResp.java URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionResp.java?rev=1558269&r1=1558268&r2=1558269&view=diff ============================================================================== --- hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionResp.java (original) +++ hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionResp.java Wed Jan 15 02:18:30 2014 @@ -650,15 +650,15 @@ public class TOpenSessionResp implements case 4: // CONFIGURATION if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map208 = iprot.readMapBegin(); - struct.configuration = new HashMap<String,String>(2*_map208.size); - for (int _i209 = 0; _i209 < _map208.size; ++_i209) + org.apache.thrift.protocol.TMap _map152 = iprot.readMapBegin(); + struct.configuration = new HashMap<String,String>(2*_map152.size); + for (int _i153 = 0; _i153 < _map152.size; ++_i153) { - String _key210; // required - String _val211; // required - _key210 = iprot.readString(); - _val211 = iprot.readString(); - struct.configuration.put(_key210, _val211); + String _key154; // required + String _val155; // required + _key154 = iprot.readString(); + _val155 = iprot.readString(); + struct.configuration.put(_key154, _val155); } iprot.readMapEnd(); } @@ -702,10 +702,10 @@ public class TOpenSessionResp implements oprot.writeFieldBegin(CONFIGURATION_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.configuration.size())); - for (Map.Entry<String, String> _iter212 : struct.configuration.entrySet()) + for (Map.Entry<String, String> _iter156 : struct.configuration.entrySet()) { - oprot.writeString(_iter212.getKey()); - oprot.writeString(_iter212.getValue()); + oprot.writeString(_iter156.getKey()); + oprot.writeString(_iter156.getValue()); } oprot.writeMapEnd(); } @@ -745,10 +745,10 @@ public class TOpenSessionResp implements if (struct.isSetConfiguration()) { { oprot.writeI32(struct.configuration.size()); - for (Map.Entry<String, String> _iter213 : struct.configuration.entrySet()) + for (Map.Entry<String, String> _iter157 : struct.configuration.entrySet()) { - oprot.writeString(_iter213.getKey()); - oprot.writeString(_iter213.getValue()); + oprot.writeString(_iter157.getKey()); + oprot.writeString(_iter157.getValue()); } } } @@ -770,15 +770,15 @@ public class TOpenSessionResp implements } if (incoming.get(1)) { { - org.apache.thrift.protocol.TMap _map214 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.configuration = new HashMap<String,String>(2*_map214.size); - for (int _i215 = 0; _i215 < _map214.size; ++_i215) + org.apache.thrift.protocol.TMap _map158 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.configuration = new HashMap<String,String>(2*_map158.size); + for (int _i159 = 0; _i159 < _map158.size; ++_i159) { - String _key216; // required - String _val217; // required - _key216 = iprot.readString(); - _val217 = iprot.readString(); - struct.configuration.put(_key216, _val217); + String _key160; // required + String _val161; // required + _key160 = iprot.readString(); + _val161 = iprot.readString(); + struct.configuration.put(_key160, _val161); } } struct.setConfigurationIsSet(true);
Modified: hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java?rev=1558269&r1=1558268&r2=1558269&view=diff ============================================================================== --- hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java (original) +++ hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java Wed Jan 15 02:18:30 2014 @@ -350,14 +350,14 @@ public class TRow implements org.apache. case 1: // COL_VALS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list102 = iprot.readListBegin(); - struct.colVals = new ArrayList<TColumnValue>(_list102.size); - for (int _i103 = 0; _i103 < _list102.size; ++_i103) + org.apache.thrift.protocol.TList _list46 = iprot.readListBegin(); + struct.colVals = new ArrayList<TColumnValue>(_list46.size); + for (int _i47 = 0; _i47 < _list46.size; ++_i47) { - TColumnValue _elem104; // required - _elem104 = new TColumnValue(); - _elem104.read(iprot); - struct.colVals.add(_elem104); + TColumnValue _elem48; // required + _elem48 = new TColumnValue(); + _elem48.read(iprot); + struct.colVals.add(_elem48); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class TRow implements org.apache. oprot.writeFieldBegin(COL_VALS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.colVals.size())); - for (TColumnValue _iter105 : struct.colVals) + for (TColumnValue _iter49 : struct.colVals) { - _iter105.write(oprot); + _iter49.write(oprot); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class TRow implements org.apache. TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.colVals.size()); - for (TColumnValue _iter106 : struct.colVals) + for (TColumnValue _iter50 : struct.colVals) { - _iter106.write(oprot); + _iter50.write(oprot); } } } @@ -421,14 +421,14 @@ public class TRow implements org.apache. public void read(org.apache.thrift.protocol.TProtocol prot, TRow struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list107 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.colVals = new ArrayList<TColumnValue>(_list107.size); - for (int _i108 = 0; _i108 < _list107.size; ++_i108) + org.apache.thrift.protocol.TList _list51 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.colVals = new ArrayList<TColumnValue>(_list51.size); + for (int _i52 = 0; _i52 < _list51.size; ++_i52) { - TColumnValue _elem109; // required - _elem109 = new TColumnValue(); - _elem109.read(iprot); - struct.colVals.add(_elem109); + TColumnValue _elem53; // required + _elem53 = new TColumnValue(); + _elem53.read(iprot); + struct.colVals.add(_elem53); } } struct.setColValsIsSet(true); Modified: hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java?rev=1558269&r1=1558268&r2=1558269&view=diff ============================================================================== --- hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java (original) +++ hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java Wed Jan 15 02:18:30 2014 @@ -545,14 +545,14 @@ public class TRowSet implements org.apac case 2: // ROWS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list174 = iprot.readListBegin(); - struct.rows = new ArrayList<TRow>(_list174.size); - for (int _i175 = 0; _i175 < _list174.size; ++_i175) + org.apache.thrift.protocol.TList _list118 = iprot.readListBegin(); + struct.rows = new ArrayList<TRow>(_list118.size); + for (int _i119 = 0; _i119 < _list118.size; ++_i119) { - TRow _elem176; // required - _elem176 = new TRow(); - _elem176.read(iprot); - struct.rows.add(_elem176); + TRow _elem120; // required + _elem120 = new TRow(); + _elem120.read(iprot); + struct.rows.add(_elem120); } iprot.readListEnd(); } @@ -564,14 +564,14 @@ public class TRowSet implements org.apac case 3: // COLUMNS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list177 = iprot.readListBegin(); - struct.columns = new ArrayList<TColumn>(_list177.size); - for (int _i178 = 0; _i178 < _list177.size; ++_i178) + org.apache.thrift.protocol.TList _list121 = iprot.readListBegin(); + struct.columns = new ArrayList<TColumn>(_list121.size); + for (int _i122 = 0; _i122 < _list121.size; ++_i122) { - TColumn _elem179; // required - _elem179 = new TColumn(); - _elem179.read(iprot); - struct.columns.add(_elem179); + TColumn _elem123; // required + _elem123 = new TColumn(); + _elem123.read(iprot); + struct.columns.add(_elem123); } iprot.readListEnd(); } @@ -600,9 +600,9 @@ public class TRowSet implements org.apac oprot.writeFieldBegin(ROWS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.rows.size())); - for (TRow _iter180 : struct.rows) + for (TRow _iter124 : struct.rows) { - _iter180.write(oprot); + _iter124.write(oprot); } oprot.writeListEnd(); } @@ -613,9 +613,9 @@ public class TRowSet implements org.apac oprot.writeFieldBegin(COLUMNS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.columns.size())); - for (TColumn _iter181 : struct.columns) + for (TColumn _iter125 : struct.columns) { - _iter181.write(oprot); + _iter125.write(oprot); } oprot.writeListEnd(); } @@ -642,9 +642,9 @@ public class TRowSet implements org.apac oprot.writeI64(struct.startRowOffset); { oprot.writeI32(struct.rows.size()); - for (TRow _iter182 : struct.rows) + for (TRow _iter126 : struct.rows) { - _iter182.write(oprot); + _iter126.write(oprot); } } BitSet optionals = new BitSet(); @@ -655,9 +655,9 @@ public class TRowSet implements org.apac if (struct.isSetColumns()) { { oprot.writeI32(struct.columns.size()); - for (TColumn _iter183 : struct.columns) + for (TColumn _iter127 : struct.columns) { - _iter183.write(oprot); + _iter127.write(oprot); } } } @@ -669,28 +669,28 @@ public class TRowSet implements org.apac struct.startRowOffset = iprot.readI64(); struct.setStartRowOffsetIsSet(true); { - org.apache.thrift.protocol.TList _list184 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.rows = new ArrayList<TRow>(_list184.size); - for (int _i185 = 0; _i185 < _list184.size; ++_i185) + org.apache.thrift.protocol.TList _list128 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.rows = new ArrayList<TRow>(_list128.size); + for (int _i129 = 0; _i129 < _list128.size; ++_i129) { - TRow _elem186; // required - _elem186 = new TRow(); - _elem186.read(iprot); - struct.rows.add(_elem186); + TRow _elem130; // required + _elem130 = new TRow(); + _elem130.read(iprot); + struct.rows.add(_elem130); } } struct.setRowsIsSet(true); BitSet incoming = iprot.readBitSet(1); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list187 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.columns = new ArrayList<TColumn>(_list187.size); - for (int _i188 = 0; _i188 < _list187.size; ++_i188) + org.apache.thrift.protocol.TList _list131 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.columns = new ArrayList<TColumn>(_list131.size); + for (int _i132 = 0; _i132 < _list131.size; ++_i132) { - TColumn _elem189; // required - _elem189 = new TColumn(); - _elem189.read(iprot); - struct.columns.add(_elem189); + TColumn _elem133; // required + _elem133 = new TColumn(); + _elem133.read(iprot); + struct.columns.add(_elem133); } } struct.setColumnsIsSet(true); Modified: hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java?rev=1558269&r1=1558268&r2=1558269&view=diff ============================================================================== --- hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java (original) +++ hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java Wed Jan 15 02:18:30 2014 @@ -694,13 +694,13 @@ public class TStatus implements org.apac case 2: // INFO_MESSAGES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list190 = iprot.readListBegin(); - struct.infoMessages = new ArrayList<String>(_list190.size); - for (int _i191 = 0; _i191 < _list190.size; ++_i191) + org.apache.thrift.protocol.TList _list134 = iprot.readListBegin(); + struct.infoMessages = new ArrayList<String>(_list134.size); + for (int _i135 = 0; _i135 < _list134.size; ++_i135) { - String _elem192; // required - _elem192 = iprot.readString(); - struct.infoMessages.add(_elem192); + String _elem136; // required + _elem136 = iprot.readString(); + struct.infoMessages.add(_elem136); } iprot.readListEnd(); } @@ -756,9 +756,9 @@ public class TStatus implements org.apac oprot.writeFieldBegin(INFO_MESSAGES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.infoMessages.size())); - for (String _iter193 : struct.infoMessages) + for (String _iter137 : struct.infoMessages) { - oprot.writeString(_iter193); + oprot.writeString(_iter137); } oprot.writeListEnd(); } @@ -819,9 +819,9 @@ public class TStatus implements org.apac if (struct.isSetInfoMessages()) { { oprot.writeI32(struct.infoMessages.size()); - for (String _iter194 : struct.infoMessages) + for (String _iter138 : struct.infoMessages) { - oprot.writeString(_iter194); + oprot.writeString(_iter138); } } } @@ -844,13 +844,13 @@ public class TStatus implements org.apac BitSet incoming = iprot.readBitSet(4); if (incoming.get(0)) { { - org.apache.thrift.protocol.TList _list195 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.infoMessages = new ArrayList<String>(_list195.size); - for (int _i196 = 0; _i196 < _list195.size; ++_i196) + org.apache.thrift.protocol.TList _list139 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.infoMessages = new ArrayList<String>(_list139.size); + for (int _i140 = 0; _i140 < _list139.size; ++_i140) { - String _elem197; // required - _elem197 = iprot.readString(); - struct.infoMessages.add(_elem197); + String _elem141; // required + _elem141 = iprot.readString(); + struct.infoMessages.add(_elem141); } } struct.setInfoMessagesIsSet(true); Modified: hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java?rev=1558269&r1=1558268&r2=1558269&view=diff ============================================================================== --- hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java (original) +++ hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java Wed Jan 15 02:18:30 2014 @@ -445,13 +445,13 @@ public class TStringColumn implements or case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list158 = iprot.readListBegin(); - struct.values = new ArrayList<String>(_list158.size); - for (int _i159 = 0; _i159 < _list158.size; ++_i159) + org.apache.thrift.protocol.TList _list102 = iprot.readListBegin(); + struct.values = new ArrayList<String>(_list102.size); + for (int _i103 = 0; _i103 < _list102.size; ++_i103) { - String _elem160; // required - _elem160 = iprot.readString(); - struct.values.add(_elem160); + String _elem104; // required + _elem104 = iprot.readString(); + struct.values.add(_elem104); } iprot.readListEnd(); } @@ -485,9 +485,9 @@ public class TStringColumn implements or oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.values.size())); - for (String _iter161 : struct.values) + for (String _iter105 : struct.values) { - oprot.writeString(_iter161); + oprot.writeString(_iter105); } oprot.writeListEnd(); } @@ -517,9 +517,9 @@ public class TStringColumn implements or TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (String _iter162 : struct.values) + for (String _iter106 : struct.values) { - oprot.writeString(_iter162); + oprot.writeString(_iter106); } } oprot.writeBinary(struct.nulls); @@ -529,13 +529,13 @@ public class TStringColumn implements or public void read(org.apache.thrift.protocol.TProtocol prot, TStringColumn struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list163 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.values = new ArrayList<String>(_list163.size); - for (int _i164 = 0; _i164 < _list163.size; ++_i164) + org.apache.thrift.protocol.TList _list107 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.values = new ArrayList<String>(_list107.size); + for (int _i108 = 0; _i108 < _list107.size; ++_i108) { - String _elem165; // required - _elem165 = iprot.readString(); - struct.values.add(_elem165); + String _elem109; // required + _elem109 = iprot.readString(); + struct.values.add(_elem109); } } struct.setValuesIsSet(true); Modified: hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java?rev=1558269&r1=1558268&r2=1558269&view=diff ============================================================================== --- hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java (original) +++ hive/trunk/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java Wed Jan 15 02:18:30 2014 @@ -360,7 +360,7 @@ public class TTypeQualifiers implements for (int _i1 = 0; _i1 < _map0.size; ++_i1) { String _key2; // required - TTypeQualifierValue _val3; // optional + TTypeQualifierValue _val3; // required _key2 = iprot.readString(); _val3 = new TTypeQualifierValue(); _val3.read(iprot); @@ -435,7 +435,7 @@ public class TTypeQualifiers implements for (int _i7 = 0; _i7 < _map6.size; ++_i7) { String _key8; // required - TTypeQualifierValue _val9; // optional + TTypeQualifierValue _val9; // required _key8 = iprot.readString(); _val9 = new TTypeQualifierValue(); _val9.read(iprot); Modified: hive/trunk/service/src/gen/thrift/gen-py/TCLIService/ttypes.py URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-py/TCLIService/ttypes.py?rev=1558269&r1=1558268&r2=1558269&view=diff ============================================================================== --- hive/trunk/service/src/gen/thrift/gen-py/TCLIService/ttypes.py (original) +++ hive/trunk/service/src/gen/thrift/gen-py/TCLIService/ttypes.py Wed Jan 15 02:18:30 2014 @@ -1731,201 +1731,6 @@ class TStringValue: def __ne__(self, other): return not (self == other) -class TColumn: - """ - Attributes: - - boolColumn - - byteColumn - - i16Column - - i32Column - - i64Column - - doubleColumn - - stringColumn - """ - - thrift_spec = ( - None, # 0 - (1, TType.LIST, 'boolColumn', (TType.STRUCT,(TBoolValue, TBoolValue.thrift_spec)), None, ), # 1 - (2, TType.LIST, 'byteColumn', (TType.STRUCT,(TByteValue, TByteValue.thrift_spec)), None, ), # 2 - (3, TType.LIST, 'i16Column', (TType.STRUCT,(TI16Value, TI16Value.thrift_spec)), None, ), # 3 - (4, TType.LIST, 'i32Column', (TType.STRUCT,(TI32Value, TI32Value.thrift_spec)), None, ), # 4 - (5, TType.LIST, 'i64Column', (TType.STRUCT,(TI64Value, TI64Value.thrift_spec)), None, ), # 5 - (6, TType.LIST, 'doubleColumn', (TType.STRUCT,(TDoubleValue, TDoubleValue.thrift_spec)), None, ), # 6 - (7, TType.LIST, 'stringColumn', (TType.STRUCT,(TStringValue, TStringValue.thrift_spec)), None, ), # 7 - ) - - def __init__(self, boolColumn=None, byteColumn=None, i16Column=None, i32Column=None, i64Column=None, doubleColumn=None, stringColumn=None,): - self.boolColumn = boolColumn - self.byteColumn = byteColumn - self.i16Column = i16Column - self.i32Column = i32Column - self.i64Column = i64Column - self.doubleColumn = doubleColumn - self.stringColumn = stringColumn - - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) - return - iprot.readStructBegin() - while True: - (fname, ftype, fid) = iprot.readFieldBegin() - if ftype == TType.STOP: - break - if fid == 1: - if ftype == TType.LIST: - self.boolColumn = [] - (_etype44, _size41) = iprot.readListBegin() - for _i45 in xrange(_size41): - _elem46 = TBoolValue() - _elem46.read(iprot) - self.boolColumn.append(_elem46) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.LIST: - self.byteColumn = [] - (_etype50, _size47) = iprot.readListBegin() - for _i51 in xrange(_size47): - _elem52 = TByteValue() - _elem52.read(iprot) - self.byteColumn.append(_elem52) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.LIST: - self.i16Column = [] - (_etype56, _size53) = iprot.readListBegin() - for _i57 in xrange(_size53): - _elem58 = TI16Value() - _elem58.read(iprot) - self.i16Column.append(_elem58) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.LIST: - self.i32Column = [] - (_etype62, _size59) = iprot.readListBegin() - for _i63 in xrange(_size59): - _elem64 = TI32Value() - _elem64.read(iprot) - self.i32Column.append(_elem64) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.LIST: - self.i64Column = [] - (_etype68, _size65) = iprot.readListBegin() - for _i69 in xrange(_size65): - _elem70 = TI64Value() - _elem70.read(iprot) - self.i64Column.append(_elem70) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.LIST: - self.doubleColumn = [] - (_etype74, _size71) = iprot.readListBegin() - for _i75 in xrange(_size71): - _elem76 = TDoubleValue() - _elem76.read(iprot) - self.doubleColumn.append(_elem76) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.LIST: - self.stringColumn = [] - (_etype80, _size77) = iprot.readListBegin() - for _i81 in xrange(_size77): - _elem82 = TStringValue() - _elem82.read(iprot) - self.stringColumn.append(_elem82) - iprot.readListEnd() - else: - iprot.skip(ftype) - else: - iprot.skip(ftype) - iprot.readFieldEnd() - iprot.readStructEnd() - - def write(self, oprot): - if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: - oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) - return - oprot.writeStructBegin('TColumn') - if self.boolColumn is not None: - oprot.writeFieldBegin('boolColumn', TType.LIST, 1) - oprot.writeListBegin(TType.STRUCT, len(self.boolColumn)) - for iter83 in self.boolColumn: - iter83.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.byteColumn is not None: - oprot.writeFieldBegin('byteColumn', TType.LIST, 2) - oprot.writeListBegin(TType.STRUCT, len(self.byteColumn)) - for iter84 in self.byteColumn: - iter84.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.i16Column is not None: - oprot.writeFieldBegin('i16Column', TType.LIST, 3) - oprot.writeListBegin(TType.STRUCT, len(self.i16Column)) - for iter85 in self.i16Column: - iter85.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.i32Column is not None: - oprot.writeFieldBegin('i32Column', TType.LIST, 4) - oprot.writeListBegin(TType.STRUCT, len(self.i32Column)) - for iter86 in self.i32Column: - iter86.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.i64Column is not None: - oprot.writeFieldBegin('i64Column', TType.LIST, 5) - oprot.writeListBegin(TType.STRUCT, len(self.i64Column)) - for iter87 in self.i64Column: - iter87.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.doubleColumn is not None: - oprot.writeFieldBegin('doubleColumn', TType.LIST, 6) - oprot.writeListBegin(TType.STRUCT, len(self.doubleColumn)) - for iter88 in self.doubleColumn: - iter88.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.stringColumn is not None: - oprot.writeFieldBegin('stringColumn', TType.LIST, 7) - oprot.writeListBegin(TType.STRUCT, len(self.stringColumn)) - for iter89 in self.stringColumn: - iter89.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __repr__(self): - L = ['%s=%r' % (key, value) - for key, value in self.__dict__.iteritems()] - return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) - - def __eq__(self, other): - return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ - - def __ne__(self, other): - return not (self == other) - class TColumnValue: """ Attributes: @@ -2091,11 +1896,11 @@ class TRow: if fid == 1: if ftype == TType.LIST: self.colVals = [] - (_etype93, _size90) = iprot.readListBegin() - for _i94 in xrange(_size90): - _elem95 = TColumnValue() - _elem95.read(iprot) - self.colVals.append(_elem95) + (_etype44, _size41) = iprot.readListBegin() + for _i45 in xrange(_size41): + _elem46 = TColumnValue() + _elem46.read(iprot) + self.colVals.append(_elem46) iprot.readListEnd() else: iprot.skip(ftype) @@ -2112,8 +1917,8 @@ class TRow: if self.colVals is not None: oprot.writeFieldBegin('colVals', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.colVals)) - for iter96 in self.colVals: - iter96.write(oprot) + for iter47 in self.colVals: + iter47.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -2165,10 +1970,10 @@ class TBoolColumn: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype100, _size97) = iprot.readListBegin() - for _i101 in xrange(_size97): - _elem102 = iprot.readBool(); - self.values.append(_elem102) + (_etype51, _size48) = iprot.readListBegin() + for _i52 in xrange(_size48): + _elem53 = iprot.readBool(); + self.values.append(_elem53) iprot.readListEnd() else: iprot.skip(ftype) @@ -2190,8 +1995,8 @@ class TBoolColumn: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.BOOL, len(self.values)) - for iter103 in self.values: - oprot.writeBool(iter103) + for iter54 in self.values: + oprot.writeBool(iter54) oprot.writeListEnd() oprot.writeFieldEnd() if self.nulls is not None: @@ -2249,10 +2054,10 @@ class TByteColumn: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype107, _size104) = iprot.readListBegin() - for _i108 in xrange(_size104): - _elem109 = iprot.readByte(); - self.values.append(_elem109) + (_etype58, _size55) = iprot.readListBegin() + for _i59 in xrange(_size55): + _elem60 = iprot.readByte(); + self.values.append(_elem60) iprot.readListEnd() else: iprot.skip(ftype) @@ -2274,8 +2079,8 @@ class TByteColumn: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.BYTE, len(self.values)) - for iter110 in self.values: - oprot.writeByte(iter110) + for iter61 in self.values: + oprot.writeByte(iter61) oprot.writeListEnd() oprot.writeFieldEnd() if self.nulls is not None: @@ -2333,10 +2138,10 @@ class TI16Column: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype114, _size111) = iprot.readListBegin() - for _i115 in xrange(_size111): - _elem116 = iprot.readI16(); - self.values.append(_elem116) + (_etype65, _size62) = iprot.readListBegin() + for _i66 in xrange(_size62): + _elem67 = iprot.readI16(); + self.values.append(_elem67) iprot.readListEnd() else: iprot.skip(ftype) @@ -2358,8 +2163,8 @@ class TI16Column: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.I16, len(self.values)) - for iter117 in self.values: - oprot.writeI16(iter117) + for iter68 in self.values: + oprot.writeI16(iter68) oprot.writeListEnd() oprot.writeFieldEnd() if self.nulls is not None: @@ -2417,10 +2222,10 @@ class TI32Column: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype121, _size118) = iprot.readListBegin() - for _i122 in xrange(_size118): - _elem123 = iprot.readI32(); - self.values.append(_elem123) + (_etype72, _size69) = iprot.readListBegin() + for _i73 in xrange(_size69): + _elem74 = iprot.readI32(); + self.values.append(_elem74) iprot.readListEnd() else: iprot.skip(ftype) @@ -2442,8 +2247,8 @@ class TI32Column: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.I32, len(self.values)) - for iter124 in self.values: - oprot.writeI32(iter124) + for iter75 in self.values: + oprot.writeI32(iter75) oprot.writeListEnd() oprot.writeFieldEnd() if self.nulls is not None: @@ -2501,10 +2306,10 @@ class TI64Column: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype128, _size125) = iprot.readListBegin() - for _i129 in xrange(_size125): - _elem130 = iprot.readI64(); - self.values.append(_elem130) + (_etype79, _size76) = iprot.readListBegin() + for _i80 in xrange(_size76): + _elem81 = iprot.readI64(); + self.values.append(_elem81) iprot.readListEnd() else: iprot.skip(ftype) @@ -2526,8 +2331,8 @@ class TI64Column: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.I64, len(self.values)) - for iter131 in self.values: - oprot.writeI64(iter131) + for iter82 in self.values: + oprot.writeI64(iter82) oprot.writeListEnd() oprot.writeFieldEnd() if self.nulls is not None: @@ -2585,10 +2390,10 @@ class TDoubleColumn: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype135, _size132) = iprot.readListBegin() - for _i136 in xrange(_size132): - _elem137 = iprot.readDouble(); - self.values.append(_elem137) + (_etype86, _size83) = iprot.readListBegin() + for _i87 in xrange(_size83): + _elem88 = iprot.readDouble(); + self.values.append(_elem88) iprot.readListEnd() else: iprot.skip(ftype) @@ -2610,8 +2415,8 @@ class TDoubleColumn: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.DOUBLE, len(self.values)) - for iter138 in self.values: - oprot.writeDouble(iter138) + for iter89 in self.values: + oprot.writeDouble(iter89) oprot.writeListEnd() oprot.writeFieldEnd() if self.nulls is not None: @@ -2669,10 +2474,10 @@ class TStringColumn: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype142, _size139) = iprot.readListBegin() - for _i143 in xrange(_size139): - _elem144 = iprot.readString(); - self.values.append(_elem144) + (_etype93, _size90) = iprot.readListBegin() + for _i94 in xrange(_size90): + _elem95 = iprot.readString(); + self.values.append(_elem95) iprot.readListEnd() else: iprot.skip(ftype) @@ -2694,8 +2499,8 @@ class TStringColumn: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.values)) - for iter145 in self.values: - oprot.writeString(iter145) + for iter96 in self.values: + oprot.writeString(iter96) oprot.writeListEnd() oprot.writeFieldEnd() if self.nulls is not None: @@ -2753,10 +2558,10 @@ class TBinaryColumn: if fid == 1: if ftype == TType.LIST: self.values = [] - (_etype149, _size146) = iprot.readListBegin() - for _i150 in xrange(_size146): - _elem151 = iprot.readString(); - self.values.append(_elem151) + (_etype100, _size97) = iprot.readListBegin() + for _i101 in xrange(_size97): + _elem102 = iprot.readString(); + self.values.append(_elem102) iprot.readListEnd() else: iprot.skip(ftype) @@ -2778,8 +2583,8 @@ class TBinaryColumn: if self.values is not None: oprot.writeFieldBegin('values', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.values)) - for iter152 in self.values: - oprot.writeString(iter152) + for iter103 in self.values: + oprot.writeString(iter103) oprot.writeListEnd() oprot.writeFieldEnd() if self.nulls is not None: @@ -2997,22 +2802,22 @@ class TRowSet: elif fid == 2: if ftype == TType.LIST: self.rows = [] - (_etype156, _size153) = iprot.readListBegin() - for _i157 in xrange(_size153): - _elem158 = TRow() - _elem158.read(iprot) - self.rows.append(_elem158) + (_etype107, _size104) = iprot.readListBegin() + for _i108 in xrange(_size104): + _elem109 = TRow() + _elem109.read(iprot) + self.rows.append(_elem109) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.columns = [] - (_etype162, _size159) = iprot.readListBegin() - for _i163 in xrange(_size159): - _elem164 = TColumn() - _elem164.read(iprot) - self.columns.append(_elem164) + (_etype113, _size110) = iprot.readListBegin() + for _i114 in xrange(_size110): + _elem115 = TColumn() + _elem115.read(iprot) + self.columns.append(_elem115) iprot.readListEnd() else: iprot.skip(ftype) @@ -3033,15 +2838,15 @@ class TRowSet: if self.rows is not None: oprot.writeFieldBegin('rows', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.rows)) - for iter165 in self.rows: - iter165.write(oprot) + for iter116 in self.rows: + iter116.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.columns is not None: oprot.writeFieldBegin('columns', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.columns)) - for iter166 in self.columns: - iter166.write(oprot) + for iter117 in self.columns: + iter117.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -3109,10 +2914,10 @@ class TStatus: elif fid == 2: if ftype == TType.LIST: self.infoMessages = [] - (_etype170, _size167) = iprot.readListBegin() - for _i171 in xrange(_size167): - _elem172 = iprot.readString(); - self.infoMessages.append(_elem172) + (_etype121, _size118) = iprot.readListBegin() + for _i122 in xrange(_size118): + _elem123 = iprot.readString(); + self.infoMessages.append(_elem123) iprot.readListEnd() else: iprot.skip(ftype) @@ -3148,8 +2953,8 @@ class TStatus: if self.infoMessages is not None: oprot.writeFieldBegin('infoMessages', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.infoMessages)) - for iter173 in self.infoMessages: - oprot.writeString(iter173) + for iter124 in self.infoMessages: + oprot.writeString(iter124) oprot.writeListEnd() oprot.writeFieldEnd() if self.sqlState is not None: @@ -3476,11 +3281,11 @@ class TOpenSessionReq: elif fid == 4: if ftype == TType.MAP: self.configuration = {} - (_ktype175, _vtype176, _size174 ) = iprot.readMapBegin() - for _i178 in xrange(_size174): - _key179 = iprot.readString(); - _val180 = iprot.readString(); - self.configuration[_key179] = _val180 + (_ktype126, _vtype127, _size125 ) = iprot.readMapBegin() + for _i129 in xrange(_size125): + _key130 = iprot.readString(); + _val131 = iprot.readString(); + self.configuration[_key130] = _val131 iprot.readMapEnd() else: iprot.skip(ftype) @@ -3509,9 +3314,9 @@ class TOpenSessionReq: if self.configuration is not None: oprot.writeFieldBegin('configuration', TType.MAP, 4) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.configuration)) - for kiter181,viter182 in self.configuration.items(): - oprot.writeString(kiter181) - oprot.writeString(viter182) + for kiter132,viter133 in self.configuration.items(): + oprot.writeString(kiter132) + oprot.writeString(viter133) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -3586,11 +3391,11 @@ class TOpenSessionResp: elif fid == 4: if ftype == TType.MAP: self.configuration = {} - (_ktype184, _vtype185, _size183 ) = iprot.readMapBegin() - for _i187 in xrange(_size183): - _key188 = iprot.readString(); - _val189 = iprot.readString(); - self.configuration[_key188] = _val189 + (_ktype135, _vtype136, _size134 ) = iprot.readMapBegin() + for _i138 in xrange(_size134): + _key139 = iprot.readString(); + _val140 = iprot.readString(); + self.configuration[_key139] = _val140 iprot.readMapEnd() else: iprot.skip(ftype) @@ -3619,9 +3424,9 @@ class TOpenSessionResp: if self.configuration is not None: oprot.writeFieldBegin('configuration', TType.MAP, 4) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.configuration)) - for kiter190,viter191 in self.configuration.items(): - oprot.writeString(kiter190) - oprot.writeString(viter191) + for kiter141,viter142 in self.configuration.items(): + oprot.writeString(kiter141) + oprot.writeString(viter142) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -4093,11 +3898,11 @@ class TExecuteStatementReq: elif fid == 3: if ftype == TType.MAP: self.confOverlay = {} - (_ktype193, _vtype194, _size192 ) = iprot.readMapBegin() - for _i196 in xrange(_size192): - _key197 = iprot.readString(); - _val198 = iprot.readString(); - self.confOverlay[_key197] = _val198 + (_ktype144, _vtype145, _size143 ) = iprot.readMapBegin() + for _i147 in xrange(_size143): + _key148 = iprot.readString(); + _val149 = iprot.readString(); + self.confOverlay[_key148] = _val149 iprot.readMapEnd() else: iprot.skip(ftype) @@ -4127,9 +3932,9 @@ class TExecuteStatementReq: if self.confOverlay is not None: oprot.writeFieldBegin('confOverlay', TType.MAP, 3) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.confOverlay)) - for kiter199,viter200 in self.confOverlay.items(): - oprot.writeString(kiter199) - oprot.writeString(viter200) + for kiter150,viter151 in self.confOverlay.items(): + oprot.writeString(kiter150) + oprot.writeString(viter151) oprot.writeMapEnd() oprot.writeFieldEnd() if self.runAsync is not None: @@ -4734,10 +4539,10 @@ class TGetTablesReq: elif fid == 5: if ftype == TType.LIST: self.tableTypes = [] - (_etype204, _size201) = iprot.readListBegin() - for _i205 in xrange(_size201): - _elem206 = iprot.readString(); - self.tableTypes.append(_elem206) + (_etype155, _size152) = iprot.readListBegin() + for _i156 in xrange(_size152): + _elem157 = iprot.readString(); + self.tableTypes.append(_elem157) iprot.readListEnd() else: iprot.skip(ftype) @@ -4770,8 +4575,8 @@ class TGetTablesReq: if self.tableTypes is not None: oprot.writeFieldBegin('tableTypes', TType.LIST, 5) oprot.writeListBegin(TType.STRING, len(self.tableTypes)) - for iter207 in self.tableTypes: - oprot.writeString(iter207) + for iter158 in self.tableTypes: + oprot.writeString(iter158) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() Modified: hive/trunk/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb URL: http://svn.apache.org/viewvc/hive/trunk/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb?rev=1558269&r1=1558268&r2=1558269&view=diff ============================================================================== --- hive/trunk/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb (original) +++ hive/trunk/service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb Wed Jan 15 02:18:30 2014 @@ -522,65 +522,6 @@ class TStringValue ::Thrift::Struct.generate_accessors self end -class TColumn < ::Thrift::Union - include ::Thrift::Struct_Union - class << self - def boolColumn(val) - TColumn.new(:boolColumn, val) - end - - def byteColumn(val) - TColumn.new(:byteColumn, val) - end - - def i16Column(val) - TColumn.new(:i16Column, val) - end - - def i32Column(val) - TColumn.new(:i32Column, val) - end - - def i64Column(val) - TColumn.new(:i64Column, val) - end - - def doubleColumn(val) - TColumn.new(:doubleColumn, val) - end - - def stringColumn(val) - TColumn.new(:stringColumn, val) - end - end - - BOOLCOLUMN = 1 - BYTECOLUMN = 2 - I16COLUMN = 3 - I32COLUMN = 4 - I64COLUMN = 5 - DOUBLECOLUMN = 6 - STRINGCOLUMN = 7 - - FIELDS = { - BOOLCOLUMN => {:type => ::Thrift::Types::LIST, :name => 'boolColumn', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TBoolValue}}, - BYTECOLUMN => {:type => ::Thrift::Types::LIST, :name => 'byteColumn', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TByteValue}}, - I16COLUMN => {:type => ::Thrift::Types::LIST, :name => 'i16Column', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TI16Value}}, - I32COLUMN => {:type => ::Thrift::Types::LIST, :name => 'i32Column', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TI32Value}}, - I64COLUMN => {:type => ::Thrift::Types::LIST, :name => 'i64Column', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TI64Value}}, - DOUBLECOLUMN => {:type => ::Thrift::Types::LIST, :name => 'doubleColumn', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TDoubleValue}}, - STRINGCOLUMN => {:type => ::Thrift::Types::LIST, :name => 'stringColumn', :element => {:type => ::Thrift::Types::STRUCT, :class => ::TStringValue}} - } - - def struct_fields; FIELDS; end - - def validate - raise(StandardError, 'Union fields are not set.') if get_set_field.nil? || get_value.nil? - end - - ::Thrift::Union.generate_accessors self -end - class TColumnValue < ::Thrift::Union include ::Thrift::Struct_Union class << self
