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