org.apache.accumulo.test.performance.thrift
public static class NullTserver.ThriftClientHandler extends ClientServiceHandler implements TabletClientService.Iface
transactionWatcher
Constructor and Description |
---|
NullTserver.ThriftClientHandler(Instance instance,
TransactionWatcher watcher) |
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 |
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) |
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 |
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) |
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 |
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) |
authenticate, authenticateUser, bulkImportFiles, changeAuthorizations, changeLocalUserPassword, checkClass, checkTableClass, checkTableId, createLocalUser, dropLocalUser, getConfiguration, getInstanceId, getRootTabletLocation, getTableConfiguration, getUserAuthorizations, getZooKeepers, grantSystemPermission, grantTablePermission, hasSystemPermission, hasTablePermission, isActive, listLocalUsers, ping, revokeSystemPermission, revokeTablePermission
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
authenticate, authenticateUser, bulkImportFiles, changeAuthorizations, changeLocalUserPassword, checkClass, checkTableClass, createLocalUser, dropLocalUser, getConfiguration, getInstanceId, getRootTabletLocation, getTableConfiguration, getUserAuthorizations, getZooKeepers, grantSystemPermission, grantTablePermission, hasSystemPermission, hasTablePermission, isActive, listLocalUsers, ping, revokeSystemPermission, revokeTablePermission
public NullTserver.ThriftClientHandler(Instance instance, TransactionWatcher watcher)
public long startUpdate(TInfo tinfo, TCredentials credentials)
startUpdate
in interface TabletClientService.Iface
public void applyUpdates(TInfo tinfo, long updateID, TKeyExtent keyExtent, List<TMutation> mutation)
applyUpdates
in interface TabletClientService.Iface
public UpdateErrors closeUpdate(TInfo tinfo, long updateID)
closeUpdate
in interface TabletClientService.Iface
public List<TKeyExtent> bulkImport(TInfo tinfo, TCredentials credentials, long tid, Map<TKeyExtent,Map<String,MapFileInfo>> files, boolean setTime)
bulkImport
in interface TabletClientService.Iface
public void closeMultiScan(TInfo tinfo, long scanID)
closeMultiScan
in interface TabletClientService.Iface
public void closeScan(TInfo tinfo, long scanID)
closeScan
in interface TabletClientService.Iface
public MultiScanResult continueMultiScan(TInfo tinfo, long scanID)
continueMultiScan
in interface TabletClientService.Iface
public ScanResult continueScan(TInfo tinfo, long scanID)
continueScan
in interface TabletClientService.Iface
public void splitTablet(TInfo tinfo, TCredentials credentials, TKeyExtent extent, ByteBuffer splitPoint)
splitTablet
in interface TabletClientService.Iface
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)
startMultiScan
in interface TabletClientService.Iface
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)
startScan
in interface TabletClientService.Iface
public void update(TInfo tinfo, TCredentials credentials, TKeyExtent keyExtent, TMutation mutation)
update
in interface TabletClientService.Iface
public TabletServerStatus getTabletServerStatus(TInfo tinfo, TCredentials credentials) throws ThriftSecurityException, org.apache.thrift.TException
getTabletServerStatus
in interface TabletClientService.Iface
ThriftSecurityException
org.apache.thrift.TException
public List<TabletStats> getTabletStats(TInfo tinfo, TCredentials credentials, String tableId) throws ThriftSecurityException, org.apache.thrift.TException
getTabletStats
in interface TabletClientService.Iface
ThriftSecurityException
org.apache.thrift.TException
public TabletStats getHistoricalStats(TInfo tinfo, TCredentials credentials) throws ThriftSecurityException, org.apache.thrift.TException
getHistoricalStats
in interface TabletClientService.Iface
ThriftSecurityException
org.apache.thrift.TException
public void halt(TInfo tinfo, TCredentials credentials, String lock) throws ThriftSecurityException, org.apache.thrift.TException
halt
in interface TabletClientService.Iface
ThriftSecurityException
org.apache.thrift.TException
public void fastHalt(TInfo tinfo, TCredentials credentials, String lock)
fastHalt
in interface TabletClientService.Iface
public void loadTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent) throws org.apache.thrift.TException
loadTablet
in interface TabletClientService.Iface
org.apache.thrift.TException
public void unloadTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, boolean save) throws org.apache.thrift.TException
unloadTablet
in interface TabletClientService.Iface
org.apache.thrift.TException
public List<ActiveScan> getActiveScans(TInfo tinfo, TCredentials credentials) throws ThriftSecurityException, org.apache.thrift.TException
getActiveScans
in interface TabletClientService.Iface
ThriftSecurityException
org.apache.thrift.TException
public void chop(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent) throws org.apache.thrift.TException
chop
in interface TabletClientService.Iface
org.apache.thrift.TException
public void flushTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent) throws org.apache.thrift.TException
flushTablet
in interface TabletClientService.Iface
org.apache.thrift.TException
public void compact(TInfo tinfo, TCredentials credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow) throws org.apache.thrift.TException
compact
in interface TabletClientService.Iface
org.apache.thrift.TException
public void flush(TInfo tinfo, TCredentials credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow) throws org.apache.thrift.TException
flush
in interface TabletClientService.Iface
org.apache.thrift.TException
public void removeLogs(TInfo tinfo, TCredentials credentials, List<String> filenames) throws org.apache.thrift.TException
removeLogs
in interface TabletClientService.Iface
org.apache.thrift.TException
public List<ActiveCompaction> getActiveCompactions(TInfo tinfo, TCredentials credentials) throws ThriftSecurityException, org.apache.thrift.TException
getActiveCompactions
in interface TabletClientService.Iface
ThriftSecurityException
org.apache.thrift.TException
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.