Package | Description |
---|---|
tachyon.master | |
tachyon.thrift | |
tachyon.worker |
Worker process and utils for working with the worker remotely.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RawTables.addRawTable(int tableId,
int columns,
ByteBuffer metadata)
Add a raw table.
|
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.delete(int fileId,
boolean recursive)
Delete a file based on the file's ID.
|
boolean |
MasterInfo.delete(TachyonURI path,
boolean recursive)
Delete files based on the path.
|
boolean |
MasterInfo.freepath(TachyonURI path,
boolean recursive)
Frees files based on the path
|
boolean |
MasterInfo.mkdirs(TachyonURI path,
boolean recursive)
Create a directory at the given path.
|
void |
RawTables.updateMetadata(int tableId,
ByteBuffer metadata)
Update the metadata of the specified raw table.
|
void |
MasterInfo.updateRawTableMetadata(int tableId,
ByteBuffer metadata)
Update the metadata of a table.
|
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_delete(int fileId,
String path,
boolean recursive) |
boolean |
MasterServiceHandler.user_freepath(int fileId,
String path,
boolean recursive) |
boolean |
MasterServiceHandler.user_mkdirs(String path,
boolean recursive) |
void |
MasterServiceHandler.user_updateRawTableMetadata(int tableId,
ByteBuffer metadata) |
Modifier and Type | Field and Description |
---|---|
TachyonException |
WorkerService.asyncCheckpoint_result.e |
TachyonException |
MasterService.user_delete_result.e |
TachyonException |
MasterService.user_createDependency_result.eT |
TachyonException |
MasterService.user_createFile_result.eT |
TachyonException |
MasterService.user_mkdirs_result.eT |
TachyonException |
MasterService.user_createRawTable_result.eTa |
TachyonException |
MasterService.user_updateRawTableMetadata_result.eTa |
Modifier and Type | Method and Description |
---|---|
TachyonException |
TachyonException.deepCopy() |
TachyonException |
WorkerService.asyncCheckpoint_result.getE() |
TachyonException |
MasterService.user_delete_result.getE() |
TachyonException |
MasterService.user_createDependency_result.getET() |
TachyonException |
MasterService.user_createFile_result.getET() |
TachyonException |
MasterService.user_mkdirs_result.getET() |
TachyonException |
MasterService.user_createRawTable_result.getETa() |
TachyonException |
MasterService.user_updateRawTableMetadata_result.getETa() |
TachyonException |
TachyonException.setMessage(String message) |
Modifier and Type | Method and Description |
---|---|
int |
TachyonException.compareTo(TachyonException other) |
boolean |
TachyonException.equals(TachyonException that) |
WorkerService.asyncCheckpoint_result |
WorkerService.asyncCheckpoint_result.setE(TachyonException e) |
MasterService.user_delete_result |
MasterService.user_delete_result.setE(TachyonException e) |
MasterService.user_createDependency_result |
MasterService.user_createDependency_result.setET(TachyonException eT) |
MasterService.user_createFile_result |
MasterService.user_createFile_result.setET(TachyonException eT) |
MasterService.user_mkdirs_result |
MasterService.user_mkdirs_result.setET(TachyonException eT) |
MasterService.user_createRawTable_result |
MasterService.user_createRawTable_result.setETa(TachyonException eTa) |
MasterService.user_updateRawTableMetadata_result |
MasterService.user_updateRawTableMetadata_result.setETa(TachyonException eTa) |
Modifier and Type | Method and Description |
---|---|
boolean |
WorkerService.Iface.asyncCheckpoint(int fileId) |
boolean |
WorkerService.Client.asyncCheckpoint(int fileId) |
boolean |
WorkerService.AsyncClient.asyncCheckpoint_call.getResult() |
int |
MasterService.AsyncClient.user_createDependency_call.getResult() |
int |
MasterService.AsyncClient.user_createFile_call.getResult() |
boolean |
MasterService.AsyncClient.user_delete_call.getResult() |
boolean |
MasterService.AsyncClient.user_mkdirs_call.getResult() |
int |
MasterService.AsyncClient.user_createRawTable_call.getResult() |
void |
MasterService.AsyncClient.user_updateRawTableMetadata_call.getResult() |
boolean |
WorkerService.Client.recv_asyncCheckpoint() |
int |
MasterService.Client.recv_user_createDependency() |
int |
MasterService.Client.recv_user_createFile() |
int |
MasterService.Client.recv_user_createRawTable() |
boolean |
MasterService.Client.recv_user_delete() |
boolean |
MasterService.Client.recv_user_mkdirs() |
void |
MasterService.Client.recv_user_updateRawTableMetadata() |
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_delete(int fileId,
String path,
boolean recursive)
Delete file
|
boolean |
MasterService.Client.user_delete(int fileId,
String path,
boolean recursive) |
boolean |
MasterService.Iface.user_mkdirs(String path,
boolean recursive) |
boolean |
MasterService.Client.user_mkdirs(String path,
boolean recursive) |
void |
MasterService.Iface.user_updateRawTableMetadata(int tableId,
ByteBuffer metadata) |
void |
MasterService.Client.user_updateRawTableMetadata(int tableId,
ByteBuffer metadata) |
Modifier and Type | Method and Description |
---|---|
boolean |
WorkerServiceHandler.asyncCheckpoint(int fileId) |
Copyright © 2015. All Rights Reserved.