org.apache.accumulo.server.test.performance.thrift
Class NullTserver.ThriftClientHandler

java.lang.Object
  extended by org.apache.accumulo.server.client.ClientServiceHandler
      extended by org.apache.accumulo.server.test.performance.thrift.NullTserver.ThriftClientHandler
All Implemented Interfaces:
ClientService.Iface, TabletClientService.Iface
Direct Known Subclasses:
ZombieTServer.ThriftClientHandler
Enclosing class:
NullTserver

public static class NullTserver.ThriftClientHandler
extends ClientServiceHandler
implements TabletClientService.Iface


Constructor Summary
NullTserver.ThriftClientHandler(TransactionWatcher watcher)
           
 
Method Summary
 void applyUpdates(TInfo tinfo, long updateID, TKeyExtent keyExtent, List<TMutation> mutation)
           
 List<TKeyExtent> bulkImport(TInfo tinfo, AuthInfo credentials, long tid, Map<TKeyExtent,Map<String,MapFileInfo>> files, boolean setTime)
           
 void chop(TInfo tinfo, AuthInfo credentials, String lock, TKeyExtent extent)
           
 void closeMultiScan(TInfo tinfo, long scanID)
           
 void closeScan(TInfo tinfo, long scanID)
           
 UpdateErrors closeUpdate(TInfo tinfo, long updateID)
           
 void compact(TInfo tinfo, AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow)
           
 MultiScanResult continueMultiScan(TInfo tinfo, long scanID)
           
 ScanResult continueScan(TInfo tinfo, long scanID)
           
 void fastHalt(TInfo tinfo, AuthInfo credentials, String lock)
           
 void flush(TInfo tinfo, AuthInfo credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow)
           
 void flushTablet(TInfo tinfo, AuthInfo credentials, String lock, TKeyExtent extent)
           
 List<ActiveScan> getActiveScans(TInfo tinfo, AuthInfo credentials)
           
 TabletStats getHistoricalStats(TInfo tinfo, AuthInfo credentials)
           
 TabletServerStatus getTabletServerStatus(TInfo tinfo, AuthInfo credentials)
           
 List<TabletStats> getTabletStats(TInfo tinfo, AuthInfo credentials, String tableId)
           
 void halt(TInfo tinfo, AuthInfo credentials, String lock)
           
 void loadTablet(TInfo tinfo, AuthInfo credentials, String lock, TKeyExtent extent)
           
 void splitTablet(TInfo tinfo, AuthInfo credentials, TKeyExtent extent, ByteBuffer splitPoint)
           
 InitialMultiScan startMultiScan(TInfo tinfo, AuthInfo credentials, Map<TKeyExtent,List<TRange>> batch, List<TColumn> columns, List<IterInfo> ssiList, Map<String,Map<String,String>> ssio, List<ByteBuffer> authorizations, boolean waitForWrites)
           
 InitialScan startScan(TInfo tinfo, AuthInfo credentials, TKeyExtent extent, TRange range, List<TColumn> columns, int batchSize, List<IterInfo> ssiList, Map<String,Map<String,String>> ssio, List<ByteBuffer> authorizations, boolean waitForWrites, boolean isolated)
           
 long startUpdate(TInfo tinfo, AuthInfo credentials)
           
 void unloadTablet(TInfo tinfo, AuthInfo credentials, String lock, TKeyExtent extent, boolean save)
           
 void update(TInfo tinfo, AuthInfo credentials, TKeyExtent keyExtent, TMutation mutation)
           
 void useLoggers(TInfo tinfo, AuthInfo credentials, Set<String> loggers)
           
 
Methods inherited from class org.apache.accumulo.server.client.ClientServiceHandler
authenticateUser, bulkImportFiles, changeAuthorizations, changePassword, checkClass, checkTableId, createUser, dropUser, getConfiguration, getInstanceId, getRootTabletLocation, getTableConfiguration, getUserAuthorizations, getZooKeepers, grantSystemPermission, grantTablePermission, hasSystemPermission, hasTablePermission, isActive, listUsers, ping, revokeSystemPermission, revokeTablePermission
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.accumulo.core.client.impl.thrift.ClientService.Iface
authenticateUser, bulkImportFiles, changeAuthorizations, changePassword, checkClass, createUser, dropUser, getConfiguration, getInstanceId, getRootTabletLocation, getTableConfiguration, getUserAuthorizations, getZooKeepers, grantSystemPermission, grantTablePermission, hasSystemPermission, hasTablePermission, isActive, listUsers, ping, revokeSystemPermission, revokeTablePermission
 

Constructor Detail

NullTserver.ThriftClientHandler

public NullTserver.ThriftClientHandler(TransactionWatcher watcher)
Method Detail

startUpdate

public long startUpdate(TInfo tinfo,
                        AuthInfo credentials)
Specified by:
startUpdate in interface TabletClientService.Iface

applyUpdates

public void applyUpdates(TInfo tinfo,
                         long updateID,
                         TKeyExtent keyExtent,
                         List<TMutation> mutation)
Specified by:
applyUpdates in interface TabletClientService.Iface

closeUpdate

public UpdateErrors closeUpdate(TInfo tinfo,
                                long updateID)
Specified by:
closeUpdate in interface TabletClientService.Iface

bulkImport

public List<TKeyExtent> bulkImport(TInfo tinfo,
                                   AuthInfo credentials,
                                   long tid,
                                   Map<TKeyExtent,Map<String,MapFileInfo>> files,
                                   boolean setTime)
Specified by:
bulkImport in interface TabletClientService.Iface

closeMultiScan

public void closeMultiScan(TInfo tinfo,
                           long scanID)
Specified by:
closeMultiScan in interface TabletClientService.Iface

