You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by su...@apache.org on 2015/07/17 21:52:55 UTC
[03/48] hive git commit: HIVE-9152 - Dynamic Partition Pruning [Spark
Branch] (Chao Sun, reviewed by Xuefu Zhang and Chengxiang Li)
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java
index 3dae460..024ed36 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringColumn.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,10 +29,13 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TStringColumn._Fields>, java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TStringColumn._Fields>, java.io.Serializable, Cloneable, Comparable<TStringColumn> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TStringColumn");
private static final org.apache.thrift.protocol.TField VALUES_FIELD_DESC = new org.apache.thrift.protocol.TField("values", org.apache.thrift.protocol.TType.LIST, (short)1);
@@ -129,7 +133,7 @@ public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TSt
{
this();
this.values = values;
- this.nulls = nulls;
+ this.nulls = org.apache.thrift.TBaseHelper.copyBinary(nulls);
}
/**
@@ -137,15 +141,11 @@ public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TSt
*/
public TStringColumn(TStringColumn other) {
if (other.isSetValues()) {
- List<String> __this__values = new ArrayList<String>();
- for (String other_element : other.values) {
- __this__values.add(other_element);
- }
+ List<String> __this__values = new ArrayList<String>(other.values);
this.values = __this__values;
}
if (other.isSetNulls()) {
this.nulls = org.apache.thrift.TBaseHelper.copyBinary(other.nulls);
-;
}
}
@@ -203,15 +203,15 @@ public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TSt
}
public ByteBuffer bufferForNulls() {
- return nulls;
+ return org.apache.thrift.TBaseHelper.copyBinary(nulls);
}
public void setNulls(byte[] nulls) {
- setNulls(nulls == null ? (ByteBuffer)null : ByteBuffer.wrap(nulls));
+ this.nulls = nulls == null ? (ByteBuffer)null : ByteBuffer.wrap(Arrays.copyOf(nulls, nulls.length));
}
public void setNulls(ByteBuffer nulls) {
- this.nulls = nulls;
+ this.nulls = org.apache.thrift.TBaseHelper.copyBinary(nulls);
}
public void unsetNulls() {
@@ -313,45 +313,45 @@ public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TSt
@Override
public int hashCode() {
- HashCodeBuilder builder = new HashCodeBuilder();
+ List<Object> list = new ArrayList<Object>();
boolean present_values = true && (isSetValues());
- builder.append(present_values);
+ list.add(present_values);
if (present_values)
- builder.append(values);
+ list.add(values);
boolean present_nulls = true && (isSetNulls());
- builder.append(present_nulls);
+ list.add(present_nulls);
if (present_nulls)
- builder.append(nulls);
+ list.add(nulls);
- return builder.toHashCode();
+ return list.hashCode();
}
+ @Override
public int compareTo(TStringColumn other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- TStringColumn typedOther = (TStringColumn)other;
- lastComparison = Boolean.valueOf(isSetValues()).compareTo(typedOther.isSetValues());
+ lastComparison = Boolean.valueOf(isSetValues()).compareTo(other.isSetValues());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetValues()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.values, typedOther.values);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.values, other.values);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetNulls()).compareTo(typedOther.isSetNulls());
+ lastComparison = Boolean.valueOf(isSetNulls()).compareTo(other.isSetNulls());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNulls()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nulls, typedOther.nulls);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nulls, other.nulls);
if (lastComparison != 0) {
return lastComparison;
}
@@ -447,11 +447,11 @@ public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TSt
{
org.apache.thrift.protocol.TList _list102 = iprot.readListBegin();
struct.values = new ArrayList<String>(_list102.size);
- for (int _i103 = 0; _i103 < _list102.size; ++_i103)
+ String _elem103;
+ for (int _i104 = 0; _i104 < _list102.size; ++_i104)
{
- String _elem104; // optional
- _elem104 = iprot.readString();
- struct.values.add(_elem104);
+ _elem103 = iprot.readString();
+ struct.values.add(_elem103);
}
iprot.readListEnd();
}
@@ -531,11 +531,11 @@ public class TStringColumn implements org.apache.thrift.TBase<TStringColumn, TSt
{
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 _elem108;
+ for (int _i109 = 0; _i109 < _list107.size; ++_i109)
{
- String _elem109; // optional
- _elem109 = iprot.readString();
- struct.values.add(_elem109);
+ _elem108 = iprot.readString();
+ struct.values.add(_elem108);
}
}
struct.setValuesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java
index af7a109..bc7f121 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStringValue.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,10 +29,13 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class TStringValue implements org.apache.thrift.TBase<TStringValue, TStringValue._Fields>, java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+public class TStringValue implements org.apache.thrift.TBase<TStringValue, TStringValue._Fields>, java.io.Serializable, Cloneable, Comparable<TStringValue> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TStringValue");
private static final org.apache.thrift.protocol.TField VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("value", org.apache.thrift.protocol.TType.STRING, (short)1);
@@ -103,7 +107,7 @@ public class TStringValue implements org.apache.thrift.TBase<TStringValue, TStri
}
// isset id assignments
- private _Fields optionals[] = {_Fields.VALUE};
+ private static final _Fields optionals[] = {_Fields.VALUE};
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -219,30 +223,30 @@ public class TStringValue implements org.apache.thrift.TBase<TStringValue, TStri
@Override
public int hashCode() {
- HashCodeBuilder builder = new HashCodeBuilder();
+ List<Object> list = new ArrayList<Object>();
boolean present_value = true && (isSetValue());
- builder.append(present_value);
+ list.add(present_value);
if (present_value)
- builder.append(value);
+ list.add(value);
- return builder.toHashCode();
+ return list.hashCode();
}
+ @Override
public int compareTo(TStringValue other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- TStringValue typedOther = (TStringValue)other;
- lastComparison = Boolean.valueOf(isSetValue()).compareTo(typedOther.isSetValue());
+ lastComparison = Boolean.valueOf(isSetValue()).compareTo(other.isSetValue());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetValue()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.value, typedOther.value);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.value, other.value);
if (lastComparison != 0) {
return lastComparison;
}
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java
index 20f5fb6..ad95cce 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TStructTypeEntry.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,10 +29,13 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class TStructTypeEntry implements org.apache.thrift.TBase<TStructTypeEntry, TStructTypeEntry._Fields>, java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+public class TStructTypeEntry implements org.apache.thrift.TBase<TStructTypeEntry, TStructTypeEntry._Fields>, java.io.Serializable, Cloneable, Comparable<TStructTypeEntry> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TStructTypeEntry");
private static final org.apache.thrift.protocol.TField NAME_TO_TYPE_PTR_FIELD_DESC = new org.apache.thrift.protocol.TField("nameToTypePtr", org.apache.thrift.protocol.TType.MAP, (short)1);
@@ -129,7 +133,7 @@ public class TStructTypeEntry implements org.apache.thrift.TBase<TStructTypeEntr
*/
public TStructTypeEntry(TStructTypeEntry other) {
if (other.isSetNameToTypePtr()) {
- Map<String,Integer> __this__nameToTypePtr = new HashMap<String,Integer>();
+ Map<String,Integer> __this__nameToTypePtr = new HashMap<String,Integer>(other.nameToTypePtr.size());
for (Map.Entry<String, Integer> other_element : other.nameToTypePtr.entrySet()) {
String other_element_key = other_element.getKey();
@@ -250,30 +254,30 @@ public class TStructTypeEntry implements org.apache.thrift.TBase<TStructTypeEntr
@Override
public int hashCode() {
- HashCodeBuilder builder = new HashCodeBuilder();
+ List<Object> list = new ArrayList<Object>();
boolean present_nameToTypePtr = true && (isSetNameToTypePtr());
- builder.append(present_nameToTypePtr);
+ list.add(present_nameToTypePtr);
if (present_nameToTypePtr)
- builder.append(nameToTypePtr);
+ list.add(nameToTypePtr);
- return builder.toHashCode();
+ return list.hashCode();
}
+ @Override
public int compareTo(TStructTypeEntry other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- TStructTypeEntry typedOther = (TStructTypeEntry)other;
- lastComparison = Boolean.valueOf(isSetNameToTypePtr()).compareTo(typedOther.isSetNameToTypePtr());
+ lastComparison = Boolean.valueOf(isSetNameToTypePtr()).compareTo(other.isSetNameToTypePtr());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNameToTypePtr()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nameToTypePtr, typedOther.nameToTypePtr);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nameToTypePtr, other.nameToTypePtr);
if (lastComparison != 0) {
return lastComparison;
}
@@ -357,13 +361,13 @@ public class TStructTypeEntry implements org.apache.thrift.TBase<TStructTypeEntr
{
org.apache.thrift.protocol.TMap _map10 = iprot.readMapBegin();
struct.nameToTypePtr = new HashMap<String,Integer>(2*_map10.size);
- for (int _i11 = 0; _i11 < _map10.size; ++_i11)
+ String _key11;
+ int _val12;
+ for (int _i13 = 0; _i13 < _map10.size; ++_i13)
{
- String _key12; // required
- int _val13; // required
- _key12 = iprot.readString();
- _val13 = iprot.readI32();
- struct.nameToTypePtr.put(_key12, _val13);
+ _key11 = iprot.readString();
+ _val12 = iprot.readI32();
+ struct.nameToTypePtr.put(_key11, _val12);
}
iprot.readMapEnd();
}
@@ -431,13 +435,13 @@ public class TStructTypeEntry implements org.apache.thrift.TBase<TStructTypeEntr
{
org.apache.thrift.protocol.TMap _map16 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
struct.nameToTypePtr = new HashMap<String,Integer>(2*_map16.size);
- for (int _i17 = 0; _i17 < _map16.size; ++_i17)
+ String _key17;
+ int _val18;
+ for (int _i19 = 0; _i19 < _map16.size; ++_i19)
{
- String _key18; // required
- int _val19; // required
- _key18 = iprot.readString();
- _val19 = iprot.readI32();
- struct.nameToTypePtr.put(_key18, _val19);
+ _key17 = iprot.readString();
+ _val18 = iprot.readI32();
+ struct.nameToTypePtr.put(_key17, _val18);
}
}
struct.setNameToTypePtrIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java
index ff5e54d..4416a07 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTableSchema.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,10 +29,13 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class TTableSchema implements org.apache.thrift.TBase<TTableSchema, TTableSchema._Fields>, java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+public class TTableSchema implements org.apache.thrift.TBase<TTableSchema, TTableSchema._Fields>, java.io.Serializable, Cloneable, Comparable<TTableSchema> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTableSchema");
private static final org.apache.thrift.protocol.TField COLUMNS_FIELD_DESC = new org.apache.thrift.protocol.TField("columns", org.apache.thrift.protocol.TType.LIST, (short)1);
@@ -128,7 +132,7 @@ public class TTableSchema implements org.apache.thrift.TBase<TTableSchema, TTabl
*/
public TTableSchema(TTableSchema other) {
if (other.isSetColumns()) {
- List<TColumnDesc> __this__columns = new ArrayList<TColumnDesc>();
+ List<TColumnDesc> __this__columns = new ArrayList<TColumnDesc>(other.columns.size());
for (TColumnDesc other_element : other.columns) {
__this__columns.add(new TColumnDesc(other_element));
}
@@ -245,30 +249,30 @@ public class TTableSchema implements org.apache.thrift.TBase<TTableSchema, TTabl
@Override
public int hashCode() {
- HashCodeBuilder builder = new HashCodeBuilder();
+ List<Object> list = new ArrayList<Object>();
boolean present_columns = true && (isSetColumns());
- builder.append(present_columns);
+ list.add(present_columns);
if (present_columns)
- builder.append(columns);
+ list.add(columns);
- return builder.toHashCode();
+ return list.hashCode();
}
+ @Override
public int compareTo(TTableSchema other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- TTableSchema typedOther = (TTableSchema)other;
- lastComparison = Boolean.valueOf(isSetColumns()).compareTo(typedOther.isSetColumns());
+ lastComparison = Boolean.valueOf(isSetColumns()).compareTo(other.isSetColumns());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetColumns()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.columns, typedOther.columns);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.columns, other.columns);
if (lastComparison != 0) {
return lastComparison;
}
@@ -352,12 +356,12 @@ public class TTableSchema implements org.apache.thrift.TBase<TTableSchema, TTabl
{
org.apache.thrift.protocol.TList _list38 = iprot.readListBegin();
struct.columns = new ArrayList<TColumnDesc>(_list38.size);
- for (int _i39 = 0; _i39 < _list38.size; ++_i39)
+ TColumnDesc _elem39;
+ for (int _i40 = 0; _i40 < _list38.size; ++_i40)
{
- TColumnDesc _elem40; // optional
- _elem40 = new TColumnDesc();
- _elem40.read(iprot);
- struct.columns.add(_elem40);
+ _elem39 = new TColumnDesc();
+ _elem39.read(iprot);
+ struct.columns.add(_elem39);
}
iprot.readListEnd();
}
@@ -423,12 +427,12 @@ public class TTableSchema implements org.apache.thrift.TBase<TTableSchema, TTabl
{
org.apache.thrift.protocol.TList _list43 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.columns = new ArrayList<TColumnDesc>(_list43.size);
- for (int _i44 = 0; _i44 < _list43.size; ++_i44)
+ TColumnDesc _elem44;
+ for (int _i45 = 0; _i45 < _list43.size; ++_i45)
{
- TColumnDesc _elem45; // optional
- _elem45 = new TColumnDesc();
- _elem45.read(iprot);
- struct.columns.add(_elem45);
+ _elem44 = new TColumnDesc();
+ _elem44.read(iprot);
+ struct.columns.add(_elem44);
}
}
struct.setColumnsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java
index 251f86a..a97c9aa 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeDesc.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,10 +29,13 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class TTypeDesc implements org.apache.thrift.TBase<TTypeDesc, TTypeDesc._Fields>, java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+public class TTypeDesc implements org.apache.thrift.TBase<TTypeDesc, TTypeDesc._Fields>, java.io.Serializable, Cloneable, Comparable<TTypeDesc> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTypeDesc");
private static final org.apache.thrift.protocol.TField TYPES_FIELD_DESC = new org.apache.thrift.protocol.TField("types", org.apache.thrift.protocol.TType.LIST, (short)1);
@@ -128,7 +132,7 @@ public class TTypeDesc implements org.apache.thrift.TBase<TTypeDesc, TTypeDesc._
*/
public TTypeDesc(TTypeDesc other) {
if (other.isSetTypes()) {
- List<TTypeEntry> __this__types = new ArrayList<TTypeEntry>();
+ List<TTypeEntry> __this__types = new ArrayList<TTypeEntry>(other.types.size());
for (TTypeEntry other_element : other.types) {
__this__types.add(new TTypeEntry(other_element));
}
@@ -245,30 +249,30 @@ public class TTypeDesc implements org.apache.thrift.TBase<TTypeDesc, TTypeDesc._
@Override
public int hashCode() {
- HashCodeBuilder builder = new HashCodeBuilder();
+ List<Object> list = new ArrayList<Object>();
boolean present_types = true && (isSetTypes());
- builder.append(present_types);
+ list.add(present_types);
if (present_types)
- builder.append(types);
+ list.add(types);
- return builder.toHashCode();
+ return list.hashCode();
}
+ @Override
public int compareTo(TTypeDesc other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- TTypeDesc typedOther = (TTypeDesc)other;
- lastComparison = Boolean.valueOf(isSetTypes()).compareTo(typedOther.isSetTypes());
+ lastComparison = Boolean.valueOf(isSetTypes()).compareTo(other.isSetTypes());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTypes()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.types, typedOther.types);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.types, other.types);
if (lastComparison != 0) {
return lastComparison;
}
@@ -352,12 +356,12 @@ public class TTypeDesc implements org.apache.thrift.TBase<TTypeDesc, TTypeDesc._
{
org.apache.thrift.protocol.TList _list30 = iprot.readListBegin();
struct.types = new ArrayList<TTypeEntry>(_list30.size);
- for (int _i31 = 0; _i31 < _list30.size; ++_i31)
+ TTypeEntry _elem31;
+ for (int _i32 = 0; _i32 < _list30.size; ++_i32)
{
- TTypeEntry _elem32; // optional
- _elem32 = new TTypeEntry();
- _elem32.read(iprot);
- struct.types.add(_elem32);
+ _elem31 = new TTypeEntry();
+ _elem31.read(iprot);
+ struct.types.add(_elem31);
}
iprot.readListEnd();
}
@@ -423,12 +427,12 @@ public class TTypeDesc implements org.apache.thrift.TBase<TTypeDesc, TTypeDesc._
{
org.apache.thrift.protocol.TList _list35 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.types = new ArrayList<TTypeEntry>(_list35.size);
- for (int _i36 = 0; _i36 < _list35.size; ++_i36)
+ TTypeEntry _elem36;
+ for (int _i37 = 0; _i37 < _list35.size; ++_i37)
{
- TTypeEntry _elem37; // optional
- _elem37 = new TTypeEntry();
- _elem37.read(iprot);
- struct.types.add(_elem37);
+ _elem36 = new TTypeEntry();
+ _elem36.read(iprot);
+ struct.types.add(_elem36);
}
}
struct.setTypesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java
index af7c0b4..203d3b9 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeEntry.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,9 +29,11 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
public class TTypeEntry extends org.apache.thrift.TUnion<TTypeEntry, TTypeEntry._Fields> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTypeEntry");
private static final org.apache.thrift.protocol.TField PRIMITIVE_ENTRY_FIELD_DESC = new org.apache.thrift.protocol.TField("primitiveEntry", org.apache.thrift.protocol.TType.STRUCT, (short)1);
@@ -291,6 +294,7 @@ public class TTypeEntry extends org.apache.thrift.TUnion<TTypeEntry, TTypeEntry.
throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
} else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
return null;
}
}
@@ -575,19 +579,19 @@ public class TTypeEntry extends org.apache.thrift.TUnion<TTypeEntry, TTypeEntry.
@Override
public int hashCode() {
- HashCodeBuilder hcb = new HashCodeBuilder();
- hcb.append(this.getClass().getName());
+ List<Object> list = new ArrayList<Object>();
+ list.add(this.getClass().getName());
org.apache.thrift.TFieldIdEnum setField = getSetField();
if (setField != null) {
- hcb.append(setField.getThriftFieldId());
+ list.add(setField.getThriftFieldId());
Object value = getFieldValue();
if (value instanceof org.apache.thrift.TEnum) {
- hcb.append(((org.apache.thrift.TEnum)getFieldValue()).getValue());
+ list.add(((org.apache.thrift.TEnum)getFieldValue()).getValue());
} else {
- hcb.append(value);
+ list.add(value);
}
}
- return hcb.toHashCode();
+ return list.hashCode();
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java
index 40f0589..e6f2336 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeId.java
@@ -1,5 +1,5 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java
index 8c40687..54df6dc 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifierValue.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,9 +29,11 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
public class TTypeQualifierValue extends org.apache.thrift.TUnion<TTypeQualifierValue, TTypeQualifierValue._Fields> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTypeQualifierValue");
private static final org.apache.thrift.protocol.TField I32_VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("i32Value", org.apache.thrift.protocol.TType.I32, (short)1);
@@ -181,6 +184,7 @@ public class TTypeQualifierValue extends org.apache.thrift.TUnion<TTypeQualifier
throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
} else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
return null;
}
}
@@ -326,19 +330,19 @@ public class TTypeQualifierValue extends org.apache.thrift.TUnion<TTypeQualifier
@Override
public int hashCode() {
- HashCodeBuilder hcb = new HashCodeBuilder();
- hcb.append(this.getClass().getName());
+ List<Object> list = new ArrayList<Object>();
+ list.add(this.getClass().getName());
org.apache.thrift.TFieldIdEnum setField = getSetField();
if (setField != null) {
- hcb.append(setField.getThriftFieldId());
+ list.add(setField.getThriftFieldId());
Object value = getFieldValue();
if (value instanceof org.apache.thrift.TEnum) {
- hcb.append(((org.apache.thrift.TEnum)getFieldValue()).getValue());
+ list.add(((org.apache.thrift.TEnum)getFieldValue()).getValue());
} else {
- hcb.append(value);
+ list.add(value);
}
}
- return hcb.toHashCode();
+ return list.hashCode();
}
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
try {
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java
index 3935555..7f5b1b3 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TTypeQualifiers.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,10 +29,13 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class TTypeQualifiers implements org.apache.thrift.TBase<TTypeQualifiers, TTypeQualifiers._Fields>, java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+public class TTypeQualifiers implements org.apache.thrift.TBase<TTypeQualifiers, TTypeQualifiers._Fields>, java.io.Serializable, Cloneable, Comparable<TTypeQualifiers> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTypeQualifiers");
private static final org.apache.thrift.protocol.TField QUALIFIERS_FIELD_DESC = new org.apache.thrift.protocol.TField("qualifiers", org.apache.thrift.protocol.TType.MAP, (short)1);
@@ -129,7 +133,7 @@ public class TTypeQualifiers implements org.apache.thrift.TBase<TTypeQualifiers,
*/
public TTypeQualifiers(TTypeQualifiers other) {
if (other.isSetQualifiers()) {
- Map<String,TTypeQualifierValue> __this__qualifiers = new HashMap<String,TTypeQualifierValue>();
+ Map<String,TTypeQualifierValue> __this__qualifiers = new HashMap<String,TTypeQualifierValue>(other.qualifiers.size());
for (Map.Entry<String, TTypeQualifierValue> other_element : other.qualifiers.entrySet()) {
String other_element_key = other_element.getKey();
@@ -250,30 +254,30 @@ public class TTypeQualifiers implements org.apache.thrift.TBase<TTypeQualifiers,
@Override
public int hashCode() {
- HashCodeBuilder builder = new HashCodeBuilder();
+ List<Object> list = new ArrayList<Object>();
boolean present_qualifiers = true && (isSetQualifiers());
- builder.append(present_qualifiers);
+ list.add(present_qualifiers);
if (present_qualifiers)
- builder.append(qualifiers);
+ list.add(qualifiers);
- return builder.toHashCode();
+ return list.hashCode();
}
+ @Override
public int compareTo(TTypeQualifiers other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- TTypeQualifiers typedOther = (TTypeQualifiers)other;
- lastComparison = Boolean.valueOf(isSetQualifiers()).compareTo(typedOther.isSetQualifiers());
+ lastComparison = Boolean.valueOf(isSetQualifiers()).compareTo(other.isSetQualifiers());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetQualifiers()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.qualifiers, typedOther.qualifiers);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.qualifiers, other.qualifiers);
if (lastComparison != 0) {
return lastComparison;
}
@@ -357,14 +361,14 @@ public class TTypeQualifiers implements org.apache.thrift.TBase<TTypeQualifiers,
{
org.apache.thrift.protocol.TMap _map0 = iprot.readMapBegin();
struct.qualifiers = new HashMap<String,TTypeQualifierValue>(2*_map0.size);
- for (int _i1 = 0; _i1 < _map0.size; ++_i1)
+ String _key1;
+ TTypeQualifierValue _val2;
+ for (int _i3 = 0; _i3 < _map0.size; ++_i3)
{
- String _key2; // required
- TTypeQualifierValue _val3; // required
- _key2 = iprot.readString();
- _val3 = new TTypeQualifierValue();
- _val3.read(iprot);
- struct.qualifiers.put(_key2, _val3);
+ _key1 = iprot.readString();
+ _val2 = new TTypeQualifierValue();
+ _val2.read(iprot);
+ struct.qualifiers.put(_key1, _val2);
}
iprot.readMapEnd();
}
@@ -432,14 +436,14 @@ public class TTypeQualifiers implements org.apache.thrift.TBase<TTypeQualifiers,
{
org.apache.thrift.protocol.TMap _map6 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.qualifiers = new HashMap<String,TTypeQualifierValue>(2*_map6.size);
- for (int _i7 = 0; _i7 < _map6.size; ++_i7)
+ String _key7;
+ TTypeQualifierValue _val8;
+ for (int _i9 = 0; _i9 < _map6.size; ++_i9)
{
- String _key8; // required
- TTypeQualifierValue _val9; // required
- _key8 = iprot.readString();
- _val9 = new TTypeQualifierValue();
- _val9.read(iprot);
- struct.qualifiers.put(_key8, _val9);
+ _key7 = iprot.readString();
+ _val8 = new TTypeQualifierValue();
+ _val8.read(iprot);
+ struct.qualifiers.put(_key7, _val8);
}
}
struct.setQualifiersIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java
index 73dd45d..243b307 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUnionTypeEntry.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,10 +29,13 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class TUnionTypeEntry implements org.apache.thrift.TBase<TUnionTypeEntry, TUnionTypeEntry._Fields>, java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+public class TUnionTypeEntry implements org.apache.thrift.TBase<TUnionTypeEntry, TUnionTypeEntry._Fields>, java.io.Serializable, Cloneable, Comparable<TUnionTypeEntry> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TUnionTypeEntry");
private static final org.apache.thrift.protocol.TField NAME_TO_TYPE_PTR_FIELD_DESC = new org.apache.thrift.protocol.TField("nameToTypePtr", org.apache.thrift.protocol.TType.MAP, (short)1);
@@ -129,7 +133,7 @@ public class TUnionTypeEntry implements org.apache.thrift.TBase<TUnionTypeEntry,
*/
public TUnionTypeEntry(TUnionTypeEntry other) {
if (other.isSetNameToTypePtr()) {
- Map<String,Integer> __this__nameToTypePtr = new HashMap<String,Integer>();
+ Map<String,Integer> __this__nameToTypePtr = new HashMap<String,Integer>(other.nameToTypePtr.size());
for (Map.Entry<String, Integer> other_element : other.nameToTypePtr.entrySet()) {
String other_element_key = other_element.getKey();
@@ -250,30 +254,30 @@ public class TUnionTypeEntry implements org.apache.thrift.TBase<TUnionTypeEntry,
@Override
public int hashCode() {
- HashCodeBuilder builder = new HashCodeBuilder();
+ List<Object> list = new ArrayList<Object>();
boolean present_nameToTypePtr = true && (isSetNameToTypePtr());
- builder.append(present_nameToTypePtr);
+ list.add(present_nameToTypePtr);
if (present_nameToTypePtr)
- builder.append(nameToTypePtr);
+ list.add(nameToTypePtr);
- return builder.toHashCode();
+ return list.hashCode();
}
+ @Override
public int compareTo(TUnionTypeEntry other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- TUnionTypeEntry typedOther = (TUnionTypeEntry)other;
- lastComparison = Boolean.valueOf(isSetNameToTypePtr()).compareTo(typedOther.isSetNameToTypePtr());
+ lastComparison = Boolean.valueOf(isSetNameToTypePtr()).compareTo(other.isSetNameToTypePtr());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetNameToTypePtr()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nameToTypePtr, typedOther.nameToTypePtr);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.nameToTypePtr, other.nameToTypePtr);
if (lastComparison != 0) {
return lastComparison;
}
@@ -357,13 +361,13 @@ public class TUnionTypeEntry implements org.apache.thrift.TBase<TUnionTypeEntry,
{
org.apache.thrift.protocol.TMap _map20 = iprot.readMapBegin();
struct.nameToTypePtr = new HashMap<String,Integer>(2*_map20.size);
- for (int _i21 = 0; _i21 < _map20.size; ++_i21)
+ String _key21;
+ int _val22;
+ for (int _i23 = 0; _i23 < _map20.size; ++_i23)
{
- String _key22; // required
- int _val23; // required
- _key22 = iprot.readString();
- _val23 = iprot.readI32();
- struct.nameToTypePtr.put(_key22, _val23);
+ _key21 = iprot.readString();
+ _val22 = iprot.readI32();
+ struct.nameToTypePtr.put(_key21, _val22);
}
iprot.readMapEnd();
}
@@ -431,13 +435,13 @@ public class TUnionTypeEntry implements org.apache.thrift.TBase<TUnionTypeEntry,
{
org.apache.thrift.protocol.TMap _map26 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.I32, iprot.readI32());
struct.nameToTypePtr = new HashMap<String,Integer>(2*_map26.size);
- for (int _i27 = 0; _i27 < _map26.size; ++_i27)
+ String _key27;
+ int _val28;
+ for (int _i29 = 0; _i29 < _map26.size; ++_i29)
{
- String _key28; // required
- int _val29; // required
- _key28 = iprot.readString();
- _val29 = iprot.readI32();
- struct.nameToTypePtr.put(_key28, _val29);
+ _key27 = iprot.readString();
+ _val28 = iprot.readI32();
+ struct.nameToTypePtr.put(_key27, _val28);
}
}
struct.setNameToTypePtrIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java
index 3a111a2..107962e 100644
--- a/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java
+++ b/service/src/gen/thrift/gen-javabean/org/apache/hive/service/cli/thrift/TUserDefinedTypeEntry.java
@@ -1,12 +1,11 @@
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.hive.service.cli.thrift;
-import org.apache.commons.lang.builder.HashCodeBuilder;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
@@ -16,6 +15,8 @@ import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
+import org.apache.thrift.async.AsyncMethodCallback;
+import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
@@ -28,10 +29,13 @@ import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class TUserDefinedTypeEntry implements org.apache.thrift.TBase<TUserDefinedTypeEntry, TUserDefinedTypeEntry._Fields>, java.io.Serializable, Cloneable {
+@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
+@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-7-14")
+public class TUserDefinedTypeEntry implements org.apache.thrift.TBase<TUserDefinedTypeEntry, TUserDefinedTypeEntry._Fields>, java.io.Serializable, Cloneable, Comparable<TUserDefinedTypeEntry> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TUserDefinedTypeEntry");
private static final org.apache.thrift.protocol.TField TYPE_CLASS_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("typeClassName", org.apache.thrift.protocol.TType.STRING, (short)1);
@@ -225,30 +229,30 @@ public class TUserDefinedTypeEntry implements org.apache.thrift.TBase<TUserDefin
@Override
public int hashCode() {
- HashCodeBuilder builder = new HashCodeBuilder();
+ List<Object> list = new ArrayList<Object>();
boolean present_typeClassName = true && (isSetTypeClassName());
- builder.append(present_typeClassName);
+ list.add(present_typeClassName);
if (present_typeClassName)
- builder.append(typeClassName);
+ list.add(typeClassName);
- return builder.toHashCode();
+ return list.hashCode();
}
+ @Override
public int compareTo(TUserDefinedTypeEntry other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- TUserDefinedTypeEntry typedOther = (TUserDefinedTypeEntry)other;
- lastComparison = Boolean.valueOf(isSetTypeClassName()).compareTo(typedOther.isSetTypeClassName());
+ lastComparison = Boolean.valueOf(isSetTypeClassName()).compareTo(other.isSetTypeClassName());
if (lastComparison != 0) {
return lastComparison;
}
if (isSetTypeClassName()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.typeClassName, typedOther.typeClassName);
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.typeClassName, other.typeClassName);
if (lastComparison != 0) {
return lastComparison;
}
http://git-wip-us.apache.org/repos/asf/hive/blob/42216997/service/src/gen/thrift/gen-php/TCLIService.php
----------------------------------------------------------------------
diff --git a/service/src/gen/thrift/gen-php/TCLIService.php b/service/src/gen/thrift/gen-php/TCLIService.php
index d246296..f5dd904 100644
--- a/service/src/gen/thrift/gen-php/TCLIService.php
+++ b/service/src/gen/thrift/gen-php/TCLIService.php
@@ -1,7 +1,7 @@
<?php
namespace ;
/**
- * Autogenerated by Thrift Compiler (0.9.0)
+ * Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
@@ -12,28 +12,105 @@ use Thrift\Type\TMessageType;
use Thrift\Exception\TException;
use Thrift\Exception\TProtocolException;
use Thrift\Protocol\TProtocol;
+use Thrift\Protocol\TBinaryProtocolAccelerated;
use Thrift\Exception\TApplicationException;
interface TCLIServiceIf {
+ /**
+ * @param \TOpenSessionReq $req
+ * @return \TOpenSessionResp
+ */
public function OpenSession(\TOpenSessionReq $req);
+ /**
+ * @param \TCloseSessionReq $req
+ * @return \TCloseSessionResp
+ */
public function CloseSession(\TCloseSessionReq $req);
+ /**
+ * @param \TGetInfoReq $req
+ * @return \TGetInfoResp
+ */
public function GetInfo(\TGetInfoReq $req);
+ /**
+ * @param \TExecuteStatementReq $req
+ * @return \TExecuteStatementResp
+ */
public function ExecuteStatement(\TExecuteStatementReq $req);
+ /**
+ * @param \TGetTypeInfoReq $req
+ * @return \TGetTypeInfoResp
+ */
public function GetTypeInfo(\TGetTypeInfoReq $req);
+ /**
+ * @param \TGetCatalogsReq $req
+ * @return \TGetCatalogsResp
+ */
public function GetCatalogs(\TGetCatalogsReq $req);
+ /**
+ * @param \TGetSchemasReq $req
+ * @return \TGetSchemasResp
+ */
public function GetSchemas(\TGetSchemasReq $req);
+ /**
+ * @param \TGetTablesReq $req
+ * @return \TGetTablesResp
+ */
public function GetTables(\TGetTablesReq $req);
+ /**
+ * @param \TGetTableTypesReq $req
+ * @return \TGetTableTypesResp
+ */
public function GetTableTypes(\TGetTableTypesReq $req);
+ /**
+ * @param \TGetColumnsReq $req
+ * @return \TGetColumnsResp
+ */
public function GetColumns(\TGetColumnsReq $req);
+ /**
+ * @param \TGetFunctionsReq $req
+ * @return \TGetFunctionsResp
+ */
public function GetFunctions(\TGetFunctionsReq $req);
+ /**
+ * @param \TGetOperationStatusReq $req
+ * @return \TGetOperationStatusResp
+ */
public function GetOperationStatus(\TGetOperationStatusReq $req);
+ /**
+ * @param \TCancelOperationReq $req
+ * @return \TCancelOperationResp
+ */
public function CancelOperation(\TCancelOperationReq $req);
+ /**
+ * @param \TCloseOperationReq $req
+ * @return \TCloseOperationResp
+ */
public function CloseOperation(\TCloseOperationReq $req);
+ /**
+ * @param \TGetResultSetMetadataReq $req
+ * @return \TGetResultSetMetadataResp
+ */
public function GetResultSetMetadata(\TGetResultSetMetadataReq $req);
+ /**
+ * @param \TFetchResultsReq $req
+ * @return \TFetchResultsResp
+ */
public function FetchResults(\TFetchResultsReq $req);
+ /**
+ * @param \TGetDelegationTokenReq $req
+ * @return \TGetDelegationTokenResp
+ */
public function GetDelegationToken(\TGetDelegationTokenReq $req);
+ /**
+ * @param \TCancelDelegationTokenReq $req
+ * @return \TCancelDelegationTokenResp
+ */
public function CancelDelegationToken(\TCancelDelegationTokenReq $req);
+ /**
+ * @param \TRenewDelegationTokenReq $req
+ * @return \TRenewDelegationTokenResp
+ */
public function RenewDelegationToken(\TRenewDelegationTokenReq $req);
}
@@ -58,7 +135,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_OpenSession_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'OpenSession', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -74,7 +151,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_OpenSession()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_OpenSession_result', $this->input_->isStrictRead());
else
{
@@ -109,7 +186,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_CloseSession_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'CloseSession', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -125,7 +202,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_CloseSession()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_CloseSession_result', $this->input_->isStrictRead());
else
{
@@ -160,7 +237,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetInfo_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetInfo', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -176,7 +253,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetInfo()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetInfo_result', $this->input_->isStrictRead());
else
{
@@ -211,7 +288,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_ExecuteStatement_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'ExecuteStatement', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -227,7 +304,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_ExecuteStatement()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_ExecuteStatement_result', $this->input_->isStrictRead());
else
{
@@ -262,7 +339,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetTypeInfo_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetTypeInfo', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -278,7 +355,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetTypeInfo()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetTypeInfo_result', $this->input_->isStrictRead());
else
{
@@ -313,7 +390,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetCatalogs_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetCatalogs', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -329,7 +406,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetCatalogs()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetCatalogs_result', $this->input_->isStrictRead());
else
{
@@ -364,7 +441,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetSchemas_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetSchemas', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -380,7 +457,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetSchemas()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetSchemas_result', $this->input_->isStrictRead());
else
{
@@ -415,7 +492,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetTables_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetTables', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -431,7 +508,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetTables()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetTables_result', $this->input_->isStrictRead());
else
{
@@ -466,7 +543,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetTableTypes_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetTableTypes', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -482,7 +559,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetTableTypes()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetTableTypes_result', $this->input_->isStrictRead());
else
{
@@ -517,7 +594,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetColumns_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetColumns', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -533,7 +610,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetColumns()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetColumns_result', $this->input_->isStrictRead());
else
{
@@ -568,7 +645,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetFunctions_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetFunctions', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -584,7 +661,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetFunctions()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetFunctions_result', $this->input_->isStrictRead());
else
{
@@ -619,7 +696,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetOperationStatus_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetOperationStatus', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -635,7 +712,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetOperationStatus()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetOperationStatus_result', $this->input_->isStrictRead());
else
{
@@ -670,7 +747,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_CancelOperation_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'CancelOperation', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -686,7 +763,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_CancelOperation()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_CancelOperation_result', $this->input_->isStrictRead());
else
{
@@ -721,7 +798,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_CloseOperation_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'CloseOperation', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -737,7 +814,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_CloseOperation()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_CloseOperation_result', $this->input_->isStrictRead());
else
{
@@ -772,7 +849,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetResultSetMetadata_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetResultSetMetadata', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -788,7 +865,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetResultSetMetadata()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetResultSetMetadata_result', $this->input_->isStrictRead());
else
{
@@ -823,7 +900,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_FetchResults_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'FetchResults', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -839,7 +916,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_FetchResults()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_FetchResults_result', $this->input_->isStrictRead());
else
{
@@ -874,7 +951,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_GetDelegationToken_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'GetDelegationToken', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -890,7 +967,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_GetDelegationToken()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_GetDelegationToken_result', $this->input_->isStrictRead());
else
{
@@ -925,7 +1002,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_CancelDelegationToken_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'CancelDelegationToken', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -941,7 +1018,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_CancelDelegationToken()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_CancelDelegationToken_result', $this->input_->isStrictRead());
else
{
@@ -976,7 +1053,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
{
$args = new \TCLIService_RenewDelegationToken_args();
$args->req = $req;
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
thrift_protocol_write_binary($this->output_, 'RenewDelegationToken', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
@@ -992,7 +1069,7 @@ class TCLIServiceClient implements \TCLIServiceIf {
public function recv_RenewDelegationToken()
{
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\TCLIService_RenewDelegationToken_result', $this->input_->isStrictRead());
else
{
@@ -1024,6 +1101,9 @@ class TCLIServiceClient implements \TCLIServiceIf {
class TCLIService_OpenSession_args {
static $_TSPEC;
+ /**
+ * @var \TOpenSessionReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -1101,6 +1181,9 @@ class TCLIService_OpenSession_args {
class TCLIService_OpenSession_result {
static $_TSPEC;
+ /**
+ * @var \TOpenSessionResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -1178,6 +1261,9 @@ class TCLIService_OpenSession_result {
class TCLIService_CloseSession_args {
static $_TSPEC;
+ /**
+ * @var \TCloseSessionReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -1255,6 +1341,9 @@ class TCLIService_CloseSession_args {
class TCLIService_CloseSession_result {
static $_TSPEC;
+ /**
+ * @var \TCloseSessionResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -1332,6 +1421,9 @@ class TCLIService_CloseSession_result {
class TCLIService_GetInfo_args {
static $_TSPEC;
+ /**
+ * @var \TGetInfoReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -1409,6 +1501,9 @@ class TCLIService_GetInfo_args {
class TCLIService_GetInfo_result {
static $_TSPEC;
+ /**
+ * @var \TGetInfoResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -1486,6 +1581,9 @@ class TCLIService_GetInfo_result {
class TCLIService_ExecuteStatement_args {
static $_TSPEC;
+ /**
+ * @var \TExecuteStatementReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -1563,6 +1661,9 @@ class TCLIService_ExecuteStatement_args {
class TCLIService_ExecuteStatement_result {
static $_TSPEC;
+ /**
+ * @var \TExecuteStatementResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -1640,6 +1741,9 @@ class TCLIService_ExecuteStatement_result {
class TCLIService_GetTypeInfo_args {
static $_TSPEC;
+ /**
+ * @var \TGetTypeInfoReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -1717,6 +1821,9 @@ class TCLIService_GetTypeInfo_args {
class TCLIService_GetTypeInfo_result {
static $_TSPEC;
+ /**
+ * @var \TGetTypeInfoResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -1794,6 +1901,9 @@ class TCLIService_GetTypeInfo_result {
class TCLIService_GetCatalogs_args {
static $_TSPEC;
+ /**
+ * @var \TGetCatalogsReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -1871,6 +1981,9 @@ class TCLIService_GetCatalogs_args {
class TCLIService_GetCatalogs_result {
static $_TSPEC;
+ /**
+ * @var \TGetCatalogsResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -1948,6 +2061,9 @@ class TCLIService_GetCatalogs_result {
class TCLIService_GetSchemas_args {
static $_TSPEC;
+ /**
+ * @var \TGetSchemasReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -2025,6 +2141,9 @@ class TCLIService_GetSchemas_args {
class TCLIService_GetSchemas_result {
static $_TSPEC;
+ /**
+ * @var \TGetSchemasResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -2102,6 +2221,9 @@ class TCLIService_GetSchemas_result {
class TCLIService_GetTables_args {
static $_TSPEC;
+ /**
+ * @var \TGetTablesReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -2179,6 +2301,9 @@ class TCLIService_GetTables_args {
class TCLIService_GetTables_result {
static $_TSPEC;
+ /**
+ * @var \TGetTablesResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -2256,6 +2381,9 @@ class TCLIService_GetTables_result {
class TCLIService_GetTableTypes_args {
static $_TSPEC;
+ /**
+ * @var \TGetTableTypesReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -2333,6 +2461,9 @@ class TCLIService_GetTableTypes_args {
class TCLIService_GetTableTypes_result {
static $_TSPEC;
+ /**
+ * @var \TGetTableTypesResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -2410,6 +2541,9 @@ class TCLIService_GetTableTypes_result {
class TCLIService_GetColumns_args {
static $_TSPEC;
+ /**
+ * @var \TGetColumnsReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -2487,6 +2621,9 @@ class TCLIService_GetColumns_args {
class TCLIService_GetColumns_result {
static $_TSPEC;
+ /**
+ * @var \TGetColumnsResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -2564,6 +2701,9 @@ class TCLIService_GetColumns_result {
class TCLIService_GetFunctions_args {
static $_TSPEC;
+ /**
+ * @var \TGetFunctionsReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -2641,6 +2781,9 @@ class TCLIService_GetFunctions_args {
class TCLIService_GetFunctions_result {
static $_TSPEC;
+ /**
+ * @var \TGetFunctionsResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -2718,6 +2861,9 @@ class TCLIService_GetFunctions_result {
class TCLIService_GetOperationStatus_args {
static $_TSPEC;
+ /**
+ * @var \TGetOperationStatusReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -2795,6 +2941,9 @@ class TCLIService_GetOperationStatus_args {
class TCLIService_GetOperationStatus_result {
static $_TSPEC;
+ /**
+ * @var \TGetOperationStatusResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -2872,6 +3021,9 @@ class TCLIService_GetOperationStatus_result {
class TCLIService_CancelOperation_args {
static $_TSPEC;
+ /**
+ * @var \TCancelOperationReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -2949,6 +3101,9 @@ class TCLIService_CancelOperation_args {
class TCLIService_CancelOperation_result {
static $_TSPEC;
+ /**
+ * @var \TCancelOperationResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -3026,6 +3181,9 @@ class TCLIService_CancelOperation_result {
class TCLIService_CloseOperation_args {
static $_TSPEC;
+ /**
+ * @var \TCloseOperationReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -3103,6 +3261,9 @@ class TCLIService_CloseOperation_args {
class TCLIService_CloseOperation_result {
static $_TSPEC;
+ /**
+ * @var \TCloseOperationResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -3180,6 +3341,9 @@ class TCLIService_CloseOperation_result {
class TCLIService_GetResultSetMetadata_args {
static $_TSPEC;
+ /**
+ * @var \TGetResultSetMetadataReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -3257,6 +3421,9 @@ class TCLIService_GetResultSetMetadata_args {
class TCLIService_GetResultSetMetadata_result {
static $_TSPEC;
+ /**
+ * @var \TGetResultSetMetadataResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -3334,6 +3501,9 @@ class TCLIService_GetResultSetMetadata_result {
class TCLIService_FetchResults_args {
static $_TSPEC;
+ /**
+ * @var \TFetchResultsReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -3411,6 +3581,9 @@ class TCLIService_FetchResults_args {
class TCLIService_FetchResults_result {
static $_TSPEC;
+ /**
+ * @var \TFetchResultsResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -3488,6 +3661,9 @@ class TCLIService_FetchResults_result {
class TCLIService_GetDelegationToken_args {
static $_TSPEC;
+ /**
+ * @var \TGetDelegationTokenReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -3565,6 +3741,9 @@ class TCLIService_GetDelegationToken_args {
class TCLIService_GetDelegationToken_result {
static $_TSPEC;
+ /**
+ * @var \TGetDelegationTokenResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -3642,6 +3821,9 @@ class TCLIService_GetDelegationToken_result {
class TCLIService_CancelDelegationToken_args {
static $_TSPEC;
+ /**
+ * @var \TCancelDelegationTokenReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -3719,6 +3901,9 @@ class TCLIService_CancelDelegationToken_args {
class TCLIService_CancelDelegationToken_result {
static $_TSPEC;
+ /**
+ * @var \TCancelDelegationTokenResp
+ */
public $success = null;
public function __construct($vals=null) {
@@ -3796,6 +3981,9 @@ class TCLIService_CancelDelegationToken_result {
class TCLIService_RenewDelegationToken_args {
static $_TSPEC;
+ /**
+ * @var \TRenewDelegationTokenReq
+ */
public $req = null;
public function __construct($vals=null) {
@@ -3873,6 +4061,9 @@ class TCLIService_RenewDelegationToken_args {
class TCLIService_RenewDelegationToken_result {
static $_TSPEC;
+ /**
+ * @var \TRenewDelegationTokenResp
+ */
public $success = null;
public function __construct($vals=null) {