public static class FileSystemMasterWorkerService.AsyncClient extends AlluxioService.AsyncClient implements FileSystemMasterWorkerService.AsyncIface
Modifier and Type | Class and Description |
---|---|
static class |
FileSystemMasterWorkerService.AsyncClient.Factory |
static class |
FileSystemMasterWorkerService.AsyncClient.fileSystemHeartbeat_call |
static class |
FileSystemMasterWorkerService.AsyncClient.getFileInfo_call |
static class |
FileSystemMasterWorkerService.AsyncClient.getPinnedFileIds_call |
static class |
FileSystemMasterWorkerService.AsyncClient.getUfsInfo_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 |
fileSystemHeartbeat(long workerId,
List<Long> persistedFiles,
FileSystemHeartbeatTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getFileInfo(long fileId,
GetFileInfoTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getPinnedFileIds(GetPinnedFileIdsTOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getUfsInfo(long mountId,
GetUfsInfoTOptions 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 fileSystemHeartbeat(long workerId, List<Long> persistedFiles, FileSystemHeartbeatTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
fileSystemHeartbeat
in interface FileSystemMasterWorkerService.AsyncIface
org.apache.thrift.TException
public void getFileInfo(long fileId, GetFileInfoTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getFileInfo
in interface FileSystemMasterWorkerService.AsyncIface
org.apache.thrift.TException
public void getPinnedFileIds(GetPinnedFileIdsTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getPinnedFileIds
in interface FileSystemMasterWorkerService.AsyncIface
org.apache.thrift.TException
public void getUfsInfo(long mountId, GetUfsInfoTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getUfsInfo
in interface FileSystemMasterWorkerService.AsyncIface
org.apache.thrift.TException
Copyright © 2023. All Rights Reserved.