Field Detail

• LOG

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

• cachedRegionLocations

  private final ConcurrentMap<TableName,ConcurrentNavigableMap<byte[],RegionLocations>> cachedRegionLocations

  Map of table to table HRegionLocations.

• cachedServers

  private final Set<ServerName> cachedServers

• metrics

  private final MetricsConnection metrics

Constructor Detail

• MetaCache

  public MetaCache(MetricsConnection metrics)

Method Detail

• getCachedLocation

  public RegionLocations getCachedLocation(TableName tableName,
                                  byte[] row)

  Search the cache for a location that fits our table and row key. Return null if no suitable region is located.

  Returns:

  Null or region location found in cache.

• getRowComparator

  private KeyValue.KVComparator getRowComparator(TableName tableName)

• cacheLocation

  public void cacheLocation(TableName tableName,
                   ServerName source,
                   HRegionLocation location)

  Put a newly discovered HRegionLocation into the cache.

  Parameters:

  tableName - The table name.

  source - the source of the new location

  location - the new location

• cacheLocation

  public void cacheLocation(TableName tableName,
                   RegionLocations locations)

  Put a newly discovered HRegionLocation into the cache.

  Parameters:

  tableName - The table name.

  locations - the new locations

• addToCachedServers

  private void addToCachedServers(RegionLocations locations)

• getTableLocations

  private ConcurrentNavigableMap<byte[],RegionLocations> getTableLocations(TableName tableName)

  Parameters:

  tableName -

  Returns:

  Map of cached locations for passed tableName

• isRegionCached

  public boolean isRegionCached(TableName tableName,
                       byte[] row)

  Check the region cache to see whether a region is cached yet or not.

  Parameters:

  tableName - tableName

  row - row

  Returns:

  Region cached or not.

• getNumberOfCachedRegionLocations

  public int getNumberOfCachedRegionLocations(TableName tableName)

  Return the number of cached region for a table. It will only be called from a unit test.

• clearCache

  public void clearCache()

  Delete all cached entries.

• clearCache

  public void clearCache(ServerName serverName)

  Delete all cached entries of a server.

• clearCache

  public void clearCache(TableName tableName)

  Delete all cached entries of a table.

• clearCache

  public void clearCache(TableName tableName,
                byte[] row,
                int replicaId)

  Delete a cached location, no matter what it is. Called when we were told to not use cache.

  Parameters:

  tableName - tableName

  row -

• clearCache

  public void clearCache(TableName tableName,
                byte[] row)

  Delete a cached location, no matter what it is. Called when we were told to not use cache.

  Parameters:

  tableName - tableName

  row -

• clearCache

  public void clearCache(TableName tableName,
                byte[] row,
                ServerName serverName)

  Delete a cached location for a table, row and server

• clearCache

  public void clearCache(HRegionInfo hri)

  Deletes the cached location of the region if necessary, based on some error from source.

  Parameters:

  hri - The region in question.

• clearCache

  public void clearCache(HRegionLocation location)