import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public TProcessor getProcessor() {
    return new ThriftHiveMetastore.Processor<>(
        new CatalogThriftHiveMetastore(config, hiveConverters, metacatV1, partitionV1, catalogName, registry)
    );
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
public HiveSession(TCLIService.Client client, ThriftHiveMetastore.Client metastoreClient,
                   TSessionHandle tSessionHandle, TProtocolVersion protocol) {
    this.client = client;
    this.tSessionHandle = tSessionHandle;
    this.metastoreClient = metastoreClient;
    this.protocol = protocol;
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
@Override
public void open() throws Exception {
    Class.forName("org.apache.hive.jdbc.HiveDriver");

    TTransport tTransport = new TSocket(host, port);
    TProtocol protocol = new TBinaryProtocol(tTransport);
    tTransport.open();
    client = (new TCLIService.Client.Factory()).getClient(protocol);

    TTransport tTransport_ms = new TSocket(metaStoreHost, metaStorePort);
    TProtocol protocol_ms = new TBinaryProtocol(tTransport_ms);
    tTransport_ms.open();
    metastoreClient = (new ThriftHiveMetastore.Client.Factory()).getClient(protocol_ms);
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
/**
 * TODO.
 *
 * @throws HiveMetastoreException TODO
 */
private void connect() throws HiveMetastoreException {

  LOG.info("Connecting to ThriftHiveMetastore " + host + ":" + port);
  transport = new TSocket(host, port, 1000 * clientSocketTimeout);

  this.client = new ThriftHiveMetastore.Client(new TBinaryProtocol(transport));

  try {
    transport.open();
  } catch (TTransportException e) {
    close();
    throw new HiveMetastoreException(e);
  }
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
public HiveThriftClient(String thriftHost, int thriftPort)
{
    transport = new TSocket(thriftHost, thriftPort);
    try {
        transport.open();
    }
    catch (TTransportException e) {
        throw new RuntimeException(e);
    }
    TBinaryProtocol protocol = new TBinaryProtocol(transport);
    client = new ThriftHiveMetastore.Client(protocol);
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
@Override
public ThriftHiveMetastore.Iface getClient() {
  return metaStoreMapping.getClient();
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
@Override
public ThriftHiveMetastore.Iface getClient() {
  return client;
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
protected ThriftHiveMetastore.Iface getClient() {
  return client;
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
public static ThriftHiveMetastore.Iface getClient(HiveMetaStoreClient client){
  return client.client;
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
public ThriftHiveMetastoreClient(TTransport transport)
{
    this.transport = requireNonNull(transport, "transport is null");
    this.client = new ThriftHiveMetastore.Client(new TBinaryProtocol(transport));
}
 

import org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore; //导入依赖的package包/类
ThriftHiveMetastore.Iface getClient();