Package org.apache.accumulo.core.clientImpl

Class SyncingTabletLocator

java.lang.Object

org.apache.accumulo.core.clientImpl.TabletLocator

org.apache.accumulo.core.clientImpl.SyncingTabletLocator

Direct Known Subclasses:

TimeoutTabletLocator

public class SyncingTabletLocator
extends TabletLocator

Syncs itself with the static collection of TabletLocators, so that when the server clears it, it will automatically get the most up-to-date version. Caching TabletLocators locally is safe when using SyncingTabletLocator.

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor	Description
SyncingTabletLocator(Callable<TabletLocator> getLocatorFunction)
SyncingTabletLocator(ClientContext context, TableId tableId)

Method Summary

Modifier and Type	Method	Description
<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

Constructor Detail

SyncingTabletLocator

public SyncingTabletLocator(Callable<TabletLocator> getLocatorFunction)

SyncingTabletLocator

public SyncingTabletLocator(ClientContext context,
                            TableId tableId)

Method Detail

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

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()

Description copied from class: TabletLocator

Invalidate entire cache

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