org.apache.accumulo.proxy
Class ProxyServer

java.lang.Object
  extended by 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

Nested Class Summary
protected static class ProxyServer.BatchWriterPlusException
           
protected static class ProxyServer.ScannerPlusIterator
           
 
Field Summary
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 Summary
ProxyServer(Properties props)
           
 
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
 

Field Detail

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
Constructor Detail

ProxyServer

public ProxyServer(Properties props)
Method Detail

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.