Class TabletClientService.AsyncClient
- java.lang.Object
-
- org.apache.thrift.async.TAsyncClient
-
- org.apache.accumulo.core.clientImpl.thrift.ClientService.AsyncClient
-
- org.apache.accumulo.core.tabletserver.thrift.TabletClientService.AsyncClient
-
- All Implemented Interfaces:
ClientService.AsyncIface,TabletClientService.AsyncIface
- Enclosing class:
- TabletClientService
public static class TabletClientService.AsyncClient extends ClientService.AsyncClient implements TabletClientService.AsyncIface
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.accumulo.core.clientImpl.thrift.ClientService.AsyncClient
ClientService.AsyncClient.authenticate_call, ClientService.AsyncClient.authenticateUser_call, ClientService.AsyncClient.bulkImportFiles_call, ClientService.AsyncClient.changeAuthorizations_call, ClientService.AsyncClient.changeLocalUserPassword_call, ClientService.AsyncClient.checkClass_call, ClientService.AsyncClient.checkNamespaceClass_call, ClientService.AsyncClient.checkTableClass_call, ClientService.AsyncClient.createLocalUser_call, ClientService.AsyncClient.dropLocalUser_call, ClientService.AsyncClient.getConfiguration_call, ClientService.AsyncClient.getDiskUsage_call, ClientService.AsyncClient.getInstanceId_call, ClientService.AsyncClient.getNamespaceConfiguration_call, ClientService.AsyncClient.getRootTabletLocation_call, ClientService.AsyncClient.getTableConfiguration_call, ClientService.AsyncClient.getUserAuthorizations_call, ClientService.AsyncClient.getZooKeepers_call, ClientService.AsyncClient.grantNamespacePermission_call, ClientService.AsyncClient.grantSystemPermission_call, ClientService.AsyncClient.grantTablePermission_call, ClientService.AsyncClient.hasNamespacePermission_call, ClientService.AsyncClient.hasSystemPermission_call, ClientService.AsyncClient.hasTablePermission_call, ClientService.AsyncClient.isActive_call, ClientService.AsyncClient.listLocalUsers_call, ClientService.AsyncClient.ping_call, ClientService.AsyncClient.revokeNamespacePermission_call, ClientService.AsyncClient.revokeSystemPermission_call, ClientService.AsyncClient.revokeTablePermission_call
-
-
Constructor Summary
Constructors Constructor Description AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidapplyUpdates(TInfo tinfo, long updateID, TKeyExtent keyExtent, List<TMutation> mutations, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidbulkImport(TInfo tinfo, TCredentials credentials, long tid, Map<TKeyExtent,Map<String,MapFileInfo>> files, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<List<TKeyExtent>> resultHandler)voidchop(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidcloseConditionalUpdate(TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidcloseMultiScan(TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidcloseScan(TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidcloseUpdate(TInfo tinfo, long updateID, org.apache.thrift.async.AsyncMethodCallback<UpdateErrors> resultHandler)voidcompact(TInfo tinfo, TCredentials credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidconditionalUpdate(TInfo tinfo, long sessID, Map<TKeyExtent,List<TConditionalMutation>> mutations, List<String> symbols, org.apache.thrift.async.AsyncMethodCallback<List<TCMResult>> resultHandler)voidcontinueMultiScan(TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<MultiScanResult> resultHandler)voidcontinueScan(TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<ScanResult> resultHandler)voidcontiuneGetSummaries(TInfo tinfo, long sessionId, org.apache.thrift.async.AsyncMethodCallback<TSummaries> resultHandler)voidfastHalt(TInfo tinfo, TCredentials credentials, String lock, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidflush(TInfo tinfo, TCredentials credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidflushTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidgetActiveCompactions(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<List<ActiveCompaction>> resultHandler)voidgetActiveLogs(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler)voidgetActiveScans(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<List<ActiveScan>> resultHandler)voidgetHistoricalStats(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<TabletStats> resultHandler)voidgetTabletServerStatus(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<TabletServerStatus> resultHandler)voidgetTabletStats(TInfo tinfo, TCredentials credentials, String tableId, org.apache.thrift.async.AsyncMethodCallback<List<TabletStats>> resultHandler)voidhalt(TInfo tinfo, TCredentials credentials, String lock, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidinvalidateConditionalUpdate(TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidloadFiles(TInfo tinfo, TCredentials credentials, long tid, String dir, Map<TKeyExtent,Map<String,MapFileInfo>> files, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidloadTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidremoveLogs(TInfo tinfo, TCredentials credentials, List<String> filenames, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidsplitTablet(TInfo tinfo, TCredentials credentials, TKeyExtent extent, ByteBuffer splitPoint, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidstartConditionalUpdate(TInfo tinfo, TCredentials credentials, List<ByteBuffer> authorizations, String tableID, TDurability durability, String classLoaderContext, org.apache.thrift.async.AsyncMethodCallback<TConditionalSession> resultHandler)voidstartGetSummaries(TInfo tinfo, TCredentials credentials, TSummaryRequest request, org.apache.thrift.async.AsyncMethodCallback<TSummaries> resultHandler)voidstartGetSummariesForPartition(TInfo tinfo, TCredentials credentials, TSummaryRequest request, int modulus, int remainder, org.apache.thrift.async.AsyncMethodCallback<TSummaries> resultHandler)voidstartGetSummariesFromFiles(TInfo tinfo, TCredentials credentials, TSummaryRequest request, Map<String,List<TRowRange>> files, org.apache.thrift.async.AsyncMethodCallback<TSummaries> resultHandler)voidstartMultiScan(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, TSamplerConfiguration samplerConfig, long batchTimeOut, String classLoaderContext, Map<String,String> executionHints, org.apache.thrift.async.AsyncMethodCallback<InitialMultiScan> resultHandler)voidstartScan(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, TSamplerConfiguration samplerConfig, long batchTimeOut, String classLoaderContext, Map<String,String> executionHints, org.apache.thrift.async.AsyncMethodCallback<InitialScan> resultHandler)voidstartUpdate(TInfo tinfo, TCredentials credentials, TDurability durability, org.apache.thrift.async.AsyncMethodCallback<Long> resultHandler)voidunloadTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, TUnloadTabletGoal goal, long requestTime, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)voidupdate(TInfo tinfo, TCredentials credentials, TKeyExtent keyExtent, TMutation mutation, TDurability durability, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)-
Methods inherited from class org.apache.accumulo.core.clientImpl.thrift.ClientService.AsyncClient
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
-
Methods inherited from class org.apache.thrift.async.TAsyncClient
checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout
-
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.clientImpl.thrift.ClientService.AsyncIface
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
-
-
-
-
Method Detail
-
startScan
public void 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, TSamplerConfiguration samplerConfig, long batchTimeOut, String classLoaderContext, Map<String,String> executionHints, org.apache.thrift.async.AsyncMethodCallback<InitialScan> resultHandler) throws org.apache.thrift.TException
- Specified by:
startScanin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
continueScan
public void continueScan(TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<ScanResult> resultHandler) throws org.apache.thrift.TException
- Specified by:
continueScanin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
closeScan
public void closeScan(TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
closeScanin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
startMultiScan
public void 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, TSamplerConfiguration samplerConfig, long batchTimeOut, String classLoaderContext, Map<String,String> executionHints, org.apache.thrift.async.AsyncMethodCallback<InitialMultiScan> resultHandler) throws org.apache.thrift.TException
- Specified by:
startMultiScanin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
continueMultiScan
public void continueMultiScan(TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<MultiScanResult> resultHandler) throws org.apache.thrift.TException
- Specified by:
continueMultiScanin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
closeMultiScan
public void closeMultiScan(TInfo tinfo, long scanID, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
closeMultiScanin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
startUpdate
public void startUpdate(TInfo tinfo, TCredentials credentials, TDurability durability, org.apache.thrift.async.AsyncMethodCallback<Long> resultHandler) throws org.apache.thrift.TException
- Specified by:
startUpdatein interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
applyUpdates
public void applyUpdates(TInfo tinfo, long updateID, TKeyExtent keyExtent, List<TMutation> mutations, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
applyUpdatesin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
closeUpdate
public void closeUpdate(TInfo tinfo, long updateID, org.apache.thrift.async.AsyncMethodCallback<UpdateErrors> resultHandler) throws org.apache.thrift.TException
- Specified by:
closeUpdatein interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
update
public void update(TInfo tinfo, TCredentials credentials, TKeyExtent keyExtent, TMutation mutation, TDurability durability, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
updatein interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
startConditionalUpdate
public void startConditionalUpdate(TInfo tinfo, TCredentials credentials, List<ByteBuffer> authorizations, String tableID, TDurability durability, String classLoaderContext, org.apache.thrift.async.AsyncMethodCallback<TConditionalSession> resultHandler) throws org.apache.thrift.TException
- Specified by:
startConditionalUpdatein interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
conditionalUpdate
public void conditionalUpdate(TInfo tinfo, long sessID, Map<TKeyExtent,List<TConditionalMutation>> mutations, List<String> symbols, org.apache.thrift.async.AsyncMethodCallback<List<TCMResult>> resultHandler) throws org.apache.thrift.TException
- Specified by:
conditionalUpdatein interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
invalidateConditionalUpdate
public void invalidateConditionalUpdate(TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
invalidateConditionalUpdatein interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
closeConditionalUpdate
public void closeConditionalUpdate(TInfo tinfo, long sessID, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
closeConditionalUpdatein interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
bulkImport
public void bulkImport(TInfo tinfo, TCredentials credentials, long tid, Map<TKeyExtent,Map<String,MapFileInfo>> files, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<List<TKeyExtent>> resultHandler) throws org.apache.thrift.TException
- Specified by:
bulkImportin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
loadFiles
public void loadFiles(TInfo tinfo, TCredentials credentials, long tid, String dir, Map<TKeyExtent,Map<String,MapFileInfo>> files, boolean setTime, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
loadFilesin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
splitTablet
public void splitTablet(TInfo tinfo, TCredentials credentials, TKeyExtent extent, ByteBuffer splitPoint, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
splitTabletin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
loadTablet
public void loadTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
loadTabletin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
unloadTablet
public void unloadTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, TUnloadTabletGoal goal, long requestTime, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
unloadTabletin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
flush
public void flush(TInfo tinfo, TCredentials credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
flushin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
flushTablet
public void flushTablet(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
flushTabletin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
chop
public void chop(TInfo tinfo, TCredentials credentials, String lock, TKeyExtent extent, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
chopin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
compact
public void compact(TInfo tinfo, TCredentials credentials, String lock, String tableId, ByteBuffer startRow, ByteBuffer endRow, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
compactin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
getTabletServerStatus
public void getTabletServerStatus(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<TabletServerStatus> resultHandler) throws org.apache.thrift.TException
- Specified by:
getTabletServerStatusin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
getTabletStats
public void getTabletStats(TInfo tinfo, TCredentials credentials, String tableId, org.apache.thrift.async.AsyncMethodCallback<List<TabletStats>> resultHandler) throws org.apache.thrift.TException
- Specified by:
getTabletStatsin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
getHistoricalStats
public void getHistoricalStats(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<TabletStats> resultHandler) throws org.apache.thrift.TException
- Specified by:
getHistoricalStatsin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
halt
public void halt(TInfo tinfo, TCredentials credentials, String lock, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
haltin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
fastHalt
public void fastHalt(TInfo tinfo, TCredentials credentials, String lock, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
fastHaltin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
getActiveScans
public void getActiveScans(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<List<ActiveScan>> resultHandler) throws org.apache.thrift.TException
- Specified by:
getActiveScansin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
getActiveCompactions
public void getActiveCompactions(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<List<ActiveCompaction>> resultHandler) throws org.apache.thrift.TException
- Specified by:
getActiveCompactionsin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
removeLogs
public void removeLogs(TInfo tinfo, TCredentials credentials, List<String> filenames, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.thrift.TException
- Specified by:
removeLogsin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
getActiveLogs
public void getActiveLogs(TInfo tinfo, TCredentials credentials, org.apache.thrift.async.AsyncMethodCallback<List<String>> resultHandler) throws org.apache.thrift.TException
- Specified by:
getActiveLogsin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
startGetSummaries
public void startGetSummaries(TInfo tinfo, TCredentials credentials, TSummaryRequest request, org.apache.thrift.async.AsyncMethodCallback<TSummaries> resultHandler) throws org.apache.thrift.TException
- Specified by:
startGetSummariesin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
startGetSummariesForPartition
public void startGetSummariesForPartition(TInfo tinfo, TCredentials credentials, TSummaryRequest request, int modulus, int remainder, org.apache.thrift.async.AsyncMethodCallback<TSummaries> resultHandler) throws org.apache.thrift.TException
- Specified by:
startGetSummariesForPartitionin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
startGetSummariesFromFiles
public void startGetSummariesFromFiles(TInfo tinfo, TCredentials credentials, TSummaryRequest request, Map<String,List<TRowRange>> files, org.apache.thrift.async.AsyncMethodCallback<TSummaries> resultHandler) throws org.apache.thrift.TException
- Specified by:
startGetSummariesFromFilesin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
contiuneGetSummaries
public void contiuneGetSummaries(TInfo tinfo, long sessionId, org.apache.thrift.async.AsyncMethodCallback<TSummaries> resultHandler) throws org.apache.thrift.TException
- Specified by:
contiuneGetSummariesin interfaceTabletClientService.AsyncIface- Throws:
org.apache.thrift.TException
-
-