org.apache.hadoop.hive.thrift.client
Class TUGIAssumingTransport

java.lang.Object
  org.apache.thrift.transport.TTransport
      org.apache.hadoop.hive.thrift.TFilterTransport
          org.apache.hadoop.hive.thrift.client.TUGIAssumingTransport

public class TUGIAssumingTransport
extends TFilterTransport

The Thrift SASL transports call Sasl.createSaslServer and Sasl.createSaslClient inside open(). So, we need to assume the correct UGI when the transport is opened so that the SASL mechanisms have access to the right principal. This transport wraps the Sasl transports to set up the right UGI context for open(). This is used on the client side, where the API explicitly opens a transport to the server.

Field Summary

protected org.apache.hadoop.security.UserGroupInformation

ugi

Fields inherited from class org.apache.hadoop.hive.thrift.TFilterTransport

wrapped

Constructor Summary

TUGIAssumingTransport(org.apache.thrift.transport.TTransport wrapped, org.apache.hadoop.security.UserGroupInformation ugi)

Method Summary

void

open()

Methods inherited from class org.apache.hadoop.hive.thrift.TFilterTransport

close, consumeBuffer, flush, getBuffer, getBufferPosition, getBytesRemainingInBuffer, isOpen, peek, read, readAll, write, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ugi

protected org.apache.hadoop.security.UserGroupInformation ugi

Constructor Detail

TUGIAssumingTransport

public TUGIAssumingTransport(org.apache.thrift.transport.TTransport wrapped,
                             org.apache.hadoop.security.UserGroupInformation ugi)

Method Detail

open

public void open()
          throws org.apache.thrift.transport.TTransportException

Overrides:

open in class TFilterTransport

Throws:

org.apache.thrift.transport.TTransportException