org.apache.accumulo.server.test.performance.thrift
Class NullTserver.ThriftClientHandler
java.lang.Object
org.apache.accumulo.server.client.ClientServiceHandler
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
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 |
NullTserver.ThriftClientHandler
public NullTserver.ThriftClientHandler(TransactionWatcher watcher)
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.