Modifier and Type | Method and Description |
---|---|
static <T> T |
RpcUtils.call(org.slf4j.Logger logger,
RpcUtils.RpcCallable<T> callable,
String methodName,
boolean failureOk,
String description,
Object... args)
Calls the given
RpcUtils.RpcCallable and handles any exceptions thrown. |
static <T> T |
RpcUtils.call(org.slf4j.Logger logger,
RpcUtils.RpcCallable<T> callable,
String methodName,
String description,
Object... args)
Calls the given
RpcUtils.RpcCallable and handles any exceptions thrown. |
static <T> T |
RpcUtils.call(org.slf4j.Logger logger,
RpcUtils.RpcCallableThrowsIOException<T> callable,
String methodName,
boolean failureOk,
String description,
Object... args)
Calls the given
RpcUtils.RpcCallableThrowsIOException and handles any exceptions thrown. |
static <T> T |
RpcUtils.call(org.slf4j.Logger logger,
RpcUtils.RpcCallableThrowsIOException<T> callable,
String methodName,
String description,
Object... args)
Calls the given
RpcUtils.RpcCallableThrowsIOException and handles any exceptions thrown. |
static <T> T |
RpcUtils.call(RpcUtils.RpcCallable<T> callable)
Calls the given
RpcUtils.RpcCallable and handles any exceptions thrown. |
static <T> T |
RpcUtils.call(RpcUtils.RpcCallableThrowsIOException<T> callable)
Calls the given
RpcUtils.RpcCallableThrowsIOException and handles any exceptions thrown. |
Constructor and Description |
---|
AlluxioException(AlluxioTException te)
Constructs a
AlluxioException with an exception type from a AlluxioTException . |
Modifier and Type | Method and Description |
---|---|
AlluxioTException |
AlluxioStatusException.toThrift() |
Modifier and Type | Method and Description |
---|---|
static AlluxioStatusException |
AlluxioStatusException.fromThrift(AlluxioTException e)
Converts an Alluxio exception from Thrift representation to native representation.
|
Modifier and Type | Method and Description |
---|---|
BlockHeartbeatTResponse |
BlockMasterWorkerServiceHandler.blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options) |
CommitBlockTResponse |
BlockMasterWorkerServiceHandler.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
long blockId,
long length,
CommitBlockTOptions options) |
GetBlockInfoTResponse |
BlockMasterClientServiceHandler.getBlockInfo(long blockId,
GetBlockInfoTOptions options) |
GetCapacityBytesTResponse |
BlockMasterClientServiceHandler.getCapacityBytes(GetCapacityBytesTOptions options) |
GetUsedBytesTResponse |
BlockMasterClientServiceHandler.getUsedBytes(GetUsedBytesTOptions options) |
GetWorkerIdTResponse |
BlockMasterWorkerServiceHandler.getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options) |
GetWorkerInfoListTResponse |
BlockMasterClientServiceHandler.getWorkerInfoList(GetWorkerInfoListTOptions options) |
GetWorkerInfoListTResponse |
BlockMasterClientServiceHandler.getWorkerReport(GetWorkerReportTOptions options) |
RegisterWorkerTResponse |
BlockMasterWorkerServiceHandler.registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options) |
Modifier and Type | Method and Description |
---|---|
CheckConsistencyTResponse |
FileSystemMasterClientServiceHandler.checkConsistency(String path,
CheckConsistencyTOptions options) |
CompleteFileTResponse |
FileSystemMasterClientServiceHandler.completeFile(String path,
CompleteFileTOptions options) |
CreateDirectoryTResponse |
FileSystemMasterClientServiceHandler.createDirectory(String path,
CreateDirectoryTOptions options) |
CreateFileTResponse |
FileSystemMasterClientServiceHandler.createFile(String path,
CreateFileTOptions options) |
FileSystemHeartbeatTResponse |
FileSystemMasterWorkerServiceHandler.fileSystemHeartbeat(long workerId,
List<Long> persistedFiles,
FileSystemHeartbeatTOptions options) |
FreeTResponse |
FileSystemMasterClientServiceHandler.free(String path,
boolean recursive,
FreeTOptions options) |
GetFileInfoTResponse |
FileSystemMasterWorkerServiceHandler.getFileInfo(long fileId,
GetFileInfoTOptions options) |
GetFilePathTResponse |
FileSystemMasterClientServiceHandler.getFilePath(GetFilePathTOptions options) |
GetMountTableTResponse |
FileSystemMasterClientServiceHandler.getMountTable() |
GetNewBlockIdForFileTResponse |
FileSystemMasterClientServiceHandler.getNewBlockIdForFile(String path,
GetNewBlockIdForFileTOptions options) |
GetPinnedFileIdsTResponse |
FileSystemMasterWorkerServiceHandler.getPinnedFileIds(GetPinnedFileIdsTOptions options) |
GetStatusTResponse |
FileSystemMasterClientServiceHandler.getStatus(String path,
GetStatusTOptions options) |
GetUfsInfoTResponse |
FileSystemMasterWorkerServiceHandler.getUfsInfo(long mountId,
GetUfsInfoTOptions options) |
ListStatusTResponse |
FileSystemMasterClientServiceHandler.listStatus(String path,
ListStatusTOptions options) |
LoadMetadataTResponse |
FileSystemMasterClientServiceHandler.loadMetadata(String alluxioPath,
boolean recursive,
LoadMetadataTOptions options)
Deprecated.
since version 1.1 and will be removed in version 2.0
|
MountTResponse |
FileSystemMasterClientServiceHandler.mount(String alluxioPath,
String ufsPath,
MountTOptions options) |
DeleteTResponse |
FileSystemMasterClientServiceHandler.remove(String path,
boolean recursive,
DeleteTOptions options) |
RenameTResponse |
FileSystemMasterClientServiceHandler.rename(String srcPath,
String dstPath,
RenameTOptions options) |
ScheduleAsyncPersistenceTResponse |
FileSystemMasterClientServiceHandler.scheduleAsyncPersistence(String path,
ScheduleAsyncPersistenceTOptions options) |
SetAttributeTResponse |
FileSystemMasterClientServiceHandler.setAttribute(String path,
SetAttributeTOptions options) |
UnmountTResponse |
FileSystemMasterClientServiceHandler.unmount(String alluxioPath,
UnmountTOptions options) |
UpdateUfsModeTResponse |
FileSystemMasterClientServiceHandler.updateUfsMode(String ufsPath,
UpdateUfsModeTOptions options) |
Modifier and Type | Method and Description |
---|---|
CompletePartitionTResponse |
KeyValueMasterClientServiceHandler.completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options) |
CompleteStoreTResponse |
KeyValueMasterClientServiceHandler.completeStore(String path,
CompleteStoreTOptions options) |
CreateStoreTResponse |
KeyValueMasterClientServiceHandler.createStore(String path,
CreateStoreTOptions options) |
DeleteStoreTResponse |
KeyValueMasterClientServiceHandler.deleteStore(String path,
DeleteStoreTOptions options) |
GetPartitionInfoTResponse |
KeyValueMasterClientServiceHandler.getPartitionInfo(String path,
GetPartitionInfoTOptions options) |
MergeStoreTResponse |
KeyValueMasterClientServiceHandler.mergeStore(String fromPath,
String toPath,
MergeStoreTOptions options) |
RenameStoreTResponse |
KeyValueMasterClientServiceHandler.renameStore(String oldPath,
String newPath,
RenameStoreTOptions options) |
Modifier and Type | Method and Description |
---|---|
CreateLineageTResponse |
LineageMasterClientServiceHandler.createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo jobInfo,
CreateLineageTOptions options) |
DeleteLineageTResponse |
LineageMasterClientServiceHandler.deleteLineage(long lineageId,
boolean cascade,
DeleteLineageTOptions options) |
GetLineageInfoListTResponse |
LineageMasterClientServiceHandler.getLineageInfoList(GetLineageInfoListTOptions options) |
ReinitializeFileTResponse |
LineageMasterClientServiceHandler.reinitializeFile(String path,
long blockSizeBytes,
long ttl,
TTtlAction ttlAction,
ReinitializeFileTOptions options) |
ReportLostFileTResponse |
LineageMasterClientServiceHandler.reportLostFile(String path,
ReportLostFileTOptions options) |
Modifier and Type | Method and Description |
---|---|
BackupTResponse |
MetaMasterClientServiceHandler.backup(BackupTOptions options) |
GetConfigurationTResponse |
MetaMasterClientServiceHandler.getConfiguration(GetConfigurationTOptions options) |
GetMasterIdTResponse |
MetaMasterMasterServiceHandler.getMasterId(MasterNetAddress address,
GetMasterIdTOptions options) |
MasterHeartbeatTResponse |
MetaMasterMasterServiceHandler.masterHeartbeat(long masterId,
MasterHeartbeatTOptions options) |
RegisterMasterTResponse |
MetaMasterMasterServiceHandler.registerMaster(long masterId,
RegisterMasterTOptions options) |
Modifier and Type | Method and Description |
---|---|
GetServiceVersionTResponse |
MetricsMasterClientServiceHandler.getServiceVersion(GetServiceVersionTOptions options) |
MetricsHeartbeatTResponse |
MetricsMasterClientServiceHandler.metricsHeartbeat(String clientId,
String hostname,
MetricsHeartbeatTOptions options) |
Modifier and Type | Method and Description |
---|---|
AlluxioTException |
AlluxioTException.deepCopy() |
AlluxioTException |
KeyValueWorkerClientService.get_result.getE() |
AlluxioTException |
KeyValueWorkerClientService.getNextKeys_result.getE() |
AlluxioTException |
KeyValueWorkerClientService.getSize_result.getE() |
AlluxioTException |
KeyValueMasterClientService.completePartition_result.getE() |
AlluxioTException |
KeyValueMasterClientService.completeStore_result.getE() |
AlluxioTException |
KeyValueMasterClientService.createStore_result.getE() |
AlluxioTException |
KeyValueMasterClientService.deleteStore_result.getE() |
AlluxioTException |
KeyValueMasterClientService.getPartitionInfo_result.getE() |
AlluxioTException |
KeyValueMasterClientService.mergeStore_result.getE() |
AlluxioTException |
KeyValueMasterClientService.renameStore_result.getE() |
AlluxioTException |
FileSystemMasterWorkerService.fileSystemHeartbeat_result.getE() |
AlluxioTException |
FileSystemMasterWorkerService.getFileInfo_result.getE() |
AlluxioTException |
FileSystemMasterWorkerService.getPinnedFileIds_result.getE() |
AlluxioTException |
FileSystemMasterWorkerService.getUfsInfo_result.getE() |
AlluxioTException |
LineageMasterClientService.createLineage_result.getE() |
AlluxioTException |
LineageMasterClientService.deleteLineage_result.getE() |
AlluxioTException |
LineageMasterClientService.getLineageInfoList_result.getE() |
AlluxioTException |
LineageMasterClientService.reinitializeFile_result.getE() |
AlluxioTException |
LineageMasterClientService.reportLostFile_result.getE() |
AlluxioTException |
BlockMasterWorkerService.blockHeartbeat_result.getE() |
AlluxioTException |
BlockMasterWorkerService.commitBlock_result.getE() |
AlluxioTException |
BlockMasterWorkerService.getWorkerId_result.getE() |
AlluxioTException |
BlockMasterWorkerService.registerWorker_result.getE() |
AlluxioTException |
MetricsMasterClientService.metricsHeartbeat_result.getE() |
AlluxioTException |
BlockWorkerClientService.accessBlock_result.getE() |
AlluxioTException |
BlockWorkerClientService.cacheBlock_result.getE() |
AlluxioTException |
BlockWorkerClientService.cancelBlock_result.getE() |
AlluxioTException |
BlockWorkerClientService.lockBlock_result.getE() |
AlluxioTException |
BlockWorkerClientService.promoteBlock_result.getE() |
AlluxioTException |
BlockWorkerClientService.removeBlock_result.getE() |
AlluxioTException |
BlockWorkerClientService.requestBlockLocation_result.getE() |
AlluxioTException |
BlockWorkerClientService.requestSpace_result.getE() |
AlluxioTException |
BlockWorkerClientService.sessionBlockHeartbeat_result.getE() |
AlluxioTException |
BlockWorkerClientService.unlockBlock_result.getE() |
AlluxioTException |
MetaMasterMasterService.getMasterId_result.getE() |
AlluxioTException |
MetaMasterMasterService.registerMaster_result.getE() |
AlluxioTException |
MetaMasterMasterService.masterHeartbeat_result.getE() |
AlluxioTException |
MetaMasterClientService.backup_result.getE() |
AlluxioTException |
MetaMasterClientService.getConfiguration_result.getE() |
AlluxioTException |
MetaMasterClientService.getMasterInfo_result.getE() |
AlluxioTException |
MetaMasterClientService.getMetrics_result.getE() |
AlluxioTException |
MetaMasterClientService.getConfigReport_result.getE() |
AlluxioTException |
BlockMasterClientService.getBlockInfo_result.getE() |
AlluxioTException |
BlockMasterClientService.getBlockMasterInfo_result.getE() |
AlluxioTException |
BlockMasterClientService.getCapacityBytes_result.getE() |
AlluxioTException |
BlockMasterClientService.getUsedBytes_result.getE() |
AlluxioTException |
BlockMasterClientService.getWorkerInfoList_result.getE() |
AlluxioTException |
BlockMasterClientService.getWorkerReport_result.getE() |
AlluxioTException |
FileSystemWorkerClientService.cancelUfsFile_result.getE() |
AlluxioTException |
FileSystemWorkerClientService.closeUfsFile_result.getE() |
AlluxioTException |
FileSystemWorkerClientService.completeUfsFile_result.getE() |
AlluxioTException |
FileSystemWorkerClientService.createUfsFile_result.getE() |
AlluxioTException |
FileSystemWorkerClientService.openUfsFile_result.getE() |
AlluxioTException |
FileSystemWorkerClientService.sessionFileSystemHeartbeat_result.getE() |
AlluxioTException |
AlluxioService.getServiceVersion_result.getE() |
AlluxioTException |
FileSystemMasterClientService.checkConsistency_result.getE() |
AlluxioTException |
FileSystemMasterClientService.completeFile_result.getE() |
AlluxioTException |
FileSystemMasterClientService.createDirectory_result.getE() |
AlluxioTException |
FileSystemMasterClientService.createFile_result.getE() |
AlluxioTException |
FileSystemMasterClientService.free_result.getE() |
AlluxioTException |
FileSystemMasterClientService.getMountTable_result.getE() |
AlluxioTException |
FileSystemMasterClientService.getNewBlockIdForFile_result.getE() |
AlluxioTException |
FileSystemMasterClientService.getFilePath_result.getE() |
AlluxioTException |
FileSystemMasterClientService.getStatus_result.getE() |
AlluxioTException |
FileSystemMasterClientService.listStatus_result.getE() |
AlluxioTException |
FileSystemMasterClientService.loadMetadata_result.getE() |
AlluxioTException |
FileSystemMasterClientService.mount_result.getE() |
AlluxioTException |
FileSystemMasterClientService.remove_result.getE() |
AlluxioTException |
FileSystemMasterClientService.rename_result.getE() |
AlluxioTException |
FileSystemMasterClientService.scheduleAsyncPersistence_result.getE() |
AlluxioTException |
FileSystemMasterClientService.setAttribute_result.getE() |
AlluxioTException |
FileSystemMasterClientService.unmount_result.getE() |
AlluxioTException |
FileSystemMasterClientService.updateUfsMode_result.getE() |
AlluxioTException |
AlluxioTException.setMessage(String message) |
AlluxioTException |
AlluxioTException.setStatus(TStatus status) |
Modifier and Type | Method and Description |
---|---|
AccessBlockTResponse |
BlockWorkerClientService.Iface.accessBlock(long blockId,
AccessBlockTOptions options)
Accesses a block given the block id.
|
AccessBlockTResponse |
BlockWorkerClientService.Client.accessBlock(long blockId,
AccessBlockTOptions options) |
BackupTResponse |
MetaMasterClientService.Iface.backup(BackupTOptions options)
Backs up the Alluxio master to the specified URI
|
BackupTResponse |
MetaMasterClientService.Client.backup(BackupTOptions options) |
BlockHeartbeatTResponse |
BlockMasterWorkerService.Iface.blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options)
Periodic block worker heartbeat returns an optional command for the block worker to execute.
|
BlockHeartbeatTResponse |
BlockMasterWorkerService.Client.blockHeartbeat(long workerId,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<String,List<Long>> addedBlocksOnTiers,
BlockHeartbeatTOptions options) |
CacheBlockTResponse |
BlockWorkerClientService.Iface.cacheBlock(long sessionId,
long blockId,
CacheBlockTOptions options)
Used to cache a block into Alluxio space, worker will move the temporary block file from session
folder to data folder, and update the space usage information related.
|
CacheBlockTResponse |
BlockWorkerClientService.Client.cacheBlock(long sessionId,
long blockId,
CacheBlockTOptions options) |
CancelBlockTResponse |
BlockWorkerClientService.Iface.cancelBlock(long sessionId,
long blockId,
CancelBlockTOptions options)
Used to cancel a block which is being written.
|
CancelBlockTResponse |
BlockWorkerClientService.Client.cancelBlock(long sessionId,
long blockId,
CancelBlockTOptions options) |
CancelUfsFileTResponse |
FileSystemWorkerClientService.Iface.cancelUfsFile(long sessionId,
long tempUfsFileId,
CancelUfsFileTOptions options)
Cancels a file which has not been completed in the under file system.
|
CancelUfsFileTResponse |
FileSystemWorkerClientService.Client.cancelUfsFile(long sessionId,
long tempUfsFileId,
CancelUfsFileTOptions options) |
CheckConsistencyTResponse |
FileSystemMasterClientService.Iface.checkConsistency(String path,
CheckConsistencyTOptions options)
Checks the consistency of the files and directores with the path as the root of the subtree
|
CheckConsistencyTResponse |
FileSystemMasterClientService.Client.checkConsistency(String path,
CheckConsistencyTOptions options) |
CloseUfsFileTResponse |
FileSystemWorkerClientService.Iface.closeUfsFile(long sessionId,
long tempUfsFileId,
CloseUfsFileTOptions options)
Closes a file in the under file system which was previously opened for reading.
|
CloseUfsFileTResponse |
FileSystemWorkerClientService.Client.closeUfsFile(long sessionId,
long tempUfsFileId,
CloseUfsFileTOptions options) |
CommitBlockTResponse |
BlockMasterWorkerService.Iface.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
long blockId,
long length,
CommitBlockTOptions options)
Marks the given block as committed.
|
CommitBlockTResponse |
BlockMasterWorkerService.Client.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
long blockId,
long length,
CommitBlockTOptions options) |
CompleteFileTResponse |
FileSystemMasterClientService.Iface.completeFile(String path,
CompleteFileTOptions options)
Marks a file as completed.
|
CompleteFileTResponse |
FileSystemMasterClientService.Client.completeFile(String path,
CompleteFileTOptions options) |
CompletePartitionTResponse |
KeyValueMasterClientService.Iface.completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options)
Marks a partition complete and adds it to the store.
|
CompletePartitionTResponse |
KeyValueMasterClientService.Client.completePartition(String path,
PartitionInfo info,
CompletePartitionTOptions options) |
CompleteStoreTResponse |
KeyValueMasterClientService.Iface.completeStore(String path,
CompleteStoreTOptions options)
Marks a store complete with its filesystem path.
|
CompleteStoreTResponse |
KeyValueMasterClientService.Client.completeStore(String path,
CompleteStoreTOptions options) |
CompleteUfsFileTReponse |
FileSystemWorkerClientService.Iface.completeUfsFile(long sessionId,
long tempUfsFileId,
CompleteUfsFileTOptions options)
Completes a file in the under file system.
|
CompleteUfsFileTReponse |
FileSystemWorkerClientService.Client.completeUfsFile(long sessionId,
long tempUfsFileId,
CompleteUfsFileTOptions options) |
CreateDirectoryTResponse |
FileSystemMasterClientService.Iface.createDirectory(String path,
CreateDirectoryTOptions options)
Creates a directory.
|
CreateDirectoryTResponse |
FileSystemMasterClientService.Client.createDirectory(String path,
CreateDirectoryTOptions options) |
CreateFileTResponse |
FileSystemMasterClientService.Iface.createFile(String path,
CreateFileTOptions options)
Creates a file.
|
CreateFileTResponse |
FileSystemMasterClientService.Client.createFile(String path,
CreateFileTOptions options) |
CreateLineageTResponse |
LineageMasterClientService.Iface.createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options)
Creates a lineage and returns the lineage id.
|
CreateLineageTResponse |
LineageMasterClientService.Client.createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJobInfo job,
CreateLineageTOptions options) |
CreateStoreTResponse |
KeyValueMasterClientService.Iface.createStore(String path,
CreateStoreTOptions options)
Creates a new key-value store on master.
|
CreateStoreTResponse |
KeyValueMasterClientService.Client.createStore(String path,
CreateStoreTOptions options) |
CreateUfsFileTResponse |
FileSystemWorkerClientService.Iface.createUfsFile(long sessionId,
String ufsPath,
CreateUfsFileTOptions options)
Creates a file in the under file system.
|
CreateUfsFileTResponse |
FileSystemWorkerClientService.Client.createUfsFile(long sessionId,
String ufsPath,
CreateUfsFileTOptions options) |
DeleteLineageTResponse |
LineageMasterClientService.Iface.deleteLineage(long lineageId,
boolean cascade,
DeleteLineageTOptions options)
Deletes a lineage and returns whether the deletion succeeded.
|
DeleteLineageTResponse |
LineageMasterClientService.Client.deleteLineage(long lineageId,
boolean cascade,
DeleteLineageTOptions options) |
DeleteStoreTResponse |
KeyValueMasterClientService.Iface.deleteStore(String path,
DeleteStoreTOptions options)
Deletes a completed key-value store.
|
DeleteStoreTResponse |
KeyValueMasterClientService.Client.deleteStore(String path,
DeleteStoreTOptions options) |
FileSystemHeartbeatTResponse |
FileSystemMasterWorkerService.Iface.fileSystemHeartbeat(long workerId,
List<Long> persistedFiles,
FileSystemHeartbeatTOptions options)
Periodic file system worker heartbeat.
|
FileSystemHeartbeatTResponse |
FileSystemMasterWorkerService.Client.fileSystemHeartbeat(long workerId,
List<Long> persistedFiles,
FileSystemHeartbeatTOptions options) |
FreeTResponse |
FileSystemMasterClientService.Iface.free(String path,
boolean recursive,
FreeTOptions options)
Frees the given file or directory from Alluxio.
|
FreeTResponse |
FileSystemMasterClientService.Client.free(String path,
boolean recursive,
FreeTOptions options) |
GetTResponse |
KeyValueWorkerClientService.Iface.get(long blockId,
ByteBuffer key,
GetTOptions options)
Looks up a key in the block with the given block id.
|
GetTResponse |
KeyValueWorkerClientService.Client.get(long blockId,
ByteBuffer key,
GetTOptions options) |
GetBlockInfoTResponse |
BlockMasterClientService.Iface.getBlockInfo(long blockId,
GetBlockInfoTOptions options)
Returns the block information for the given block id.
|
GetBlockInfoTResponse |
BlockMasterClientService.Client.getBlockInfo(long blockId,
GetBlockInfoTOptions options) |
GetBlockMasterInfoTResponse |
BlockMasterClientService.Iface.getBlockMasterInfo(GetBlockMasterInfoTOptions options)
Returns block master information.
|
GetBlockMasterInfoTResponse |
BlockMasterClientService.Client.getBlockMasterInfo(GetBlockMasterInfoTOptions options) |
GetCapacityBytesTResponse |
BlockMasterClientService.Iface.getCapacityBytes(GetCapacityBytesTOptions options)
Returns the capacity (in bytes).
|
GetCapacityBytesTResponse |
BlockMasterClientService.Client.getCapacityBytes(GetCapacityBytesTOptions options) |
GetConfigReportTResponse |
MetaMasterClientService.Iface.getConfigReport(GetConfigReportTOptions options)
Returns server-side configuration report.
|
GetConfigReportTResponse |
MetaMasterClientService.Client.getConfigReport(GetConfigReportTOptions options) |
GetConfigurationTResponse |
MetaMasterClientService.Iface.getConfiguration(GetConfigurationTOptions options)
Returns a list of Alluxio runtime configuration information.
|
GetConfigurationTResponse |
MetaMasterClientService.Client.getConfiguration(GetConfigurationTOptions options) |
GetFileInfoTResponse |
FileSystemMasterWorkerService.Iface.getFileInfo(long fileId,
GetFileInfoTOptions options) |
GetFileInfoTResponse |
FileSystemMasterWorkerService.Client.getFileInfo(long fileId,
GetFileInfoTOptions options) |
GetFilePathTResponse |
FileSystemMasterClientService.Iface.getFilePath(GetFilePathTOptions options)
Returns the file path of a file id.
|
GetFilePathTResponse |
FileSystemMasterClientService.Client.getFilePath(GetFilePathTOptions options) |
GetLineageInfoListTResponse |
LineageMasterClientService.Iface.getLineageInfoList(GetLineageInfoListTOptions options)
Returns a list of existing lineages.
|
GetLineageInfoListTResponse |
LineageMasterClientService.Client.getLineageInfoList(GetLineageInfoListTOptions options) |
GetMasterIdTResponse |
MetaMasterMasterService.Iface.getMasterId(MasterNetAddress masterAddress,
GetMasterIdTOptions options)
Returns a master id for the given master address.
|
GetMasterIdTResponse |
MetaMasterMasterService.Client.getMasterId(MasterNetAddress masterAddress,
GetMasterIdTOptions options) |
GetMasterInfoTResponse |
MetaMasterClientService.Iface.getMasterInfo(GetMasterInfoTOptions options)
Returns information about the master.
|
GetMasterInfoTResponse |
MetaMasterClientService.Client.getMasterInfo(GetMasterInfoTOptions options) |
GetMetricsTResponse |
MetaMasterClientService.Iface.getMetrics(GetMetricsTOptions options)
Returns a map of metrics property names and their values from Alluxio metrics system.
|
GetMetricsTResponse |
MetaMasterClientService.Client.getMetrics(GetMetricsTOptions options) |
GetMountTableTResponse |
FileSystemMasterClientService.Iface.getMountTable()
Returns a map from each Alluxio path to information of corresponding mount point
|
GetMountTableTResponse |
FileSystemMasterClientService.Client.getMountTable() |
GetNewBlockIdForFileTResponse |
FileSystemMasterClientService.Iface.getNewBlockIdForFile(String path,
GetNewBlockIdForFileTOptions options)
Generates a new block id for the given file.
|
GetNewBlockIdForFileTResponse |
FileSystemMasterClientService.Client.getNewBlockIdForFile(String path,
GetNewBlockIdForFileTOptions options) |
GetNextKeysTResponse |
KeyValueWorkerClientService.Iface.getNextKeys(long blockId,
ByteBuffer key,
int numKeys,
GetNextKeysTOptions options)
Gets a batch of keys next to the given key in the partition.
|
GetNextKeysTResponse |
KeyValueWorkerClientService.Client.getNextKeys(long blockId,
ByteBuffer key,
int numKeys,
GetNextKeysTOptions options) |
GetPartitionInfoTResponse |
KeyValueMasterClientService.Iface.getPartitionInfo(String path,
GetPartitionInfoTOptions options)
Gets the partition information for the key-value store at the given filesystem path.
|
GetPartitionInfoTResponse |
KeyValueMasterClientService.Client.getPartitionInfo(String path,
GetPartitionInfoTOptions options) |
GetPinnedFileIdsTResponse |
FileSystemMasterWorkerService.Iface.getPinnedFileIds(GetPinnedFileIdsTOptions options)
Returns the set of pinned file ids.
|
GetPinnedFileIdsTResponse |
FileSystemMasterWorkerService.Client.getPinnedFileIds(GetPinnedFileIdsTOptions options) |
GetTResponse |
KeyValueWorkerClientService.AsyncClient.get_call.getResult() |
GetNextKeysTResponse |
KeyValueWorkerClientService.AsyncClient.getNextKeys_call.getResult() |
GetSizeTResponse |
KeyValueWorkerClientService.AsyncClient.getSize_call.getResult() |
CompletePartitionTResponse |
KeyValueMasterClientService.AsyncClient.completePartition_call.getResult() |
CompleteStoreTResponse |
KeyValueMasterClientService.AsyncClient.completeStore_call.getResult() |
CreateStoreTResponse |
KeyValueMasterClientService.AsyncClient.createStore_call.getResult() |
DeleteStoreTResponse |
KeyValueMasterClientService.AsyncClient.deleteStore_call.getResult() |
GetPartitionInfoTResponse |
KeyValueMasterClientService.AsyncClient.getPartitionInfo_call.getResult() |
MergeStoreTResponse |
KeyValueMasterClientService.AsyncClient.mergeStore_call.getResult() |
RenameStoreTResponse |
KeyValueMasterClientService.AsyncClient.renameStore_call.getResult() |
FileSystemHeartbeatTResponse |
FileSystemMasterWorkerService.AsyncClient.fileSystemHeartbeat_call.getResult() |
GetFileInfoTResponse |
FileSystemMasterWorkerService.AsyncClient.getFileInfo_call.getResult() |
GetPinnedFileIdsTResponse |
FileSystemMasterWorkerService.AsyncClient.getPinnedFileIds_call.getResult() |
GetUfsInfoTResponse |
FileSystemMasterWorkerService.AsyncClient.getUfsInfo_call.getResult() |
CreateLineageTResponse |
LineageMasterClientService.AsyncClient.createLineage_call.getResult() |
DeleteLineageTResponse |
LineageMasterClientService.AsyncClient.deleteLineage_call.getResult() |
GetLineageInfoListTResponse |
LineageMasterClientService.AsyncClient.getLineageInfoList_call.getResult() |
ReinitializeFileTResponse |
LineageMasterClientService.AsyncClient.reinitializeFile_call.getResult() |
ReportLostFileTResponse |
LineageMasterClientService.AsyncClient.reportLostFile_call.getResult() |
BlockHeartbeatTResponse |
BlockMasterWorkerService.AsyncClient.blockHeartbeat_call.getResult() |
CommitBlockTResponse |
BlockMasterWorkerService.AsyncClient.commitBlock_call.getResult() |
GetWorkerIdTResponse |
BlockMasterWorkerService.AsyncClient.getWorkerId_call.getResult() |
RegisterWorkerTResponse |
BlockMasterWorkerService.AsyncClient.registerWorker_call.getResult() |
MetricsHeartbeatTResponse |
MetricsMasterClientService.AsyncClient.metricsHeartbeat_call.getResult() |
AccessBlockTResponse |
BlockWorkerClientService.AsyncClient.accessBlock_call.getResult() |
CacheBlockTResponse |
BlockWorkerClientService.AsyncClient.cacheBlock_call.getResult() |
CancelBlockTResponse |
BlockWorkerClientService.AsyncClient.cancelBlock_call.getResult() |
LockBlockTResponse |
BlockWorkerClientService.AsyncClient.lockBlock_call.getResult() |
PromoteBlockTResponse |
BlockWorkerClientService.AsyncClient.promoteBlock_call.getResult() |
RemoveBlockTResponse |
BlockWorkerClientService.AsyncClient.removeBlock_call.getResult() |
RequestBlockLocationTResponse |
BlockWorkerClientService.AsyncClient.requestBlockLocation_call.getResult() |
RequestSpaceTResponse |
BlockWorkerClientService.AsyncClient.requestSpace_call.getResult() |
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.AsyncClient.sessionBlockHeartbeat_call.getResult() |
UnlockBlockTResponse |
BlockWorkerClientService.AsyncClient.unlockBlock_call.getResult() |
GetMasterIdTResponse |
MetaMasterMasterService.AsyncClient.getMasterId_call.getResult() |
RegisterMasterTResponse |
MetaMasterMasterService.AsyncClient.registerMaster_call.getResult() |
MasterHeartbeatTResponse |
MetaMasterMasterService.AsyncClient.masterHeartbeat_call.getResult() |
BackupTResponse |
MetaMasterClientService.AsyncClient.backup_call.getResult() |
GetConfigurationTResponse |
MetaMasterClientService.AsyncClient.getConfiguration_call.getResult() |
GetMasterInfoTResponse |
MetaMasterClientService.AsyncClient.getMasterInfo_call.getResult() |
GetMetricsTResponse |
MetaMasterClientService.AsyncClient.getMetrics_call.getResult() |
GetConfigReportTResponse |
MetaMasterClientService.AsyncClient.getConfigReport_call.getResult() |
GetBlockInfoTResponse |
BlockMasterClientService.AsyncClient.getBlockInfo_call.getResult() |
GetBlockMasterInfoTResponse |
BlockMasterClientService.AsyncClient.getBlockMasterInfo_call.getResult() |
GetCapacityBytesTResponse |
BlockMasterClientService.AsyncClient.getCapacityBytes_call.getResult() |
GetUsedBytesTResponse |
BlockMasterClientService.AsyncClient.getUsedBytes_call.getResult() |
GetWorkerInfoListTResponse |
BlockMasterClientService.AsyncClient.getWorkerInfoList_call.getResult() |
GetWorkerInfoListTResponse |
BlockMasterClientService.AsyncClient.getWorkerReport_call.getResult() |
CancelUfsFileTResponse |
FileSystemWorkerClientService.AsyncClient.cancelUfsFile_call.getResult() |
CloseUfsFileTResponse |
FileSystemWorkerClientService.AsyncClient.closeUfsFile_call.getResult() |
CompleteUfsFileTReponse |
FileSystemWorkerClientService.AsyncClient.completeUfsFile_call.getResult() |
CreateUfsFileTResponse |
FileSystemWorkerClientService.AsyncClient.createUfsFile_call.getResult() |
OpenUfsFileTResponse |
FileSystemWorkerClientService.AsyncClient.openUfsFile_call.getResult() |
SessionFileSystemHeartbeatTResponse |
FileSystemWorkerClientService.AsyncClient.sessionFileSystemHeartbeat_call.getResult() |
GetServiceVersionTResponse |
AlluxioService.AsyncClient.getServiceVersion_call.getResult() |
CheckConsistencyTResponse |
FileSystemMasterClientService.AsyncClient.checkConsistency_call.getResult() |
CompleteFileTResponse |
FileSystemMasterClientService.AsyncClient.completeFile_call.getResult() |
CreateDirectoryTResponse |
FileSystemMasterClientService.AsyncClient.createDirectory_call.getResult() |
CreateFileTResponse |
FileSystemMasterClientService.AsyncClient.createFile_call.getResult() |
FreeTResponse |
FileSystemMasterClientService.AsyncClient.free_call.getResult() |
GetMountTableTResponse |
FileSystemMasterClientService.AsyncClient.getMountTable_call.getResult() |
GetNewBlockIdForFileTResponse |
FileSystemMasterClientService.AsyncClient.getNewBlockIdForFile_call.getResult() |
GetFilePathTResponse |
FileSystemMasterClientService.AsyncClient.getFilePath_call.getResult() |
GetStatusTResponse |
FileSystemMasterClientService.AsyncClient.getStatus_call.getResult() |
ListStatusTResponse |
FileSystemMasterClientService.AsyncClient.listStatus_call.getResult() |
LoadMetadataTResponse |
FileSystemMasterClientService.AsyncClient.loadMetadata_call.getResult() |
MountTResponse |
FileSystemMasterClientService.AsyncClient.mount_call.getResult() |
DeleteTResponse |
FileSystemMasterClientService.AsyncClient.remove_call.getResult() |
RenameTResponse |
FileSystemMasterClientService.AsyncClient.rename_call.getResult() |
ScheduleAsyncPersistenceTResponse |
FileSystemMasterClientService.AsyncClient.scheduleAsyncPersistence_call.getResult() |
SetAttributeTResponse |
FileSystemMasterClientService.AsyncClient.setAttribute_call.getResult() |
UnmountTResponse |
FileSystemMasterClientService.AsyncClient.unmount_call.getResult() |
UpdateUfsModeTResponse |
FileSystemMasterClientService.AsyncClient.updateUfsMode_call.getResult() |
GetServiceVersionTResponse |
AlluxioService.Iface.getServiceVersion(GetServiceVersionTOptions options)
Returns the version of the master service.
|
GetServiceVersionTResponse |
AlluxioService.Client.getServiceVersion(GetServiceVersionTOptions options) |
GetSizeTResponse |
KeyValueWorkerClientService.Iface.getSize(long blockId,
GetSizeTOptions options)
Gets the number of key-value pairs in the partition.
|
GetSizeTResponse |
KeyValueWorkerClientService.Client.getSize(long blockId,
GetSizeTOptions options) |
GetStatusTResponse |
FileSystemMasterClientService.Iface.getStatus(String path,
GetStatusTOptions options)
Returns the status of the file or directory.
|
GetStatusTResponse |
FileSystemMasterClientService.Client.getStatus(String path,
GetStatusTOptions options) |
GetUfsInfoTResponse |
FileSystemMasterWorkerService.Iface.getUfsInfo(long mountId,
GetUfsInfoTOptions options)
Returns the UFS information for the given mount point identified by its id.
|
GetUfsInfoTResponse |
FileSystemMasterWorkerService.Client.getUfsInfo(long mountId,
GetUfsInfoTOptions options) |
GetUsedBytesTResponse |
BlockMasterClientService.Iface.getUsedBytes(GetUsedBytesTOptions options)
Returns the used storage (in bytes).
|
GetUsedBytesTResponse |
BlockMasterClientService.Client.getUsedBytes(GetUsedBytesTOptions options) |
GetWorkerIdTResponse |
BlockMasterWorkerService.Iface.getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options)
Returns a worker id for the given network address.
|
GetWorkerIdTResponse |
BlockMasterWorkerService.Client.getWorkerId(WorkerNetAddress workerNetAddress,
GetWorkerIdTOptions options) |
GetWorkerInfoListTResponse |
BlockMasterClientService.Iface.getWorkerInfoList(GetWorkerInfoListTOptions options)
Returns a list of workers information.
|
GetWorkerInfoListTResponse |
BlockMasterClientService.Client.getWorkerInfoList(GetWorkerInfoListTOptions options) |
GetWorkerInfoListTResponse |
BlockMasterClientService.Iface.getWorkerReport(GetWorkerReportTOptions options)
Returns a list of workers information for report CLI.
|
GetWorkerInfoListTResponse |
BlockMasterClientService.Client.getWorkerReport(GetWorkerReportTOptions options) |
ListStatusTResponse |
FileSystemMasterClientService.Iface.listStatus(String path,
ListStatusTOptions options)
If the path points to a file, the method returns a singleton with its file information.
|
ListStatusTResponse |
FileSystemMasterClientService.Client.listStatus(String path,
ListStatusTOptions options) |
LoadMetadataTResponse |
FileSystemMasterClientService.Iface.loadMetadata(String ufsPath,
boolean recursive,
LoadMetadataTOptions options)
Loads metadata for the object identified by the given Alluxio path from UFS into Alluxio.
|
LoadMetadataTResponse |
FileSystemMasterClientService.Client.loadMetadata(String ufsPath,
boolean recursive,
LoadMetadataTOptions options) |
LockBlockTResponse |
BlockWorkerClientService.Iface.lockBlock(long blockId,
long sessionId,
LockBlockTOptions options)
Locks the file in Alluxio's space while the session is reading it.
|
LockBlockTResponse |
BlockWorkerClientService.Client.lockBlock(long blockId,
long sessionId,
LockBlockTOptions options) |
MasterHeartbeatTResponse |
MetaMasterMasterService.Iface.masterHeartbeat(long masterId,
MasterHeartbeatTOptions options)
Heartbeats to indicate the master is lost or not.
|
MasterHeartbeatTResponse |
MetaMasterMasterService.Client.masterHeartbeat(long masterId,
MasterHeartbeatTOptions options) |
MergeStoreTResponse |
KeyValueMasterClientService.Iface.mergeStore(String fromPath,
String toPath,
MergeStoreTOptions options)
Merges one completed key-value store to another completed key-value store.
|
MergeStoreTResponse |
KeyValueMasterClientService.Client.mergeStore(String fromPath,
String toPath,
MergeStoreTOptions options) |
MetricsHeartbeatTResponse |
MetricsMasterClientService.Iface.metricsHeartbeat(String clientId,
String hostname,
MetricsHeartbeatTOptions options)
Periodic metrics master client heartbeat.
|
MetricsHeartbeatTResponse |
MetricsMasterClientService.Client.metricsHeartbeat(String clientId,
String hostname,
MetricsHeartbeatTOptions options) |
MountTResponse |
FileSystemMasterClientService.Iface.mount(String alluxioPath,
String ufsPath,
MountTOptions options)
Creates a new "mount point", mounts the given UFS path in the Alluxio namespace at the given
path.
|
MountTResponse |
FileSystemMasterClientService.Client.mount(String alluxioPath,
String ufsPath,
MountTOptions options) |
OpenUfsFileTResponse |
FileSystemWorkerClientService.Iface.openUfsFile(long sessionId,
String ufsPath,
OpenUfsFileTOptions options)
Opens an existing file in the under file system for reading.
|
OpenUfsFileTResponse |
FileSystemWorkerClientService.Client.openUfsFile(long sessionId,
String ufsPath,
OpenUfsFileTOptions options) |
PromoteBlockTResponse |
BlockWorkerClientService.Iface.promoteBlock(long blockId,
PromoteBlockTOptions options)
Used to promote block on under storage layer to top storage layer when there are more than one
storage layers in Alluxio's space.
|
PromoteBlockTResponse |
BlockWorkerClientService.Client.promoteBlock(long blockId,
PromoteBlockTOptions options) |
AccessBlockTResponse |
BlockWorkerClientService.Client.recv_accessBlock() |
BackupTResponse |
MetaMasterClientService.Client.recv_backup() |
BlockHeartbeatTResponse |
BlockMasterWorkerService.Client.recv_blockHeartbeat() |
CacheBlockTResponse |
BlockWorkerClientService.Client.recv_cacheBlock() |
CancelBlockTResponse |
BlockWorkerClientService.Client.recv_cancelBlock() |
CancelUfsFileTResponse |
FileSystemWorkerClientService.Client.recv_cancelUfsFile() |
CheckConsistencyTResponse |
FileSystemMasterClientService.Client.recv_checkConsistency() |
CloseUfsFileTResponse |
FileSystemWorkerClientService.Client.recv_closeUfsFile() |
CommitBlockTResponse |
BlockMasterWorkerService.Client.recv_commitBlock() |
CompleteFileTResponse |
FileSystemMasterClientService.Client.recv_completeFile() |
CompletePartitionTResponse |
KeyValueMasterClientService.Client.recv_completePartition() |
CompleteStoreTResponse |
KeyValueMasterClientService.Client.recv_completeStore() |
CompleteUfsFileTReponse |
FileSystemWorkerClientService.Client.recv_completeUfsFile() |
CreateDirectoryTResponse |
FileSystemMasterClientService.Client.recv_createDirectory() |
CreateFileTResponse |
FileSystemMasterClientService.Client.recv_createFile() |
CreateLineageTResponse |
LineageMasterClientService.Client.recv_createLineage() |
CreateStoreTResponse |
KeyValueMasterClientService.Client.recv_createStore() |
CreateUfsFileTResponse |
FileSystemWorkerClientService.Client.recv_createUfsFile() |
DeleteLineageTResponse |
LineageMasterClientService.Client.recv_deleteLineage() |
DeleteStoreTResponse |
KeyValueMasterClientService.Client.recv_deleteStore() |
FileSystemHeartbeatTResponse |
FileSystemMasterWorkerService.Client.recv_fileSystemHeartbeat() |
FreeTResponse |
FileSystemMasterClientService.Client.recv_free() |
GetTResponse |
KeyValueWorkerClientService.Client.recv_get() |
GetBlockInfoTResponse |
BlockMasterClientService.Client.recv_getBlockInfo() |
GetBlockMasterInfoTResponse |
BlockMasterClientService.Client.recv_getBlockMasterInfo() |
GetCapacityBytesTResponse |
BlockMasterClientService.Client.recv_getCapacityBytes() |
GetConfigReportTResponse |
MetaMasterClientService.Client.recv_getConfigReport() |
GetConfigurationTResponse |
MetaMasterClientService.Client.recv_getConfiguration() |
GetFileInfoTResponse |
FileSystemMasterWorkerService.Client.recv_getFileInfo() |
GetFilePathTResponse |
FileSystemMasterClientService.Client.recv_getFilePath() |
GetLineageInfoListTResponse |
LineageMasterClientService.Client.recv_getLineageInfoList() |
GetMasterIdTResponse |
MetaMasterMasterService.Client.recv_getMasterId() |
GetMasterInfoTResponse |
MetaMasterClientService.Client.recv_getMasterInfo() |
GetMetricsTResponse |
MetaMasterClientService.Client.recv_getMetrics() |
GetMountTableTResponse |
FileSystemMasterClientService.Client.recv_getMountTable() |
GetNewBlockIdForFileTResponse |
FileSystemMasterClientService.Client.recv_getNewBlockIdForFile() |
GetNextKeysTResponse |
KeyValueWorkerClientService.Client.recv_getNextKeys() |
GetPartitionInfoTResponse |
KeyValueMasterClientService.Client.recv_getPartitionInfo() |
GetPinnedFileIdsTResponse |
FileSystemMasterWorkerService.Client.recv_getPinnedFileIds() |
GetServiceVersionTResponse |
AlluxioService.Client.recv_getServiceVersion() |
GetSizeTResponse |
KeyValueWorkerClientService.Client.recv_getSize() |
GetStatusTResponse |
FileSystemMasterClientService.Client.recv_getStatus() |
GetUfsInfoTResponse |
FileSystemMasterWorkerService.Client.recv_getUfsInfo() |
GetUsedBytesTResponse |
BlockMasterClientService.Client.recv_getUsedBytes() |
GetWorkerIdTResponse |
BlockMasterWorkerService.Client.recv_getWorkerId() |
GetWorkerInfoListTResponse |
BlockMasterClientService.Client.recv_getWorkerInfoList() |
GetWorkerInfoListTResponse |
BlockMasterClientService.Client.recv_getWorkerReport() |
ListStatusTResponse |
FileSystemMasterClientService.Client.recv_listStatus() |
LoadMetadataTResponse |
FileSystemMasterClientService.Client.recv_loadMetadata() |
LockBlockTResponse |
BlockWorkerClientService.Client.recv_lockBlock() |
MasterHeartbeatTResponse |
MetaMasterMasterService.Client.recv_masterHeartbeat() |
MergeStoreTResponse |
KeyValueMasterClientService.Client.recv_mergeStore() |
MetricsHeartbeatTResponse |
MetricsMasterClientService.Client.recv_metricsHeartbeat() |
MountTResponse |
FileSystemMasterClientService.Client.recv_mount() |
OpenUfsFileTResponse |
FileSystemWorkerClientService.Client.recv_openUfsFile() |
PromoteBlockTResponse |
BlockWorkerClientService.Client.recv_promoteBlock() |
RegisterMasterTResponse |
MetaMasterMasterService.Client.recv_registerMaster() |
RegisterWorkerTResponse |
BlockMasterWorkerService.Client.recv_registerWorker() |
ReinitializeFileTResponse |
LineageMasterClientService.Client.recv_reinitializeFile() |
DeleteTResponse |
FileSystemMasterClientService.Client.recv_remove() |
RemoveBlockTResponse |
BlockWorkerClientService.Client.recv_removeBlock() |
RenameTResponse |
FileSystemMasterClientService.Client.recv_rename() |
RenameStoreTResponse |
KeyValueMasterClientService.Client.recv_renameStore() |
ReportLostFileTResponse |
LineageMasterClientService.Client.recv_reportLostFile() |
RequestBlockLocationTResponse |
BlockWorkerClientService.Client.recv_requestBlockLocation() |
RequestSpaceTResponse |
BlockWorkerClientService.Client.recv_requestSpace() |
ScheduleAsyncPersistenceTResponse |
FileSystemMasterClientService.Client.recv_scheduleAsyncPersistence() |
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.Client.recv_sessionBlockHeartbeat() |
SessionFileSystemHeartbeatTResponse |
FileSystemWorkerClientService.Client.recv_sessionFileSystemHeartbeat() |
SetAttributeTResponse |
FileSystemMasterClientService.Client.recv_setAttribute() |
UnlockBlockTResponse |
BlockWorkerClientService.Client.recv_unlockBlock() |
UnmountTResponse |
FileSystemMasterClientService.Client.recv_unmount() |
UpdateUfsModeTResponse |
FileSystemMasterClientService.Client.recv_updateUfsMode() |
RegisterMasterTResponse |
MetaMasterMasterService.Iface.registerMaster(long masterId,
RegisterMasterTOptions options)
Registers a master.
|
RegisterMasterTResponse |
MetaMasterMasterService.Client.registerMaster(long masterId,
RegisterMasterTOptions options) |
RegisterWorkerTResponse |
BlockMasterWorkerService.Iface.registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options)
Registers a worker.
|
RegisterWorkerTResponse |
BlockMasterWorkerService.Client.registerWorker(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<String,List<Long>> currentBlocksOnTiers,
RegisterWorkerTOptions options) |
ReinitializeFileTResponse |
LineageMasterClientService.Iface.reinitializeFile(String path,
long blockSizeBytes,
long ttl,
TTtlAction ttlAction,
ReinitializeFileTOptions options)
Reinitializes a file.
|
ReinitializeFileTResponse |
LineageMasterClientService.Client.reinitializeFile(String path,
long blockSizeBytes,
long ttl,
TTtlAction ttlAction,
ReinitializeFileTOptions options) |
DeleteTResponse |
FileSystemMasterClientService.Iface.remove(String path,
boolean recursive,
DeleteTOptions options)
Deletes a file or a directory and returns whether the remove operation succeeded.
|
DeleteTResponse |
FileSystemMasterClientService.Client.remove(String path,
boolean recursive,
DeleteTOptions options) |
RemoveBlockTResponse |
BlockWorkerClientService.Iface.removeBlock(long blockId,
RemoveBlockTOptions options)
Used to remove a block from an Alluxio worker.
|
RemoveBlockTResponse |
BlockWorkerClientService.Client.removeBlock(long blockId,
RemoveBlockTOptions options) |
RenameTResponse |
FileSystemMasterClientService.Iface.rename(String path,
String dstPath,
RenameTOptions options)
Renames a file or a directory.
|
RenameTResponse |
FileSystemMasterClientService.Client.rename(String path,
String dstPath,
RenameTOptions options) |
RenameStoreTResponse |
KeyValueMasterClientService.Iface.renameStore(String oldPath,
String newPath,
RenameStoreTOptions options)
Renames a completed key-value store.
|
RenameStoreTResponse |
KeyValueMasterClientService.Client.renameStore(String oldPath,
String newPath,
RenameStoreTOptions options) |
ReportLostFileTResponse |
LineageMasterClientService.Iface.reportLostFile(String path,
ReportLostFileTOptions options)
Reports file as lost.
|
ReportLostFileTResponse |
LineageMasterClientService.Client.reportLostFile(String path,
ReportLostFileTOptions options) |
RequestBlockLocationTResponse |
BlockWorkerClientService.Iface.requestBlockLocation(long sessionId,
long blockId,
long initialBytes,
int writeTier,
RequestBlockLocationTOptions options)
Used to allocate location and space for a new coming block, worker will choose the appropriate
storage directory which fits the initial block size by some allocation strategy, and the
temporary file path of the block file will be returned.
|
RequestBlockLocationTResponse |
BlockWorkerClientService.Client.requestBlockLocation(long sessionId,
long blockId,
long initialBytes,
int writeTier,
RequestBlockLocationTOptions options) |
RequestSpaceTResponse |
BlockWorkerClientService.Iface.requestSpace(long sessionId,
long blockId,
long requestBytes,
RequestSpaceTOptions options)
Used to request space for some block file.
|
RequestSpaceTResponse |
BlockWorkerClientService.Client.requestSpace(long sessionId,
long blockId,
long requestBytes,
RequestSpaceTOptions options) |
ScheduleAsyncPersistenceTResponse |
FileSystemMasterClientService.Iface.scheduleAsyncPersistence(String path,
ScheduleAsyncPersistenceTOptions options)
Schedules async persistence.
|
ScheduleAsyncPersistenceTResponse |
FileSystemMasterClientService.Client.scheduleAsyncPersistence(String path,
ScheduleAsyncPersistenceTOptions options) |
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.Iface.sessionBlockHeartbeat(long sessionId,
List<Long> metrics,
SessionBlockHeartbeatTOptions options)
Local session send heartbeat to local worker to keep its temporary folder.
|
SessionBlockHeartbeatTResponse |
BlockWorkerClientService.Client.sessionBlockHeartbeat(long sessionId,
List<Long> metrics,
SessionBlockHeartbeatTOptions options) |
SessionFileSystemHeartbeatTResponse |
FileSystemWorkerClientService.Iface.sessionFileSystemHeartbeat(long sessionId,
List<Long> metrics,
SessionFileSystemHeartbeatTOptions options)
Local session send heartbeat to local worker to keep its state.
|
SessionFileSystemHeartbeatTResponse |
FileSystemWorkerClientService.Client.sessionFileSystemHeartbeat(long sessionId,
List<Long> metrics,
SessionFileSystemHeartbeatTOptions options) |
SetAttributeTResponse |
FileSystemMasterClientService.Iface.setAttribute(String path,
SetAttributeTOptions options)
Sets file or directory attributes.
|
SetAttributeTResponse |
FileSystemMasterClientService.Client.setAttribute(String path,
SetAttributeTOptions options) |
UnlockBlockTResponse |
BlockWorkerClientService.Iface.unlockBlock(long blockId,
long sessionId,
UnlockBlockTOptions options)
Used to unlock a block after the block is accessed, if the block is to be removed, delete the
block file.
|
UnlockBlockTResponse |
BlockWorkerClientService.Client.unlockBlock(long blockId,
long sessionId,
UnlockBlockTOptions options) |
UnmountTResponse |
FileSystemMasterClientService.Iface.unmount(String alluxioPath,
UnmountTOptions options)
Deletes an existing "mount point", voiding the Alluxio namespace at the given path.
|
UnmountTResponse |
FileSystemMasterClientService.Client.unmount(String alluxioPath,
UnmountTOptions options) |
UpdateUfsModeTResponse |
FileSystemMasterClientService.Iface.updateUfsMode(String ufsPath,
UpdateUfsModeTOptions options)
Updates the ufs mode for a ufs path under one or more mount points.
|
UpdateUfsModeTResponse |
FileSystemMasterClientService.Client.updateUfsMode(String ufsPath,
UpdateUfsModeTOptions options) |
Modifier and Type | Method and Description |
---|---|
AccessBlockTResponse |
BlockWorkerClientServiceHandler.accessBlock(long blockId,
AccessBlockTOptions options) |
CacheBlockTResponse |
BlockWorkerClientServiceHandler.cacheBlock(long sessionId,
long blockId,
CacheBlockTOptions options) |
CancelBlockTResponse |
BlockWorkerClientServiceHandler.cancelBlock(long sessionId,
long blockId,
CancelBlockTOptions options) |
LockBlockTResponse |
BlockWorkerClientServiceHandler.lockBlock(long blockId,
long sessionId,
LockBlockTOptions options) |
PromoteBlockTResponse |
BlockWorkerClientServiceHandler.promoteBlock(long blockId,
PromoteBlockTOptions options) |
RemoveBlockTResponse |
BlockWorkerClientServiceHandler.removeBlock(long blockId,
RemoveBlockTOptions options) |
RequestBlockLocationTResponse |
BlockWorkerClientServiceHandler.requestBlockLocation(long sessionId,
long blockId,
long initialBytes,
int writeTier,
RequestBlockLocationTOptions options) |
RequestSpaceTResponse |
BlockWorkerClientServiceHandler.requestSpace(long sessionId,
long blockId,
long requestBytes,
RequestSpaceTOptions options) |
SessionBlockHeartbeatTResponse |
BlockWorkerClientServiceHandler.sessionBlockHeartbeat(long sessionId,
List<Long> metrics,
SessionBlockHeartbeatTOptions options) |
UnlockBlockTResponse |
BlockWorkerClientServiceHandler.unlockBlock(long blockId,
long sessionId,
UnlockBlockTOptions options) |
Modifier and Type | Method and Description |
---|---|
CancelUfsFileTResponse |
FileSystemWorkerClientServiceHandler.cancelUfsFile(long sessionId,
long tempUfsFileId,
CancelUfsFileTOptions options) |
CloseUfsFileTResponse |
FileSystemWorkerClientServiceHandler.closeUfsFile(long sessionId,
long tempUfsFileId,
CloseUfsFileTOptions options) |
CompleteUfsFileTReponse |
FileSystemWorkerClientServiceHandler.completeUfsFile(long sessionId,
long tempUfsFileId,
CompleteUfsFileTOptions options) |
CreateUfsFileTResponse |
FileSystemWorkerClientServiceHandler.createUfsFile(long sessionId,
String ufsUri,
CreateUfsFileTOptions options) |
OpenUfsFileTResponse |
FileSystemWorkerClientServiceHandler.openUfsFile(long sessionId,
String ufsUri,
OpenUfsFileTOptions options) |
SessionFileSystemHeartbeatTResponse |
FileSystemWorkerClientServiceHandler.sessionFileSystemHeartbeat(long sessionId,
List<Long> metrics,
SessionFileSystemHeartbeatTOptions options) |
Modifier and Type | Method and Description |
---|---|
GetTResponse |
KeyValueWorkerClientServiceHandler.get(long blockId,
ByteBuffer key,
GetTOptions options) |
GetNextKeysTResponse |
KeyValueWorkerClientServiceHandler.getNextKeys(long blockId,
ByteBuffer key,
int numKeys,
GetNextKeysTOptions options) |
GetSizeTResponse |
KeyValueWorkerClientServiceHandler.getSize(long blockId,
GetSizeTOptions options) |
Copyright © 2023. All Rights Reserved.