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