Package org.apache.accumulo.core.clientImpl

Class TabletLocatorImpl

java.lang.Object

org.apache.accumulo.core.clientImpl.TabletLocator

org.apache.accumulo.core.clientImpl.TabletLocatorImpl

public class TabletLocatorImpl
extends TabletLocator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	TabletLocatorImpl.TabletLocationObtainer
static interface	TabletLocatorImpl.TabletServerLockChecker

Nested classes/interfaces inherited from class org.apache.accumulo.core.clientImpl.TabletLocator

TabletLocator.TabletLocation, TabletLocator.TabletLocations, TabletLocator.TabletServerMutations<T extends Mutation>

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.hadoop.io.Text	lastTabletRow
protected TabletLocatorImpl.TabletLocationObtainer	locationObtainer
protected TreeMap<org.apache.hadoop.io.Text,TabletLocator.TabletLocation>	metaCache
protected TabletLocator	parent
protected TableId	tableId

Constructor Summary

Constructors

Constructor	Description
TabletLocatorImpl(TableId tableId, TabletLocator parent, TabletLocatorImpl.TabletLocationObtainer tlo, TabletLocatorImpl.TabletServerLockChecker tslc)

Method Summary

Modifier and Type	Method	Description
protected TabletLocator.TabletLocation	_locateTablet(ClientContext context, org.apache.hadoop.io.Text row, boolean skipRow, boolean retry, boolean lock, org.apache.accumulo.core.clientImpl.TabletLocatorImpl.LockCheckerSession lcSession)
protected static void	addRange(Map<String,Map<KeyExtent,List<Range>>> binnedRanges, String location, KeyExtent ke, Range range)
<T extends Mutation> void	binMutations(ClientContext context, List<T> mutations, Map<String,TabletLocator.TabletServerMutations<T>> binnedMutations, List<T> failures)
List<Range>	binRanges(ClientContext context, List<Range> ranges, Map<String,Map<KeyExtent,List<Range>>> binnedRanges)
void	invalidateCache()	Invalidate entire cache
void	invalidateCache(Collection<KeyExtent> keySet)
void	invalidateCache(ClientContext context, String server)	Invalidate all metadata entries that point to server
void	invalidateCache(KeyExtent failedExtent)
TabletLocator.TabletLocation	locateTablet(ClientContext context, org.apache.hadoop.io.Text row, boolean skipRow, boolean retry)

Methods inherited from class org.apache.accumulo.core.clientImpl.TabletLocator

clearLocators, getLocator

Methods inherited from class java.lang.Object

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

Field Detail

tableId

protected TableId tableId

parent

protected TabletLocator parent

metaCache

protected TreeMap<org.apache.hadoop.io.Text,TabletLocator.TabletLocation> metaCache

locationObtainer

protected TabletLocatorImpl.TabletLocationObtainer locationObtainer

lastTabletRow

protected org.apache.hadoop.io.Text lastTabletRow

Constructor Detail

TabletLocatorImpl

public TabletLocatorImpl(TableId tableId,
                         TabletLocator parent,
                         TabletLocatorImpl.TabletLocationObtainer tlo,
                         TabletLocatorImpl.TabletServerLockChecker tslc)

Method Detail

binMutations

public <T extends Mutation> void binMutations(ClientContext context,
                                              List<T> mutations,
                                              Map<String,TabletLocator.TabletServerMutations<T>> binnedMutations,
                                              List<T> failures)
                                       throws AccumuloException,
                                              AccumuloSecurityException,
                                              TableNotFoundException

Specified by:

binMutations in class TabletLocator

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

binRanges

public List<Range> binRanges(ClientContext context,
                             List<Range> ranges,
                             Map<String,Map<KeyExtent,List<Range>>> binnedRanges)
                      throws AccumuloException,
                             AccumuloSecurityException,
                             TableNotFoundException

Specified by:

binRanges in class TabletLocator

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

invalidateCache

public void invalidateCache(KeyExtent failedExtent)

Specified by:

invalidateCache in class TabletLocator

invalidateCache

public void invalidateCache(Collection<KeyExtent> keySet)

Specified by:

invalidateCache in class TabletLocator

invalidateCache

public void invalidateCache(ClientContext context,
                            String server)

Description copied from class: TabletLocator

Invalidate all metadata entries that point to server

Specified by:

invalidateCache in class TabletLocator

invalidateCache

public void invalidateCache()

Description copied from class: TabletLocator

Invalidate entire cache

Specified by:

invalidateCache in class TabletLocator

locateTablet

public TabletLocator.TabletLocation locateTablet(ClientContext context,
                                                 org.apache.hadoop.io.Text row,
                                                 boolean skipRow,
                                                 boolean retry)
                                          throws AccumuloException,
                                                 AccumuloSecurityException,
                                                 TableNotFoundException

Specified by:

locateTablet in class TabletLocator

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

_locateTablet

protected TabletLocator.TabletLocation _locateTablet(ClientContext context,
                                                     org.apache.hadoop.io.Text row,
                                                     boolean skipRow,
                                                     boolean retry,
                                                     boolean lock,
                                                     org.apache.accumulo.core.clientImpl.TabletLocatorImpl.LockCheckerSession lcSession)
                                              throws AccumuloException,
                                                     AccumuloSecurityException,
                                                     TableNotFoundException

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

addRange

protected static void addRange(Map<String,Map<KeyExtent,List<Range>>> binnedRanges,
                               String location,
                               KeyExtent ke,
                               Range range)