org.apache.accumulo.test.performance.thrift

Class NullTserver.ThriftClientHandler

java.lang.Object

org.apache.accumulo.server.client.ClientServiceHandler

org.apache.accumulo.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

Field Summary

Fields inherited from class org.apache.accumulo.server.client.ClientServiceHandler

transactionWatcher

Constructor Summary

Constructors

Constructor and Description
NullTserver.ThriftClientHandler(Instance instance, TransactionWatcher watcher)

Method Summary

Methods

Modifier and Type	Method and Description
void	applyUpdates(TInfo tinfo, long updateID, TKeyExtent keyExtent, List<TMutation> mutation)
List<TKeyExtent>	bulkImport(TInfo tinfo, TCredentials credentials, long tid, Map<TKeyExtent,Map<String,MapFileInfo>> files, boolean setTime)
void	chop(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent)
void	closeConditionalUpdate(TInfo tinfo, long sessID)
void	closeMultiScan(TInfo tinfo, long scanID)
void	closeScan(TInfo tinfo, long scanID)
UpdateErrors	closeUpdate(TInfo tinfo, long updateID)
void	compact(TInfo tinfo, TCredentials credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow)
List<TCMResult>	conditionalUpdate(TInfo tinfo, long sessID, Map<TKeyExtent,List<TConditionalMutation>> mutations, List<String> symbols)
MultiScanResult	continueMultiScan(TInfo tinfo, long scanID)
ScanResult	continueScan(TInfo tinfo, long scanID)
void	fastHalt(TInfo tinfo, TCredentials credentials, String lock)
void	flush(TInfo tinfo, TCredentials credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow)
void	flushTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent)
List<ActiveCompaction>	getActiveCompactions(TInfo tinfo, TCredentials credentials)
List<ActiveScan>	getActiveScans(TInfo tinfo, TCredentials credentials)
TabletStats	getHistoricalStats(TInfo tinfo, TCredentials credentials)
TabletServerStatus	getTabletServerStatus(TInfo tinfo, TCredentials credentials)
List<TabletStats>	getTabletStats(TInfo tinfo, TCredentials credentials, String tableId)
void	halt(TInfo tinfo, TCredentials credentials, String lock)
void	invalidateConditionalUpdate(TInfo tinfo, long sessID)
void	loadTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent)
void	removeLogs(TInfo tinfo, TCredentials credentials, List<String> filenames)
void	splitTablet(TInfo tinfo, TCredentials credentials, TKeyExtent extent, ByteBuffer splitPoint)
TConditionalSession	startConditionalUpdate(TInfo tinfo, TCredentials credentials, List<ByteBuffer> authorizations, String tableID)
InitialMultiScan	startMultiScan(TInfo tinfo, TCredentials 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, TCredentials 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 readaheadThreshold)
long	startUpdate(TInfo tinfo, TCredentials credentials)
void	unloadTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, boolean save)
void	update(TInfo tinfo, TCredentials credentials, TKeyExtent keyExtent, TMutation mutation)

Methods inherited from class org.apache.accumulo.server.client.ClientServiceHandler

authenticate, authenticateUser, bulkImportFiles, changeAuthorizations, changeLocalUserPassword, checkClass, checkNamespaceClass, checkNamespaceId, checkTableClass, checkTableId, createLocalUser, dropLocalUser, getConfiguration, getDiskUsage, getInstanceId, getNamespaceConfiguration, getRootTabletLocation, getTableConfiguration, getUserAuthorizations, getZooKeepers, grantNamespacePermission, grantSystemPermission, grantTablePermission, hasNamespacePermission, hasSystemPermission, hasTablePermission, isActive, listLocalUsers, ping, revokeNamespacePermission, 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

