public final class WorkerFileSystemMasterClient extends MasterClientBase
mUseZookeeper
mAddress, mClosed, mConnected, mMode, mProtocol, mTachyonConf, RPC_MAX_NUM_RETRY
Constructor and Description |
---|
WorkerFileSystemMasterClient(InetSocketAddress masterAddress,
TachyonConf tachyonConf)
Creates a new file system master client for the worker.
|
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect() |
FileInfo |
getFileInfo(long fileId) |
Set<Long> |
getPinList() |
protected String |
getServiceName() |
boolean |
persistFile(long fileId,
long length)
Persists a file.
|
getAddress
afterDisconnect, close, connect, disconnect, isConnected, resetConnection
public WorkerFileSystemMasterClient(InetSocketAddress masterAddress, TachyonConf tachyonConf)
masterAddress
- the master addresstachyonConf
- the Tachyon configurationprotected String getServiceName()
getServiceName
in class ClientBase
protected void afterConnect()
afterConnect
in class ClientBase
public boolean persistFile(long fileId, long length) throws IOException
fileId
- the file idlength
- the checkpoint lengthIOException
- if an I/O error occurspublic FileInfo getFileInfo(long fileId) throws IOException
fileId
- the file idIOException
- if an I/O error occurspublic Set<Long> getPinList() throws IOException
IOException
- if an I/O error occursCopyright © 2015. All Rights Reserved.