public class TachyonFS extends Object
| Modifier and Type | Method and Description |
|---|---|
void |
accessLocalBlock(long blockId) |
void |
addCheckpoint(int fid) |
boolean |
asyncCheckpoint(int fid) |
void |
cacheBlock(long blockId) |
void |
close() |
void |
completeFile(int fId) |
void |
connect() |
File |
createAndGetUserTempFolder() |
String |
createAndGetUserUnderfsTempFolder() |
int |
createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
int dependencyType,
long childrenBlockSizeByte) |
int |
createFile(String path) |
int |
createFile(String path,
long blockSizeByte) |
int |
createFile(String path,
String checkpointPath) |
int |
createRawTable(String path,
int columns) |
int |
createRawTable(String path,
int columns,
ByteBuffer metadata) |
boolean |
delete(int fid,
boolean recursive) |
boolean |
delete(String path,
boolean recursive) |
boolean |
exist(String path) |
static TachyonFS |
get(String tachyonAddress) |
long |
getBlockId(int fId,
int blockIndex) |
long |
getBlockIdBasedOnOffset(int fId,
long offset) |
int |
getBlockLockId() |
long |
getBlockSizeByte(int fId) |
ClientBlockInfo |
getClientBlockInfo(int fId,
int blockIndex) |
ClientDependencyInfo |
getClientDependencyInfo(int did) |
long |
getCreationTimeMs(int fId) |
TachyonFile |
getFile(int fid)
Get
TachyonFile based on the file id. |
TachyonFile |
getFile(String path)
Get
TachyonFile based on the path. |
TachyonFile |
getFile(String path,
boolean useCachedMetadata) |
List<Long> |
getFileBlockIdList(int fId) |
List<ClientBlockInfo> |
getFileBlocks(int fid) |
List<String> |
getFileHosts(int fileId) |
int |
getFileId(String path) |
List<NetAddress> |
getFileNetAddresses(int fileId) |
List<List<String>> |
getFilesHosts(List<Integer> fileIds) |
List<List<NetAddress>> |
getFilesNetAddresses(List<Integer> fileIds) |
int |
getNumberOfFiles(String folderPath) |
RawTable |
getRawTable(int id) |
RawTable |
getRawTable(String path) |
String |
getRootFolder() |
String |
getUnderfsAddress() |
List<ClientWorkerInfo> |
getWorkersInfo() |
boolean |
hasLocalWorker() |
boolean |
isConnected() |
List<Integer> |
listFiles(String path,
boolean recursive) |
List<ClientFileInfo> |
listStatus(String path)
If the
path is a directory, return all the direct entries in it. |
List<String> |
ls(String path,
boolean recursive) |
boolean |
mkdir(String path)
Create a directory if it does not exist.
|
void |
outOfMemoryForPinFile(int fid) |
void |
releaseSpace(long releaseSpaceBytes) |
boolean |
rename(int fId,
String path) |
boolean |
rename(String srcPath,
String dstPath) |
void |
reportLostFile(int fileId) |
void |
requestFilesInDependency(int depId) |
boolean |
requestSpace(long requestSpaceBytes) |
boolean |
unpinFile(int fid) |
void |
updateRawTableMetadata(int id,
ByteBuffer metadata) |
public static TachyonFS get(String tachyonAddress) throws IOException
IOExceptionpublic void accessLocalBlock(long blockId)
public void addCheckpoint(int fid)
throws IOException
IOExceptionpublic void cacheBlock(long blockId)
throws IOException
IOExceptionpublic void close()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void connect()
public void completeFile(int fId)
throws IOException
IOExceptionpublic File createAndGetUserTempFolder() throws IOException
IOExceptionpublic String createAndGetUserUnderfsTempFolder() throws IOException
IOExceptionpublic int createRawTable(String path, int columns) throws IOException
IOExceptionpublic int createRawTable(String path, int columns, ByteBuffer metadata) throws IOException
IOExceptionpublic int createFile(String path) throws IOException
IOExceptionpublic int createFile(String path, long blockSizeByte) throws IOException
IOExceptionpublic int createFile(String path, String checkpointPath) throws IOException
IOExceptionpublic boolean delete(int fid,
boolean recursive)
throws IOException
IOExceptionpublic boolean delete(String path, boolean recursive) throws IOException
IOExceptionpublic boolean exist(String path) throws IOException
IOExceptionpublic long getBlockId(int fId,
int blockIndex)
throws IOException
IOExceptionpublic long getBlockIdBasedOnOffset(int fId,
long offset)
throws IOException
IOExceptionpublic ClientBlockInfo getClientBlockInfo(int fId, int blockIndex) throws IOException
IOExceptionpublic long getBlockSizeByte(int fId)
public long getCreationTimeMs(int fId)
public List<Long> getFileBlockIdList(int fId) throws IOException
IOExceptionpublic List<ClientBlockInfo> getFileBlocks(int fid) throws IOException
IOExceptionpublic TachyonFile getFile(String path) throws IOException
TachyonFile based on the path.path - file path.IOExceptionpublic TachyonFile getFile(String path, boolean useCachedMetadata) throws IOException
IOExceptionpublic TachyonFile getFile(int fid)
TachyonFile based on the file id.fid - file id.public int getFileId(String path) throws IOException
IOExceptionpublic int getNumberOfFiles(String folderPath) throws IOException
IOExceptionpublic RawTable getRawTable(String path) throws IOException
IOExceptionpublic RawTable getRawTable(int id) throws IOException
IOExceptionpublic String getRootFolder()
public int getBlockLockId()
public String getUnderfsAddress() throws IOException
IOExceptionpublic List<ClientWorkerInfo> getWorkersInfo() throws IOException
IOExceptionpublic boolean hasLocalWorker()
public boolean isConnected()
public List<Integer> listFiles(String path, boolean recursive) throws IOException
IOExceptionpublic List<ClientFileInfo> listStatus(String path) throws IOException
path is a directory, return all the direct entries in it. If the
path is a file, return its ClientFileInfo.path - the target directory/file pathIOExceptionpublic List<String> ls(String path, boolean recursive) throws IOException
IOExceptionpublic boolean mkdir(String path) throws IOException
path - Directory path.IOExceptionpublic void outOfMemoryForPinFile(int fid)
public void releaseSpace(long releaseSpaceBytes)
public boolean rename(String srcPath, String dstPath) throws IOException
IOExceptionpublic boolean rename(int fId,
String path)
throws IOException
IOExceptionpublic boolean requestSpace(long requestSpaceBytes)
public boolean unpinFile(int fid)
throws IOException
IOExceptionpublic void updateRawTableMetadata(int id,
ByteBuffer metadata)
throws IOException
IOExceptionpublic int createDependency(List<String> parents, List<String> children, String commandPrefix, List<ByteBuffer> data, String comment, String framework, String frameworkVersion, int dependencyType, long childrenBlockSizeByte) throws IOException
IOExceptionpublic void reportLostFile(int fileId)
throws IOException
IOExceptionpublic void requestFilesInDependency(int depId)
throws IOException
IOExceptionpublic boolean asyncCheckpoint(int fid)
throws IOException
IOExceptionpublic ClientDependencyInfo getClientDependencyInfo(int did) throws IOException
IOExceptionpublic List<NetAddress> getFileNetAddresses(int fileId) throws IOException
IOExceptionpublic List<List<NetAddress>> getFilesNetAddresses(List<Integer> fileIds) throws IOException
IOExceptionpublic List<String> getFileHosts(int fileId) throws IOException
IOExceptionpublic List<List<String>> getFilesHosts(List<Integer> fileIds) throws IOException
IOExceptionCopyright © 2014. All rights reserved.