org.apache.accumulo.core.client.mock

Class MockTabletLocator

java.lang.Object

org.apache.accumulo.core.client.impl.TabletLocator

org.apache.accumulo.core.client.mock.MockTabletLocator

public class MockTabletLocator
extends org.apache.accumulo.core.client.impl.TabletLocator

Nested Class Summary

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

org.apache.accumulo.core.client.impl.TabletLocator.TabletLocation, org.apache.accumulo.core.client.impl.TabletLocator.TabletLocations, org.apache.accumulo.core.client.impl.TabletLocator.TabletServerMutations

Constructor Summary

Constructors

Constructor and Description
MockTabletLocator()

Method Summary

Methods

Modifier and Type	Method and Description
void	binMutations(List<Mutation> mutations, Map<String,org.apache.accumulo.core.client.impl.TabletLocator.TabletServerMutations> binnedMutations, List<Mutation> failures, org.apache.accumulo.core.security.thrift.TCredentials credentials)
List<Range>	binRanges(List<Range> ranges, Map<String,Map<KeyExtent,List<Range>>> binnedRanges, org.apache.accumulo.core.security.thrift.TCredentials credentials)
void	invalidateCache() Invalidate entire cache
void	invalidateCache(Collection<KeyExtent> keySet)
void	invalidateCache(KeyExtent failedExtent)
void	invalidateCache(String server) Invalidate all metadata entries that point to server
org.apache.accumulo.core.client.impl.TabletLocator.TabletLocation	locateTablet(org.apache.hadoop.io.Text row, boolean skipRow, boolean retry, org.apache.accumulo.core.security.thrift.TCredentials credentials)

Methods inherited from class org.apache.accumulo.core.client.impl.TabletLocator

getInstance

Methods inherited from class java.lang.Object

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

Constructor Detail

MockTabletLocator

public MockTabletLocator()

Method Detail

locateTablet

public org.apache.accumulo.core.client.impl.TabletLocator.TabletLocation locateTablet(org.apache.hadoop.io.Text row,
                                                                             boolean skipRow,
                                                                             boolean retry,
                                                                             org.apache.accumulo.core.security.thrift.TCredentials credentials)
                                                                               throws AccumuloException,
                                                                                      AccumuloSecurityException,
                                                                                      TableNotFoundException

Specified by:

locateTablet in class org.apache.accumulo.core.client.impl.TabletLocator

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

binMutations

public void binMutations(List<Mutation> mutations,
                Map<String,org.apache.accumulo.core.client.impl.TabletLocator.TabletServerMutations> binnedMutations,
                List<Mutation> failures,
                org.apache.accumulo.core.security.thrift.TCredentials credentials)
                  throws AccumuloException,
                         AccumuloSecurityException,
                         TableNotFoundException

Specified by:

binMutations in class org.apache.accumulo.core.client.impl.TabletLocator

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

binRanges

public List<Range> binRanges(List<Range> ranges,
                    Map<String,Map<KeyExtent,List<Range>>> binnedRanges,
                    org.apache.accumulo.core.security.thrift.TCredentials credentials)
                      throws AccumuloException,
                             AccumuloSecurityException,
                             TableNotFoundException

Specified by:

binRanges in class org.apache.accumulo.core.client.impl.TabletLocator

Throws:

AccumuloException

AccumuloSecurityException

TableNotFoundException

invalidateCache

public void invalidateCache(KeyExtent failedExtent)

Specified by:

invalidateCache in class org.apache.accumulo.core.client.impl.TabletLocator

invalidateCache

public void invalidateCache(Collection<KeyExtent> keySet)

Specified by:

invalidateCache in class org.apache.accumulo.core.client.impl.TabletLocator

invalidateCache

public void invalidateCache()

Description copied from class: org.apache.accumulo.core.client.impl.TabletLocator

Invalidate entire cache

Specified by:

invalidateCache in class org.apache.accumulo.core.client.impl.TabletLocator

invalidateCache

public void invalidateCache(String server)

Description copied from class: org.apache.accumulo.core.client.impl.TabletLocator

Invalidate all metadata entries that point to server

Specified by:

invalidateCache in class org.apache.accumulo.core.client.impl.TabletLocator