org.apache.accumulo.core.client.mock

Class MockInstanceOperations

java.lang.Object

org.apache.accumulo.core.client.mock.MockInstanceOperations

All Implemented Interfaces:

InstanceOperations

public class MockInstanceOperations
extends Object
implements InstanceOperations

Constructor Summary

Constructors

Constructor and Description
MockInstanceOperations(MockAccumulo acu)

Method Summary

Methods

Modifier and Type	Method and Description
List<ActiveCompaction>	getActiveCompactions(String tserver) List the active compaction running on a tablet server
List<ActiveScan>	getActiveScans(String tserver) List the active scans on tablet server.
Map<String,String>	getSiteConfiguration()
Map<String,String>	getSystemConfiguration()
List<String>	getTabletServers() List the currently active tablet servers participating in the accumulo instance
void	ping(String tserver) Throws an exception if a tablet server can not be contacted.
void	removeProperty(String property) Removes a system property from zookeeper.
void	setProperty(String property, String value) Sets an system property in zookeeper.
boolean	testClassLoad(String className, String asTypeName) Test to see if the instance can load the given class as the given type.

Methods inherited from class java.lang.Object

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

Constructor Detail

MockInstanceOperations

public MockInstanceOperations(MockAccumulo acu)

Method Detail

setProperty

public void setProperty(String property,
               String value)
                 throws AccumuloException,
                        AccumuloSecurityException

Description copied from interface: InstanceOperations

Sets an system property in zookeeper. Tablet servers will pull this setting and override the equivalent setting in accumulo-site.xml. Changes can be seen using InstanceOperations.getSystemConfiguration()

Specified by:

setProperty in interface InstanceOperations

Parameters:

property - the name of a per-table property

value - the value to set a per-table property to

Throws:

AccumuloException - if a general error occurs

AccumuloSecurityException - if the user does not have permission

removeProperty

public void removeProperty(String property)
                    throws AccumuloException,
                           AccumuloSecurityException

Description copied from interface: InstanceOperations

Removes a system property from zookeeper. Changes can be seen using InstanceOperations.getSystemConfiguration()

Specified by:

removeProperty in interface InstanceOperations

Parameters:

property - the name of a per-table property

Throws:

AccumuloException - if a general error occurs

AccumuloSecurityException - if the user does not have permission

getSystemConfiguration

public Map<String,String> getSystemConfiguration()
                                          throws AccumuloException,
                                                 AccumuloSecurityException

Specified by:

getSystemConfiguration in interface InstanceOperations

Returns:

A map of system properties set in zookeeper. If a property is not set in zookeeper, then it will return the value set in accumulo-site.xml on some server. If nothing is set in an accumulo-site.xml file it will return the default value for each property.

Throws:

AccumuloException

AccumuloSecurityException

getSiteConfiguration

public Map<String,String> getSiteConfiguration()
                                        throws AccumuloException,
                                               AccumuloSecurityException

Specified by:

getSiteConfiguration in interface InstanceOperations

Returns:

A map of system properties set in accumulo-site.xml on some server. If nothing is set in an accumulo-site.xml file it will return the default value for each property.

Throws:

AccumuloException

AccumuloSecurityException

getTabletServers

public List<String> getTabletServers()

Description copied from interface: InstanceOperations

List the currently active tablet servers participating in the accumulo instance

Specified by:

getTabletServers in interface InstanceOperations

Returns:

A list of currently active tablet servers.

getActiveScans

public List<ActiveScan> getActiveScans(String tserver)
                                throws AccumuloException,
                                       AccumuloSecurityException

Description copied from interface: InstanceOperations

List the active scans on tablet server.

Specified by:

getActiveScans in interface InstanceOperations

Parameters:

tserver - The tablet server address should be of the form <ip address>:<port>

Returns:

A list of active scans on tablet server.

Throws:

AccumuloException

AccumuloSecurityException

testClassLoad

public boolean testClassLoad(String className,
                    String asTypeName)
                      throws AccumuloException,
                             AccumuloSecurityException

Description copied from interface: InstanceOperations

Test to see if the instance can load the given class as the given type. This check does not consider per table classpaths, see TableOperations.testClassLoad(String, String, String)

Specified by:

testClassLoad in interface InstanceOperations

Returns:

true if the instance can load the given class as the given type, false otherwise

Throws:

AccumuloException

AccumuloSecurityException

getActiveCompactions

public List<ActiveCompaction> getActiveCompactions(String tserver)
                                            throws AccumuloException,
                                                   AccumuloSecurityException

Description copied from interface: InstanceOperations

List the active compaction running on a tablet server

Specified by:

getActiveCompactions in interface InstanceOperations

Parameters:

tserver - The tablet server address should be of the form <ip address>:<port>

Returns:

the list of active compactions

Throws:

AccumuloException

AccumuloSecurityException

ping

public void ping(String tserver)
          throws AccumuloException

Description copied from interface: InstanceOperations

Throws an exception if a tablet server can not be contacted.

Specified by:

ping in interface InstanceOperations

Parameters:

tserver - The tablet server address should be of the form <ip address>:<port>

Throws:

AccumuloException