public static class FileSystemWorkerClientService.AsyncClient extends AlluxioService.AsyncClient implements FileSystemWorkerClientService.AsyncIface
Modifier and Type | Class and Description |
---|---|
static class |
FileSystemWorkerClientService.AsyncClient.cancelUfsFile_call |
static class |
FileSystemWorkerClientService.AsyncClient.closeUfsFile_call |
static class |
FileSystemWorkerClientService.AsyncClient.completeUfsFile_call |
static class |
FileSystemWorkerClientService.AsyncClient.createUfsFile_call |
static class |
FileSystemWorkerClientService.AsyncClient.Factory |
static class |
FileSystemWorkerClientService.AsyncClient.openUfsFile_call |
static class |
FileSystemWorkerClientService.AsyncClient.sessionFileSystemHeartbeat_call |
AlluxioService.AsyncClient.getServiceVersion_call
Constructor and Description |
---|
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.async.TAsyncClientManager clientManager,
org.apache.thrift.transport.TNonblockingTransport transport) |
Modifier and Type | Method and Description |
---|---|
void |
cancelUfsFile(long sessionId,
long tempUfsFileId,
CancelUfsFileTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
closeUfsFile(long sessionId,
long tempUfsFileId,
CloseUfsFileTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
completeUfsFile(long sessionId,
long tempUfsFileId,
CompleteUfsFileTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
createUfsFile(long sessionId,
String ufsPath,
CreateUfsFileTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
openUfsFile(long sessionId,
String ufsPath,
OpenUfsFileTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
sessionFileSystemHeartbeat(long sessionId,
List<Long> metrics,
SessionFileSystemHeartbeatTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
getServiceVersion
checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getServiceVersion
public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)
public void cancelUfsFile(long sessionId, long tempUfsFileId, CancelUfsFileTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
cancelUfsFile
in interface FileSystemWorkerClientService.AsyncIface
org.apache.thrift.TException
public void closeUfsFile(long sessionId, long tempUfsFileId, CloseUfsFileTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
closeUfsFile
in interface FileSystemWorkerClientService.AsyncIface
org.apache.thrift.TException
public void completeUfsFile(long sessionId, long tempUfsFileId, CompleteUfsFileTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
completeUfsFile
in interface FileSystemWorkerClientService.AsyncIface
org.apache.thrift.TException
public void createUfsFile(long sessionId, String ufsPath, CreateUfsFileTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
createUfsFile
in interface FileSystemWorkerClientService.AsyncIface
org.apache.thrift.TException
public void openUfsFile(long sessionId, String ufsPath, OpenUfsFileTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
openUfsFile
in interface FileSystemWorkerClientService.AsyncIface
org.apache.thrift.TException
public void sessionFileSystemHeartbeat(long sessionId, List<Long> metrics, SessionFileSystemHeartbeatTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
sessionFileSystemHeartbeat
in interface FileSystemWorkerClientService.AsyncIface
org.apache.thrift.TException
Copyright © 2023. All Rights Reserved.