Package org.apache.accumulo.core.clientImpl

Class TimeoutTabletLocator

java.lang.Object

org.apache.accumulo.core.clientImpl.TabletLocator

org.apache.accumulo.core.clientImpl.SyncingTabletLocator

org.apache.accumulo.core.clientImpl.TimeoutTabletLocator

public class TimeoutTabletLocator
extends SyncingTabletLocator

Throws a TimedOutException if the specified timeout duration elapses between two failed TabletLocator calls.

This class is safe to cache locally.

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
TimeoutTabletLocator(long timeout, ClientContext context, TableId table)

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)
TabletLocator.TabletLocation	locateTablet(ClientContext context, org.apache.hadoop.io.Text row, boolean skipRow, boolean retry)

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

invalidateCache, invalidateCache, invalidateCache, invalidateCache

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

TimeoutTabletLocator

public TimeoutTabletLocator(long timeout,
                            ClientContext context,
                            TableId table)

Method Detail

locateTablet

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

Overrides:

locateTablet in class SyncingTabletLocator

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

Overrides:

binMutations in class SyncingTabletLocator

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

Overrides:

binRanges in class SyncingTabletLocator

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException