Uses of Class
org.apache.accumulo.core.client.AccumuloException
Package
Description
Mock framework for Accumulo
-
Uses of AccumuloException in org.apache.accumulo.core.client
Modifier and TypeClassDescriptionclass
Communicate the failed mutations of a BatchWriter back to the client.Modifier and TypeMethodDescriptionMultiTableBatchWriter.getBatchWriter
(String table) Returns a BatchWriter for a particular table.Instance.getConnector
(String user, byte[] pass) Deprecated.Instance.getConnector
(String user, CharSequence pass) Deprecated.since 1.5, useInstance.getConnector(String, AuthenticationToken)
withPasswordToken
Instance.getConnector
(String user, ByteBuffer pass) Deprecated.since 1.5, useInstance.getConnector(String, AuthenticationToken)
withPasswordToken
Instance.getConnector
(String principal, AuthenticationToken token) Returns a connection to this instance of accumulo.ZooKeeperInstance.getConnector
(String principal, byte[] pass) Deprecated.ZooKeeperInstance.getConnector
(String user, CharSequence pass) Deprecated.ZooKeeperInstance.getConnector
(String user, ByteBuffer pass) Deprecated.ZooKeeperInstance.getConnector
(String principal, AuthenticationToken token) ConditionalWriter.Result.getStatus()
If this method throws an exception, then its possible the mutation is still being actively processed. -
Uses of AccumuloException in org.apache.accumulo.core.client.admin
Modifier and TypeMethodDescriptionint
NamespaceOperations.addConstraint
(String namespace, String constraintClassName) Add a new constraint to a namespace.int
TableOperations.addConstraint
(String tableName, String constraintClassName) Add a new constraint to a table.void
Defines a cluster with the given name and the given name system.void
Ensures that tablets are split along a set of keys.void
NamespaceOperations.attachIterator
(String namespace, IteratorSetting setting) Add an iterator to a namespace on all scopes.void
NamespaceOperations.attachIterator
(String namespace, IteratorSetting setting, EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) Add an iterator to a namespace on the given scopes.void
TableOperations.attachIterator
(String tableName, IteratorSetting setting) Add an iterator to a table on all scopes.void
TableOperations.attachIterator
(String tableName, IteratorSetting setting, EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) Add an iterator to a table on the given scopes.boolean
SecurityOperations.authenticateUser
(String user, byte[] password) Deprecated.since 1.5.0; useSecurityOperations.authenticateUser(String, AuthenticationToken)
instead.boolean
SecurityOperations.authenticateUser
(String principal, AuthenticationToken token) Verify a username/password combination is validvoid
TableOperations.cancelCompaction
(String tableName) Cancels a user initiated major compaction of a table initiated withTableOperations.compact(String, Text, Text, boolean, boolean)
orTableOperations.compact(String, Text, Text, List, boolean, boolean)
.void
SecurityOperations.changeLocalUserPassword
(String principal, PasswordToken token) Set the user's passwordvoid
SecurityOperations.changeUserAuthorizations
(String principal, Authorizations authorizations) Set the user's record-level authorizationsvoid
SecurityOperations.changeUserPassword
(String user, byte[] password) Deprecated.since 1.5.0; useSecurityOperations.changeLocalUserPassword(String, PasswordToken)
or the user management functions of your configured authenticator instead.void
NamespaceOperations.checkIteratorConflicts
(String namespace, IteratorSetting setting, EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) Check whether a given iterator configuration conflicts with existing configuration; in particular, determine if the name or priority are already in use for the specified scopes.void
TableOperations.checkIteratorConflicts
(String tableName, IteratorSetting setting, EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) Check whether a given iterator configuration conflicts with existing configuration; in particular, determine if the name or priority are already in use for the specified scopes.void
TableOperations.clearSamplerConfiguration
(String tableName) Clear all sampling configuration properties on the table.void
TableOperations.clone
(String srcTableName, String newTableName, boolean flush, Map<String, String> propertiesToSet, Set<String> propertiesToExclude) Clone a table from an existing table.void
TableOperations.clone
(String srcTableName, String newTableName, CloneConfiguration config) Clone a table from an existing table.void
TableOperations.compact
(String tableName, CompactionConfig config) Starts a full major compaction of the tablets in the range (start, end].void
TableOperations.compact
(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end, boolean flush, boolean wait) Starts a full major compaction of the tablets in the range (start, end].void
TableOperations.compact
(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end, List<IteratorSetting> iterators, boolean flush, boolean wait) Starts a full major compaction of the tablets in the range (start, end].void
Create an empty namespace with no initial configuration.void
Create a table with no special configurationvoid
Deprecated.since 1.7.0; useTableOperations.create(String, NewTableConfiguration)
instead.void
Deprecated.since 1.7.0; useTableOperations.create(String, NewTableConfiguration)
instead.void
TableOperations.create
(String tableName, NewTableConfiguration ntc) void
SecurityOperations.createLocalUser
(String principal, PasswordToken password) Create a uservoid
SecurityOperations.createUser
(String user, byte[] password, Authorizations authorizations) Deprecated.since 1.5.0; useSecurityOperations.createLocalUser(String, PasswordToken)
or the user management functions of your configured authenticator instead.void
Delete an empty namespacevoid
Delete a tablevoid
TableOperations.deleteRows
(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end) Delete rows between (start, end]void
Waits for a table to be fully replicated, given the state of files pending replication for the provided table at the point in time which this method is invoked.void
Given the provided set of files that are pending replication for a table, wait for those files to be fully replicated to all configured peers.void
SecurityOperations.dropLocalUser
(String principal) Delete a uservoid
Deprecated.since 1.5.0; useSecurityOperations.dropUser(String)
or the user management functions of your configured authenticator instead.boolean
A method to check if a namespace exists in Accumulo.void
TableOperations.exportTable
(String tableName, String exportDir) Exports a table.void
Deprecated.since 1.4; useTableOperations.flush(String, Text, Text, boolean)
insteadvoid
TableOperations.flush
(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end, boolean wait) Flush a table's data that is currently in memory.InstanceOperations.getActiveCompactions
(String tserver) List the active compaction running on a tablet serverInstanceOperations.getActiveScans
(String tserver) List the active scans on tablet server.SecurityOperations.getDelegationToken
(DelegationTokenConfig cfg) Obtain aDelegationToken
for use when Kerberos credentials cannot be used (e.g.TableOperations.getDiskUsage
(Set<String> tables) Gets the number of bytes being used in the files for a set of tablesNamespaceOperations.getIteratorSetting
(String namespace, String name, org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope scope) Get the settings for an iterator.TableOperations.getIteratorSetting
(String tableName, String name, org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope scope) Get the settings for an iterator.TableOperations.getLocalityGroups
(String tableName) Gets the locality groups currently set for a table.org.apache.hadoop.io.Text
TableOperations.getMaxRow
(String tableName, Authorizations auths, org.apache.hadoop.io.Text startRow, boolean startInclusive, org.apache.hadoop.io.Text endRow, boolean endInclusive) Finds the max row within a given range.NamespaceOperations.getProperties
(String namespace) Gets properties of a namespace, which are inherited by tables in this namespace.TableOperations.getProperties
(String tableName) Gets properties of a table.TableOperations.getSamplerConfiguration
(String tableName) Reads the sampling configuration properties for a table.InstanceOperations.getSiteConfiguration()
InstanceOperations.getSystemConfiguration()
SecurityOperations.getUserAuthorizations
(String principal) Retrieves the user's authorizations for scanningvoid
SecurityOperations.grantNamespacePermission
(String principal, String namespace, NamespacePermission permission) Grant a user a specific permission for a specific namespacevoid
SecurityOperations.grantSystemPermission
(String principal, SystemPermission permission) Grant a user a system permissionvoid
SecurityOperations.grantTablePermission
(String principal, String table, TablePermission permission) Grant a user a specific permission for a specific tableboolean
SecurityOperations.hasNamespacePermission
(String principal, String namespace, NamespacePermission perm) Verify the user has a particular namespace permissionboolean
SecurityOperations.hasSystemPermission
(String principal, SystemPermission perm) Verify the user has a particular system permissionboolean
SecurityOperations.hasTablePermission
(String principal, String table, TablePermission perm) Verify the user has a particular table permissionvoid
TableOperations.importDirectory
(String tableName, String dir, String failureDir, boolean setTime) Bulk import all the files in a directory into a table.void
TableOperations.importTable
(String tableName, String importDir) Imports a table exported via exportTable and copied via hadoop distcp.NamespaceOperations.list()
Retrieve a list of namespaces in Accumulo.NamespaceOperations.listConstraints
(String namespace) List constraints on a namespace with their assigned numbers.TableOperations.listConstraints
(String tableName) List constraints on a table with their assigned numbers.NamespaceOperations.listIterators
(String namespace) Get a list of iterators for this namespace.TableOperations.listIterators
(String tableName) Get a list of iterators for this table.SecurityOperations.listLocalUsers()
Return a list of users in accumuloCollection<org.apache.hadoop.io.Text>
TableOperations.listSplits
(String tableName) Collection<org.apache.hadoop.io.Text>
TableOperations.listSplits
(String tableName, int maxSplits) SecurityOperations.listUsers()
Deprecated.since 1.5.0; useSecurityOperations.listLocalUsers()
or the user management functions of your configured authenticator instead.TableOperations.locate
(String tableName, Collection<Range> ranges) Locates the tablet servers and tablets that would service a collections of ranges.void
TableOperations.merge
(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end) Merge tablets between (start, end]NamespaceOperations.namespaceIdMap()
Get a mapping of namespace name to internal namespace id.void
Initiates taking a table offline, but does not wait for action to completevoid
void
Initiates bringing a table online, but does not wait for action to completevoid
void
Throws an exception if a tablet server can not be contacted.ReplicationOperations.referencedFiles
(String tableName) Gets all of the referenced files for a table from the metadata table.void
NamespaceOperations.removeConstraint
(String namespace, int id) Remove a constraint from a namespace.void
TableOperations.removeConstraint
(String tableName, int number) Remove a constraint from a table.void
NamespaceOperations.removeIterator
(String namespace, String name, EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) Remove an iterator from a namespace by name.void
TableOperations.removeIterator
(String tableName, String name, EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) Remove an iterator from a table by name.void
ReplicationOperations.removePeer
(String name) Removes a cluster with the given name.void
InstanceOperations.removeProperty
(String property) Removes a system property from zookeeper.void
NamespaceOperations.removeProperty
(String namespace, String property) Removes a property from a namespace.void
TableOperations.removeProperty
(String tableName, String property) Removes a property from a table.void
Rename a namespacevoid
Rename a tablevoid
SecurityOperations.revokeNamespacePermission
(String principal, String namespace, NamespacePermission permission) Revoke a namespace permission for a specific user on a specific namespacevoid
SecurityOperations.revokeSystemPermission
(String principal, SystemPermission permission) Revoke a system permission from a uservoid
SecurityOperations.revokeTablePermission
(String principal, String table, TablePermission permission) Revoke a table permission for a specific user on a specific tablevoid
TableOperations.setLocalityGroups
(String tableName, Map<String, Set<org.apache.hadoop.io.Text>> groups) Sets a table's locality groups.void
InstanceOperations.setProperty
(String property, String value) Sets an system property in zookeeper.void
NamespaceOperations.setProperty
(String namespace, String property, String value) Sets a property on a namespace which applies to all tables in the namespace.void
TableOperations.setProperty
(String tableName, String property, String value) Sets a property on a table.void
TableOperations.setSamplerConfiguration
(String tableName, SamplerConfiguration samplerConfiguration) Set or update the sampler configuration for a table.TableOperations.splitRangeByTablets
(String tableName, Range range, int maxSplits) boolean
InstanceOperations.testClassLoad
(String className, String asTypeName) Test to see if the instance can load the given class as the given type.boolean
NamespaceOperations.testClassLoad
(String namespace, String className, String asTypeName) Test to see if the instance can load the given class as the given type.boolean
TableOperations.testClassLoad
(String tableName, String className, String asTypeName) Test to see if the instance can load the given class as the given type.void
InstanceOperations.waitForBalance()
Waits for the tablet balancer to run and return no migrations. -
Uses of AccumuloException in org.apache.accumulo.core.client.mapred
Modifier and TypeMethodDescriptionvoid
AccumuloOutputFormat.AccumuloRecordWriter.addTable
(org.apache.hadoop.io.Text tableName) ModifierConstructorDescriptionprotected
AccumuloRecordWriter
(org.apache.hadoop.mapred.JobConf job) -
Uses of AccumuloException in org.apache.accumulo.core.client.mapreduce
Modifier and TypeMethodDescriptionvoid
AccumuloOutputFormat.AccumuloRecordWriter.addTable
(org.apache.hadoop.io.Text tableName) ModifierConstructorDescriptionprotected
AccumuloRecordWriter
(org.apache.hadoop.mapreduce.TaskAttemptContext context) -
Uses of AccumuloException in org.apache.accumulo.core.client.mock
Modifier and TypeMethodDescriptionMockMultiTableBatchWriter.getBatchWriter
(String table) Deprecated.MockInstance.getConnector
(String user, byte[] pass) Deprecated.MockInstance.getConnector
(String user, CharSequence pass) Deprecated.MockInstance.getConnector
(String user, ByteBuffer pass) Deprecated.MockInstance.getConnector
(String principal, AuthenticationToken token) Deprecated. -
Uses of AccumuloException in org.apache.accumulo.minicluster
Modifier and TypeMethodDescriptionMiniAccumuloCluster.getConnector
(String user, String passwd) Utility method to get a connector to the MAC.
Instance.getConnector(String, AuthenticationToken)
withPasswordToken