Package | Description |
---|---|
tachyon.master | |
tachyon.thrift | |
tachyon.worker |
Worker process and utils for working with the worker remotely.
|
Modifier and Type | Method and Description |
---|---|
int |
MasterInfo.createFile(boolean recursive,
TachyonURI path,
boolean directory,
long blockSizeByte)
Create a file.
|
int |
MasterInfo.createFile(TachyonURI path,
long blockSizeByte) |
int |
MasterInfo.createFile(TachyonURI path,
long blockSizeByte,
boolean recursive) |
int |
MasterInfo.createRawTable(TachyonURI path,
int columns,
ByteBuffer metadata)
Creates a raw table.
|
boolean |
MasterInfo.mkdirs(TachyonURI path,
boolean recursive)
Create a directory at the given path.
|
int |
MasterServiceHandler.user_createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
int dependencyType,
long childrenBlockSizeByte) |
int |
MasterServiceHandler.user_createFile(String path,
String ufsPath,
long blockSizeByte,
boolean recursive) |
int |
MasterServiceHandler.user_createRawTable(String path,
int columns,
ByteBuffer metadata) |
boolean |
MasterServiceHandler.user_mkdirs(String path,
boolean recursive) |
boolean |
MasterServiceHandler.user_rename(int fileId,
String srcPath,
String dstPath) |
Modifier and Type | Field and Description |
---|---|
FileAlreadyExistException |
MasterService.user_createDependency_result.eA |
FileAlreadyExistException |
MasterService.user_rename_result.eA |
FileAlreadyExistException |
MasterService.user_createFile_result.eR |
FileAlreadyExistException |
MasterService.user_mkdirs_result.eR |
FileAlreadyExistException |
MasterService.user_createRawTable_result.eR |
FileAlreadyExistException |
WorkerService.requestBlockLocation_result.eS |
Modifier and Type | Method and Description |
---|---|
FileAlreadyExistException |
FileAlreadyExistException.deepCopy() |
FileAlreadyExistException |
MasterService.user_createDependency_result.getEA() |
FileAlreadyExistException |
MasterService.user_rename_result.getEA() |
FileAlreadyExistException |
MasterService.user_createFile_result.getER() |
FileAlreadyExistException |
MasterService.user_mkdirs_result.getER() |
FileAlreadyExistException |
MasterService.user_createRawTable_result.getER() |
FileAlreadyExistException |
WorkerService.requestBlockLocation_result.getES() |
FileAlreadyExistException |
FileAlreadyExistException.setMessage(String message) |
Modifier and Type | Method and Description |
---|---|
int |
FileAlreadyExistException.compareTo(FileAlreadyExistException other) |
boolean |
FileAlreadyExistException.equals(FileAlreadyExistException that) |
MasterService.user_createDependency_result |
MasterService.user_createDependency_result.setEA(FileAlreadyExistException eA) |
MasterService.user_rename_result |
MasterService.user_rename_result.setEA(FileAlreadyExistException eA) |
MasterService.user_createFile_result |
MasterService.user_createFile_result.setER(FileAlreadyExistException eR) |
MasterService.user_mkdirs_result |
MasterService.user_mkdirs_result.setER(FileAlreadyExistException eR) |
MasterService.user_createRawTable_result |
MasterService.user_createRawTable_result.setER(FileAlreadyExistException eR) |
WorkerService.requestBlockLocation_result |
WorkerService.requestBlockLocation_result.setES(FileAlreadyExistException eS) |
Modifier and Type | Method and Description |
---|---|
String |
WorkerService.AsyncClient.requestBlockLocation_call.getResult() |
int |
MasterService.AsyncClient.user_createDependency_call.getResult() |
int |
MasterService.AsyncClient.user_createFile_call.getResult() |
boolean |
MasterService.AsyncClient.user_rename_call.getResult() |
boolean |
MasterService.AsyncClient.user_mkdirs_call.getResult() |
int |
MasterService.AsyncClient.user_createRawTable_call.getResult() |
String |
WorkerService.Client.recv_requestBlockLocation() |
int |
MasterService.Client.recv_user_createDependency() |
int |
MasterService.Client.recv_user_createFile() |
int |
MasterService.Client.recv_user_createRawTable() |
boolean |
MasterService.Client.recv_user_mkdirs() |
boolean |
MasterService.Client.recv_user_rename() |
String |
WorkerService.Iface.requestBlockLocation(long userId,
long blockId,
long initialBytes)
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.
|
String |
WorkerService.Client.requestBlockLocation(long userId,
long blockId,
long initialBytes) |
int |
MasterService.Iface.user_createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
int dependencyType,
long childrenBlockSizeByte) |
int |
MasterService.Client.user_createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
int dependencyType,
long childrenBlockSizeByte) |
int |
MasterService.Iface.user_createFile(String path,
String ufsPath,
long blockSizeByte,
boolean recursive) |
int |
MasterService.Client.user_createFile(String path,
String ufsPath,
long blockSizeByte,
boolean recursive) |
int |
MasterService.Iface.user_createRawTable(String path,
int columns,
ByteBuffer metadata) |
int |
MasterService.Client.user_createRawTable(String path,
int columns,
ByteBuffer metadata) |
boolean |
MasterService.Iface.user_mkdirs(String path,
boolean recursive) |
boolean |
MasterService.Client.user_mkdirs(String path,
boolean recursive) |
boolean |
MasterService.Iface.user_rename(int fileId,
String srcPath,
String dstPath) |
boolean |
MasterService.Client.user_rename(int fileId,
String srcPath,
String dstPath) |
Modifier and Type | Method and Description |
---|---|
String |
WorkerStorage.requestBlockLocation(long userId,
long blockId,
long initialBytes)
Get temporary file path for some block, it is used to choose appropriate StorageDir for some
block file with specified initial size.
|
String |
WorkerServiceHandler.requestBlockLocation(long userId,
long blockId,
long initialBytes) |
Copyright © 2015. All Rights Reserved.