This is an automated email from the ASF dual-hosted git repository.
chengpan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kyuubi-shaded.git
The following commit(s) were added to refs/heads/master by this push:
new 13ac3f3 [KYUUBI-SHADED #41] Relocated Hive MetaStore client uses
relocated Thrift
13ac3f3 is described below
commit 13ac3f3805f9c0e1e0817c9362526fc969b4e6bc
Author: zhouyifan279 <[email protected]>
AuthorDate: Thu Feb 29 18:30:36 2024 +0800
[KYUUBI-SHADED #41] Relocated Hive MetaStore client uses relocated Thrift
### _Why are the changes needed?_
Decouple from Hive's libthrift version
### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including
negative and positive cases if possible
- [ ] Add screenshots for manual tests if appropriate
- [ ] [Run
test](https://kyuubi.readthedocs.io/en/master/develop_tools/testing.html#running-tests)
locally before make a pull request
Closes #41 from zhouyifan279/relocate-thrift.
43bc96a [zhouyifan279] relocate-thrift
Authored-by: zhouyifan279 <[email protected]>
Signed-off-by: Cheng Pan <[email protected]>
---
kyuubi-relocated-hive-metastore-client/pom.xml | 40 ++-
.../shaded/hive/metastore/api/MetaException.java | 88 +++---
.../hive/metastore/api/ThriftHiveMetastore.java | 322 ++++++++++-----------
.../shaded/hive/metastore/HiveMetaStoreClient.java | 22 +-
.../shaded/hive/metastore/IMetaStoreClient.java | 2 +-
.../hive/metastore/MetaStorePlainSaslHelper.java | 6 +-
.../hive/metastore/RetryingMetaStoreClient.java | 4 +-
.../metastore/security/HadoopThriftAuthBridge.java | 6 +-
.../hive/metastore/security/TFilterTransport.java | 6 +-
.../metastore/security/TUGIAssumingTransport.java | 4 +-
.../shaded/hive/metastore/utils/SecurityUtils.java | 12 +-
.../src/main/resources/thrift-replacements.txt | 27 ++
12 files changed, 293 insertions(+), 246 deletions(-)
diff --git a/kyuubi-relocated-hive-metastore-client/pom.xml
b/kyuubi-relocated-hive-metastore-client/pom.xml
index 84d7adb..367da4b 100644
--- a/kyuubi-relocated-hive-metastore-client/pom.xml
+++ b/kyuubi-relocated-hive-metastore-client/pom.xml
@@ -35,6 +35,7 @@ under the License.
<!-- Dependency versions -->
<commons-lang3.version>3.12.0</commons-lang3.version>
<hadoop.version>3.3.6</hadoop.version>
+ <httpcomponents.core.version>4.5.14</httpcomponents.core.version>
<libfb303.version>0.9.3</libfb303.version>
<libthrift.version>0.16.0</libthrift.version>
<slf4j.version>1.7.36</slf4j.version>
@@ -46,6 +47,12 @@ under the License.
</properties>
<dependencies>
+ <dependency>
+ <groupId>org.apache.kyuubi</groupId>
+ <artifactId>kyuubi-relocated-thrift</artifactId>
+ <version>${project.version}</version>
+ <scope>provided</scope>
+ </dependency>
<dependency>
<groupId>org.apache.kyuubi</groupId>
<artifactId>kyuubi-relocated-zookeeper-34</artifactId>
@@ -64,22 +71,18 @@ under the License.
<version>${hadoop.version}</version>
<scope>provided</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.httpcomponents</groupId>
+ <artifactId>httpclient</artifactId>
+ <version>${httpcomponents.core.version}</version>
+ <scope>provided</scope>
+ </dependency>
<!-- TODO: remove this dependency -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>${commons-lang3.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.thrift</groupId>
- <artifactId>libfb303</artifactId>
- <version>${libfb303.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.thrift</groupId>
- <artifactId>libthrift</artifactId>
- <version>${libthrift.version}</version>
- </dependency>
</dependencies>
<build>
@@ -141,6 +144,23 @@ under the License.
<artifactId>replacer</artifactId>
<version>1.5.3</version>
<executions>
+ <execution>
+
<id>process-thrift-sources-relocate-thrift-package</id>
+ <goals>
+ <goal>replace</goal>
+ </goals>
+ <phase>process-sources</phase>
+ <configuration>
+
<basedir>${basedir}/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/</basedir>
+ <includes>
+ <include>MetaException.java</include>
+
<include>ThriftHiveMetastore.java</include>
+ </includes>
+
<tokenValueMap>${basedir}/src/main/resources/thrift-replacements.txt</tokenValueMap>
+ <regex>true</regex>
+ <quiet>false</quiet>
+ </configuration>
+ </execution>
<execution>
<id>process-thrift-sources-interface-annotations</id>
<goals>
diff --git
a/kyuubi-relocated-hive-metastore-client/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/MetaException.java
b/kyuubi-relocated-hive-metastore-client/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/MetaException.java
index 3fd073a..b73c98c 100644
---
a/kyuubi-relocated-hive-metastore-client/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/MetaException.java
+++
b/kyuubi-relocated-hive-metastore-client/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/MetaException.java
@@ -8,18 +8,18 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler
(0.16.0)")
[email protected]
@org.apache.hadoop.classification.InterfaceStability.Stable public class
MetaException extends org.apache.thrift.TException implements
org.apache.thrift.TBase<MetaException, MetaException._Fields>,
java.io.Serializable, Cloneable, Comparable<MetaException> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("MetaException");
[email protected]
@org.apache.hadoop.classification.InterfaceStability.Stable public class
MetaException extends org.apache.kyuubi.shaded.thrift.TException implements
org.apache.kyuubi.shaded.thrift.TBase<MetaException, MetaException._Fields>,
java.io.Serializable, Cloneable, Comparable<MetaException> {
+ private static final org.apache.kyuubi.shaded.thrift.protocol.TStruct
STRUCT_DESC = new
org.apache.kyuubi.shaded.thrift.protocol.TStruct("MetaException");
- private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC =
new org.apache.thrift.protocol.TField("message",
org.apache.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.kyuubi.shaded.thrift.protocol.TField
MESSAGE_FIELD_DESC = new
org.apache.kyuubi.shaded.thrift.protocol.TField("message",
org.apache.kyuubi.shaded.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new MetaExceptionStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new MetaExceptionTupleSchemeFactory();
+ private static final org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new MetaExceptionStandardSchemeFactory();
+ private static final org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new MetaExceptionTupleSchemeFactory();
- private @org.apache.thrift.annotation.Nullable java.lang.String message; //
required
+ private @org.apache.kyuubi.shaded.thrift.annotation.Nullable
java.lang.String message; // required
/** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ public enum _Fields implements org.apache.kyuubi.shaded.thrift.TFieldIdEnum {
MESSAGE((short)1, "message");
private static final java.util.Map<java.lang.String, _Fields> byName = new
java.util.HashMap<java.lang.String, _Fields>();
@@ -33,7 +33,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
/**
* Find the _Fields constant that matches fieldId, or null if its not
found.
*/
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
case 1: // MESSAGE
@@ -56,7 +56,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
@@ -79,13 +79,13 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
// isset id assignments
- public static final java.util.Map<_Fields,
org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap =
new java.util.EnumMap<_Fields,
org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.MESSAGE, new
org.apache.thrift.meta_data.FieldMetaData("message",
org.apache.thrift.TFieldRequirementType.DEFAULT,
- new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ java.util.Map<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData> tmpMap = new
java.util.EnumMap<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.MESSAGE, new
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData("message",
org.apache.kyuubi.shaded.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.kyuubi.shaded.thrift.meta_data.FieldValueMetaData(org.apache.kyuubi.shaded.thrift.protocol.TType.STRING)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
-
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(MetaException.class,
metaDataMap);
+
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData.addStructMetaDataMap(MetaException.class,
metaDataMap);
}
public MetaException() {
@@ -116,12 +116,12 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
this.message = null;
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public java.lang.String getMessage() {
return this.message;
}
- public void setMessage(@org.apache.thrift.annotation.Nullable
java.lang.String message) {
+ public void setMessage(@org.apache.kyuubi.shaded.thrift.annotation.Nullable
java.lang.String message) {
this.message = message;
}
@@ -140,7 +140,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- public void setFieldValue(_Fields field,
@org.apache.thrift.annotation.Nullable java.lang.Object value) {
+ public void setFieldValue(_Fields field,
@org.apache.kyuubi.shaded.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case MESSAGE:
if (value == null) {
@@ -153,7 +153,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case MESSAGE:
@@ -225,7 +225,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return lastComparison;
}
if (isSetMessage()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message,
other.message);
+ lastComparison =
org.apache.kyuubi.shaded.thrift.TBaseHelper.compareTo(this.message,
other.message);
if (lastComparison != 0) {
return lastComparison;
}
@@ -233,16 +233,16 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return 0;
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public _Fields fieldForId(int fieldId) {
return _Fields.findByThriftId(fieldId);
}
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws
org.apache.thrift.TException {
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol iprot)
throws org.apache.kyuubi.shaded.thrift.TException {
scheme(iprot).read(iprot, this);
}
- public void write(org.apache.thrift.protocol.TProtocol oprot) throws
org.apache.thrift.TException {
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol oprot)
throws org.apache.kyuubi.shaded.thrift.TException {
scheme(oprot).write(oprot, this);
}
@@ -262,55 +262,55 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return sb.toString();
}
- public void validate() throws org.apache.thrift.TException {
+ public void validate() throws org.apache.kyuubi.shaded.thrift.TException {
// check for required fields
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws
java.io.IOException {
try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new
org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
+ write(new org.apache.kyuubi.shaded.thrift.protocol.TCompactProtocol(new
org.apache.kyuubi.shaded.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.kyuubi.shaded.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws
java.io.IOException, java.lang.ClassNotFoundException {
try {
- read(new org.apache.thrift.protocol.TCompactProtocol(new
org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
+ read(new org.apache.kyuubi.shaded.thrift.protocol.TCompactProtocol(new
org.apache.kyuubi.shaded.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.kyuubi.shaded.thrift.TException te) {
throw new java.io.IOException(te);
}
}
- private static class MetaExceptionStandardSchemeFactory implements
org.apache.thrift.scheme.SchemeFactory {
+ private static class MetaExceptionStandardSchemeFactory implements
org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory {
public MetaExceptionStandardScheme getScheme() {
return new MetaExceptionStandardScheme();
}
}
- private static class MetaExceptionStandardScheme extends
org.apache.thrift.scheme.StandardScheme<MetaException> {
+ private static class MetaExceptionStandardScheme extends
org.apache.kyuubi.shaded.thrift.scheme.StandardScheme<MetaException> {
- public void read(org.apache.thrift.protocol.TProtocol iprot, MetaException
struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol iprot,
MetaException struct) throws org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ if (schemeField.type ==
org.apache.kyuubi.shaded.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // MESSAGE
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ if (schemeField.type ==
org.apache.kyuubi.shaded.thrift.protocol.TType.STRING) {
struct.message = iprot.readString();
struct.setMessageIsSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+
org.apache.kyuubi.shaded.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
break;
default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+ org.apache.kyuubi.shaded.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
iprot.readFieldEnd();
}
@@ -318,7 +318,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot,
MetaException struct) throws org.apache.thrift.TException {
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
oprot, MetaException struct) throws org.apache.kyuubi.shaded.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -333,17 +333,17 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
- private static class MetaExceptionTupleSchemeFactory implements
org.apache.thrift.scheme.SchemeFactory {
+ private static class MetaExceptionTupleSchemeFactory implements
org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory {
public MetaExceptionTupleScheme getScheme() {
return new MetaExceptionTupleScheme();
}
}
- private static class MetaExceptionTupleScheme extends
org.apache.thrift.scheme.TupleScheme<MetaException> {
+ private static class MetaExceptionTupleScheme extends
org.apache.kyuubi.shaded.thrift.scheme.TupleScheme<MetaException> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot, MetaException
struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol oprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol prot,
MetaException struct) throws org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol oprot =
(org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetMessage()) {
optionals.set(0);
@@ -355,8 +355,8 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot, MetaException
struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol iprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol prot,
MetaException struct) throws org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol iprot =
(org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
struct.message = iprot.readString();
@@ -365,8 +365,8 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- private static <S extends org.apache.thrift.scheme.IScheme> S
scheme(org.apache.thrift.protocol.TProtocol proto) {
- return
(org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ?
STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
+ private static <S extends org.apache.kyuubi.shaded.thrift.scheme.IScheme> S
scheme(org.apache.kyuubi.shaded.thrift.protocol.TProtocol proto) {
+ return
(org.apache.kyuubi.shaded.thrift.scheme.StandardScheme.class.equals(proto.getScheme())
? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}
diff --git
a/kyuubi-relocated-hive-metastore-client/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/ThriftHiveMetastore.java
b/kyuubi-relocated-hive-metastore-client/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/ThriftHiveMetastore.java
index 7d65933..c566f46 100644
---
a/kyuubi-relocated-hive-metastore-client/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/ThriftHiveMetastore.java
+++
b/kyuubi-relocated-hive-metastore-client/src/gen/thrift/gen-javabean/org/apache/kyuubi/shaded/hive/metastore/api/ThriftHiveMetastore.java
@@ -13,45 +13,45 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
/**
* This interface is live.
*/
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public interface
Iface extends com.facebook.fb303.FacebookService.Iface {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public interface
Iface extends org.apache.kyuubi.shaded.fb303.FacebookService.Iface {
- public java.lang.String get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name) throws MetaException,
org.apache.thrift.TException;
+ public java.lang.String get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name) throws MetaException,
org.apache.kyuubi.shaded.thrift.TException;
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public interface
AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public interface
AsyncIface extends org.apache.kyuubi.shaded.fb303.FacebookService .AsyncIface {
- public void get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name,
org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler)
throws org.apache.thrift.TException;
+ public void get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name,
org.apache.kyuubi.shaded.thrift.async.AsyncMethodCallback<java.lang.String>
resultHandler) throws org.apache.kyuubi.shaded.thrift.TException;
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Client extends com.facebook.fb303.FacebookService.Client implements Iface {
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Factory implements org.apache.thrift.TServiceClientFactory<Client> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Client extends org.apache.kyuubi.shaded.fb303.FacebookService.Client implements
Iface {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Factory implements
org.apache.kyuubi.shaded.thrift.TServiceClientFactory<Client> {
public Factory() {}
- public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
+ public Client
getClient(org.apache.kyuubi.shaded.thrift.protocol.TProtocol prot) {
return new Client(prot);
}
- public Client getClient(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot) {
+ public Client
getClient(org.apache.kyuubi.shaded.thrift.protocol.TProtocol iprot,
org.apache.kyuubi.shaded.thrift.protocol.TProtocol oprot) {
return new Client(iprot, oprot);
}
}
- public Client(org.apache.thrift.protocol.TProtocol prot)
+ public Client(org.apache.kyuubi.shaded.thrift.protocol.TProtocol prot)
{
super(prot, prot);
}
- public Client(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot) {
+ public Client(org.apache.kyuubi.shaded.thrift.protocol.TProtocol iprot,
org.apache.kyuubi.shaded.thrift.protocol.TProtocol oprot) {
super(iprot, oprot);
}
- public java.lang.String get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name) throws MetaException,
org.apache.thrift.TException
+ public java.lang.String get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name) throws MetaException,
org.apache.kyuubi.shaded.thrift.TException
{
send_get_delegation_token(token_owner, renewer_kerberos_principal_name);
return recv_get_delegation_token();
}
- public void send_get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name) throws
org.apache.thrift.TException
+ public void send_get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name) throws
org.apache.kyuubi.shaded.thrift.TException
{
get_delegation_token_args args = new get_delegation_token_args();
args.setToken_owner(token_owner);
@@ -59,7 +59,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
sendBase("get_delegation_token", args);
}
- public java.lang.String recv_get_delegation_token() throws MetaException,
org.apache.thrift.TException
+ public java.lang.String recv_get_delegation_token() throws MetaException,
org.apache.kyuubi.shaded.thrift.TException
{
get_delegation_token_result result = new get_delegation_token_result();
receiveBase(result, "get_delegation_token");
@@ -69,45 +69,45 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
if (result.o1 != null) {
throw result.o1;
}
- throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"get_delegation_token failed: unknown result");
+ throw new
org.apache.kyuubi.shaded.thrift.TApplicationException(org.apache.kyuubi.shaded.thrift.TApplicationException.MISSING_RESULT,
"get_delegation_token failed: unknown result");
}
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
AsyncClient extends com.facebook.fb303.FacebookService.AsyncClient implements
AsyncIface {
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
- private org.apache.thrift.async.TAsyncClientManager clientManager;
- private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
- public Factory(org.apache.thrift.async.TAsyncClientManager
clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
AsyncClient extends org.apache.kyuubi.shaded.fb303.FacebookService.AsyncClient
implements AsyncIface {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Factory implements
org.apache.kyuubi.shaded.thrift.async.TAsyncClientFactory<AsyncClient> {
+ private org.apache.kyuubi.shaded.thrift.async.TAsyncClientManager
clientManager;
+ private org.apache.kyuubi.shaded.thrift.protocol.TProtocolFactory
protocolFactory;
+ public Factory(org.apache.kyuubi.shaded.thrift.async.TAsyncClientManager
clientManager, org.apache.kyuubi.shaded.thrift.protocol.TProtocolFactory
protocolFactory) {
this.clientManager = clientManager;
this.protocolFactory = protocolFactory;
}
- public AsyncClient
getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
+ public AsyncClient
getAsyncClient(org.apache.kyuubi.shaded.thrift.transport.TNonblockingTransport
transport) {
return new AsyncClient(protocolFactory, clientManager, transport);
}
}
- public AsyncClient(org.apache.thrift.protocol.TProtocolFactory
protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager,
org.apache.thrift.transport.TNonblockingTransport transport) {
+ public
AsyncClient(org.apache.kyuubi.shaded.thrift.protocol.TProtocolFactory
protocolFactory, org.apache.kyuubi.shaded.thrift.async.TAsyncClientManager
clientManager, org.apache.kyuubi.shaded.thrift.transport.TNonblockingTransport
transport) {
super(protocolFactory, clientManager, transport);
}
- public void get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name,
org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler)
throws org.apache.thrift.TException {
+ public void get_delegation_token(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name,
org.apache.kyuubi.shaded.thrift.async.AsyncMethodCallback<java.lang.String>
resultHandler) throws org.apache.kyuubi.shaded.thrift.TException {
checkReady();
get_delegation_token_call method_call = new
get_delegation_token_call(token_owner, renewer_kerberos_principal_name,
resultHandler, this, ___protocolFactory, ___transport);
this.___currentMethod = method_call;
___manager.call(method_call);
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token_call extends
org.apache.thrift.async.TAsyncMethodCall<java.lang.String> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token_call extends
org.apache.kyuubi.shaded.thrift.async.TAsyncMethodCall<java.lang.String> {
private java.lang.String token_owner;
private java.lang.String renewer_kerberos_principal_name;
- public get_delegation_token_call(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name,
org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) throws
org.apache.thrift.TException {
+ public get_delegation_token_call(java.lang.String token_owner,
java.lang.String renewer_kerberos_principal_name,
org.apache.kyuubi.shaded.thrift.async.AsyncMethodCallback<java.lang.String>
resultHandler, org.apache.kyuubi.shaded.thrift.async.TAsyncClient client,
org.apache.kyuubi.shaded.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.kyuubi.shaded.thrift.transport.TNonblockingTransport transport)
throws org.apache.kyuubi.shaded.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.token_owner = token_owner;
this.renewer_kerberos_principal_name = renewer_kerberos_principal_name;
}
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws
org.apache.thrift.TException {
- prot.writeMessageBegin(new
org.apache.thrift.protocol.TMessage("get_delegation_token",
org.apache.thrift.protocol.TMessageType.CALL, 0));
+ public void
write_args(org.apache.kyuubi.shaded.thrift.protocol.TProtocol prot) throws
org.apache.kyuubi.shaded.thrift.TException {
+ prot.writeMessageBegin(new
org.apache.kyuubi.shaded.thrift.protocol.TMessage("get_delegation_token",
org.apache.kyuubi.shaded.thrift.protocol.TMessageType.CALL, 0));
get_delegation_token_args args = new get_delegation_token_args();
args.setToken_owner(token_owner);
args.setRenewer_kerberos_principal_name(renewer_kerberos_principal_name);
@@ -115,34 +115,34 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
prot.writeMessageEnd();
}
- public java.lang.String getResult() throws MetaException,
org.apache.thrift.TException {
- if (getState() !=
org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
+ public java.lang.String getResult() throws MetaException,
org.apache.kyuubi.shaded.thrift.TException {
+ if (getState() !=
org.apache.kyuubi.shaded.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new java.lang.IllegalStateException("Method call not
finished!");
}
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport =
new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot =
client.getProtocolFactory().getProtocol(memoryTransport);
+ org.apache.kyuubi.shaded.thrift.transport.TMemoryInputTransport
memoryTransport = new
org.apache.kyuubi.shaded.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
+ org.apache.kyuubi.shaded.thrift.protocol.TProtocol prot =
client.getProtocolFactory().getProtocol(memoryTransport);
return (new Client(prot)).recv_get_delegation_token();
}
}
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Processor<I extends Iface> extends
com.facebook.fb303.FacebookService.Processor<I> implements
org.apache.thrift.TProcessor {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Processor<I extends Iface> extends
org.apache.kyuubi.shaded.fb303.FacebookService.Processor<I> implements
org.apache.kyuubi.shaded.thrift.TProcessor {
private static final org.slf4j.Logger _LOGGER =
org.slf4j.LoggerFactory.getLogger(Processor.class.getName());
public Processor(I iface) {
- super(iface, getProcessMap(new java.util.HashMap<java.lang.String,
org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
+ super(iface, getProcessMap(new java.util.HashMap<java.lang.String,
org.apache.kyuubi.shaded.thrift.ProcessFunction<I, ? extends
org.apache.kyuubi.shaded.thrift.TBase>>()));
}
- protected Processor(I iface, java.util.Map<java.lang.String,
org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>
processMap) {
+ protected Processor(I iface, java.util.Map<java.lang.String,
org.apache.kyuubi.shaded.thrift.ProcessFunction<I, ? extends
org.apache.kyuubi.shaded.thrift.TBase>> processMap) {
super(iface, getProcessMap(processMap));
}
- private static <I extends Iface> java.util.Map<java.lang.String,
org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>
getProcessMap(java.util.Map<java.lang.String,
org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>
processMap) {
+ private static <I extends Iface> java.util.Map<java.lang.String,
org.apache.kyuubi.shaded.thrift.ProcessFunction<I, ? extends
org.apache.kyuubi.shaded.thrift.TBase>>
getProcessMap(java.util.Map<java.lang.String,
org.apache.kyuubi.shaded.thrift.ProcessFunction<I, ? extends
org.apache.kyuubi.shaded.thrift.TBase>> processMap) {
processMap.put("get_delegation_token", new get_delegation_token());
return processMap;
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token<I extends Iface> extends
org.apache.thrift.ProcessFunction<I, get_delegation_token_args> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token<I extends Iface> extends
org.apache.kyuubi.shaded.thrift.ProcessFunction<I, get_delegation_token_args> {
public get_delegation_token() {
super("get_delegation_token");
}
@@ -160,7 +160,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return false;
}
- public get_delegation_token_result getResult(I iface,
get_delegation_token_args args) throws org.apache.thrift.TException {
+ public get_delegation_token_result getResult(I iface,
get_delegation_token_args args) throws
org.apache.kyuubi.shaded.thrift.TException {
get_delegation_token_result result = new get_delegation_token_result();
try {
result.success = iface.get_delegation_token(args.token_owner,
args.renewer_kerberos_principal_name);
@@ -173,22 +173,22 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
AsyncProcessor<I extends AsyncIface> extends
com.facebook.fb303.FacebookService.AsyncProcessor<I> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
AsyncProcessor<I extends AsyncIface> extends
org.apache.kyuubi.shaded.fb303.FacebookService.AsyncProcessor<I> {
private static final org.slf4j.Logger _LOGGER =
org.slf4j.LoggerFactory.getLogger(AsyncProcessor.class.getName());
public AsyncProcessor(I iface) {
- super(iface, getProcessMap(new java.util.HashMap<java.lang.String,
org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,
?>>()));
+ super(iface, getProcessMap(new java.util.HashMap<java.lang.String,
org.apache.kyuubi.shaded.thrift.AsyncProcessFunction<I, ? extends
org.apache.kyuubi.shaded.thrift.TBase, ?>>()));
}
- protected AsyncProcessor(I iface, java.util.Map<java.lang.String,
org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,
?>> processMap) {
+ protected AsyncProcessor(I iface, java.util.Map<java.lang.String,
org.apache.kyuubi.shaded.thrift.AsyncProcessFunction<I, ? extends
org.apache.kyuubi.shaded.thrift.TBase, ?>> processMap) {
super(iface, getProcessMap(processMap));
}
- private static <I extends AsyncIface> java.util.Map<java.lang.String,
org.apache.thrift.AsyncProcessFunction<I, ? extends
org.apache.thrift.TBase,?>> getProcessMap(java.util.Map<java.lang.String,
org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,
?>> processMap) {
+ private static <I extends AsyncIface> java.util.Map<java.lang.String,
org.apache.kyuubi.shaded.thrift.AsyncProcessFunction<I, ? extends
org.apache.kyuubi.shaded.thrift.TBase,?>>
getProcessMap(java.util.Map<java.lang.String,
org.apache.kyuubi.shaded.thrift.AsyncProcessFunction<I, ? extends
org.apache.kyuubi.shaded.thrift.TBase, ?>> processMap) {
processMap.put("get_delegation_token", new get_delegation_token());
return processMap;
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token<I extends AsyncIface> extends
org.apache.thrift.AsyncProcessFunction<I, get_delegation_token_args,
java.lang.String> {
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token<I extends AsyncIface> extends
org.apache.kyuubi.shaded.thrift.AsyncProcessFunction<I,
get_delegation_token_args, java.lang.String> {
public get_delegation_token() {
super("get_delegation_token");
}
@@ -197,15 +197,15 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return new get_delegation_token_args();
}
- public org.apache.thrift.async.AsyncMethodCallback<java.lang.String>
getResultHandler(final
org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final
int seqid) {
- final org.apache.thrift.AsyncProcessFunction fcall = this;
- return new
org.apache.thrift.async.AsyncMethodCallback<java.lang.String>() {
+ public
org.apache.kyuubi.shaded.thrift.async.AsyncMethodCallback<java.lang.String>
getResultHandler(final
org.apache.kyuubi.shaded.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer
fb, final int seqid) {
+ final org.apache.kyuubi.shaded.thrift.AsyncProcessFunction fcall =
this;
+ return new
org.apache.kyuubi.shaded.thrift.async.AsyncMethodCallback<java.lang.String>() {
public void onComplete(java.lang.String o) {
get_delegation_token_result result = new
get_delegation_token_result();
result.success = o;
try {
- fcall.sendResponse(fb, result,
org.apache.thrift.protocol.TMessageType.REPLY,seqid);
- } catch (org.apache.thrift.transport.TTransportException e) {
+ fcall.sendResponse(fb, result,
org.apache.kyuubi.shaded.thrift.protocol.TMessageType.REPLY,seqid);
+ } catch
(org.apache.kyuubi.shaded.thrift.transport.TTransportException e) {
_LOGGER.error("TTransportException writing to internal frame
buffer", e);
fb.close();
} catch (java.lang.Exception e) {
@@ -214,25 +214,25 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
public void onError(java.lang.Exception e) {
- byte msgType = org.apache.thrift.protocol.TMessageType.REPLY;
- org.apache.thrift.TSerializable msg;
+ byte msgType =
org.apache.kyuubi.shaded.thrift.protocol.TMessageType.REPLY;
+ org.apache.kyuubi.shaded.thrift.TSerializable msg;
get_delegation_token_result result = new
get_delegation_token_result();
if (e instanceof MetaException) {
result.o1 = (MetaException) e;
result.setO1IsSet(true);
msg = result;
- } else if (e instanceof
org.apache.thrift.transport.TTransportException) {
+ } else if (e instanceof
org.apache.kyuubi.shaded.thrift.transport.TTransportException) {
_LOGGER.error("TTransportException inside handler", e);
fb.close();
return;
- } else if (e instanceof org.apache.thrift.TApplicationException) {
+ } else if (e instanceof
org.apache.kyuubi.shaded.thrift.TApplicationException) {
_LOGGER.error("TApplicationException inside handler", e);
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = (org.apache.thrift.TApplicationException)e;
+ msgType =
org.apache.kyuubi.shaded.thrift.protocol.TMessageType.EXCEPTION;
+ msg = (org.apache.kyuubi.shaded.thrift.TApplicationException)e;
} else {
_LOGGER.error("Exception inside handler", e);
- msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION;
- msg = new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,
e.getMessage());
+ msgType =
org.apache.kyuubi.shaded.thrift.protocol.TMessageType.EXCEPTION;
+ msg = new
org.apache.kyuubi.shaded.thrift.TApplicationException(org.apache.kyuubi.shaded.thrift.TApplicationException.INTERNAL_ERROR,
e.getMessage());
}
try {
fcall.sendResponse(fb,msg,msgType,seqid);
@@ -248,27 +248,27 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return false;
}
- public void start(I iface, get_delegation_token_args args,
org.apache.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler)
throws org.apache.thrift.TException {
+ public void start(I iface, get_delegation_token_args args,
org.apache.kyuubi.shaded.thrift.async.AsyncMethodCallback<java.lang.String>
resultHandler) throws org.apache.kyuubi.shaded.thrift.TException {
iface.get_delegation_token(args.token_owner,
args.renewer_kerberos_principal_name,resultHandler);
}
}
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token_args implements
org.apache.thrift.TBase<get_delegation_token_args,
get_delegation_token_args._Fields>, java.io.Serializable, Cloneable,
Comparable<get_delegation_token_args> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("get_delegation_token_args");
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token_args implements
org.apache.kyuubi.shaded.thrift.TBase<get_delegation_token_args,
get_delegation_token_args._Fields>, java.io.Serializable, Cloneable,
Comparable<get_delegation_token_args> {
+ private static final org.apache.kyuubi.shaded.thrift.protocol.TStruct
STRUCT_DESC = new
org.apache.kyuubi.shaded.thrift.protocol.TStruct("get_delegation_token_args");
- private static final org.apache.thrift.protocol.TField
TOKEN_OWNER_FIELD_DESC = new org.apache.thrift.protocol.TField("token_owner",
org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField
RENEWER_KERBEROS_PRINCIPAL_NAME_FIELD_DESC = new
org.apache.thrift.protocol.TField("renewer_kerberos_principal_name",
org.apache.thrift.protocol.TType.STRING, (short)2);
+ private static final org.apache.kyuubi.shaded.thrift.protocol.TField
TOKEN_OWNER_FIELD_DESC = new
org.apache.kyuubi.shaded.thrift.protocol.TField("token_owner",
org.apache.kyuubi.shaded.thrift.protocol.TType.STRING, (short)1);
+ private static final org.apache.kyuubi.shaded.thrift.protocol.TField
RENEWER_KERBEROS_PRINCIPAL_NAME_FIELD_DESC = new
org.apache.kyuubi.shaded.thrift.protocol.TField("renewer_kerberos_principal_name",
org.apache.kyuubi.shaded.thrift.protocol.TType.STRING, (short)2);
- private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new get_delegation_token_argsStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new get_delegation_token_argsTupleSchemeFactory();
+ private static final org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new get_delegation_token_argsStandardSchemeFactory();
+ private static final org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new get_delegation_token_argsTupleSchemeFactory();
- private @org.apache.thrift.annotation.Nullable java.lang.String
token_owner; // required
- private @org.apache.thrift.annotation.Nullable java.lang.String
renewer_kerberos_principal_name; // required
+ private @org.apache.kyuubi.shaded.thrift.annotation.Nullable
java.lang.String token_owner; // required
+ private @org.apache.kyuubi.shaded.thrift.annotation.Nullable
java.lang.String renewer_kerberos_principal_name; // required
/** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ public enum _Fields implements
org.apache.kyuubi.shaded.thrift.TFieldIdEnum {
TOKEN_OWNER((short)1, "token_owner"),
RENEWER_KERBEROS_PRINCIPAL_NAME((short)2,
"renewer_kerberos_principal_name");
@@ -283,7 +283,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
/**
* Find the _Fields constant that matches fieldId, or null if its not
found.
*/
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
case 1: // TOKEN_OWNER
@@ -308,7 +308,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
@@ -331,15 +331,15 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
// isset id assignments
- public static final java.util.Map<_Fields,
org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap
= new java.util.EnumMap<_Fields,
org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.TOKEN_OWNER, new
org.apache.thrift.meta_data.FieldMetaData("token_owner",
org.apache.thrift.TFieldRequirementType.DEFAULT,
- new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.RENEWER_KERBEROS_PRINCIPAL_NAME, new
org.apache.thrift.meta_data.FieldMetaData("renewer_kerberos_principal_name",
org.apache.thrift.TFieldRequirementType.DEFAULT,
- new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ java.util.Map<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData> tmpMap = new
java.util.EnumMap<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.TOKEN_OWNER, new
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData("token_owner",
org.apache.kyuubi.shaded.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.kyuubi.shaded.thrift.meta_data.FieldValueMetaData(org.apache.kyuubi.shaded.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.RENEWER_KERBEROS_PRINCIPAL_NAME, new
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData("renewer_kerberos_principal_name",
org.apache.kyuubi.shaded.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.kyuubi.shaded.thrift.meta_data.FieldValueMetaData(org.apache.kyuubi.shaded.thrift.protocol.TType.STRING)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
-
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_delegation_token_args.class,
metaDataMap);
+
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_delegation_token_args.class,
metaDataMap);
}
public get_delegation_token_args() {
@@ -376,12 +376,12 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
this.renewer_kerberos_principal_name = null;
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public java.lang.String getToken_owner() {
return this.token_owner;
}
- public void setToken_owner(@org.apache.thrift.annotation.Nullable
java.lang.String token_owner) {
+ public void
setToken_owner(@org.apache.kyuubi.shaded.thrift.annotation.Nullable
java.lang.String token_owner) {
this.token_owner = token_owner;
}
@@ -400,12 +400,12 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public java.lang.String getRenewer_kerberos_principal_name() {
return this.renewer_kerberos_principal_name;
}
- public void
setRenewer_kerberos_principal_name(@org.apache.thrift.annotation.Nullable
java.lang.String renewer_kerberos_principal_name) {
+ public void
setRenewer_kerberos_principal_name(@org.apache.kyuubi.shaded.thrift.annotation.Nullable
java.lang.String renewer_kerberos_principal_name) {
this.renewer_kerberos_principal_name = renewer_kerberos_principal_name;
}
@@ -424,7 +424,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- public void setFieldValue(_Fields field,
@org.apache.thrift.annotation.Nullable java.lang.Object value) {
+ public void setFieldValue(_Fields field,
@org.apache.kyuubi.shaded.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case TOKEN_OWNER:
if (value == null) {
@@ -445,7 +445,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case TOKEN_OWNER:
@@ -535,7 +535,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return lastComparison;
}
if (isSetToken_owner()) {
- lastComparison =
org.apache.thrift.TBaseHelper.compareTo(this.token_owner, other.token_owner);
+ lastComparison =
org.apache.kyuubi.shaded.thrift.TBaseHelper.compareTo(this.token_owner,
other.token_owner);
if (lastComparison != 0) {
return lastComparison;
}
@@ -545,7 +545,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return lastComparison;
}
if (isSetRenewer_kerberos_principal_name()) {
- lastComparison =
org.apache.thrift.TBaseHelper.compareTo(this.renewer_kerberos_principal_name,
other.renewer_kerberos_principal_name);
+ lastComparison =
org.apache.kyuubi.shaded.thrift.TBaseHelper.compareTo(this.renewer_kerberos_principal_name,
other.renewer_kerberos_principal_name);
if (lastComparison != 0) {
return lastComparison;
}
@@ -553,16 +553,16 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return 0;
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public _Fields fieldForId(int fieldId) {
return _Fields.findByThriftId(fieldId);
}
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws
org.apache.thrift.TException {
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol iprot)
throws org.apache.kyuubi.shaded.thrift.TException {
scheme(iprot).read(iprot, this);
}
- public void write(org.apache.thrift.protocol.TProtocol oprot) throws
org.apache.thrift.TException {
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
oprot) throws org.apache.kyuubi.shaded.thrift.TException {
scheme(oprot).write(oprot, this);
}
@@ -590,63 +590,63 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return sb.toString();
}
- public void validate() throws org.apache.thrift.TException {
+ public void validate() throws org.apache.kyuubi.shaded.thrift.TException {
// check for required fields
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws
java.io.IOException {
try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new
org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
+ write(new
org.apache.kyuubi.shaded.thrift.protocol.TCompactProtocol(new
org.apache.kyuubi.shaded.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.kyuubi.shaded.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws
java.io.IOException, java.lang.ClassNotFoundException {
try {
- read(new org.apache.thrift.protocol.TCompactProtocol(new
org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
+ read(new org.apache.kyuubi.shaded.thrift.protocol.TCompactProtocol(new
org.apache.kyuubi.shaded.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.kyuubi.shaded.thrift.TException te) {
throw new java.io.IOException(te);
}
}
- private static class get_delegation_token_argsStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ private static class get_delegation_token_argsStandardSchemeFactory
implements org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory {
public get_delegation_token_argsStandardScheme getScheme() {
return new get_delegation_token_argsStandardScheme();
}
}
- private static class get_delegation_token_argsStandardScheme extends
org.apache.thrift.scheme.StandardScheme<get_delegation_token_args> {
+ private static class get_delegation_token_argsStandardScheme extends
org.apache.kyuubi.shaded.thrift.scheme.StandardScheme<get_delegation_token_args>
{
- public void read(org.apache.thrift.protocol.TProtocol iprot,
get_delegation_token_args struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
iprot, get_delegation_token_args struct) throws
org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ if (schemeField.type ==
org.apache.kyuubi.shaded.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 1: // TOKEN_OWNER
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING)
{
+ if (schemeField.type ==
org.apache.kyuubi.shaded.thrift.protocol.TType.STRING) {
struct.token_owner = iprot.readString();
struct.setToken_ownerIsSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+
org.apache.kyuubi.shaded.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
break;
case 2: // RENEWER_KERBEROS_PRINCIPAL_NAME
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING)
{
+ if (schemeField.type ==
org.apache.kyuubi.shaded.thrift.protocol.TType.STRING) {
struct.renewer_kerberos_principal_name = iprot.readString();
struct.setRenewer_kerberos_principal_nameIsSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+
org.apache.kyuubi.shaded.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
break;
default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+
org.apache.kyuubi.shaded.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
iprot.readFieldEnd();
}
@@ -654,7 +654,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot,
get_delegation_token_args struct) throws org.apache.thrift.TException {
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
oprot, get_delegation_token_args struct) throws
org.apache.kyuubi.shaded.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -674,17 +674,17 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
- private static class get_delegation_token_argsTupleSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ private static class get_delegation_token_argsTupleSchemeFactory
implements org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory {
public get_delegation_token_argsTupleScheme getScheme() {
return new get_delegation_token_argsTupleScheme();
}
}
- private static class get_delegation_token_argsTupleScheme extends
org.apache.thrift.scheme.TupleScheme<get_delegation_token_args> {
+ private static class get_delegation_token_argsTupleScheme extends
org.apache.kyuubi.shaded.thrift.scheme.TupleScheme<get_delegation_token_args> {
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot,
get_delegation_token_args struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol oprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
prot, get_delegation_token_args struct) throws
org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol oprot =
(org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetToken_owner()) {
optionals.set(0);
@@ -702,8 +702,8 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot,
get_delegation_token_args struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol iprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
prot, get_delegation_token_args struct) throws
org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol iprot =
(org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.token_owner = iprot.readString();
@@ -716,25 +716,25 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- private static <S extends org.apache.thrift.scheme.IScheme> S
scheme(org.apache.thrift.protocol.TProtocol proto) {
- return
(org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ?
STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
+ private static <S extends org.apache.kyuubi.shaded.thrift.scheme.IScheme>
S scheme(org.apache.kyuubi.shaded.thrift.protocol.TProtocol proto) {
+ return
(org.apache.kyuubi.shaded.thrift.scheme.StandardScheme.class.equals(proto.getScheme())
? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}
- @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token_result implements
org.apache.thrift.TBase<get_delegation_token_result,
get_delegation_token_result._Fields>, java.io.Serializable, Cloneable,
Comparable<get_delegation_token_result> {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new
org.apache.thrift.protocol.TStruct("get_delegation_token_result");
+ @org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
get_delegation_token_result implements
org.apache.kyuubi.shaded.thrift.TBase<get_delegation_token_result,
get_delegation_token_result._Fields>, java.io.Serializable, Cloneable,
Comparable<get_delegation_token_result> {
+ private static final org.apache.kyuubi.shaded.thrift.protocol.TStruct
STRUCT_DESC = new
org.apache.kyuubi.shaded.thrift.protocol.TStruct("get_delegation_token_result");
- private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC
= new org.apache.thrift.protocol.TField("success",
org.apache.thrift.protocol.TType.STRING, (short)0);
- private static final org.apache.thrift.protocol.TField O1_FIELD_DESC = new
org.apache.thrift.protocol.TField("o1",
org.apache.thrift.protocol.TType.STRUCT, (short)1);
+ private static final org.apache.kyuubi.shaded.thrift.protocol.TField
SUCCESS_FIELD_DESC = new
org.apache.kyuubi.shaded.thrift.protocol.TField("success",
org.apache.kyuubi.shaded.thrift.protocol.TType.STRING, (short)0);
+ private static final org.apache.kyuubi.shaded.thrift.protocol.TField
O1_FIELD_DESC = new org.apache.kyuubi.shaded.thrift.protocol.TField("o1",
org.apache.kyuubi.shaded.thrift.protocol.TType.STRUCT, (short)1);
- private static final org.apache.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new
get_delegation_token_resultStandardSchemeFactory();
- private static final org.apache.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new get_delegation_token_resultTupleSchemeFactory();
+ private static final org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory
STANDARD_SCHEME_FACTORY = new
get_delegation_token_resultStandardSchemeFactory();
+ private static final org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory
TUPLE_SCHEME_FACTORY = new get_delegation_token_resultTupleSchemeFactory();
- private @org.apache.thrift.annotation.Nullable java.lang.String success;
// required
- private @org.apache.thrift.annotation.Nullable MetaException o1; //
required
+ private @org.apache.kyuubi.shaded.thrift.annotation.Nullable
java.lang.String success; // required
+ private @org.apache.kyuubi.shaded.thrift.annotation.Nullable MetaException
o1; // required
/** The set of fields this struct contains, along with convenience methods
for finding and manipulating them. */
- public enum _Fields implements org.apache.thrift.TFieldIdEnum {
+ public enum _Fields implements
org.apache.kyuubi.shaded.thrift.TFieldIdEnum {
SUCCESS((short)0, "success"),
O1((short)1, "o1");
@@ -749,7 +749,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
/**
* Find the _Fields constant that matches fieldId, or null if its not
found.
*/
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public static _Fields findByThriftId(int fieldId) {
switch(fieldId) {
case 0: // SUCCESS
@@ -774,7 +774,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
/**
* Find the _Fields constant that matches name, or null if its not found.
*/
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public static _Fields findByName(java.lang.String name) {
return byName.get(name);
}
@@ -797,15 +797,15 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
// isset id assignments
- public static final java.util.Map<_Fields,
org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
+ public static final java.util.Map<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData> metaDataMap;
static {
- java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap
= new java.util.EnumMap<_Fields,
org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
- tmpMap.put(_Fields.SUCCESS, new
org.apache.thrift.meta_data.FieldMetaData("success",
org.apache.thrift.TFieldRequirementType.DEFAULT,
- new
org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.O1, new
org.apache.thrift.meta_data.FieldMetaData("o1",
org.apache.thrift.TFieldRequirementType.DEFAULT,
- new
org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT,
MetaException.class)));
+ java.util.Map<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData> tmpMap = new
java.util.EnumMap<_Fields,
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData>(_Fields.class);
+ tmpMap.put(_Fields.SUCCESS, new
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData("success",
org.apache.kyuubi.shaded.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.kyuubi.shaded.thrift.meta_data.FieldValueMetaData(org.apache.kyuubi.shaded.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.O1, new
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData("o1",
org.apache.kyuubi.shaded.thrift.TFieldRequirementType.DEFAULT,
+ new
org.apache.kyuubi.shaded.thrift.meta_data.StructMetaData(org.apache.kyuubi.shaded.thrift.protocol.TType.STRUCT,
MetaException.class)));
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
-
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_delegation_token_result.class,
metaDataMap);
+
org.apache.kyuubi.shaded.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_delegation_token_result.class,
metaDataMap);
}
public get_delegation_token_result() {
@@ -842,12 +842,12 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
this.o1 = null;
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public java.lang.String getSuccess() {
return this.success;
}
- public void setSuccess(@org.apache.thrift.annotation.Nullable
java.lang.String success) {
+ public void
setSuccess(@org.apache.kyuubi.shaded.thrift.annotation.Nullable
java.lang.String success) {
this.success = success;
}
@@ -866,12 +866,12 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public MetaException getO1() {
return this.o1;
}
- public void setO1(@org.apache.thrift.annotation.Nullable MetaException o1)
{
+ public void setO1(@org.apache.kyuubi.shaded.thrift.annotation.Nullable
MetaException o1) {
this.o1 = o1;
}
@@ -890,7 +890,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- public void setFieldValue(_Fields field,
@org.apache.thrift.annotation.Nullable java.lang.Object value) {
+ public void setFieldValue(_Fields field,
@org.apache.kyuubi.shaded.thrift.annotation.Nullable java.lang.Object value) {
switch (field) {
case SUCCESS:
if (value == null) {
@@ -911,7 +911,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public java.lang.Object getFieldValue(_Fields field) {
switch (field) {
case SUCCESS:
@@ -1001,7 +1001,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return lastComparison;
}
if (isSetSuccess()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success,
other.success);
+ lastComparison =
org.apache.kyuubi.shaded.thrift.TBaseHelper.compareTo(this.success,
other.success);
if (lastComparison != 0) {
return lastComparison;
}
@@ -1011,7 +1011,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return lastComparison;
}
if (isSetO1()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.o1,
other.o1);
+ lastComparison =
org.apache.kyuubi.shaded.thrift.TBaseHelper.compareTo(this.o1, other.o1);
if (lastComparison != 0) {
return lastComparison;
}
@@ -1019,16 +1019,16 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return 0;
}
- @org.apache.thrift.annotation.Nullable
+ @org.apache.kyuubi.shaded.thrift.annotation.Nullable
public _Fields fieldForId(int fieldId) {
return _Fields.findByThriftId(fieldId);
}
- public void read(org.apache.thrift.protocol.TProtocol iprot) throws
org.apache.thrift.TException {
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol iprot)
throws org.apache.kyuubi.shaded.thrift.TException {
scheme(iprot).read(iprot, this);
}
- public void write(org.apache.thrift.protocol.TProtocol oprot) throws
org.apache.thrift.TException {
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
oprot) throws org.apache.kyuubi.shaded.thrift.TException {
scheme(oprot).write(oprot, this);
}
@@ -1056,64 +1056,64 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
return sb.toString();
}
- public void validate() throws org.apache.thrift.TException {
+ public void validate() throws org.apache.kyuubi.shaded.thrift.TException {
// check for required fields
// check for sub-struct validity
}
private void writeObject(java.io.ObjectOutputStream out) throws
java.io.IOException {
try {
- write(new org.apache.thrift.protocol.TCompactProtocol(new
org.apache.thrift.transport.TIOStreamTransport(out)));
- } catch (org.apache.thrift.TException te) {
+ write(new
org.apache.kyuubi.shaded.thrift.protocol.TCompactProtocol(new
org.apache.kyuubi.shaded.thrift.transport.TIOStreamTransport(out)));
+ } catch (org.apache.kyuubi.shaded.thrift.TException te) {
throw new java.io.IOException(te);
}
}
private void readObject(java.io.ObjectInputStream in) throws
java.io.IOException, java.lang.ClassNotFoundException {
try {
- read(new org.apache.thrift.protocol.TCompactProtocol(new
org.apache.thrift.transport.TIOStreamTransport(in)));
- } catch (org.apache.thrift.TException te) {
+ read(new org.apache.kyuubi.shaded.thrift.protocol.TCompactProtocol(new
org.apache.kyuubi.shaded.thrift.transport.TIOStreamTransport(in)));
+ } catch (org.apache.kyuubi.shaded.thrift.TException te) {
throw new java.io.IOException(te);
}
}
- private static class get_delegation_token_resultStandardSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ private static class get_delegation_token_resultStandardSchemeFactory
implements org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory {
public get_delegation_token_resultStandardScheme getScheme() {
return new get_delegation_token_resultStandardScheme();
}
}
- private static class get_delegation_token_resultStandardScheme extends
org.apache.thrift.scheme.StandardScheme<get_delegation_token_result> {
+ private static class get_delegation_token_resultStandardScheme extends
org.apache.kyuubi.shaded.thrift.scheme.StandardScheme<get_delegation_token_result>
{
- public void read(org.apache.thrift.protocol.TProtocol iprot,
get_delegation_token_result struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TField schemeField;
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
iprot, get_delegation_token_result struct) throws
org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TField schemeField;
iprot.readStructBegin();
while (true)
{
schemeField = iprot.readFieldBegin();
- if (schemeField.type == org.apache.thrift.protocol.TType.STOP) {
+ if (schemeField.type ==
org.apache.kyuubi.shaded.thrift.protocol.TType.STOP) {
break;
}
switch (schemeField.id) {
case 0: // SUCCESS
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING)
{
+ if (schemeField.type ==
org.apache.kyuubi.shaded.thrift.protocol.TType.STRING) {
struct.success = iprot.readString();
struct.setSuccessIsSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+
org.apache.kyuubi.shaded.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
break;
case 1: // O1
- if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT)
{
+ if (schemeField.type ==
org.apache.kyuubi.shaded.thrift.protocol.TType.STRUCT) {
struct.o1 = new MetaException();
struct.o1.read(iprot);
struct.setO1IsSet(true);
} else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+
org.apache.kyuubi.shaded.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
break;
default:
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
+
org.apache.kyuubi.shaded.thrift.protocol.TProtocolUtil.skip(iprot,
schemeField.type);
}
iprot.readFieldEnd();
}
@@ -1121,7 +1121,7 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
struct.validate();
}
- public void write(org.apache.thrift.protocol.TProtocol oprot,
get_delegation_token_result struct) throws org.apache.thrift.TException {
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
oprot, get_delegation_token_result struct) throws
org.apache.kyuubi.shaded.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
@@ -1141,17 +1141,17 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
- private static class get_delegation_token_resultTupleSchemeFactory
implements org.apache.thrift.scheme.SchemeFactory {
+ private static class get_delegation_token_resultTupleSchemeFactory
implements org.apache.kyuubi.shaded.thrift.scheme.SchemeFactory {
public get_delegation_token_resultTupleScheme getScheme() {
return new get_delegation_token_resultTupleScheme();
}
}
- private static class get_delegation_token_resultTupleScheme extends
org.apache.thrift.scheme.TupleScheme<get_delegation_token_result> {
+ private static class get_delegation_token_resultTupleScheme extends
org.apache.kyuubi.shaded.thrift.scheme.TupleScheme<get_delegation_token_result>
{
@Override
- public void write(org.apache.thrift.protocol.TProtocol prot,
get_delegation_token_result struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol oprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void write(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
prot, get_delegation_token_result struct) throws
org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol oprot =
(org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetSuccess()) {
optionals.set(0);
@@ -1169,8 +1169,8 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
@Override
- public void read(org.apache.thrift.protocol.TProtocol prot,
get_delegation_token_result struct) throws org.apache.thrift.TException {
- org.apache.thrift.protocol.TTupleProtocol iprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
+ public void read(org.apache.kyuubi.shaded.thrift.protocol.TProtocol
prot, get_delegation_token_result struct) throws
org.apache.kyuubi.shaded.thrift.TException {
+ org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol iprot =
(org.apache.kyuubi.shaded.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet incoming = iprot.readBitSet(2);
if (incoming.get(0)) {
struct.success = iprot.readString();
@@ -1184,8 +1184,8 @@ package org.apache.kyuubi.shaded.hive.metastore.api;
}
}
- private static <S extends org.apache.thrift.scheme.IScheme> S
scheme(org.apache.thrift.protocol.TProtocol proto) {
- return
(org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ?
STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
+ private static <S extends org.apache.kyuubi.shaded.thrift.scheme.IScheme>
S scheme(org.apache.kyuubi.shaded.thrift.protocol.TProtocol proto) {
+ return
(org.apache.kyuubi.shaded.thrift.scheme.StandardScheme.class.equals(proto.getScheme())
? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
}
}
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/HiveMetaStoreClient.java
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/HiveMetaStoreClient.java
index c9e61fc..0bc155b 100644
---
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/HiveMetaStoreClient.java
+++
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/HiveMetaStoreClient.java
@@ -51,16 +51,16 @@ import
org.apache.kyuubi.shaded.hive.metastore.security.HadoopThriftAuthBridge;
import org.apache.kyuubi.shaded.hive.metastore.utils.JavaUtils;
import org.apache.kyuubi.shaded.hive.metastore.utils.MetaStoreUtils;
import org.apache.kyuubi.shaded.hive.metastore.utils.SecurityUtils;
-import org.apache.thrift.TConfiguration;
-import org.apache.thrift.TException;
-import org.apache.thrift.protocol.TBinaryProtocol;
-import org.apache.thrift.protocol.TCompactProtocol;
-import org.apache.thrift.protocol.TProtocol;
-import org.apache.thrift.transport.THttpClient;
-import org.apache.thrift.transport.TSocket;
-import org.apache.thrift.transport.TTransport;
-import org.apache.thrift.transport.TTransportException;
-import org.apache.thrift.transport.layered.TFramedTransport;
+import org.apache.kyuubi.shaded.thrift.TConfiguration;
+import org.apache.kyuubi.shaded.thrift.TException;
+import org.apache.kyuubi.shaded.thrift.protocol.TBinaryProtocol;
+import org.apache.kyuubi.shaded.thrift.protocol.TCompactProtocol;
+import org.apache.kyuubi.shaded.thrift.protocol.TProtocol;
+import org.apache.kyuubi.shaded.thrift.transport.THttpClient;
+import org.apache.kyuubi.shaded.thrift.transport.TSocket;
+import org.apache.kyuubi.shaded.thrift.transport.TTransport;
+import org.apache.kyuubi.shaded.thrift.transport.TTransportException;
+import org.apache.kyuubi.shaded.thrift.transport.layered.TFramedTransport;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -571,7 +571,7 @@ public class HiveMetaStoreClient implements
IMetaStoreClient, AutoCloseable {
boolean isHttpTransportMode =
MetastoreConf.getVar(conf,
ConfVars.METASTORE_CLIENT_THRIFT_TRANSPORT_MODE)
.equalsIgnoreCase("http");
- if (!isHttpTransportMode) {
+ if (isHttpTransportMode) {
throw new IllegalArgumentException("HTTP mode is not supported");
}
Objects.requireNonNull(underlyingTransport, "Underlying transport should
not be null");
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/IMetaStoreClient.java
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/IMetaStoreClient.java
index fd054a8..bb69675 100644
---
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/IMetaStoreClient.java
+++
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/IMetaStoreClient.java
@@ -22,7 +22,7 @@ import org.apache.hadoop.classification.InterfaceAudience;
import org.apache.hadoop.classification.InterfaceStability;
import org.apache.kyuubi.shaded.hive.metastore.annotation.NoReconnect;
import org.apache.kyuubi.shaded.hive.metastore.api.MetaException;
-import org.apache.thrift.TException;
+import org.apache.kyuubi.shaded.thrift.TException;
/** Wrapper around hive metastore thrift api */
@InterfaceAudience.Public
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/MetaStorePlainSaslHelper.java
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/MetaStorePlainSaslHelper.java
index 9828fe5..25e000e 100644
---
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/MetaStorePlainSaslHelper.java
+++
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/MetaStorePlainSaslHelper.java
@@ -25,9 +25,9 @@ import javax.security.auth.callback.NameCallback;
import javax.security.auth.callback.PasswordCallback;
import javax.security.auth.callback.UnsupportedCallbackException;
import javax.security.sasl.SaslException;
-import org.apache.thrift.transport.TSaslClientTransport;
-import org.apache.thrift.transport.TTransport;
-import org.apache.thrift.transport.TTransportException;
+import org.apache.kyuubi.shaded.thrift.transport.TSaslClientTransport;
+import org.apache.kyuubi.shaded.thrift.transport.TTransport;
+import org.apache.kyuubi.shaded.thrift.transport.TTransportException;
// This is a copy of org.apache.hive.service.auth.PlainSaslHelper modified for
HMS. See whether
// we can deduplicate the code.
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/RetryingMetaStoreClient.java
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/RetryingMetaStoreClient.java
index bc432db..8920f68 100644
---
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/RetryingMetaStoreClient.java
+++
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/RetryingMetaStoreClient.java
@@ -41,8 +41,8 @@ import
org.apache.kyuubi.shaded.hive.metastore.conf.MetastoreConf;
import org.apache.kyuubi.shaded.hive.metastore.conf.MetastoreConf.ConfVars;
import org.apache.kyuubi.shaded.hive.metastore.utils.JavaUtils;
import org.apache.kyuubi.shaded.hive.metastore.utils.SecurityUtils;
-import org.apache.thrift.TException;
-import org.apache.thrift.transport.TTransportException;
+import org.apache.kyuubi.shaded.thrift.TException;
+import org.apache.kyuubi.shaded.thrift.transport.TTransportException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/HadoopThriftAuthBridge.java
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/HadoopThriftAuthBridge.java
index decb2cf..4b739f2 100644
---
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/HadoopThriftAuthBridge.java
+++
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/HadoopThriftAuthBridge.java
@@ -37,9 +37,9 @@ import org.apache.hadoop.security.SecurityUtil;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.hadoop.security.token.Token;
import org.apache.hadoop.security.token.TokenIdentifier;
-import org.apache.thrift.transport.TSaslClientTransport;
-import org.apache.thrift.transport.TTransport;
-import org.apache.thrift.transport.TTransportException;
+import org.apache.kyuubi.shaded.thrift.transport.TSaslClientTransport;
+import org.apache.kyuubi.shaded.thrift.transport.TTransport;
+import org.apache.kyuubi.shaded.thrift.transport.TTransportException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TFilterTransport.java
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TFilterTransport.java
index 915d855..e01d9ca 100644
---
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TFilterTransport.java
+++
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TFilterTransport.java
@@ -18,9 +18,9 @@
package org.apache.kyuubi.shaded.hive.metastore.security;
-import org.apache.thrift.TConfiguration;
-import org.apache.thrift.transport.TTransport;
-import org.apache.thrift.transport.TTransportException;
+import org.apache.kyuubi.shaded.thrift.TConfiguration;
+import org.apache.kyuubi.shaded.thrift.transport.TTransport;
+import org.apache.kyuubi.shaded.thrift.transport.TTransportException;
/**
* Transport that simply wraps another transport. This is the equivalent of
FilterInputStream for
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TUGIAssumingTransport.java
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TUGIAssumingTransport.java
index 5689d2c..cb125ef 100644
---
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TUGIAssumingTransport.java
+++
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TUGIAssumingTransport.java
@@ -21,8 +21,8 @@ package org.apache.kyuubi.shaded.hive.metastore.security;
import java.io.IOException;
import java.security.PrivilegedExceptionAction;
import org.apache.hadoop.security.UserGroupInformation;
-import org.apache.thrift.transport.TTransport;
-import org.apache.thrift.transport.TTransportException;
+import org.apache.kyuubi.shaded.thrift.transport.TTransport;
+import org.apache.kyuubi.shaded.thrift.transport.TTransportException;
/**
* The Thrift SASL transports call Sasl.createSaslServer and
Sasl.createSaslClient inside open().
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/utils/SecurityUtils.java
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/utils/SecurityUtils.java
index 40fd46e..3646286 100644
---
a/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/utils/SecurityUtils.java
+++
b/kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/utils/SecurityUtils.java
@@ -54,13 +54,13 @@ import org.apache.http.ssl.SSLContexts;
import org.apache.kyuubi.shaded.hive.metastore.api.MetaException;
import
org.apache.kyuubi.shaded.hive.metastore.security.DelegationTokenIdentifier;
import
org.apache.kyuubi.shaded.hive.metastore.security.DelegationTokenSelector;
+import org.apache.kyuubi.shaded.thrift.transport.THttpClient;
+import org.apache.kyuubi.shaded.thrift.transport.TSSLTransportFactory;
+import org.apache.kyuubi.shaded.thrift.transport.TServerSocket;
+import org.apache.kyuubi.shaded.thrift.transport.TSocket;
+import org.apache.kyuubi.shaded.thrift.transport.TTransport;
+import org.apache.kyuubi.shaded.thrift.transport.TTransportException;
import org.apache.kyuubi.shaded.zookeeper.client.ZooKeeperSaslClient;
-import org.apache.thrift.transport.THttpClient;
-import org.apache.thrift.transport.TSSLTransportFactory;
-import org.apache.thrift.transport.TServerSocket;
-import org.apache.thrift.transport.TSocket;
-import org.apache.thrift.transport.TTransport;
-import org.apache.thrift.transport.TTransportException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/kyuubi-relocated-hive-metastore-client/src/main/resources/thrift-replacements.txt
b/kyuubi-relocated-hive-metastore-client/src/main/resources/thrift-replacements.txt
new file mode 100644
index 0000000..de67df1
--- /dev/null
+++
b/kyuubi-relocated-hive-metastore-client/src/main/resources/thrift-replacements.txt
@@ -0,0 +1,27 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+###################################################################################################
+#
#
+# Used for relocating references to libthrift classes to
kyuubi-relocated-thrift classes in the #
+# Thrift generated files: MetaException.java, ThriftHiveMetastore.java.
#
+#
#
+# Look in kyuubi-relocated-hive-metastore-client/pom.xml for the thriftif
profile. #
+# Usage: thriftif profile automatically refers to this file.
#
+#
#
+###################################################################################################
+
+org\.apache\.thrift\.=org.apache.kyuubi.shaded.thrift.
+com\.facebook\.fb303\.=org.apache.kyuubi.shaded.fb303.
\ No newline at end of file