closeScan

public void closeScan(TInfo tinfo,
                      long scanID)
Specified by:
closeScan in interface TabletClientService.Iface

continueMultiScan

public MultiScanResult continueMultiScan(TInfo tinfo,
                                         long scanID)
Specified by:
continueMultiScan in interface TabletClientService.Iface

continueScan

public ScanResult continueScan(TInfo tinfo,
                               long scanID)
Specified by:
continueScan in interface TabletClientService.Iface

splitTablet

public void splitTablet(TInfo tinfo,
                        AuthInfo credentials,
                        TKeyExtent extent,
                        ByteBuffer splitPoint)
Specified by:
splitTablet in interface TabletClientService.Iface

startMultiScan

public InitialMultiScan startMultiScan(TInfo tinfo,
                                       AuthInfo credentials,
                                       Map<TKeyExtent,List<TRange>> batch,
                                       List<TColumn> columns,
                                       List<IterInfo> ssiList,
                                       Map<String,Map<String,String>> ssio,
                                       List<ByteBuffer> authorizations,
                                       boolean waitForWrites)
Specified by:
startMultiScan in interface TabletClientService.Iface

startScan

public InitialScan startScan(TInfo tinfo,
                             AuthInfo credentials,
                             TKeyExtent extent,
                             TRange range,
                             List<TColumn> columns,
                             int batchSize,
                             List<IterInfo> ssiList,
                             Map<String,Map<String,String>> ssio,
                             List<ByteBuffer> authorizations,
                             boolean waitForWrites,
                             boolean isolated)
Specified by:
startScan in interface TabletClientService.Iface

update

public void update(TInfo tinfo,
                   AuthInfo credentials,
                   TKeyExtent keyExtent,
                   TMutation mutation)
Specified by:
update in interface TabletClientService.Iface

getTabletServerStatus

public TabletServerStatus getTabletServerStatus(TInfo tinfo,
                                                AuthInfo credentials)
                                         throws ThriftSecurityException,
                                                org.apache.thrift.TException
Specified by:
getTabletServerStatus in interface TabletClientService.Iface
Throws:
ThriftSecurityException
org.apache.thrift.TException

getTabletStats

public List<TabletStats> getTabletStats(TInfo tinfo,
                                        AuthInfo credentials,
                                        String tableId)
                                 throws ThriftSecurityException,
                                        org.apache.thrift.TException
Specified by:
getTabletStats in interface TabletClientService.Iface
Throws:
ThriftSecurityException
org.apache.thrift.TException

getHistoricalStats

public TabletStats getHistoricalStats(TInfo tinfo,
                                      AuthInfo credentials)
                               throws ThriftSecurityException,
                                      org.apache.thrift.TException
Specified by:
getHistoricalStats in interface TabletClientService.Iface
Throws:
ThriftSecurityException
org.apache.thrift.TException

halt

public void halt(TInfo tinfo,
                 AuthInfo credentials,
                 String lock)
          throws ThriftSecurityException,
                 org.apache.thrift.TException
Specified by:
halt in interface TabletClientService.Iface
Throws:
ThriftSecurityException
org.apache.thrift.TException

fastHalt

public void fastHalt(TInfo tinfo,
                     AuthInfo credentials,
                     String lock)
Specified by:
fastHalt in interface TabletClientService.Iface

loadTablet

public void loadTablet(TInfo tinfo,
                       AuthInfo credentials,
                       String lock,
                       TKeyExtent extent)
                throws org.apache.thrift.TException
Specified by:
loadTablet in interface TabletClientService.Iface
Throws:
org.apache.thrift.TException

unloadTablet

public void unloadTablet(TInfo tinfo,
                         AuthInfo credentials,
                         String lock,
                         TKeyExtent extent,
                         boolean save)
                  throws org.apache.thrift.TException
Specified by:
unloadTablet in interface TabletClientService.Iface
Throws:
org.apache.thrift.TException

useLoggers

public void useLoggers(TInfo tinfo,
                       AuthInfo credentials,
                       Set<String> loggers)
                throws org.apache.thrift.TException
Specified by:
useLoggers in interface TabletClientService.Iface
Throws:
org.apache.thrift.TException

getActiveScans

public List<ActiveScan> getActiveScans(TInfo tinfo,
                                       AuthInfo credentials)
                                throws ThriftSecurityException,
                                       org.apache.thrift.TException
Specified by:
getActiveScans in interface TabletClientService.Iface
Throws:
ThriftSecurityException
org.apache.thrift.TException

chop

public void chop(TInfo tinfo,
                 AuthInfo credentials,
                 String lock,
                 TKeyExtent extent)
          throws org.apache.thrift.TException
Specified by:
chop in interface TabletClientService.Iface
Throws:
org.apache.thrift.TException

flushTablet

public void flushTablet(TInfo tinfo,
                        AuthInfo credentials,
                        String lock,
                        TKeyExtent extent)
                 throws org.apache.thrift.TException
Specified by:
flushTablet in interface TabletClientService.Iface
Throws:
org.apache.thrift.TException

compact

public void compact(TInfo tinfo,
                    AuthInfo credentials,
                    String lock,
                    String tableId,
                    ByteBuffer startRow,
                    ByteBuffer endRow)
             throws org.apache.thrift.TException
Specified by:
compact in interface TabletClientService.Iface
Throws:
org.apache.thrift.TException

flush

public void flush(TInfo tinfo,
                  AuthInfo credentials,
                  String lock,
                  String tableId,
                  ByteBuffer startRow,
                  ByteBuffer endRow)
           throws org.apache.thrift.TException
Specified by:
flush in interface TabletClientService.Iface
Throws:
org.apache.thrift.TException


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.