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

• updateConnectionAccessTime

  public boolean updateConnectionAccessTime()

  Updates the access time for the current connection. Used to keep Connections alive for long-lived scanners.

  Returns:

  whether we successfully updated the last access time