Package | Description |
---|---|
org.apache.accumulo.core.client | |
org.apache.accumulo.core.client.admin | |
org.apache.accumulo.core.client.mapreduce | |
org.apache.accumulo.core.client.mock |
Modifier and Type | Class and Description |
---|---|
class |
MutationsRejectedException
Communicate the failed mutations of a BatchWriter back to the client.
|
Modifier and Type | Method and Description |
---|---|
BatchWriter |
MultiTableBatchWriter.getBatchWriter(String table)
Returns a BatchWriter for a particular table.
|
Connector |
ZooKeeperInstance.getConnector(org.apache.accumulo.core.security.thrift.AuthInfo auth) |
Connector |
Instance.getConnector(org.apache.accumulo.core.security.thrift.AuthInfo auth)
Returns a connection to accumulo.
|
Connector |
ZooKeeperInstance.getConnector(String user,
byte[] pass) |
Connector |
Instance.getConnector(String user,
byte[] pass)
Returns a connection to accumulo.
|
Connector |
ZooKeeperInstance.getConnector(String user,
ByteBuffer pass) |
Connector |
Instance.getConnector(String user,
ByteBuffer pass)
Returns a connection to accumulo.
|
Connector |
ZooKeeperInstance.getConnector(String user,
CharSequence pass) |
Connector |
Instance.getConnector(String user,
CharSequence pass)
Returns a connection to this instance of accumulo.
|
Constructor and Description |
---|
Connector(Instance instance,
String user,
byte[] password)
Deprecated.
Not for client use
|
Modifier and Type | Method and Description |
---|---|
void |
TableOperationsImpl.addAggregators(String tableName,
List<? extends org.apache.accumulo.core.iterators.conf.PerColumnIteratorConfig> aggregators)
Deprecated.
|
void |
TableOperations.addAggregators(String tableName,
List<? extends org.apache.accumulo.core.iterators.conf.PerColumnIteratorConfig> aggregators)
Deprecated.
|
void |
TableOperationsImpl.addSplits(String tableName,
SortedSet<org.apache.hadoop.io.Text> partitionKeys) |
void |
TableOperations.addSplits(String tableName,
SortedSet<org.apache.hadoop.io.Text> partitionKeys) |
void |
TableOperationsHelper.attachIterator(String tableName,
IteratorSetting setting) |
void |
TableOperations.attachIterator(String tableName,
IteratorSetting setting)
Add an iterator to a table on all scopes.
|
void |
TableOperationsHelper.attachIterator(String tableName,
IteratorSetting setting,
EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> 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 |
SecurityOperationsImpl.authenticateUser(String user,
byte[] password)
Verify a username/password combination is valid
|
boolean |
SecurityOperations.authenticateUser(String user,
byte[] password)
Verify a username/password combination is valid
|
void |
SecurityOperationsImpl.changeUserAuthorizations(String user,
Authorizations authorizations)
Set the user's record-level authorizations
|
void |
SecurityOperations.changeUserAuthorizations(String user,
Authorizations authorizations)
Set the user's record-level authorizations
|
void |
SecurityOperationsImpl.changeUserPassword(String user,
byte[] password)
Set the user's password
|
void |
SecurityOperations.changeUserPassword(String user,
byte[] password)
Set the user's password
|
void |
TableOperationsHelper.checkIteratorConflicts(String tableName,
IteratorSetting setting,
EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> 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 |
TableOperationsImpl.clone(String srcTableName,
String newTableName,
boolean flush,
Map<String,String> propertiesToSet,
Set<String> propertiesToExclude) |
void |
TableOperations.clone(String srcTableName,
String newTableName,
boolean flush,
Map<String,String> propertiesToSet,
Set<String> propertiesToExclude)
Clone a table from an existing table.
|
void |
TableOperationsImpl.compact(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end,
boolean flush,
boolean wait) |
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 |
TableOperationsImpl.create(String tableName)
Create a table with no special configuration
|
void |
TableOperations.create(String tableName)
Create a table with no special configuration
|
void |
TableOperationsImpl.create(String tableName,
boolean limitVersion) |
void |
TableOperations.create(String tableName,
boolean limitVersion) |
void |
TableOperationsImpl.create(String tableName,
boolean limitVersion,
TimeType timeType) |
void |
TableOperations.create(String tableName,
boolean versioningIter,
TimeType timeType) |
void |
SecurityOperationsImpl.createUser(String user,
byte[] password,
Authorizations authorizations)
Create a user
|
void |
SecurityOperations.createUser(String user,
byte[] password,
Authorizations authorizations)
Create a user
|
void |
TableOperationsImpl.delete(String tableName)
Delete a table
|
void |
TableOperations.delete(String tableName)
Delete a table
|
void |
TableOperationsImpl.deleteRows(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end) |
void |
TableOperations.deleteRows(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end)
Delete rows between (start, end]
|
void |
SecurityOperationsImpl.dropUser(String user)
Delete a user
|
void |
SecurityOperations.dropUser(String user)
Delete a user
|
void |
TableOperationsImpl.flush(String tableName)
Deprecated.
|
void |
TableOperations.flush(String tableName)
Deprecated.
As of release 1.4, replaced by
TableOperations.flush(String, Text, Text, boolean) |
void |
TableOperationsImpl.flush(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end,
boolean wait)
Flush a table
|
void |
TableOperations.flush(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end,
boolean wait)
Flush a tables data that is currently in memory.
|
List<ActiveScan> |
InstanceOperationsImpl.getActiveScans(String tserver) |
List<ActiveScan> |
InstanceOperations.getActiveScans(String tserver)
List the active scans on tablet server.
|
IteratorSetting |
TableOperationsHelper.getIteratorSetting(String tableName,
String name,
org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope scope) |
IteratorSetting |
TableOperations.getIteratorSetting(String tableName,
String name,
org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope scope)
Get the settings for an iterator.
|
Map<String,Set<org.apache.hadoop.io.Text>> |
TableOperationsImpl.getLocalityGroups(String tableName)
Gets the locality groups currently set for a table.
|
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.Text |
TableOperationsImpl.getMaxRow(String tableName,
Authorizations auths,
org.apache.hadoop.io.Text startRow,
boolean startInclusive,
org.apache.hadoop.io.Text endRow,
boolean endInclusive) |
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.
|
Iterable<Map.Entry<String,String>> |
TableOperationsImpl.getProperties(String tableName)
Gets properties of a table
|
Iterable<Map.Entry<String,String>> |
TableOperations.getProperties(String tableName)
Gets properties of a table
|
Map<String,String> |
InstanceOperationsImpl.getSiteConfiguration() |
Map<String,String> |
InstanceOperations.getSiteConfiguration() |
Map<String,String> |
InstanceOperationsImpl.getSystemConfiguration() |
Map<String,String> |
InstanceOperations.getSystemConfiguration() |
Authorizations |
SecurityOperationsImpl.getUserAuthorizations(String user)
Retrieves the user's authorizations for scanning
|
Authorizations |
SecurityOperations.getUserAuthorizations(String user)
Retrieves the user's authorizations for scanning
|
void |
SecurityOperationsImpl.grantSystemPermission(String user,
SystemPermission permission)
Grant a user a system permission
|
void |
SecurityOperations.grantSystemPermission(String user,
SystemPermission permission)
Grant a user a system permission
|
void |
SecurityOperationsImpl.grantTablePermission(String user,
String table,
TablePermission permission)
Grant a user a specific permission for a specific table
|
void |
SecurityOperations.grantTablePermission(String user,
String table,
TablePermission permission)
Grant a user a specific permission for a specific table
|
boolean |
SecurityOperationsImpl.hasSystemPermission(String user,
SystemPermission perm)
Verify the user has a particular system permission
|
boolean |
SecurityOperations.hasSystemPermission(String user,
SystemPermission perm)
Verify the user has a particular system permission
|
boolean |
SecurityOperationsImpl.hasTablePermission(String user,
String table,
TablePermission perm)
Verify the user has a particular table permission
|
boolean |
SecurityOperations.hasTablePermission(String user,
String table,
TablePermission perm)
Verify the user has a particular table permission
|
void |
TableOperationsImpl.importDirectory(String tableName,
String dir,
String failureDir,
boolean setTime) |
void |
TableOperations.importDirectory(String tableName,
String dir,
String failureDir,
boolean setTime)
Bulk import all the files in a directory into a table.
|
org.apache.accumulo.core.util.BulkImportHelper.AssignmentStats |
TableOperationsImpl.importDirectory(String tableName,
String dir,
String failureDir,
int numThreads,
int numAssignThreads,
boolean disableGC)
Deprecated.
|
org.apache.accumulo.core.util.BulkImportHelper.AssignmentStats |
TableOperations.importDirectory(String tableName,
String dir,
String failureDir,
int numThreads,
int numAssignThreads,
boolean disableGC)
Deprecated.
|
Map<String,EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope>> |
TableOperationsHelper.listIterators(String tableName) |
Map<String,EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope>> |
TableOperations.listIterators(String tableName)
Get a list of iterators for this table.
|
Set<String> |
SecurityOperationsImpl.listUsers()
Return a list of users in accumulo
|
Set<String> |
SecurityOperations.listUsers()
Return a list of users in accumulo
|
void |
TableOperationsImpl.merge(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end) |
void |
TableOperations.merge(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end)
Merge tablets between (start, end]
|
void |
TableOperationsImpl.offline(String tableName) |
void |
TableOperations.offline(String tableName) |
void |
TableOperationsImpl.online(String tableName) |
void |
TableOperations.online(String tableName) |
void |
TableOperationsHelper.removeIterator(String tableName,
String name,
EnumSet<org.apache.accumulo.core.iterators.IteratorUtil.IteratorScope> scopes) |
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 |
InstanceOperationsImpl.removeProperty(String property) |
void |
InstanceOperations.removeProperty(String property)
Removes a system property from zookeeper.
|
void |
TableOperationsImpl.removeProperty(String tableName,
String property)
Removes a property from a table
|
void |
TableOperations.removeProperty(String tableName,
String property)
Removes a property from a table
|
void |
TableOperationsImpl.rename(String oldTableName,
String newTableName)
Rename a table
|
void |
TableOperations.rename(String oldTableName,
String newTableName)
Rename a table
|
void |
SecurityOperationsImpl.revokeSystemPermission(String user,
SystemPermission permission)
Revoke a system permission from a user
|
void |
SecurityOperations.revokeSystemPermission(String user,
SystemPermission permission)
Revoke a system permission from a user
|
void |
SecurityOperationsImpl.revokeTablePermission(String user,
String table,
TablePermission permission)
Revoke a table permission for a specific user on a specific table
|
void |
SecurityOperations.revokeTablePermission(String user,
String table,
TablePermission permission)
Revoke a table permission for a specific user on a specific table
|
void |
TableOperationsImpl.setLocalityGroups(String tableName,
Map<String,Set<org.apache.hadoop.io.Text>> groups)
Sets a tables locality groups.
|
void |
TableOperations.setLocalityGroups(String tableName,
Map<String,Set<org.apache.hadoop.io.Text>> groups)
Sets a tables locality groups.
|
void |
InstanceOperationsImpl.setProperty(String property,
String value) |
void |
InstanceOperations.setProperty(String property,
String value)
Sets an system property in zookeeper.
|
void |
TableOperationsImpl.setProperty(String tableName,
String property,
String value)
Sets a property on a table
|
void |
TableOperations.setProperty(String tableName,
String property,
String value)
Sets a property on a table
|
Set<Range> |
TableOperationsImpl.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
Set<Range> |
TableOperations.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
boolean |
InstanceOperationsImpl.testClassLoad(String className,
String asTypeName) |
boolean |
InstanceOperations.testClassLoad(String className,
String asTypeName)
Test to see if the instance can load the given class as the given type.
|
Modifier and Type | Method and Description |
---|---|
protected void |
InputFormatBase.RecordReaderBase.setupIterators(Scanner scanner,
List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIterator> iterators,
List<org.apache.accumulo.core.client.mapreduce.InputFormatBase.AccumuloIteratorOption> options)
Apply the configured iterators from the configuration to the scanner.
|
protected boolean |
InputFormatBase.RecordReaderBase.setupRegex(org.apache.hadoop.mapreduce.TaskAttemptContext attempt,
Scanner scanner)
Deprecated.
since 1.4, configure
RegExFilter instead. |
Modifier and Type | Method and Description |
---|---|
void |
MockTableOperations.addAggregators(String tableName,
List<? extends org.apache.accumulo.core.iterators.conf.PerColumnIteratorConfig> aggregators)
Deprecated.
|
void |
MockTableOperations.addSplits(String tableName,
SortedSet<org.apache.hadoop.io.Text> partitionKeys) |
boolean |
MockSecurityOperations.authenticateUser(String name,
byte[] password) |
void |
MockTabletLocator.binMutations(List<Mutation> mutations,
Map<String,org.apache.accumulo.core.client.impl.TabletLocator.TabletServerMutations> binnedMutations,
List<Mutation> failures) |
List<Range> |
MockTabletLocator.binRanges(List<Range> ranges,
Map<String,Map<KeyExtent,List<Range>>> binnedRanges) |
void |
MockSecurityOperations.changeUserAuthorizations(String name,
Authorizations authorizations) |
void |
MockSecurityOperations.changeUserPassword(String name,
byte[] password) |
void |
MockTableOperations.clone(String srcTableName,
String newTableName,
boolean flush,
Map<String,String> propertiesToSet,
Set<String> propertiesToExclude) |
void |
MockTableOperations.compact(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end,
boolean flush,
boolean wait) |
void |
MockTableOperations.create(String tableName) |
void |
MockTableOperations.create(String tableName,
boolean versioningIter) |
void |
MockTableOperations.create(String tableName,
boolean versioningIter,
TimeType timeType) |
void |
MockSecurityOperations.createUser(String user,
byte[] password,
Authorizations authorizations) |
void |
MockTableOperations.delete(String tableName) |
void |
MockTableOperations.deleteRows(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end) |
void |
MockSecurityOperations.dropUser(String user) |
void |
MockTableOperations.flush(String tableName) |
void |
MockTableOperations.flush(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end,
boolean wait) |
List<ActiveScan> |
MockInstanceOperations.getActiveScans(String tserver) |
BatchWriter |
MockMultiTableBatchWriter.getBatchWriter(String table) |
Connector |
MockInstance.getConnector(org.apache.accumulo.core.security.thrift.AuthInfo auth) |
Connector |
MockInstance.getConnector(String user,
byte[] pass) |
Connector |
MockInstance.getConnector(String user,
ByteBuffer pass) |
Connector |
MockInstance.getConnector(String user,
CharSequence pass) |
Map<String,Set<org.apache.hadoop.io.Text>> |
MockTableOperations.getLocalityGroups(String tableName) |
org.apache.hadoop.io.Text |
MockTableOperations.getMaxRow(String tableName,
Authorizations auths,
org.apache.hadoop.io.Text startRow,
boolean startInclusive,
org.apache.hadoop.io.Text endRow,
boolean endInclusive) |
Map<String,String> |
MockInstanceOperations.getSiteConfiguration() |
Map<String,String> |
MockInstanceOperations.getSystemConfiguration() |
Authorizations |
MockSecurityOperations.getUserAuthorizations(String name) |
void |
MockSecurityOperations.grantSystemPermission(String name,
SystemPermission permission) |
void |
MockSecurityOperations.grantTablePermission(String name,
String tableName,
TablePermission permission) |
boolean |
MockSecurityOperations.hasSystemPermission(String name,
SystemPermission perm) |
boolean |
MockSecurityOperations.hasTablePermission(String name,
String tableName,
TablePermission perm) |
void |
MockTableOperations.importDirectory(String tableName,
String dir,
String failureDir,
boolean setTime) |
org.apache.accumulo.core.util.BulkImportHelper.AssignmentStats |
MockTableOperations.importDirectory(String tableName,
String dir,
String failureDir,
int numThreads,
int numAssignThreads,
boolean disableGC) |
Set<String> |
MockSecurityOperations.listUsers() |
org.apache.accumulo.core.client.impl.TabletLocator.TabletLocation |
MockTabletLocator.locateTablet(org.apache.hadoop.io.Text row,
boolean skipRow,
boolean retry) |
void |
MockTableOperations.merge(String tableName,
org.apache.hadoop.io.Text start,
org.apache.hadoop.io.Text end) |
void |
MockTableOperations.offline(String tableName) |
void |
MockTableOperations.online(String tableName) |
void |
MockInstanceOperations.removeProperty(String property) |
void |
MockTableOperations.removeProperty(String tableName,
String property) |
void |
MockTableOperations.rename(String oldTableName,
String newTableName) |
void |
MockSecurityOperations.revokeSystemPermission(String name,
SystemPermission permission) |
void |
MockSecurityOperations.revokeTablePermission(String name,
String tableName,
TablePermission permission) |
void |
MockTableOperations.setLocalityGroups(String tableName,
Map<String,Set<org.apache.hadoop.io.Text>> groups) |
void |
MockInstanceOperations.setProperty(String property,
String value) |
void |
MockTableOperations.setProperty(String tableName,
String property,
String value) |
Set<Range> |
MockTableOperations.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
boolean |
MockInstanceOperations.testClassLoad(String className,
String asTypeName) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.