Uses of Class
org.apache.accumulo.core.client.AccumuloException
-
-
Uses of AccumuloException in org.apache.accumulo.core.client
Subclasses of AccumuloException in org.apache.accumulo.core.client Modifier and Type Class Description classMutationsRejectedExceptionCommunicate the failed mutations of a BatchWriter back to the client.Methods in org.apache.accumulo.core.client that throw AccumuloException Modifier and Type Method Description BatchScannerAccumuloClient. createBatchScanner(String tableName)Factory method to create a BatchScanner with all of user's authorizations and the number of query threads configured when AccumuloClient was created.ScannerAccumuloClient. createScanner(String tableName)Factory method to create a Scanner with all of the user's authorizations.static ConnectorConnector. from(AccumuloClient client)Deprecated.Creates a Connector from an AccumuloClient.BatchWriterMultiTableBatchWriter. getBatchWriter(String table)Returns a BatchWriter for a particular table.default ConnectorInstance. getConnector(String user, byte[] pass)Deprecated.since 1.5, useInstance.getConnector(String, AuthenticationToken)withPasswordTokendefault ConnectorInstance. getConnector(String user, CharSequence pass)Deprecated.since 1.5, useInstance.getConnector(String, AuthenticationToken)withPasswordTokendefault ConnectorInstance. getConnector(String user, ByteBuffer pass)Deprecated.since 1.5, useInstance.getConnector(String, AuthenticationToken)withPasswordTokenConnectorInstance. getConnector(String principal, AuthenticationToken token)Deprecated.Returns a connection to this instance of accumulo.ConnectorZooKeeperInstance. getConnector(String principal, AuthenticationToken token)Deprecated.ConditionalWriter.StatusConditionalWriter.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
Methods in org.apache.accumulo.core.client.admin that throw AccumuloException Modifier and Type Method Description intNamespaceOperations. addConstraint(String namespace, String constraintClassName)Add a new constraint to a namespace.intTableOperations. addConstraint(String tableName, String constraintClassName)Add a new constraint to a table.voidReplicationOperations. addPeer(String name, String replicaType)Defines a cluster with the given name and the given name system.voidTableOperations. addSplits(String tableName, SortedSet<org.apache.hadoop.io.Text> partitionKeys)Ensures that tablets are split along a set of keys.default voidTableOperations. addSummarizers(String tableName, SummarizerConfiguration... summarizers)Enables summary generation for this table for future compactions.voidNamespaceOperations. attachIterator(String namespace, IteratorSetting setting)Add an iterator to a namespace on all scopes.voidNamespaceOperations. attachIterator(String namespace, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)Add an iterator to a namespace on the given scopes.voidTableOperations. attachIterator(String tableName, IteratorSetting setting)Add an iterator to a table on all scopes.voidTableOperations. attachIterator(String tableName, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)Add an iterator to a table on the given scopes.booleanSecurityOperations. authenticateUser(String principal, AuthenticationToken token)Verify a username/password combination is validvoidTableOperations. 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).voidSecurityOperations. changeLocalUserPassword(String principal, PasswordToken token)Set the user's passwordvoidSecurityOperations. changeUserAuthorizations(String principal, Authorizations authorizations)Set the user's record-level authorizationsvoidNamespaceOperations. checkIteratorConflicts(String namespace, IteratorSetting setting, EnumSet<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.voidTableOperations. checkIteratorConflicts(String tableName, IteratorSetting setting, EnumSet<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.voidTableOperations. clearSamplerConfiguration(String tableName)Clear all sampling configuration properties on the table.voidTableOperations. clone(String srcTableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude)Clone a table from an existing table.voidTableOperations. clone(String srcTableName, String newTableName, CloneConfiguration config)Clone a table from an existing table.voidTableOperations. compact(String tableName, CompactionConfig config)Starts a full major compaction of the tablets in the range (start, end].voidTableOperations. 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].voidTableOperations. 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].voidNamespaceOperations. create(String namespace)Create an empty namespace with no initial configuration.voidTableOperations. create(String tableName)Create a table with no special configuration.default voidTableOperations. create(String tableName, boolean limitVersion)Deprecated.since 1.7.0; useTableOperations.create(String, NewTableConfiguration)instead.default voidTableOperations. create(String tableName, boolean versioningIter, TimeType timeType)Deprecated.since 1.7.0; useTableOperations.create(String, NewTableConfiguration)instead.voidTableOperations. create(String tableName, NewTableConfiguration ntc)Create a table with specified configuration.voidSecurityOperations. createLocalUser(String principal, PasswordToken password)Create a uservoidNamespaceOperations. delete(String namespace)Delete an empty namespacevoidTableOperations. delete(String tableName)Delete a tablevoidTableOperations. deleteRows(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end)Delete rows between (start, end]voidReplicationOperations. drain(String tableName)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.voidReplicationOperations. drain(String tableName, Set<String> files)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.voidSecurityOperations. dropLocalUser(String principal)Delete a userbooleanNamespaceOperations. exists(String namespace)A method to check if a namespace exists in Accumulo.voidTableOperations. exportTable(String tableName, String exportDir)Exports a table.voidTableOperations. flush(String tableName)Initiate a flush of a table's data that is in memory.voidTableOperations. 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.List<ActiveCompaction>InstanceOperations. getActiveCompactions(String tserver)List the active compaction running on a tablet serverList<ActiveScan>InstanceOperations. getActiveScans(String tserver)List the active scans on tablet server.DelegationTokenSecurityOperations. getDelegationToken(DelegationTokenConfig cfg)Obtain aDelegationTokenfor use when Kerberos credentials cannot be used (e.g.List<DiskUsage>TableOperations. getDiskUsage(Set<String> tables)Gets the number of bytes being used in the files for a set of tablesIteratorSettingNamespaceOperations. getIteratorSetting(String namespace, String name, IteratorUtil.IteratorScope scope)Get the settings for an iterator.IteratorSettingTableOperations. getIteratorSetting(String tableName, String name, IteratorUtil.IteratorScope scope)Get the settings for an iterator.Map<String,Set<org.apache.hadoop.io.Text>>TableOperations. getLocalityGroups(String tableName)Gets the locality groups currently set for a table.org.apache.hadoop.io.TextTableOperations. 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.Iterable<Map.Entry<String,String>>NamespaceOperations. getProperties(String namespace)Gets properties of a namespace, which are inherited by tables in this namespace.Iterable<Map.Entry<String,String>>TableOperations. getProperties(String tableName)Gets properties of a table.SamplerConfigurationTableOperations. getSamplerConfiguration(String tableName)Reads the sampling configuration properties for a table.Map<String,String>InstanceOperations. getSiteConfiguration()Map<String,String>InstanceOperations. getSystemConfiguration()AuthorizationsSecurityOperations. getUserAuthorizations(String principal)Retrieves the user's authorizations for scanningvoidSecurityOperations. grantNamespacePermission(String principal, String namespace, NamespacePermission permission)Grant a user a specific permission for a specific namespacevoidSecurityOperations. grantSystemPermission(String principal, SystemPermission permission)Grant a user a system permissionvoidSecurityOperations. grantTablePermission(String principal, String table, TablePermission permission)Grant a user a specific permission for a specific tablebooleanSecurityOperations. hasNamespacePermission(String principal, String namespace, NamespacePermission perm)Verify the user has a particular namespace permissionbooleanSecurityOperations. hasSystemPermission(String principal, SystemPermission perm)Verify the user has a particular system permissionbooleanSecurityOperations. hasTablePermission(String principal, String table, TablePermission perm)Verify the user has a particular table permissionvoidTableOperations. importDirectory(String tableName, String dir, String failureDir, boolean setTime)Deprecated.since 2.0.0 useTableOperations.importDirectory(String)instead.default voidTableOperations. importTable(String tableName, String importDir)Imports a table exported via exportTable and copied via hadoop distcp.voidTableOperations. importTable(String tableName, Set<String> importDirs)Imports a table exported via exportTable and copied via hadoop distcp.SortedSet<String>NamespaceOperations. list()Retrieve a list of namespaces in Accumulo.Map<String,Integer>NamespaceOperations. listConstraints(String namespace)List constraints on a namespace with their assigned numbers.Map<String,Integer>TableOperations. listConstraints(String tableName)List constraints on a table with their assigned numbers.Map<String,EnumSet<IteratorUtil.IteratorScope>>NamespaceOperations. listIterators(String namespace)Get a list of iterators for this namespace.Map<String,EnumSet<IteratorUtil.IteratorScope>>TableOperations. listIterators(String tableName)Get a list of iterators for this table.Set<String>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)default List<SummarizerConfiguration>TableOperations. listSummarizers(String tableName)voidTableOperations.ImportOptions. load()Loads the files into the table.LocationsTableOperations. locate(String tableName, Collection<Range> ranges)Locates the tablet servers and tablets that would service a collections of ranges.voidTableOperations. merge(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end)Merge tablets between (start, end]Map<String,String>NamespaceOperations. namespaceIdMap()Get a mapping of namespace name to internal namespace id.voidTableOperations. offline(String tableName)Initiates taking a table offline, but does not wait for action to completevoidTableOperations. offline(String tableName, boolean wait)voidTableOperations. online(String tableName)Initiates bringing a table online, but does not wait for action to completevoidTableOperations. online(String tableName, boolean wait)voidInstanceOperations. ping(String tserver)Throws an exception if a tablet server can not be contacted.Set<String>ReplicationOperations. referencedFiles(String tableName)Gets all of the referenced files for a table from the metadata table.voidNamespaceOperations. removeConstraint(String namespace, int id)Remove a constraint from a namespace.voidTableOperations. removeConstraint(String tableName, int number)Remove a constraint from a table.voidNamespaceOperations. removeIterator(String namespace, String name, EnumSet<IteratorUtil.IteratorScope> scopes)Remove an iterator from a namespace by name.voidTableOperations. removeIterator(String tableName, String name, EnumSet<IteratorUtil.IteratorScope> scopes)Remove an iterator from a table by name.voidReplicationOperations. removePeer(String name)Removes a cluster with the given name.voidInstanceOperations. removeProperty(String property)Removes a system property from zookeeper.voidNamespaceOperations. removeProperty(String namespace, String property)Removes a property from a namespace.voidTableOperations. removeProperty(String tableName, String property)Removes a property from a table.default voidTableOperations. removeSummarizers(String tableName, Predicate<SummarizerConfiguration> predicate)Removes summary generation for this table for the matching summarizers.voidNamespaceOperations. rename(String oldNamespaceName, String newNamespaceName)Rename a namespacevoidTableOperations. rename(String oldTableName, String newTableName)Rename a tableList<Summary>SummaryRetriever. retrieve()voidSecurityOperations. revokeNamespacePermission(String principal, String namespace, NamespacePermission permission)Revoke a namespace permission for a specific user on a specific namespacevoidSecurityOperations. revokeSystemPermission(String principal, SystemPermission permission)Revoke a system permission from a uservoidSecurityOperations. revokeTablePermission(String principal, String table, TablePermission permission)Revoke a table permission for a specific user on a specific tablevoidTableOperations. setLocalityGroups(String tableName, Map<String,Set<org.apache.hadoop.io.Text>> groups)Sets a table's locality groups.voidInstanceOperations. setProperty(String property, String value)Sets an system property in zookeeper.voidNamespaceOperations. setProperty(String namespace, String property, String value)Sets a property on a namespace which applies to all tables in the namespace.voidTableOperations. setProperty(String tableName, String property, String value)Sets a property on a table.voidTableOperations. setSamplerConfiguration(String tableName, SamplerConfiguration samplerConfiguration)Set or update the sampler configuration for a table.Set<Range>TableOperations. splitRangeByTablets(String tableName, Range range, int maxSplits)booleanInstanceOperations. testClassLoad(String className, String asTypeName)Test to see if the instance can load the given class as the given type.booleanNamespaceOperations. testClassLoad(String namespace, String className, String asTypeName)Test to see if the instance can load the given class as the given type.booleanTableOperations. testClassLoad(String tableName, String className, String asTypeName)Test to see if the instance can load the given class as the given type.voidInstanceOperations. waitForBalance()Waits for the tablet balancer to run and return no migrations. -
Uses of AccumuloException in org.apache.accumulo.core.client.mapred
Methods in org.apache.accumulo.core.client.mapred that throw AccumuloException Modifier and Type Method Description voidAccumuloOutputFormat.AccumuloRecordWriter. addTable(org.apache.hadoop.io.Text tableName)Constructors in org.apache.accumulo.core.client.mapred that throw AccumuloException Constructor Description AccumuloRecordWriter(org.apache.hadoop.mapred.JobConf job) -
Uses of AccumuloException in org.apache.accumulo.core.client.mapreduce
Methods in org.apache.accumulo.core.client.mapreduce that throw AccumuloException Modifier and Type Method Description voidAccumuloOutputFormat.AccumuloRecordWriter. addTable(org.apache.hadoop.io.Text tableName)Constructors in org.apache.accumulo.core.client.mapreduce that throw AccumuloException Constructor Description AccumuloRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) -
Uses of AccumuloException in org.apache.accumulo.core.clientImpl
Subclasses of AccumuloException in org.apache.accumulo.core.clientImpl Modifier and Type Class Description classAccumuloBulkMergeExceptionInternal class indicating a concurrent merge occurred during the new bulk import.classAccumuloServerExceptionThis class is intended to encapsulate errors that occurred on the server side.Methods in org.apache.accumulo.core.clientImpl that throw AccumuloException Modifier and Type Method Description protected TabletLocator.TabletLocationTabletLocatorImpl. _locateTablet(ClientContext context, org.apache.hadoop.io.Text row, boolean skipRow, boolean retry, boolean lock, org.apache.accumulo.core.clientImpl.TabletLocatorImpl.LockCheckerSession lcSession)intNamespaceOperationsHelper. addConstraint(String namespace, String constraintClassName)intNamespaceOperationsImpl. addConstraint(String namespace, String constraintClassName)intTableOperationsHelper. addConstraint(String tableName, String constraintClassName)intTableOperationsImpl. addConstraint(String tableName, String constraintClassName)voidReplicationOperationsImpl. addPeer(String name, String replicaType)voidTableOperationsImpl. addSplits(String tableName, SortedSet<org.apache.hadoop.io.Text> partitionKeys)voidTableOperationsImpl. addSummarizers(String tableName, SummarizerConfiguration... newConfigs)voidNamespaceOperationsHelper. attachIterator(String namespace, IteratorSetting setting)voidNamespaceOperationsHelper. attachIterator(String namespace, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)voidNamespaceOperationsImpl. attachIterator(String namespace, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)voidTableOperationsHelper. attachIterator(String tableName, IteratorSetting setting)voidTableOperationsHelper. attachIterator(String tableName, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)voidTableOperationsImpl. attachIterator(String tableName, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)booleanSecurityOperationsImpl. authenticateUser(String principal, AuthenticationToken token)<T extends Mutation>
voidSyncingTabletLocator. binMutations(ClientContext context, List<T> mutations, Map<String,TabletLocator.TabletServerMutations<T>> binnedMutations, List<T> failures)abstract <T extends Mutation>
voidTabletLocator. binMutations(ClientContext context, List<T> mutations, Map<String,TabletLocator.TabletServerMutations<T>> binnedMutations, List<T> failures)<T extends Mutation>
voidTabletLocatorImpl. binMutations(ClientContext context, List<T> mutations, Map<String,TabletLocator.TabletServerMutations<T>> binnedMutations, List<T> failures)<T extends Mutation>
voidTimeoutTabletLocator. binMutations(ClientContext context, List<T> mutations, Map<String,TabletLocator.TabletServerMutations<T>> binnedMutations, List<T> failures)List<Range>SyncingTabletLocator. binRanges(ClientContext context, List<Range> ranges, Map<String,Map<KeyExtent,List<Range>>> binnedRanges)abstract List<Range>TabletLocator. binRanges(ClientContext context, List<Range> ranges, Map<String,Map<KeyExtent,List<Range>>> binnedRanges)List<Range>TabletLocatorImpl. binRanges(ClientContext context, List<Range> ranges, Map<String,Map<KeyExtent,List<Range>>> binnedRanges)List<Range>TimeoutTabletLocator. binRanges(ClientContext context, List<Range> ranges, Map<String,Map<KeyExtent,List<Range>>> binnedRanges)voidTableOperationsImpl. cancelCompaction(String tableName)voidSecurityOperationsImpl. changeLocalUserPassword(String principal, PasswordToken token)voidSecurityOperationsImpl. changeUserAuthorizations(String principal, Authorizations authorizations)voidNamespaceOperationsHelper. checkIteratorConflicts(String namespace, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)voidTableOperationsHelper. checkIteratorConflicts(String tableName, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)static voidTableOperationsHelper. checkIteratorConflicts(Map<String,String> props, IteratorSetting setting, EnumSet<IteratorUtil.IteratorScope> scopes)voidTableOperationsImpl. clearSamplerConfiguration(String tableName)voidTableOperationsImpl. clone(String srcTableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude)voidTableOperationsImpl. clone(String srcTableName, String newTableName, CloneConfiguration config)voidTableOperationsImpl. compact(String tableName, CompactionConfig config)voidTableOperationsImpl. compact(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end, boolean flush, boolean wait)voidTableOperationsImpl. compact(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end, List<IteratorSetting> iterators, boolean flush, boolean wait)voidNamespaceOperationsImpl. create(String namespace)voidTableOperationsImpl. create(String tableName)voidTableOperationsImpl. create(String tableName, NewTableConfiguration ntc)BatchScannerClientContext. createBatchScanner(String tableName)voidSecurityOperationsImpl. createLocalUser(String principal, PasswordToken password)ScannerClientContext. createScanner(String tableName)voidNamespaceOperationsImpl. delete(String namespace)voidTableOperationsImpl. delete(String tableName)voidTableOperationsImpl. deleteRows(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end)StringTableOperationsImpl. doBulkFateOperation(List<ByteBuffer> args, String tableName)voidReplicationOperationsImpl. drain(String tableName)voidReplicationOperationsImpl. drain(String tableName, Set<String> wals)voidSecurityOperationsImpl. dropLocalUser(String principal)static <T> TMasterClient. execute(ClientContext context, ClientExecReturn<T,MasterClientService.Client> exec)static <T> TServerClient. execute(ClientContext context, ClientExecReturn<T,ClientService.Client> exec)static <CT extends org.apache.thrift.TServiceClient,RT>
RTServerClient. execute(ClientContext context, org.apache.thrift.TServiceClientFactory<CT> factory, ClientExecReturn<RT,CT> exec)static <T> TReplicationClient. executeCoordinatorWithReturn(ClientContext context, ClientExecReturn<T,ReplicationCoordinator.Client> exec)static voidMasterClient. executeGeneric(ClientContext context, ClientExec<MasterClientService.Client> exec)static voidMasterClient. executeNamespace(ClientContext context, ClientExec<MasterClientService.Client> exec)static <T> TReplicationClient. executeServicerWithReturn(ClientContext context, HostAndPort tserver, ClientExecReturn<T,ReplicationServicer.Client> exec, long timeout)static voidMasterClient. executeTable(ClientContext context, ClientExec<MasterClientService.Client> exec)static voidMasterClient. executeVoid(ClientContext context, ClientExec<MasterClientService.Client> exec)static voidServerClient. executeVoid(ClientContext context, ClientExec<ClientService.Client> exec)voidTableOperationsImpl. exportTable(String tableName, String exportDir)static org.apache.hadoop.fs.PathTableOperationsImpl. findExportFile(ClientContext context, Set<String> importDirs)Search multiple directories for exportMetadata.zip, the control file used for the importable command.voidTableOperationsImpl. flush(String tableName)voidTableOperationsImpl. flush(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end, boolean wait)List<ActiveCompaction>InstanceOperationsImpl. getActiveCompactions(String tserver)List<ActiveScan>InstanceOperationsImpl. getActiveScans(String tserver)static booleanThriftScanner. getBatchFromServer(ClientContext context, Range range, KeyExtent extent, String server, SortedMap<Key,Value> results, SortedSet<Column> fetchedColumns, List<IterInfo> serverSideIteratorList, Map<String,Map<String,String>> serverSideIteratorOptions, int size, Authorizations authorizations, long batchTimeOut, String classLoaderContext)static ReplicationCoordinator.ClientReplicationClient. getCoordinatorConnectionWithRetry(ClientContext context)DelegationTokenSecurityOperationsImpl. getDelegationToken(DelegationTokenConfig cfg)List<DiskUsage>TableOperationsImpl. getDiskUsage(Set<String> tableNames)IteratorSettingNamespaceOperationsHelper. getIteratorSetting(String namespace, String name, IteratorUtil.IteratorScope scope)IteratorSettingTableOperationsHelper. getIteratorSetting(String tableName, String name, IteratorUtil.IteratorScope scope)Map<String,Set<org.apache.hadoop.io.Text>>TableOperationsImpl. getLocalityGroups(String tableName)protected booleanReplicationOperationsImpl. getMasterDrain(TInfo tinfo, TCredentials rpcCreds, String tableName, Set<String> wals)Iterable<Map.Entry<String,String>>NamespaceOperationsImpl. getProperties(String namespace)Iterable<Map.Entry<String,String>>TableOperationsImpl. getProperties(String tableName)SamplerConfigurationTableOperationsImpl. getSamplerConfiguration(String tableName)Map<String,String>InstanceOperationsImpl. getSiteConfiguration()Map<String,String>InstanceOperationsImpl. getSystemConfiguration()AuthorizationsSecurityOperationsImpl. getUserAuthorizations(String principal)voidSecurityOperationsImpl. grantNamespacePermission(String principal, String namespace, NamespacePermission permission)voidSecurityOperationsImpl. grantSystemPermission(String principal, SystemPermission permission)voidSecurityOperationsImpl. grantTablePermission(String principal, String table, TablePermission permission)booleanSecurityOperationsImpl. hasNamespacePermission(String principal, String namespace, NamespacePermission permission)booleanSecurityOperationsImpl. hasSystemPermission(String principal, SystemPermission perm)booleanSecurityOperationsImpl. hasTablePermission(String principal, String table, TablePermission perm)voidTableOperationsImpl. importDirectory(String tableName, String dir, String failureDir, boolean setTime)Deprecated.voidTableOperationsImpl. importTable(String tableName, Set<String> importDirs)Map<String,Integer>NamespaceOperationsHelper. listConstraints(String namespace)Map<String,Integer>TableOperationsHelper. listConstraints(String tableName)Map<String,EnumSet<IteratorUtil.IteratorScope>>NamespaceOperationsHelper. listIterators(String namespace)Map<String,EnumSet<IteratorUtil.IteratorScope>>TableOperationsHelper. listIterators(String tableName)Set<String>SecurityOperationsImpl. listLocalUsers()List<SummarizerConfiguration>TableOperationsImpl. listSummarizers(String tableName)LocationsTableOperationsImpl. locate(String tableName, Collection<Range> ranges)TabletLocator.TabletLocationSyncingTabletLocator. locateTablet(ClientContext context, org.apache.hadoop.io.Text row, boolean skipRow, boolean retry)abstract TabletLocator.TabletLocationTabletLocator. locateTablet(ClientContext context, org.apache.hadoop.io.Text row, boolean skipRow, boolean retry)TabletLocator.TabletLocationTabletLocatorImpl. locateTablet(ClientContext context, org.apache.hadoop.io.Text row, boolean skipRow, boolean retry)TabletLocator.TabletLocationTimeoutTabletLocator. locateTablet(ClientContext context, org.apache.hadoop.io.Text row, boolean skipRow, boolean retry)TabletLocator.TabletLocationsTabletLocatorImpl.TabletLocationObtainer. lookupTablet(ClientContext context, TabletLocator.TabletLocation src, org.apache.hadoop.io.Text row, org.apache.hadoop.io.Text stopRow, TabletLocator parent)List<TabletLocator.TabletLocation>TabletLocatorImpl.TabletLocationObtainer. lookupTablets(ClientContext context, String tserver, Map<KeyExtent,List<Range>> map, TabletLocator parent)voidTableOperationsImpl. merge(String tableName, org.apache.hadoop.io.Text start, org.apache.hadoop.io.Text end)voidTableOperationsImpl. offline(String tableName)voidTableOperationsImpl. offline(String tableName, boolean wait)voidTableOperationsImpl. online(String tableName)voidTableOperationsImpl. online(String tableName, boolean wait)voidInstanceOperationsImpl. ping(String tserver)voidNamespaceOperationsHelper. removeConstraint(String namespace, int number)voidTableOperationsHelper. removeConstraint(String tableName, int number)voidNamespaceOperationsHelper. removeIterator(String namespace, String name, EnumSet<IteratorUtil.IteratorScope> scopes)voidTableOperationsHelper. removeIterator(String tableName, String name, EnumSet<IteratorUtil.IteratorScope> scopes)voidReplicationOperationsImpl. removePeer(String name)voidInstanceOperationsImpl. removeProperty(String property)voidNamespaceOperationsImpl. removeProperty(String namespace, String property)voidTableOperationsImpl. removeProperty(String tableName, String property)voidTableOperationsImpl. removeSummarizers(String tableName, Predicate<SummarizerConfiguration> predicate)voidNamespaceOperationsImpl. rename(String oldNamespaceName, String newNamespaceName)voidTableOperationsImpl. rename(String oldTableName, String newTableName)voidSecurityOperationsImpl. revokeNamespacePermission(String principal, String namespace, NamespacePermission permission)voidSecurityOperationsImpl. revokeSystemPermission(String principal, SystemPermission permission)voidSecurityOperationsImpl. revokeTablePermission(String principal, String table, TablePermission permission)static List<KeyValue>ThriftScanner. scan(ClientContext context, ThriftScanner.ScanState scanState, long timeOut)voidTableOperationsImpl. setLocalityGroups(String tableName, Map<String,Set<org.apache.hadoop.io.Text>> groups)voidInstanceOperationsImpl. setProperty(String property, String value)voidNamespaceOperationsImpl. setProperty(String namespace, String property, String value)voidTableOperationsImpl. setProperty(String tableName, String property, String value)voidTableOperationsImpl. setSamplerConfiguration(String tableName, SamplerConfiguration samplerConfiguration)Set<Range>TableOperationsImpl. splitRangeByTablets(String tableName, Range range, int maxSplits)booleanInstanceOperationsImpl. testClassLoad(String className, String asTypeName)booleanNamespaceOperationsImpl. testClassLoad(String namespace, String className, String asTypeName)booleanTableOperationsImpl. testClassLoad(String tableName, String className, String asTypeName)voidWriter. update(Mutation m)voidInstanceOperationsImpl. waitForBalance()Constructors in org.apache.accumulo.core.clientImpl that throw AccumuloException Constructor Description ConnectorImpl(ClientContext context)Deprecated. -
Uses of AccumuloException in org.apache.accumulo.core.clientImpl.bulk
Methods in org.apache.accumulo.core.clientImpl.bulk that throw AccumuloException Modifier and Type Method Description static List<KeyExtent>BulkImport. findOverlappingTablets(BulkImport.KeyExtentCache extentCache, FileSKVIterator reader)static List<KeyExtent>BulkImport. findOverlappingTablets(ClientContext context, BulkImport.KeyExtentCache extentCache, org.apache.hadoop.fs.Path file, org.apache.hadoop.fs.FileSystem fs, com.google.common.cache.Cache<String,Long> fileLenCache, CryptoService cs)voidBulkImport. load()KeyExtentBulkImport.KeyExtentCache. lookup(org.apache.hadoop.io.Text row) -
Uses of AccumuloException in org.apache.accumulo.core.clientImpl.mapreduce.lib
Methods in org.apache.accumulo.core.clientImpl.mapreduce.lib that throw AccumuloException Modifier and Type Method Description static Map<String,Map<KeyExtent,List<Range>>>InputConfigurator. binOffline(TableId tableId, List<Range> ranges, ClientContext context)static ClientContextConfiguratorBase. client(Class<?> CLASS, org.apache.hadoop.conf.Configuration conf) -
Uses of AccumuloException in org.apache.accumulo.core.metadata
Methods in org.apache.accumulo.core.metadata that throw AccumuloException Modifier and Type Method Description static MetadataServicerMetadataServicer. forTableName(ClientContext context, String tableName)abstract voidMetadataServicer. getTabletLocations(SortedMap<KeyExtent,String> tablets)Populate the provided data structure with the known tablets for the table being servicedTabletLocator.TabletLocationsMetadataLocationObtainer. lookupTablet(ClientContext context, TabletLocator.TabletLocation src, org.apache.hadoop.io.Text row, org.apache.hadoop.io.Text stopRow, TabletLocator parent)List<TabletLocator.TabletLocation>MetadataLocationObtainer. lookupTablets(ClientContext context, String tserver, Map<KeyExtent,List<Range>> tabletsRanges, TabletLocator parent) -
Uses of AccumuloException in org.apache.accumulo.core.replication
Methods in org.apache.accumulo.core.replication that throw AccumuloException Modifier and Type Method Description longAccumuloReplicationReplayer. replicateLog(ClientContext context, String tableName, WalEdits data)static voidReplicationTable. setOnline(AccumuloClient client) -
Uses of AccumuloException in org.apache.accumulo.core.util
Subclasses of AccumuloException in org.apache.accumulo.core.util Modifier and Type Class Description static classLocalityGroupUtil.LocalityGroupConfigurationError
-