diff --git service/if/TCLIService.thrift service/if/TCLIService.thrift index 692d49b..43e6976 100644 --- service/if/TCLIService.thrift +++ service/if/TCLIService.thrift @@ -307,16 +307,6 @@ struct TStringValue { 1: optional string value } -union TColumn { - 1: list boolColumn - 2: list byteColumn - 3: list i16Column - 4: list i32Column - 5: list i64Column - 6: list doubleColumn - 7: list stringColumn -} - // A single column value in a result set. // Note that Hive's type system is richer than Thrift's, // so in some cases we have to map multiple Hive types diff --git service/src/gen/thrift/gen-cpp/TCLIService_types.cpp service/src/gen/thrift/gen-cpp/TCLIService_types.cpp index 1afa43d..ff7df74 100644 --- service/src/gen/thrift/gen-cpp/TCLIService_types.cpp +++ service/src/gen/thrift/gen-cpp/TCLIService_types.cpp @@ -1731,286 +1731,6 @@ void swap(TStringValue &a, TStringValue &b) { swap(a.__isset, b.__isset); } -const char* TColumn::ascii_fingerprint = "B39B4E4E565DB31DC891D62FDC3208DC"; -const uint8_t TColumn::binary_fingerprint[16] = {0xB3,0x9B,0x4E,0x4E,0x56,0x5D,0xB3,0x1D,0xC8,0x91,0xD6,0x2F,0xDC,0x32,0x08,0xDC}; - -uint32_t TColumn::read(::apache::thrift::protocol::TProtocol* iprot) { - - uint32_t xfer = 0; - std::string fname; - ::apache::thrift::protocol::TType ftype; - int16_t fid; - - xfer += iprot->readStructBegin(fname); - - using ::apache::thrift::protocol::TProtocolException; - - - while (true) - { - xfer += iprot->readFieldBegin(fname, ftype, fid); - if (ftype == ::apache::thrift::protocol::T_STOP) { - break; - } - switch (fid) - { - case 1: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->boolColumn.clear(); - uint32_t _size37; - ::apache::thrift::protocol::TType _etype40; - xfer += iprot->readListBegin(_etype40, _size37); - this->boolColumn.resize(_size37); - uint32_t _i41; - for (_i41 = 0; _i41 < _size37; ++_i41) - { - xfer += this->boolColumn[_i41].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.boolColumn = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 2: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->byteColumn.clear(); - uint32_t _size42; - ::apache::thrift::protocol::TType _etype45; - xfer += iprot->readListBegin(_etype45, _size42); - this->byteColumn.resize(_size42); - uint32_t _i46; - for (_i46 = 0; _i46 < _size42; ++_i46) - { - xfer += this->byteColumn[_i46].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.byteColumn = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 3: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->i16Column.clear(); - uint32_t _size47; - ::apache::thrift::protocol::TType _etype50; - xfer += iprot->readListBegin(_etype50, _size47); - this->i16Column.resize(_size47); - uint32_t _i51; - for (_i51 = 0; _i51 < _size47; ++_i51) - { - xfer += this->i16Column[_i51].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.i16Column = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 4: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->i32Column.clear(); - uint32_t _size52; - ::apache::thrift::protocol::TType _etype55; - xfer += iprot->readListBegin(_etype55, _size52); - this->i32Column.resize(_size52); - uint32_t _i56; - for (_i56 = 0; _i56 < _size52; ++_i56) - { - xfer += this->i32Column[_i56].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.i32Column = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 5: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->i64Column.clear(); - uint32_t _size57; - ::apache::thrift::protocol::TType _etype60; - xfer += iprot->readListBegin(_etype60, _size57); - this->i64Column.resize(_size57); - uint32_t _i61; - for (_i61 = 0; _i61 < _size57; ++_i61) - { - xfer += this->i64Column[_i61].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.i64Column = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 6: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->doubleColumn.clear(); - uint32_t _size62; - ::apache::thrift::protocol::TType _etype65; - xfer += iprot->readListBegin(_etype65, _size62); - this->doubleColumn.resize(_size62); - uint32_t _i66; - for (_i66 = 0; _i66 < _size62; ++_i66) - { - xfer += this->doubleColumn[_i66].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.doubleColumn = true; - } else { - xfer += iprot->skip(ftype); - } - break; - case 7: - if (ftype == ::apache::thrift::protocol::T_LIST) { - { - this->stringColumn.clear(); - uint32_t _size67; - ::apache::thrift::protocol::TType _etype70; - xfer += iprot->readListBegin(_etype70, _size67); - this->stringColumn.resize(_size67); - uint32_t _i71; - for (_i71 = 0; _i71 < _size67; ++_i71) - { - xfer += this->stringColumn[_i71].read(iprot); - } - xfer += iprot->readListEnd(); - } - this->__isset.stringColumn = true; - } else { - xfer += iprot->skip(ftype); - } - break; - default: - xfer += iprot->skip(ftype); - break; - } - xfer += iprot->readFieldEnd(); - } - - xfer += iprot->readStructEnd(); - - return xfer; -} - -uint32_t TColumn::write(::apache::thrift::protocol::TProtocol* oprot) const { - uint32_t xfer = 0; - xfer += oprot->writeStructBegin("TColumn"); - - xfer += oprot->writeFieldBegin("boolColumn", ::apache::thrift::protocol::T_LIST, 1); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->boolColumn.size())); - std::vector ::const_iterator _iter72; - for (_iter72 = this->boolColumn.begin(); _iter72 != this->boolColumn.end(); ++_iter72) - { - xfer += (*_iter72).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("byteColumn", ::apache::thrift::protocol::T_LIST, 2); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->byteColumn.size())); - std::vector ::const_iterator _iter73; - for (_iter73 = this->byteColumn.begin(); _iter73 != this->byteColumn.end(); ++_iter73) - { - xfer += (*_iter73).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("i16Column", ::apache::thrift::protocol::T_LIST, 3); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->i16Column.size())); - std::vector ::const_iterator _iter74; - for (_iter74 = this->i16Column.begin(); _iter74 != this->i16Column.end(); ++_iter74) - { - xfer += (*_iter74).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("i32Column", ::apache::thrift::protocol::T_LIST, 4); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->i32Column.size())); - std::vector ::const_iterator _iter75; - for (_iter75 = this->i32Column.begin(); _iter75 != this->i32Column.end(); ++_iter75) - { - xfer += (*_iter75).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("i64Column", ::apache::thrift::protocol::T_LIST, 5); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->i64Column.size())); - std::vector ::const_iterator _iter76; - for (_iter76 = this->i64Column.begin(); _iter76 != this->i64Column.end(); ++_iter76) - { - xfer += (*_iter76).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("doubleColumn", ::apache::thrift::protocol::T_LIST, 6); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->doubleColumn.size())); - std::vector ::const_iterator _iter77; - for (_iter77 = this->doubleColumn.begin(); _iter77 != this->doubleColumn.end(); ++_iter77) - { - xfer += (*_iter77).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldBegin("stringColumn", ::apache::thrift::protocol::T_LIST, 7); - { - xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->stringColumn.size())); - std::vector ::const_iterator _iter78; - for (_iter78 = this->stringColumn.begin(); _iter78 != this->stringColumn.end(); ++_iter78) - { - xfer += (*_iter78).write(oprot); - } - xfer += oprot->writeListEnd(); - } - xfer += oprot->writeFieldEnd(); - - xfer += oprot->writeFieldStop(); - xfer += oprot->writeStructEnd(); - return xfer; -} - -void swap(TColumn &a, TColumn &b) { - using ::std::swap; - swap(a.boolColumn, b.boolColumn); - swap(a.byteColumn, b.byteColumn); - swap(a.i16Column, b.i16Column); - swap(a.i32Column, b.i32Column); - swap(a.i64Column, b.i64Column); - swap(a.doubleColumn, b.doubleColumn); - swap(a.stringColumn, b.stringColumn); - swap(a.__isset, b.__isset); -} - const char* TColumnValue::ascii_fingerprint = "C2DDD988447EA7999A8285AA38AAE9AD"; const uint8_t TColumnValue::binary_fingerprint[16] = {0xC2,0xDD,0xD9,0x88,0x44,0x7E,0xA7,0x99,0x9A,0x82,0x85,0xAA,0x38,0xAA,0xE9,0xAD}; @@ -2179,14 +1899,14 @@ uint32_t TRow::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->colVals.clear(); - uint32_t _size79; - ::apache::thrift::protocol::TType _etype82; - xfer += iprot->readListBegin(_etype82, _size79); - this->colVals.resize(_size79); - uint32_t _i83; - for (_i83 = 0; _i83 < _size79; ++_i83) + uint32_t _size37; + ::apache::thrift::protocol::TType _etype40; + xfer += iprot->readListBegin(_etype40, _size37); + this->colVals.resize(_size37); + uint32_t _i41; + for (_i41 = 0; _i41 < _size37; ++_i41) { - xfer += this->colVals[_i83].read(iprot); + xfer += this->colVals[_i41].read(iprot); } xfer += iprot->readListEnd(); } @@ -2216,10 +1936,10 @@ uint32_t TRow::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeFieldBegin("colVals", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->colVals.size())); - std::vector ::const_iterator _iter84; - for (_iter84 = this->colVals.begin(); _iter84 != this->colVals.end(); ++_iter84) + std::vector ::const_iterator _iter42; + for (_iter42 = this->colVals.begin(); _iter42 != this->colVals.end(); ++_iter42) { - xfer += (*_iter84).write(oprot); + xfer += (*_iter42).write(oprot); } xfer += oprot->writeListEnd(); } @@ -2264,14 +1984,14 @@ uint32_t TBoolColumn::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size85; - ::apache::thrift::protocol::TType _etype88; - xfer += iprot->readListBegin(_etype88, _size85); - this->values.resize(_size85); - uint32_t _i89; - for (_i89 = 0; _i89 < _size85; ++_i89) + uint32_t _size43; + ::apache::thrift::protocol::TType _etype46; + xfer += iprot->readListBegin(_etype46, _size43); + this->values.resize(_size43); + uint32_t _i47; + for (_i47 = 0; _i47 < _size43; ++_i47) { - xfer += iprot->readBool(this->values[_i89]); + xfer += iprot->readBool(this->values[_i47]); } xfer += iprot->readListEnd(); } @@ -2311,10 +2031,10 @@ uint32_t TBoolColumn::write(::apache::thrift::protocol::TProtocol* oprot) const xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_BOOL, static_cast(this->values.size())); - std::vector ::const_iterator _iter90; - for (_iter90 = this->values.begin(); _iter90 != this->values.end(); ++_iter90) + std::vector ::const_iterator _iter48; + for (_iter48 = this->values.begin(); _iter48 != this->values.end(); ++_iter48) { - xfer += oprot->writeBool((*_iter90)); + xfer += oprot->writeBool((*_iter48)); } xfer += oprot->writeListEnd(); } @@ -2364,14 +2084,14 @@ uint32_t TByteColumn::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size91; - ::apache::thrift::protocol::TType _etype94; - xfer += iprot->readListBegin(_etype94, _size91); - this->values.resize(_size91); - uint32_t _i95; - for (_i95 = 0; _i95 < _size91; ++_i95) + uint32_t _size49; + ::apache::thrift::protocol::TType _etype52; + xfer += iprot->readListBegin(_etype52, _size49); + this->values.resize(_size49); + uint32_t _i53; + for (_i53 = 0; _i53 < _size49; ++_i53) { - xfer += iprot->readByte(this->values[_i95]); + xfer += iprot->readByte(this->values[_i53]); } xfer += iprot->readListEnd(); } @@ -2411,10 +2131,10 @@ uint32_t TByteColumn::write(::apache::thrift::protocol::TProtocol* oprot) const xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_BYTE, static_cast(this->values.size())); - std::vector ::const_iterator _iter96; - for (_iter96 = this->values.begin(); _iter96 != this->values.end(); ++_iter96) + std::vector ::const_iterator _iter54; + for (_iter54 = this->values.begin(); _iter54 != this->values.end(); ++_iter54) { - xfer += oprot->writeByte((*_iter96)); + xfer += oprot->writeByte((*_iter54)); } xfer += oprot->writeListEnd(); } @@ -2464,14 +2184,14 @@ uint32_t TI16Column::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size97; - ::apache::thrift::protocol::TType _etype100; - xfer += iprot->readListBegin(_etype100, _size97); - this->values.resize(_size97); - uint32_t _i101; - for (_i101 = 0; _i101 < _size97; ++_i101) + uint32_t _size55; + ::apache::thrift::protocol::TType _etype58; + xfer += iprot->readListBegin(_etype58, _size55); + this->values.resize(_size55); + uint32_t _i59; + for (_i59 = 0; _i59 < _size55; ++_i59) { - xfer += iprot->readI16(this->values[_i101]); + xfer += iprot->readI16(this->values[_i59]); } xfer += iprot->readListEnd(); } @@ -2511,10 +2231,10 @@ uint32_t TI16Column::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I16, static_cast(this->values.size())); - std::vector ::const_iterator _iter102; - for (_iter102 = this->values.begin(); _iter102 != this->values.end(); ++_iter102) + std::vector ::const_iterator _iter60; + for (_iter60 = this->values.begin(); _iter60 != this->values.end(); ++_iter60) { - xfer += oprot->writeI16((*_iter102)); + xfer += oprot->writeI16((*_iter60)); } xfer += oprot->writeListEnd(); } @@ -2564,14 +2284,14 @@ uint32_t TI32Column::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size103; - ::apache::thrift::protocol::TType _etype106; - xfer += iprot->readListBegin(_etype106, _size103); - this->values.resize(_size103); - uint32_t _i107; - for (_i107 = 0; _i107 < _size103; ++_i107) + uint32_t _size61; + ::apache::thrift::protocol::TType _etype64; + xfer += iprot->readListBegin(_etype64, _size61); + this->values.resize(_size61); + uint32_t _i65; + for (_i65 = 0; _i65 < _size61; ++_i65) { - xfer += iprot->readI32(this->values[_i107]); + xfer += iprot->readI32(this->values[_i65]); } xfer += iprot->readListEnd(); } @@ -2611,10 +2331,10 @@ uint32_t TI32Column::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I32, static_cast(this->values.size())); - std::vector ::const_iterator _iter108; - for (_iter108 = this->values.begin(); _iter108 != this->values.end(); ++_iter108) + std::vector ::const_iterator _iter66; + for (_iter66 = this->values.begin(); _iter66 != this->values.end(); ++_iter66) { - xfer += oprot->writeI32((*_iter108)); + xfer += oprot->writeI32((*_iter66)); } xfer += oprot->writeListEnd(); } @@ -2664,14 +2384,14 @@ uint32_t TI64Column::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size109; - ::apache::thrift::protocol::TType _etype112; - xfer += iprot->readListBegin(_etype112, _size109); - this->values.resize(_size109); - uint32_t _i113; - for (_i113 = 0; _i113 < _size109; ++_i113) + uint32_t _size67; + ::apache::thrift::protocol::TType _etype70; + xfer += iprot->readListBegin(_etype70, _size67); + this->values.resize(_size67); + uint32_t _i71; + for (_i71 = 0; _i71 < _size67; ++_i71) { - xfer += iprot->readI64(this->values[_i113]); + xfer += iprot->readI64(this->values[_i71]); } xfer += iprot->readListEnd(); } @@ -2711,10 +2431,10 @@ uint32_t TI64Column::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast(this->values.size())); - std::vector ::const_iterator _iter114; - for (_iter114 = this->values.begin(); _iter114 != this->values.end(); ++_iter114) + std::vector ::const_iterator _iter72; + for (_iter72 = this->values.begin(); _iter72 != this->values.end(); ++_iter72) { - xfer += oprot->writeI64((*_iter114)); + xfer += oprot->writeI64((*_iter72)); } xfer += oprot->writeListEnd(); } @@ -2764,14 +2484,14 @@ uint32_t TDoubleColumn::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size115; - ::apache::thrift::protocol::TType _etype118; - xfer += iprot->readListBegin(_etype118, _size115); - this->values.resize(_size115); - uint32_t _i119; - for (_i119 = 0; _i119 < _size115; ++_i119) + uint32_t _size73; + ::apache::thrift::protocol::TType _etype76; + xfer += iprot->readListBegin(_etype76, _size73); + this->values.resize(_size73); + uint32_t _i77; + for (_i77 = 0; _i77 < _size73; ++_i77) { - xfer += iprot->readDouble(this->values[_i119]); + xfer += iprot->readDouble(this->values[_i77]); } xfer += iprot->readListEnd(); } @@ -2811,10 +2531,10 @@ uint32_t TDoubleColumn::write(::apache::thrift::protocol::TProtocol* oprot) cons xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_DOUBLE, static_cast(this->values.size())); - std::vector ::const_iterator _iter120; - for (_iter120 = this->values.begin(); _iter120 != this->values.end(); ++_iter120) + std::vector ::const_iterator _iter78; + for (_iter78 = this->values.begin(); _iter78 != this->values.end(); ++_iter78) { - xfer += oprot->writeDouble((*_iter120)); + xfer += oprot->writeDouble((*_iter78)); } xfer += oprot->writeListEnd(); } @@ -2864,14 +2584,14 @@ uint32_t TStringColumn::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size121; - ::apache::thrift::protocol::TType _etype124; - xfer += iprot->readListBegin(_etype124, _size121); - this->values.resize(_size121); - uint32_t _i125; - for (_i125 = 0; _i125 < _size121; ++_i125) + uint32_t _size79; + ::apache::thrift::protocol::TType _etype82; + xfer += iprot->readListBegin(_etype82, _size79); + this->values.resize(_size79); + uint32_t _i83; + for (_i83 = 0; _i83 < _size79; ++_i83) { - xfer += iprot->readString(this->values[_i125]); + xfer += iprot->readString(this->values[_i83]); } xfer += iprot->readListEnd(); } @@ -2911,10 +2631,10 @@ uint32_t TStringColumn::write(::apache::thrift::protocol::TProtocol* oprot) cons xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->values.size())); - std::vector ::const_iterator _iter126; - for (_iter126 = this->values.begin(); _iter126 != this->values.end(); ++_iter126) + std::vector ::const_iterator _iter84; + for (_iter84 = this->values.begin(); _iter84 != this->values.end(); ++_iter84) { - xfer += oprot->writeString((*_iter126)); + xfer += oprot->writeString((*_iter84)); } xfer += oprot->writeListEnd(); } @@ -2964,14 +2684,14 @@ uint32_t TBinaryColumn::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->values.clear(); - uint32_t _size127; - ::apache::thrift::protocol::TType _etype130; - xfer += iprot->readListBegin(_etype130, _size127); - this->values.resize(_size127); - uint32_t _i131; - for (_i131 = 0; _i131 < _size127; ++_i131) + uint32_t _size85; + ::apache::thrift::protocol::TType _etype88; + xfer += iprot->readListBegin(_etype88, _size85); + this->values.resize(_size85); + uint32_t _i89; + for (_i89 = 0; _i89 < _size85; ++_i89) { - xfer += iprot->readBinary(this->values[_i131]); + xfer += iprot->readBinary(this->values[_i89]); } xfer += iprot->readListEnd(); } @@ -3011,10 +2731,10 @@ uint32_t TBinaryColumn::write(::apache::thrift::protocol::TProtocol* oprot) cons xfer += oprot->writeFieldBegin("values", ::apache::thrift::protocol::T_LIST, 1); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->values.size())); - std::vector ::const_iterator _iter132; - for (_iter132 = this->values.begin(); _iter132 != this->values.end(); ++_iter132) + std::vector ::const_iterator _iter90; + for (_iter90 = this->values.begin(); _iter90 != this->values.end(); ++_iter90) { - xfer += oprot->writeBinary((*_iter132)); + xfer += oprot->writeBinary((*_iter90)); } xfer += oprot->writeListEnd(); } @@ -3225,14 +2945,14 @@ uint32_t TRowSet::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->rows.clear(); - uint32_t _size133; - ::apache::thrift::protocol::TType _etype136; - xfer += iprot->readListBegin(_etype136, _size133); - this->rows.resize(_size133); - uint32_t _i137; - for (_i137 = 0; _i137 < _size133; ++_i137) + uint32_t _size91; + ::apache::thrift::protocol::TType _etype94; + xfer += iprot->readListBegin(_etype94, _size91); + this->rows.resize(_size91); + uint32_t _i95; + for (_i95 = 0; _i95 < _size91; ++_i95) { - xfer += this->rows[_i137].read(iprot); + xfer += this->rows[_i95].read(iprot); } xfer += iprot->readListEnd(); } @@ -3245,14 +2965,14 @@ uint32_t TRowSet::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->columns.clear(); - uint32_t _size138; - ::apache::thrift::protocol::TType _etype141; - xfer += iprot->readListBegin(_etype141, _size138); - this->columns.resize(_size138); - uint32_t _i142; - for (_i142 = 0; _i142 < _size138; ++_i142) + uint32_t _size96; + ::apache::thrift::protocol::TType _etype99; + xfer += iprot->readListBegin(_etype99, _size96); + this->columns.resize(_size96); + uint32_t _i100; + for (_i100 = 0; _i100 < _size96; ++_i100) { - xfer += this->columns[_i142].read(iprot); + xfer += this->columns[_i100].read(iprot); } xfer += iprot->readListEnd(); } @@ -3288,10 +3008,10 @@ uint32_t TRowSet::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeFieldBegin("rows", ::apache::thrift::protocol::T_LIST, 2); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->rows.size())); - std::vector ::const_iterator _iter143; - for (_iter143 = this->rows.begin(); _iter143 != this->rows.end(); ++_iter143) + std::vector ::const_iterator _iter101; + for (_iter101 = this->rows.begin(); _iter101 != this->rows.end(); ++_iter101) { - xfer += (*_iter143).write(oprot); + xfer += (*_iter101).write(oprot); } xfer += oprot->writeListEnd(); } @@ -3301,10 +3021,10 @@ uint32_t TRowSet::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeFieldBegin("columns", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->columns.size())); - std::vector ::const_iterator _iter144; - for (_iter144 = this->columns.begin(); _iter144 != this->columns.end(); ++_iter144) + std::vector ::const_iterator _iter102; + for (_iter102 = this->columns.begin(); _iter102 != this->columns.end(); ++_iter102) { - xfer += (*_iter144).write(oprot); + xfer += (*_iter102).write(oprot); } xfer += oprot->writeListEnd(); } @@ -3349,9 +3069,9 @@ uint32_t TStatus::read(::apache::thrift::protocol::TProtocol* iprot) { { case 1: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast145; - xfer += iprot->readI32(ecast145); - this->statusCode = (TStatusCode::type)ecast145; + int32_t ecast103; + xfer += iprot->readI32(ecast103); + this->statusCode = (TStatusCode::type)ecast103; isset_statusCode = true; } else { xfer += iprot->skip(ftype); @@ -3361,14 +3081,14 @@ uint32_t TStatus::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->infoMessages.clear(); - uint32_t _size146; - ::apache::thrift::protocol::TType _etype149; - xfer += iprot->readListBegin(_etype149, _size146); - this->infoMessages.resize(_size146); - uint32_t _i150; - for (_i150 = 0; _i150 < _size146; ++_i150) + uint32_t _size104; + ::apache::thrift::protocol::TType _etype107; + xfer += iprot->readListBegin(_etype107, _size104); + this->infoMessages.resize(_size104); + uint32_t _i108; + for (_i108 = 0; _i108 < _size104; ++_i108) { - xfer += iprot->readString(this->infoMessages[_i150]); + xfer += iprot->readString(this->infoMessages[_i108]); } xfer += iprot->readListEnd(); } @@ -3427,10 +3147,10 @@ uint32_t TStatus::write(::apache::thrift::protocol::TProtocol* oprot) const { xfer += oprot->writeFieldBegin("infoMessages", ::apache::thrift::protocol::T_LIST, 2); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->infoMessages.size())); - std::vector ::const_iterator _iter151; - for (_iter151 = this->infoMessages.begin(); _iter151 != this->infoMessages.end(); ++_iter151) + std::vector ::const_iterator _iter109; + for (_iter109 = this->infoMessages.begin(); _iter109 != this->infoMessages.end(); ++_iter109) { - xfer += oprot->writeString((*_iter151)); + xfer += oprot->writeString((*_iter109)); } xfer += oprot->writeListEnd(); } @@ -3646,9 +3366,9 @@ uint32_t TOperationHandle::read(::apache::thrift::protocol::TProtocol* iprot) { break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast152; - xfer += iprot->readI32(ecast152); - this->operationType = (TOperationType::type)ecast152; + int32_t ecast110; + xfer += iprot->readI32(ecast110); + this->operationType = (TOperationType::type)ecast110; isset_operationType = true; } else { xfer += iprot->skip(ftype); @@ -3749,9 +3469,9 @@ uint32_t TOpenSessionReq::read(::apache::thrift::protocol::TProtocol* iprot) { { case 1: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast153; - xfer += iprot->readI32(ecast153); - this->client_protocol = (TProtocolVersion::type)ecast153; + int32_t ecast111; + xfer += iprot->readI32(ecast111); + this->client_protocol = (TProtocolVersion::type)ecast111; isset_client_protocol = true; } else { xfer += iprot->skip(ftype); @@ -3777,17 +3497,17 @@ uint32_t TOpenSessionReq::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_MAP) { { this->configuration.clear(); - uint32_t _size154; - ::apache::thrift::protocol::TType _ktype155; - ::apache::thrift::protocol::TType _vtype156; - xfer += iprot->readMapBegin(_ktype155, _vtype156, _size154); - uint32_t _i158; - for (_i158 = 0; _i158 < _size154; ++_i158) + uint32_t _size112; + ::apache::thrift::protocol::TType _ktype113; + ::apache::thrift::protocol::TType _vtype114; + xfer += iprot->readMapBegin(_ktype113, _vtype114, _size112); + uint32_t _i116; + for (_i116 = 0; _i116 < _size112; ++_i116) { - std::string _key159; - xfer += iprot->readString(_key159); - std::string& _val160 = this->configuration[_key159]; - xfer += iprot->readString(_val160); + std::string _key117; + xfer += iprot->readString(_key117); + std::string& _val118 = this->configuration[_key117]; + xfer += iprot->readString(_val118); } xfer += iprot->readMapEnd(); } @@ -3832,11 +3552,11 @@ uint32_t TOpenSessionReq::write(::apache::thrift::protocol::TProtocol* oprot) co xfer += oprot->writeFieldBegin("configuration", ::apache::thrift::protocol::T_MAP, 4); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->configuration.size())); - std::map ::const_iterator _iter161; - for (_iter161 = this->configuration.begin(); _iter161 != this->configuration.end(); ++_iter161) + std::map ::const_iterator _iter119; + for (_iter119 = this->configuration.begin(); _iter119 != this->configuration.end(); ++_iter119) { - xfer += oprot->writeString(_iter161->first); - xfer += oprot->writeString(_iter161->second); + xfer += oprot->writeString(_iter119->first); + xfer += oprot->writeString(_iter119->second); } xfer += oprot->writeMapEnd(); } @@ -3891,9 +3611,9 @@ uint32_t TOpenSessionResp::read(::apache::thrift::protocol::TProtocol* iprot) { break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast162; - xfer += iprot->readI32(ecast162); - this->serverProtocolVersion = (TProtocolVersion::type)ecast162; + int32_t ecast120; + xfer += iprot->readI32(ecast120); + this->serverProtocolVersion = (TProtocolVersion::type)ecast120; isset_serverProtocolVersion = true; } else { xfer += iprot->skip(ftype); @@ -3911,17 +3631,17 @@ uint32_t TOpenSessionResp::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_MAP) { { this->configuration.clear(); - uint32_t _size163; - ::apache::thrift::protocol::TType _ktype164; - ::apache::thrift::protocol::TType _vtype165; - xfer += iprot->readMapBegin(_ktype164, _vtype165, _size163); - uint32_t _i167; - for (_i167 = 0; _i167 < _size163; ++_i167) + uint32_t _size121; + ::apache::thrift::protocol::TType _ktype122; + ::apache::thrift::protocol::TType _vtype123; + xfer += iprot->readMapBegin(_ktype122, _vtype123, _size121); + uint32_t _i125; + for (_i125 = 0; _i125 < _size121; ++_i125) { - std::string _key168; - xfer += iprot->readString(_key168); - std::string& _val169 = this->configuration[_key168]; - xfer += iprot->readString(_val169); + std::string _key126; + xfer += iprot->readString(_key126); + std::string& _val127 = this->configuration[_key126]; + xfer += iprot->readString(_val127); } xfer += iprot->readMapEnd(); } @@ -3967,11 +3687,11 @@ uint32_t TOpenSessionResp::write(::apache::thrift::protocol::TProtocol* oprot) c xfer += oprot->writeFieldBegin("configuration", ::apache::thrift::protocol::T_MAP, 4); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->configuration.size())); - std::map ::const_iterator _iter170; - for (_iter170 = this->configuration.begin(); _iter170 != this->configuration.end(); ++_iter170) + std::map ::const_iterator _iter128; + for (_iter128 = this->configuration.begin(); _iter128 != this->configuration.end(); ++_iter128) { - xfer += oprot->writeString(_iter170->first); - xfer += oprot->writeString(_iter170->second); + xfer += oprot->writeString(_iter128->first); + xfer += oprot->writeString(_iter128->second); } xfer += oprot->writeMapEnd(); } @@ -4281,9 +4001,9 @@ uint32_t TGetInfoReq::read(::apache::thrift::protocol::TProtocol* iprot) { break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast171; - xfer += iprot->readI32(ecast171); - this->infoType = (TGetInfoType::type)ecast171; + int32_t ecast129; + xfer += iprot->readI32(ecast129); + this->infoType = (TGetInfoType::type)ecast129; isset_infoType = true; } else { xfer += iprot->skip(ftype); @@ -4453,17 +4173,17 @@ uint32_t TExecuteStatementReq::read(::apache::thrift::protocol::TProtocol* iprot if (ftype == ::apache::thrift::protocol::T_MAP) { { this->confOverlay.clear(); - uint32_t _size172; - ::apache::thrift::protocol::TType _ktype173; - ::apache::thrift::protocol::TType _vtype174; - xfer += iprot->readMapBegin(_ktype173, _vtype174, _size172); - uint32_t _i176; - for (_i176 = 0; _i176 < _size172; ++_i176) + uint32_t _size130; + ::apache::thrift::protocol::TType _ktype131; + ::apache::thrift::protocol::TType _vtype132; + xfer += iprot->readMapBegin(_ktype131, _vtype132, _size130); + uint32_t _i134; + for (_i134 = 0; _i134 < _size130; ++_i134) { - std::string _key177; - xfer += iprot->readString(_key177); - std::string& _val178 = this->confOverlay[_key177]; - xfer += iprot->readString(_val178); + std::string _key135; + xfer += iprot->readString(_key135); + std::string& _val136 = this->confOverlay[_key135]; + xfer += iprot->readString(_val136); } xfer += iprot->readMapEnd(); } @@ -4512,11 +4232,11 @@ uint32_t TExecuteStatementReq::write(::apache::thrift::protocol::TProtocol* opro xfer += oprot->writeFieldBegin("confOverlay", ::apache::thrift::protocol::T_MAP, 3); { xfer += oprot->writeMapBegin(::apache::thrift::protocol::T_STRING, ::apache::thrift::protocol::T_STRING, static_cast(this->confOverlay.size())); - std::map ::const_iterator _iter179; - for (_iter179 = this->confOverlay.begin(); _iter179 != this->confOverlay.end(); ++_iter179) + std::map ::const_iterator _iter137; + for (_iter137 = this->confOverlay.begin(); _iter137 != this->confOverlay.end(); ++_iter137) { - xfer += oprot->writeString(_iter179->first); - xfer += oprot->writeString(_iter179->second); + xfer += oprot->writeString(_iter137->first); + xfer += oprot->writeString(_iter137->second); } xfer += oprot->writeMapEnd(); } @@ -5138,14 +4858,14 @@ uint32_t TGetTablesReq::read(::apache::thrift::protocol::TProtocol* iprot) { if (ftype == ::apache::thrift::protocol::T_LIST) { { this->tableTypes.clear(); - uint32_t _size180; - ::apache::thrift::protocol::TType _etype183; - xfer += iprot->readListBegin(_etype183, _size180); - this->tableTypes.resize(_size180); - uint32_t _i184; - for (_i184 = 0; _i184 < _size180; ++_i184) + uint32_t _size138; + ::apache::thrift::protocol::TType _etype141; + xfer += iprot->readListBegin(_etype141, _size138); + this->tableTypes.resize(_size138); + uint32_t _i142; + for (_i142 = 0; _i142 < _size138; ++_i142) { - xfer += iprot->readString(this->tableTypes[_i184]); + xfer += iprot->readString(this->tableTypes[_i142]); } xfer += iprot->readListEnd(); } @@ -5195,10 +4915,10 @@ uint32_t TGetTablesReq::write(::apache::thrift::protocol::TProtocol* oprot) cons xfer += oprot->writeFieldBegin("tableTypes", ::apache::thrift::protocol::T_LIST, 5); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->tableTypes.size())); - std::vector ::const_iterator _iter185; - for (_iter185 = this->tableTypes.begin(); _iter185 != this->tableTypes.end(); ++_iter185) + std::vector ::const_iterator _iter143; + for (_iter143 = this->tableTypes.begin(); _iter143 != this->tableTypes.end(); ++_iter143) { - xfer += oprot->writeString((*_iter185)); + xfer += oprot->writeString((*_iter143)); } xfer += oprot->writeListEnd(); } @@ -5927,9 +5647,9 @@ uint32_t TGetOperationStatusResp::read(::apache::thrift::protocol::TProtocol* ip break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast186; - xfer += iprot->readI32(ecast186); - this->operationState = (TOperationState::type)ecast186; + int32_t ecast144; + xfer += iprot->readI32(ecast144); + this->operationState = (TOperationState::type)ecast144; this->__isset.operationState = true; } else { xfer += iprot->skip(ftype); @@ -6451,9 +6171,9 @@ uint32_t TFetchResultsReq::read(::apache::thrift::protocol::TProtocol* iprot) { break; case 2: if (ftype == ::apache::thrift::protocol::T_I32) { - int32_t ecast187; - xfer += iprot->readI32(ecast187); - this->orientation = (TFetchOrientation::type)ecast187; + int32_t ecast145; + xfer += iprot->readI32(ecast145); + this->orientation = (TFetchOrientation::type)ecast145; isset_orientation = true; } else { xfer += iprot->skip(ftype); diff --git service/src/gen/thrift/gen-cpp/TCLIService_types.h service/src/gen/thrift/gen-cpp/TCLIService_types.h index a870b8a..950bf25 100644 --- service/src/gen/thrift/gen-cpp/TCLIService_types.h +++ service/src/gen/thrift/gen-cpp/TCLIService_types.h @@ -1059,97 +1059,6 @@ class TStringValue { void swap(TStringValue &a, TStringValue &b); -typedef struct _TColumn__isset { - _TColumn__isset() : boolColumn(false), byteColumn(false), i16Column(false), i32Column(false), i64Column(false), doubleColumn(false), stringColumn(false) {} - bool boolColumn; - bool byteColumn; - bool i16Column; - bool i32Column; - bool i64Column; - bool doubleColumn; - bool stringColumn; -} _TColumn__isset; - -class TColumn { - public: - - static const char* ascii_fingerprint; // = "B39B4E4E565DB31DC891D62FDC3208DC"; - static const uint8_t binary_fingerprint[16]; // = {0xB3,0x9B,0x4E,0x4E,0x56,0x5D,0xB3,0x1D,0xC8,0x91,0xD6,0x2F,0xDC,0x32,0x08,0xDC}; - - TColumn() { - } - - virtual ~TColumn() throw() {} - - std::vector boolColumn; - std::vector byteColumn; - std::vector i16Column; - std::vector i32Column; - std::vector i64Column; - std::vector doubleColumn; - std::vector stringColumn; - - _TColumn__isset __isset; - - void __set_boolColumn(const std::vector & val) { - boolColumn = val; - } - - void __set_byteColumn(const std::vector & val) { - byteColumn = val; - } - - void __set_i16Column(const std::vector & val) { - i16Column = val; - } - - void __set_i32Column(const std::vector & val) { - i32Column = val; - } - - void __set_i64Column(const std::vector & val) { - i64Column = val; - } - - void __set_doubleColumn(const std::vector & val) { - doubleColumn = val; - } - - void __set_stringColumn(const std::vector & val) { - stringColumn = val; - } - - bool operator == (const TColumn & rhs) const - { - if (!(boolColumn == rhs.boolColumn)) - return false; - if (!(byteColumn == rhs.byteColumn)) - return false; - if (!(i16Column == rhs.i16Column)) - return false; - if (!(i32Column == rhs.i32Column)) - return false; - if (!(i64Column == rhs.i64Column)) - return false; - if (!(doubleColumn == rhs.doubleColumn)) - return false; - if (!(stringColumn == rhs.stringColumn)) - return false; - return true; - } - bool operator != (const TColumn &rhs) const { - return !(*this == rhs); - } - - bool operator < (const TColumn & ) const; - - uint32_t read(::apache::thrift::protocol::TProtocol* iprot); - uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; - -}; - -void swap(TColumn &a, TColumn &b); - typedef struct _TColumnValue__isset { _TColumnValue__isset() : boolVal(false), byteVal(false), i16Val(false), i32Val(false), i64Val(false), doubleVal(false), stringVal(false) {} bool boolVal; diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TBinaryColumn.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TBinaryColumn.java index 4690f6b..1ac28a2 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TBinaryColumn.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TBinaryColumn.java @@ -447,13 +447,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TBinaryColumn struc case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list166 = iprot.readListBegin(); - struct.values = new ArrayList(_list166.size); - for (int _i167 = 0; _i167 < _list166.size; ++_i167) + org.apache.thrift.protocol.TList _list110 = iprot.readListBegin(); + struct.values = new ArrayList(_list110.size); + for (int _i111 = 0; _i111 < _list110.size; ++_i111) { - ByteBuffer _elem168; // required - _elem168 = iprot.readBinary(); - struct.values.add(_elem168); + ByteBuffer _elem112; // required + _elem112 = iprot.readBinary(); + struct.values.add(_elem112); } iprot.readListEnd(); } @@ -487,9 +487,9 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TBinaryColumn stru oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.values.size())); - for (ByteBuffer _iter169 : struct.values) + for (ByteBuffer _iter113 : struct.values) { - oprot.writeBinary(_iter169); + oprot.writeBinary(_iter113); } oprot.writeListEnd(); } @@ -519,9 +519,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TBinaryColumn struc TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (ByteBuffer _iter170 : struct.values) + for (ByteBuffer _iter114 : struct.values) { - oprot.writeBinary(_iter170); + oprot.writeBinary(_iter114); } } oprot.writeBinary(struct.nulls); @@ -531,13 +531,13 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TBinaryColumn struc public void read(org.apache.thrift.protocol.TProtocol prot, TBinaryColumn struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list171 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.values = new ArrayList(_list171.size); - for (int _i172 = 0; _i172 < _list171.size; ++_i172) + org.apache.thrift.protocol.TList _list115 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.values = new ArrayList(_list115.size); + for (int _i116 = 0; _i116 < _list115.size; ++_i116) { - ByteBuffer _elem173; // required - _elem173 = iprot.readBinary(); - struct.values.add(_elem173); + ByteBuffer _elem117; // required + _elem117 = iprot.readBinary(); + struct.values.add(_elem117); } } struct.setValuesIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TBoolColumn.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TBoolColumn.java index e3d08d5..b2bda35 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TBoolColumn.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TBoolColumn.java @@ -445,13 +445,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TBoolColumn struct) case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list110 = iprot.readListBegin(); - struct.values = new ArrayList(_list110.size); - for (int _i111 = 0; _i111 < _list110.size; ++_i111) + org.apache.thrift.protocol.TList _list54 = iprot.readListBegin(); + struct.values = new ArrayList(_list54.size); + for (int _i55 = 0; _i55 < _list54.size; ++_i55) { - boolean _elem112; // required - _elem112 = iprot.readBool(); - struct.values.add(_elem112); + boolean _elem56; // required + _elem56 = iprot.readBool(); + struct.values.add(_elem56); } iprot.readListEnd(); } @@ -485,9 +485,9 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TBoolColumn struct oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.BOOL, struct.values.size())); - for (boolean _iter113 : struct.values) + for (boolean _iter57 : struct.values) { - oprot.writeBool(_iter113); + oprot.writeBool(_iter57); } oprot.writeListEnd(); } @@ -517,9 +517,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TBoolColumn struct) TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (boolean _iter114 : struct.values) + for (boolean _iter58 : struct.values) { - oprot.writeBool(_iter114); + oprot.writeBool(_iter58); } } oprot.writeBinary(struct.nulls); @@ -529,13 +529,13 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TBoolColumn struct) public void read(org.apache.thrift.protocol.TProtocol prot, TBoolColumn struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list115 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.BOOL, iprot.readI32()); - struct.values = new ArrayList(_list115.size); - for (int _i116 = 0; _i116 < _list115.size; ++_i116) + org.apache.thrift.protocol.TList _list59 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.BOOL, iprot.readI32()); + struct.values = new ArrayList(_list59.size); + for (int _i60 = 0; _i60 < _list59.size; ++_i60) { - boolean _elem117; // required - _elem117 = iprot.readBool(); - struct.values.add(_elem117); + boolean _elem61; // required + _elem61 = iprot.readBool(); + struct.values.add(_elem61); } } struct.setValuesIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TByteColumn.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TByteColumn.java index eeeeff5..defdec0 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TByteColumn.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TByteColumn.java @@ -445,13 +445,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TByteColumn struct) case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list118 = iprot.readListBegin(); - struct.values = new ArrayList(_list118.size); - for (int _i119 = 0; _i119 < _list118.size; ++_i119) + org.apache.thrift.protocol.TList _list62 = iprot.readListBegin(); + struct.values = new ArrayList(_list62.size); + for (int _i63 = 0; _i63 < _list62.size; ++_i63) { - byte _elem120; // required - _elem120 = iprot.readByte(); - struct.values.add(_elem120); + byte _elem64; // required + _elem64 = iprot.readByte(); + struct.values.add(_elem64); } iprot.readListEnd(); } @@ -485,9 +485,9 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TByteColumn struct oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.BYTE, struct.values.size())); - for (byte _iter121 : struct.values) + for (byte _iter65 : struct.values) { - oprot.writeByte(_iter121); + oprot.writeByte(_iter65); } oprot.writeListEnd(); } @@ -517,9 +517,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TByteColumn struct) TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (byte _iter122 : struct.values) + for (byte _iter66 : struct.values) { - oprot.writeByte(_iter122); + oprot.writeByte(_iter66); } } oprot.writeBinary(struct.nulls); @@ -529,13 +529,13 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TByteColumn struct) public void read(org.apache.thrift.protocol.TProtocol prot, TByteColumn struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list123 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.BYTE, iprot.readI32()); - struct.values = new ArrayList(_list123.size); - for (int _i124 = 0; _i124 < _list123.size; ++_i124) + org.apache.thrift.protocol.TList _list67 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.BYTE, iprot.readI32()); + struct.values = new ArrayList(_list67.size); + for (int _i68 = 0; _i68 < _list67.size; ++_i68) { - byte _elem125; // required - _elem125 = iprot.readByte(); - struct.values.add(_elem125); + byte _elem69; // required + _elem69 = iprot.readByte(); + struct.values.add(_elem69); } } struct.setValuesIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TDoubleColumn.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TDoubleColumn.java index a1aab11..88926c8 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TDoubleColumn.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TDoubleColumn.java @@ -445,13 +445,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TDoubleColumn struc case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list150 = iprot.readListBegin(); - struct.values = new ArrayList(_list150.size); - for (int _i151 = 0; _i151 < _list150.size; ++_i151) + org.apache.thrift.protocol.TList _list94 = iprot.readListBegin(); + struct.values = new ArrayList(_list94.size); + for (int _i95 = 0; _i95 < _list94.size; ++_i95) { - double _elem152; // required - _elem152 = iprot.readDouble(); - struct.values.add(_elem152); + double _elem96; // required + _elem96 = iprot.readDouble(); + struct.values.add(_elem96); } iprot.readListEnd(); } @@ -485,9 +485,9 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TDoubleColumn stru oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.DOUBLE, struct.values.size())); - for (double _iter153 : struct.values) + for (double _iter97 : struct.values) { - oprot.writeDouble(_iter153); + oprot.writeDouble(_iter97); } oprot.writeListEnd(); } @@ -517,9 +517,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TDoubleColumn struc TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (double _iter154 : struct.values) + for (double _iter98 : struct.values) { - oprot.writeDouble(_iter154); + oprot.writeDouble(_iter98); } } oprot.writeBinary(struct.nulls); @@ -529,13 +529,13 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TDoubleColumn struc public void read(org.apache.thrift.protocol.TProtocol prot, TDoubleColumn struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list155 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32()); - struct.values = new ArrayList(_list155.size); - for (int _i156 = 0; _i156 < _list155.size; ++_i156) + org.apache.thrift.protocol.TList _list99 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.DOUBLE, iprot.readI32()); + struct.values = new ArrayList(_list99.size); + for (int _i100 = 0; _i100 < _list99.size; ++_i100) { - double _elem157; // required - _elem157 = iprot.readDouble(); - struct.values.add(_elem157); + double _elem101; // required + _elem101 = iprot.readDouble(); + struct.values.add(_elem101); } } struct.setValuesIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TExecuteStatementReq.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TExecuteStatementReq.java index 4cb9a55..4f157ad 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TExecuteStatementReq.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TExecuteStatementReq.java @@ -624,15 +624,15 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TExecuteStatementRe case 3: // CONF_OVERLAY if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map218 = iprot.readMapBegin(); - struct.confOverlay = new HashMap(2*_map218.size); - for (int _i219 = 0; _i219 < _map218.size; ++_i219) + org.apache.thrift.protocol.TMap _map162 = iprot.readMapBegin(); + struct.confOverlay = new HashMap(2*_map162.size); + for (int _i163 = 0; _i163 < _map162.size; ++_i163) { - String _key220; // required - String _val221; // required - _key220 = iprot.readString(); - _val221 = iprot.readString(); - struct.confOverlay.put(_key220, _val221); + String _key164; // required + String _val165; // required + _key164 = iprot.readString(); + _val165 = iprot.readString(); + struct.confOverlay.put(_key164, _val165); } iprot.readMapEnd(); } @@ -677,10 +677,10 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TExecuteStatementR oprot.writeFieldBegin(CONF_OVERLAY_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.confOverlay.size())); - for (Map.Entry _iter222 : struct.confOverlay.entrySet()) + for (Map.Entry _iter166 : struct.confOverlay.entrySet()) { - oprot.writeString(_iter222.getKey()); - oprot.writeString(_iter222.getValue()); + oprot.writeString(_iter166.getKey()); + oprot.writeString(_iter166.getValue()); } oprot.writeMapEnd(); } @@ -722,10 +722,10 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TExecuteStatementRe if (struct.isSetConfOverlay()) { { oprot.writeI32(struct.confOverlay.size()); - for (Map.Entry _iter223 : struct.confOverlay.entrySet()) + for (Map.Entry _iter167 : struct.confOverlay.entrySet()) { - oprot.writeString(_iter223.getKey()); - oprot.writeString(_iter223.getValue()); + oprot.writeString(_iter167.getKey()); + oprot.writeString(_iter167.getValue()); } } } @@ -745,15 +745,15 @@ public void read(org.apache.thrift.protocol.TProtocol prot, TExecuteStatementReq BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { { - org.apache.thrift.protocol.TMap _map224 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.confOverlay = new HashMap(2*_map224.size); - for (int _i225 = 0; _i225 < _map224.size; ++_i225) + org.apache.thrift.protocol.TMap _map168 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.confOverlay = new HashMap(2*_map168.size); + for (int _i169 = 0; _i169 < _map168.size; ++_i169) { - String _key226; // required - String _val227; // required - _key226 = iprot.readString(); - _val227 = iprot.readString(); - struct.confOverlay.put(_key226, _val227); + String _key170; // required + String _val171; // required + _key170 = iprot.readString(); + _val171 = iprot.readString(); + struct.confOverlay.put(_key170, _val171); } } struct.setConfOverlayIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TGetTablesReq.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TGetTablesReq.java index dad2008..d0c3059 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TGetTablesReq.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TGetTablesReq.java @@ -711,13 +711,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TGetTablesReq struc case 5: // TABLE_TYPES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list228 = iprot.readListBegin(); - struct.tableTypes = new ArrayList(_list228.size); - for (int _i229 = 0; _i229 < _list228.size; ++_i229) + org.apache.thrift.protocol.TList _list172 = iprot.readListBegin(); + struct.tableTypes = new ArrayList(_list172.size); + for (int _i173 = 0; _i173 < _list172.size; ++_i173) { - String _elem230; // required - _elem230 = iprot.readString(); - struct.tableTypes.add(_elem230); + String _elem174; // required + _elem174 = iprot.readString(); + struct.tableTypes.add(_elem174); } iprot.readListEnd(); } @@ -770,9 +770,9 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TGetTablesReq stru oprot.writeFieldBegin(TABLE_TYPES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.tableTypes.size())); - for (String _iter231 : struct.tableTypes) + for (String _iter175 : struct.tableTypes) { - oprot.writeString(_iter231); + oprot.writeString(_iter175); } oprot.writeListEnd(); } @@ -823,9 +823,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TGetTablesReq struc if (struct.isSetTableTypes()) { { oprot.writeI32(struct.tableTypes.size()); - for (String _iter232 : struct.tableTypes) + for (String _iter176 : struct.tableTypes) { - oprot.writeString(_iter232); + oprot.writeString(_iter176); } } } @@ -852,13 +852,13 @@ public void read(org.apache.thrift.protocol.TProtocol prot, TGetTablesReq struct } if (incoming.get(3)) { { - org.apache.thrift.protocol.TList _list233 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.tableTypes = new ArrayList(_list233.size); - for (int _i234 = 0; _i234 < _list233.size; ++_i234) + org.apache.thrift.protocol.TList _list177 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.tableTypes = new ArrayList(_list177.size); + for (int _i178 = 0; _i178 < _list177.size; ++_i178) { - String _elem235; // required - _elem235 = iprot.readString(); - struct.tableTypes.add(_elem235); + String _elem179; // required + _elem179 = iprot.readString(); + struct.tableTypes.add(_elem179); } } struct.setTableTypesIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI16Column.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI16Column.java index 7ec49b3..e997bd9 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI16Column.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI16Column.java @@ -445,13 +445,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TI16Column struct) case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list126 = iprot.readListBegin(); - struct.values = new ArrayList(_list126.size); - for (int _i127 = 0; _i127 < _list126.size; ++_i127) + org.apache.thrift.protocol.TList _list70 = iprot.readListBegin(); + struct.values = new ArrayList(_list70.size); + for (int _i71 = 0; _i71 < _list70.size; ++_i71) { - short _elem128; // required - _elem128 = iprot.readI16(); - struct.values.add(_elem128); + short _elem72; // required + _elem72 = iprot.readI16(); + struct.values.add(_elem72); } iprot.readListEnd(); } @@ -485,9 +485,9 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TI16Column struct) oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I16, struct.values.size())); - for (short _iter129 : struct.values) + for (short _iter73 : struct.values) { - oprot.writeI16(_iter129); + oprot.writeI16(_iter73); } oprot.writeListEnd(); } @@ -517,9 +517,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TI16Column struct) TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (short _iter130 : struct.values) + for (short _iter74 : struct.values) { - oprot.writeI16(_iter130); + oprot.writeI16(_iter74); } } oprot.writeBinary(struct.nulls); @@ -529,13 +529,13 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TI16Column struct) public void read(org.apache.thrift.protocol.TProtocol prot, TI16Column struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list131 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I16, iprot.readI32()); - struct.values = new ArrayList(_list131.size); - for (int _i132 = 0; _i132 < _list131.size; ++_i132) + org.apache.thrift.protocol.TList _list75 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I16, iprot.readI32()); + struct.values = new ArrayList(_list75.size); + for (int _i76 = 0; _i76 < _list75.size; ++_i76) { - short _elem133; // required - _elem133 = iprot.readI16(); - struct.values.add(_elem133); + short _elem77; // required + _elem77 = iprot.readI16(); + struct.values.add(_elem77); } } struct.setValuesIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI32Column.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI32Column.java index d774ba4..3cdd2a5 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI32Column.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI32Column.java @@ -445,13 +445,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TI32Column struct) case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list134 = iprot.readListBegin(); - struct.values = new ArrayList(_list134.size); - for (int _i135 = 0; _i135 < _list134.size; ++_i135) + org.apache.thrift.protocol.TList _list78 = iprot.readListBegin(); + struct.values = new ArrayList(_list78.size); + for (int _i79 = 0; _i79 < _list78.size; ++_i79) { - int _elem136; // required - _elem136 = iprot.readI32(); - struct.values.add(_elem136); + int _elem80; // required + _elem80 = iprot.readI32(); + struct.values.add(_elem80); } iprot.readListEnd(); } @@ -485,9 +485,9 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TI32Column struct) oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.values.size())); - for (int _iter137 : struct.values) + for (int _iter81 : struct.values) { - oprot.writeI32(_iter137); + oprot.writeI32(_iter81); } oprot.writeListEnd(); } @@ -517,9 +517,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TI32Column struct) TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (int _iter138 : struct.values) + for (int _iter82 : struct.values) { - oprot.writeI32(_iter138); + oprot.writeI32(_iter82); } } oprot.writeBinary(struct.nulls); @@ -529,13 +529,13 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TI32Column struct) public void read(org.apache.thrift.protocol.TProtocol prot, TI32Column struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list139 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32()); - struct.values = new ArrayList(_list139.size); - for (int _i140 = 0; _i140 < _list139.size; ++_i140) + org.apache.thrift.protocol.TList _list83 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32()); + struct.values = new ArrayList(_list83.size); + for (int _i84 = 0; _i84 < _list83.size; ++_i84) { - int _elem141; // required - _elem141 = iprot.readI32(); - struct.values.add(_elem141); + int _elem85; // required + _elem85 = iprot.readI32(); + struct.values.add(_elem85); } } struct.setValuesIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI64Column.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI64Column.java index a819658..c8fc41f 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI64Column.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TI64Column.java @@ -445,13 +445,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TI64Column struct) case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list142 = iprot.readListBegin(); - struct.values = new ArrayList(_list142.size); - for (int _i143 = 0; _i143 < _list142.size; ++_i143) + org.apache.thrift.protocol.TList _list86 = iprot.readListBegin(); + struct.values = new ArrayList(_list86.size); + for (int _i87 = 0; _i87 < _list86.size; ++_i87) { - long _elem144; // required - _elem144 = iprot.readI64(); - struct.values.add(_elem144); + long _elem88; // required + _elem88 = iprot.readI64(); + struct.values.add(_elem88); } iprot.readListEnd(); } @@ -485,9 +485,9 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TI64Column struct) oprot.writeFieldBegin(VALUES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.values.size())); - for (long _iter145 : struct.values) + for (long _iter89 : struct.values) { - oprot.writeI64(_iter145); + oprot.writeI64(_iter89); } oprot.writeListEnd(); } @@ -517,9 +517,9 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TI64Column struct) TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.values.size()); - for (long _iter146 : struct.values) + for (long _iter90 : struct.values) { - oprot.writeI64(_iter146); + oprot.writeI64(_iter90); } } oprot.writeBinary(struct.nulls); @@ -529,13 +529,13 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TI64Column struct) public void read(org.apache.thrift.protocol.TProtocol prot, TI64Column struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list147 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.values = new ArrayList(_list147.size); - for (int _i148 = 0; _i148 < _list147.size; ++_i148) + org.apache.thrift.protocol.TList _list91 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.values = new ArrayList(_list91.size); + for (int _i92 = 0; _i92 < _list91.size; ++_i92) { - long _elem149; // required - _elem149 = iprot.readI64(); - struct.values.add(_elem149); + long _elem93; // required + _elem93 = iprot.readI64(); + struct.values.add(_elem93); } } struct.setValuesIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionReq.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionReq.java index 859196b..64cf9fe 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionReq.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionReq.java @@ -638,15 +638,15 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TOpenSessionReq str case 4: // CONFIGURATION if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map198 = iprot.readMapBegin(); - struct.configuration = new HashMap(2*_map198.size); - for (int _i199 = 0; _i199 < _map198.size; ++_i199) + org.apache.thrift.protocol.TMap _map142 = iprot.readMapBegin(); + struct.configuration = new HashMap(2*_map142.size); + for (int _i143 = 0; _i143 < _map142.size; ++_i143) { - String _key200; // required - String _val201; // required - _key200 = iprot.readString(); - _val201 = iprot.readString(); - struct.configuration.put(_key200, _val201); + String _key144; // required + String _val145; // required + _key144 = iprot.readString(); + _val145 = iprot.readString(); + struct.configuration.put(_key144, _val145); } iprot.readMapEnd(); } @@ -692,10 +692,10 @@ public void write(org.apache.thrift.protocol.TProtocol oprot, TOpenSessionReq st 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 _iter202 : struct.configuration.entrySet()) + for (Map.Entry _iter146 : struct.configuration.entrySet()) { - oprot.writeString(_iter202.getKey()); - oprot.writeString(_iter202.getValue()); + oprot.writeString(_iter146.getKey()); + oprot.writeString(_iter146.getValue()); } oprot.writeMapEnd(); } @@ -740,10 +740,10 @@ public void write(org.apache.thrift.protocol.TProtocol prot, TOpenSessionReq str if (struct.isSetConfiguration()) { { oprot.writeI32(struct.configuration.size()); - for (Map.Entry _iter203 : struct.configuration.entrySet()) + for (Map.Entry _iter147 : struct.configuration.entrySet()) { - oprot.writeString(_iter203.getKey()); - oprot.writeString(_iter203.getValue()); + oprot.writeString(_iter147.getKey()); + oprot.writeString(_iter147.getValue()); } } } @@ -765,15 +765,15 @@ public void read(org.apache.thrift.protocol.TProtocol prot, TOpenSessionReq stru } if (incoming.get(2)) { { - 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.configuration = new HashMap(2*_map204.size); - for (int _i205 = 0; _i205 < _map204.size; ++_i205) + org.apache.thrift.protocol.TMap _map148 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.configuration = new HashMap(2*_map148.size); + for (int _i149 = 0; _i149 < _map148.size; ++_i149) { - String _key206; // required - String _val207; // required - _key206 = iprot.readString(); - _val207 = iprot.readString(); - struct.configuration.put(_key206, _val207); + String _key150; // required + String _val151; // required + _key150 = iprot.readString(); + _val151 = iprot.readString(); + struct.configuration.put(_key150, _val151); } } struct.setConfigurationIsSet(true); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionResp.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionResp.java index bb98382..832ea92 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionResp.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TOpenSessionResp.java @@ -650,15 +650,15 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TOpenSessionResp st case 4: // CONFIGURATION if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map208 = iprot.readMapBegin(); - struct.configuration = new HashMap(2*_map208.size); - for (int _i209 = 0; _i209 < _map208.size; ++_i209) + org.apache.thrift.protocol.TMap _map152 = iprot.readMapBegin(); + struct.configuration = new HashMap(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 void write(org.apache.thrift.protocol.TProtocol oprot, TOpenSessionResp s 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 _iter212 : struct.configuration.entrySet()) + for (Map.Entry _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 void write(org.apache.thrift.protocol.TProtocol prot, TOpenSessionResp st if (struct.isSetConfiguration()) { { oprot.writeI32(struct.configuration.size()); - for (Map.Entry _iter213 : struct.configuration.entrySet()) + for (Map.Entry _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 void read(org.apache.thrift.protocol.TProtocol prot, TOpenSessionResp str } 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(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(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); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java index b7cb55d..8e58aa5 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRow.java @@ -350,14 +350,14 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TRow struct) throws 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(_list102.size); - for (int _i103 = 0; _i103 < _list102.size; ++_i103) + org.apache.thrift.protocol.TList _list46 = iprot.readListBegin(); + struct.colVals = new ArrayList(_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 void write(org.apache.thrift.protocol.TProtocol oprot, TRow struct) throw 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 void write(org.apache.thrift.protocol.TProtocol prot, TRow struct) throws 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 void write(org.apache.thrift.protocol.TProtocol prot, TRow struct) throws 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(_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(_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); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java index 41a7540..4bb5749 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TRowSet.java @@ -545,14 +545,14 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TRowSet struct) thr case 2: // ROWS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list174 = iprot.readListBegin(); - struct.rows = new ArrayList(_list174.size); - for (int _i175 = 0; _i175 < _list174.size; ++_i175) + org.apache.thrift.protocol.TList _list118 = iprot.readListBegin(); + struct.rows = new ArrayList(_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 void read(org.apache.thrift.protocol.TProtocol iprot, TRowSet struct) thr case 3: // COLUMNS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list177 = iprot.readListBegin(); - struct.columns = new ArrayList(_list177.size); - for (int _i178 = 0; _i178 < _list177.size; ++_i178) + org.apache.thrift.protocol.TList _list121 = iprot.readListBegin(); + struct.columns = new ArrayList(_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 void write(org.apache.thrift.protocol.TProtocol oprot, TRowSet struct) th 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 void write(org.apache.thrift.protocol.TProtocol oprot, TRowSet struct) th 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 void write(org.apache.thrift.protocol.TProtocol prot, TRowSet struct) thr 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 void write(org.apache.thrift.protocol.TProtocol prot, TRowSet struct) thr 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 void read(org.apache.thrift.protocol.TProtocol prot, TRowSet struct) thro 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(_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(_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(_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(_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); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java index 9fb573f..cb5010f 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStatus.java @@ -694,13 +694,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TStatus struct) thr 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(_list190.size); - for (int _i191 = 0; _i191 < _list190.size; ++_i191) + org.apache.thrift.protocol.TList _list134 = iprot.readListBegin(); + struct.infoMessages = new ArrayList(_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 void write(org.apache.thrift.protocol.TProtocol oprot, TStatus struct) th 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 void write(org.apache.thrift.protocol.TProtocol prot, TStatus struct) thr 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 void read(org.apache.thrift.protocol.TProtocol prot, TStatus struct) thro 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(_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(_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); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java index 999412e..5398056 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java @@ -445,13 +445,13 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TStringColumn struc case 1: // VALUES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list158 = iprot.readListBegin(); - struct.values = new ArrayList(_list158.size); - for (int _i159 = 0; _i159 < _list158.size; ++_i159) + org.apache.thrift.protocol.TList _list102 = iprot.readListBegin(); + struct.values = new ArrayList(_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 void write(org.apache.thrift.protocol.TProtocol oprot, TStringColumn stru 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 void write(org.apache.thrift.protocol.TProtocol prot, TStringColumn struc 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 void write(org.apache.thrift.protocol.TProtocol prot, TStringColumn struc 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(_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(_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); diff --git service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java index 4c06c1a..3935555 100644 --- service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java +++ service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java @@ -360,7 +360,7 @@ public void read(org.apache.thrift.protocol.TProtocol iprot, TTypeQualifiers str 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 void read(org.apache.thrift.protocol.TProtocol prot, TTypeQualifiers stru 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); diff --git service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote service/src/gen/thrift/gen-py/TCLIService/TCLIService-remote old mode 100644 new mode 100755 diff --git service/src/gen/thrift/gen-py/TCLIService/ttypes.py service/src/gen/thrift/gen-py/TCLIService/ttypes.py index cbf6b25..aa9c3e8 100644 --- service/src/gen/thrift/gen-py/TCLIService/ttypes.py +++ service/src/gen/thrift/gen-py/TCLIService/ttypes.py @@ -1731,201 +1731,6 @@ def __eq__(self, other): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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 @@ def read(self, iprot): 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 @@ def write(self, oprot): 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() diff --git service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb index edc33a4..e32e10b 100644 --- service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb +++ service/src/gen/thrift/gen-rb/t_c_l_i_service_types.rb @@ -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