authenticate, authenticateUser, bulkImportFiles, changeAuthorizations, changeLocalUserPassword, checkClass, checkNamespaceClass, checkTableClass, createLocalUser, dropLocalUser, getConfiguration, getDiskUsage, getInstanceId, getNamespaceConfiguration, getRootTabletLocation, getTableConfiguration, getUserAuthorizations, getZooKeepers, grantNamespacePermission, grantSystemPermission, grantTablePermission, hasNamespacePermission, hasSystemPermission, hasTablePermission, isActive, listLocalUsers, ping, revokeNamespacePermission, revokeSystemPermission, revokeTablePermission

Constructor Detail

NullTserver.ThriftClientHandler

public NullTserver.ThriftClientHandler(Instance instance,
                               TransactionWatcher watcher)

Method Detail

startUpdate

public long startUpdate(TInfo tinfo,
               TCredentials 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,
                          TCredentials 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,
               TCredentials credentials,
               TKeyExtent extent,
               ByteBuffer splitPoint)

Specified by:

splitTablet in interface TabletClientService.Iface

startMultiScan

public InitialMultiScan startMultiScan(TInfo tinfo,
                              TCredentials 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,
                    TCredentials 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 readaheadThreshold)

Specified by:

startScan in interface TabletClientService.Iface

update

public void update(TInfo tinfo,
          TCredentials credentials,
          TKeyExtent keyExtent,
          TMutation mutation)

Specified by:

update in interface TabletClientService.Iface

getTabletServerStatus

public TabletServerStatus getTabletServerStatus(TInfo tinfo,
                                       TCredentials 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,
                               TCredentials 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,
                             TCredentials 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,
        TCredentials 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,
            TCredentials credentials,
            String lock)

Specified by:

fastHalt in interface TabletClientService.Iface

loadTablet

public void loadTablet(TInfo tinfo,
              TCredentials 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,
                TCredentials credentials,
                String lock,
                TKeyExtent extent,
                boolean save)
                  throws org.apache.thrift.TException

Specified by:

unloadTablet in interface TabletClientService.Iface

Throws:

org.apache.thrift.TException

getActiveScans

public List<ActiveScan> getActiveScans(TInfo tinfo,
                              TCredentials 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,
        TCredentials 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,
               TCredentials 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,
           TCredentials 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,
         TCredentials 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

removeLogs

public void removeLogs(TInfo tinfo,
              TCredentials credentials,
              List<String> filenames)
                throws org.apache.thrift.TException

Specified by:

removeLogs in interface TabletClientService.Iface

Throws:

org.apache.thrift.TException

getActiveCompactions

public List<ActiveCompaction> getActiveCompactions(TInfo tinfo,
                                          TCredentials credentials)
                                            throws ThriftSecurityException,
                                                   org.apache.thrift.TException

Specified by:

getActiveCompactions in interface TabletClientService.Iface

Throws:

ThriftSecurityException

org.apache.thrift.TException

startConditionalUpdate

public TConditionalSession startConditionalUpdate(TInfo tinfo,
                                         TCredentials credentials,
                                         List<ByteBuffer> authorizations,
                                         String tableID)
                                           throws ThriftSecurityException,
                                                  org.apache.thrift.TException

Specified by:

startConditionalUpdate in interface TabletClientService.Iface

Throws:

ThriftSecurityException

org.apache.thrift.TException

conditionalUpdate

public List<TCMResult> conditionalUpdate(TInfo tinfo,
                                long sessID,
                                Map<TKeyExtent,List<TConditionalMutation>> mutations,
                                List<String> symbols)
                                  throws NoSuchScanIDException,
                                         org.apache.thrift.TException

Specified by:

conditionalUpdate in interface TabletClientService.Iface

Throws:

NoSuchScanIDException

org.apache.thrift.TException

invalidateConditionalUpdate

public void invalidateConditionalUpdate(TInfo tinfo,
                               long sessID)
                                 throws org.apache.thrift.TException

Specified by:

invalidateConditionalUpdate in interface TabletClientService.Iface

Throws:

org.apache.thrift.TException

closeConditionalUpdate

public void closeConditionalUpdate(TInfo tinfo,
                          long sessID)
                            throws org.apache.thrift.TException

Specified by:

closeConditionalUpdate in interface TabletClientService.Iface

Throws:

org.apache.thrift.TException