org.apache.accumulo.proxy
public class ProxyServer extends Object implements AccumuloProxy.Iface
Modifier and Type | Class and Description |
---|---|
protected static class |
ProxyServer.BatchWriterPlusException |
protected static class |
ProxyServer.ScannerPlusIterator |
Modifier and Type | Field and Description |
---|---|
protected Instance |
instance |
static org.apache.log4j.Logger |
logger |
protected com.google.common.cache.Cache<UUID,ProxyServer.ScannerPlusIterator> |
scannerCache |
protected Class<? extends AuthenticationToken> |
tokenClass |
protected com.google.common.cache.Cache<UUID,ProxyServer.BatchWriterPlusException> |
writerCache |
Constructor and Description |
---|
ProxyServer(Properties props) |
public static final org.apache.log4j.Logger logger
protected Instance instance
protected Class<? extends AuthenticationToken> tokenClass
protected com.google.common.cache.Cache<UUID,ProxyServer.ScannerPlusIterator> scannerCache
protected com.google.common.cache.Cache<UUID,ProxyServer.BatchWriterPlusException> writerCache
public ProxyServer(Properties props)
protected Connector getConnector(ByteBuffer login) throws Exception
Exception
public int addConstraint(ByteBuffer login, String tableName, String constraintClassName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
addConstraint
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void addSplits(ByteBuffer login, String tableName, Set<ByteBuffer> splits) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
addSplits
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void clearLocatorCache(ByteBuffer login, String tableName) throws TableNotFoundException, org.apache.thrift.TException
clearLocatorCache
in interface AccumuloProxy.Iface
TableNotFoundException
org.apache.thrift.TException
public void compactTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, List<IteratorSetting> iterators, boolean flush, boolean wait) throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException
compactTable
in interface AccumuloProxy.Iface
AccumuloSecurityException
TableNotFoundException
AccumuloException
org.apache.thrift.TException
public void cancelCompaction(ByteBuffer login, String tableName) throws AccumuloSecurityException, TableNotFoundException, AccumuloException, org.apache.thrift.TException
cancelCompaction
in interface AccumuloProxy.Iface
AccumuloSecurityException
TableNotFoundException
AccumuloException
org.apache.thrift.TException
public void createTable(ByteBuffer login, String tableName, boolean versioningIter, TimeType type) throws AccumuloException, AccumuloSecurityException, TableExistsException, org.apache.thrift.TException
createTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableExistsException
org.apache.thrift.TException
public void deleteTable(ByteBuffer login, String tableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
deleteTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void deleteRows(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
deleteRows
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public boolean tableExists(ByteBuffer login, String tableName) throws org.apache.thrift.TException
tableExists
in interface AccumuloProxy.Iface
org.apache.thrift.TException
public void flushTable(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow, boolean wait) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
flushTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public Map<String,Set<String>> getLocalityGroups(ByteBuffer login, String tableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
getLocalityGroups
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public ByteBuffer getMaxRow(ByteBuffer login, String tableName, Set<ByteBuffer> auths, ByteBuffer startRow, boolean startInclusive, ByteBuffer endRow, boolean endInclusive) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
getMaxRow
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public Map<String,String> getTableProperties(ByteBuffer login, String tableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
getTableProperties
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public List<ByteBuffer> listSplits(ByteBuffer login, String tableName, int maxSplits) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
listSplits
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public Set<String> listTables(ByteBuffer login) throws org.apache.thrift.TException
listTables
in interface AccumuloProxy.Iface
org.apache.thrift.TException
public Map<String,Integer> listConstraints(ByteBuffer login, String tableName) throws AccumuloException, TableNotFoundException, org.apache.thrift.TException
listConstraints
in interface AccumuloProxy.Iface
AccumuloException
TableNotFoundException
org.apache.thrift.TException
public void mergeTablets(ByteBuffer login, String tableName, ByteBuffer startRow, ByteBuffer endRow) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
mergeTablets
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void offlineTable(ByteBuffer login, String tableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
offlineTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void onlineTable(ByteBuffer login, String tableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
onlineTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void removeConstraint(ByteBuffer login, String tableName, int constraint) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
removeConstraint
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void removeTableProperty(ByteBuffer login, String tableName, String property) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
removeTableProperty
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void renameTable(ByteBuffer login, String oldTableName, String newTableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, TableExistsException, org.apache.thrift.TException
renameTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
TableExistsException
org.apache.thrift.TException
public void setLocalityGroups(ByteBuffer login, String tableName, Map<String,Set<String>> groupStrings) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
setLocalityGroups
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void setTableProperty(ByteBuffer login, String tableName, String property, String value) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
setTableProperty
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public Map<String,String> tableIdMap(ByteBuffer login) throws org.apache.thrift.TException
tableIdMap
in interface AccumuloProxy.Iface
org.apache.thrift.TException
public Map<String,String> getSiteConfiguration(ByteBuffer login) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
getSiteConfiguration
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public Map<String,String> getSystemConfiguration(ByteBuffer login) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
getSystemConfiguration
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public List<String> getTabletServers(ByteBuffer login) throws org.apache.thrift.TException
getTabletServers
in interface AccumuloProxy.Iface
org.apache.thrift.TException
public List<ActiveScan> getActiveScans(ByteBuffer login, String tserver) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
getActiveScans
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public List<ActiveCompaction> getActiveCompactions(ByteBuffer login, String tserver) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
getActiveCompactions
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void removeProperty(ByteBuffer login, String property) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
removeProperty
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void setProperty(ByteBuffer login, String property, String value) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
setProperty
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public boolean testClassLoad(ByteBuffer login, String className, String asTypeName) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
testClassLoad
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public boolean authenticateUser(ByteBuffer login, String user, Map<String,String> properties) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
authenticateUser
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void changeUserAuthorizations(ByteBuffer login, String user, Set<ByteBuffer> authorizations) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
changeUserAuthorizations
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void changeLocalUserPassword(ByteBuffer login, String user, ByteBuffer password) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
changeLocalUserPassword
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void createLocalUser(ByteBuffer login, String user, ByteBuffer password) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
createLocalUser
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void dropLocalUser(ByteBuffer login, String user) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
dropLocalUser
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public List<ByteBuffer> getUserAuthorizations(ByteBuffer login, String user) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
getUserAuthorizations
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void grantSystemPermission(ByteBuffer login, String user, SystemPermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
grantSystemPermission
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void grantTablePermission(ByteBuffer login, String user, String table, TablePermission perm) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
grantTablePermission
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public boolean hasSystemPermission(ByteBuffer login, String user, SystemPermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
hasSystemPermission
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public boolean hasTablePermission(ByteBuffer login, String user, String table, TablePermission perm) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
hasTablePermission
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public Set<String> listLocalUsers(ByteBuffer login) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
listLocalUsers
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void revokeSystemPermission(ByteBuffer login, String user, SystemPermission perm) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
revokeSystemPermission
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public void revokeTablePermission(ByteBuffer login, String user, String table, TablePermission perm) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
revokeTablePermission
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public String createScanner(ByteBuffer login, String tableName, ScanOptions opts) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
createScanner
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public String createBatchScanner(ByteBuffer login, String tableName, BatchScanOptions opts) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
createBatchScanner
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public boolean hasNext(String scanner) throws UnknownScanner, org.apache.thrift.TException
hasNext
in interface AccumuloProxy.Iface
UnknownScanner
org.apache.thrift.TException
public KeyValueAndPeek nextEntry(String scanner) throws NoMoreEntriesException, UnknownScanner, AccumuloSecurityException, org.apache.thrift.TException
nextEntry
in interface AccumuloProxy.Iface
NoMoreEntriesException
UnknownScanner
AccumuloSecurityException
org.apache.thrift.TException
public ScanResult nextK(String scanner, int k) throws NoMoreEntriesException, UnknownScanner, AccumuloSecurityException, org.apache.thrift.TException
nextK
in interface AccumuloProxy.Iface
NoMoreEntriesException
UnknownScanner
AccumuloSecurityException
org.apache.thrift.TException
public void closeScanner(String scanner) throws UnknownScanner, org.apache.thrift.TException
closeScanner
in interface AccumuloProxy.Iface
UnknownScanner
org.apache.thrift.TException
public void updateAndFlush(ByteBuffer login, String tableName, Map<ByteBuffer,List<ColumnUpdate>> cells) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, MutationsRejectedException, org.apache.thrift.TException
updateAndFlush
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
MutationsRejectedException
org.apache.thrift.TException
public String createWriter(ByteBuffer login, String tableName, WriterOptions opts) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
createWriter
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void update(String writer, Map<ByteBuffer,List<ColumnUpdate>> cells) throws org.apache.thrift.TException
update
in interface AccumuloProxy.Iface
org.apache.thrift.TException
public void flush(String writer) throws UnknownWriter, MutationsRejectedException, org.apache.thrift.TException
flush
in interface AccumuloProxy.Iface
UnknownWriter
MutationsRejectedException
org.apache.thrift.TException
public void closeWriter(String writer) throws UnknownWriter, MutationsRejectedException, org.apache.thrift.TException
closeWriter
in interface AccumuloProxy.Iface
UnknownWriter
MutationsRejectedException
org.apache.thrift.TException
public void attachIterator(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes) throws AccumuloSecurityException, AccumuloException, TableNotFoundException, org.apache.thrift.TException
attachIterator
in interface AccumuloProxy.Iface
AccumuloSecurityException
AccumuloException
TableNotFoundException
org.apache.thrift.TException
public void checkIteratorConflicts(ByteBuffer login, String tableName, IteratorSetting setting, Set<IteratorScope> scopes) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
checkIteratorConflicts
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void cloneTable(ByteBuffer login, String tableName, String newTableName, boolean flush, Map<String,String> propertiesToSet, Set<String> propertiesToExclude) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, TableExistsException, org.apache.thrift.TException
cloneTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
TableExistsException
org.apache.thrift.TException
public void exportTable(ByteBuffer login, String tableName, String exportDir) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
exportTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void importTable(ByteBuffer login, String tableName, String importDir) throws AccumuloException, AccumuloSecurityException, TableExistsException, org.apache.thrift.TException
importTable
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableExistsException
org.apache.thrift.TException
public IteratorSetting getIteratorSetting(ByteBuffer login, String tableName, String iteratorName, IteratorScope scope) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
getIteratorSetting
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public Map<String,Set<IteratorScope>> listIterators(ByteBuffer login, String tableName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
listIterators
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void removeIterator(ByteBuffer login, String tableName, String iterName, Set<IteratorScope> scopes) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
removeIterator
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public Set<Range> splitRangeByTablets(ByteBuffer login, String tableName, Range range, int maxSplits) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
splitRangeByTablets
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
public void importDirectory(ByteBuffer login, String tableName, String importDir, String failureDir, boolean setTime) throws TableNotFoundException, AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
importDirectory
in interface AccumuloProxy.Iface
TableNotFoundException
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public Range getRowRange(ByteBuffer row) throws org.apache.thrift.TException
getRowRange
in interface AccumuloProxy.Iface
org.apache.thrift.TException
public Key getFollowing(Key key, PartialKey part) throws org.apache.thrift.TException
getFollowing
in interface AccumuloProxy.Iface
org.apache.thrift.TException
public void pingTabletServer(ByteBuffer login, String tserver) throws AccumuloException, AccumuloSecurityException, org.apache.thrift.TException
pingTabletServer
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
org.apache.thrift.TException
public ByteBuffer login(String principal, Map<String,String> loginProperties) throws AccumuloSecurityException, org.apache.thrift.TException
login
in interface AccumuloProxy.Iface
AccumuloSecurityException
org.apache.thrift.TException
public boolean testTableClassLoad(ByteBuffer login, String tableName, String className, String asTypeName) throws AccumuloException, AccumuloSecurityException, TableNotFoundException, org.apache.thrift.TException
testTableClassLoad
in interface AccumuloProxy.Iface
AccumuloException
AccumuloSecurityException
TableNotFoundException
org.apache.thrift.TException
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.