Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• connections

  private final Map<String,ConnectionCache.ConnectionInfo> connections

• locker

  private final KeyLocker<String> locker

• realUserName

  private final String realUserName

• realUser

  private final org.apache.hadoop.security.UserGroupInformation realUser

• userProvider

  private final UserProvider userProvider

• conf

  private final org.apache.hadoop.conf.Configuration conf

• choreService

  private final ChoreService choreService

• effectiveUserNames

  private final ThreadLocal<String> effectiveUserNames

Constructor Detail

• ConnectionCache

  public ConnectionCache(org.apache.hadoop.conf.Configuration conf,
                 UserProvider userProvider,
                 int cleanInterval,
                 int maxIdleTime)
                  throws IOException

  Throws:

  IOException

Method Detail

• setEffectiveUser

  public void setEffectiveUser(String user)

  Set the current thread local effective user

• getEffectiveUser

  public String getEffectiveUser()

  Get the current thread local effective user

• shutdown

  public void shutdown()

  Called when cache is no longer needed so that it can perform cleanup operations

• getAdmin

  public Admin getAdmin()
                 throws IOException

  Caller doesn't close the admin afterwards. We need to manage it and close it properly.

  Throws:

  IOException

• getTable

  public Table getTable(String tableName)
                 throws IOException

  Caller closes the table afterwards.

  Throws:

  IOException

• getRegionLocator

  public RegionLocator getRegionLocator(byte[] tableName)
                                 throws IOException

  Retrieve a regionLocator for the table. The user should close the RegionLocator.

  Throws:

  IOException

• getCurrentConnection

  ConnectionCache.ConnectionInfo getCurrentConnection()
                                                throws IOException

  Get the cached connection for the current user. If none or timed out, create a new one.

  Throws:

  IOException