@ThreadSafe public final class FileSystemMasterClient extends AbstractMasterClient
AbstractClient.RpcCallable<V>
mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService
Constructor and Description |
---|
FileSystemMasterClient(MasterClientContext conf)
Creates a instance of
FileSystemMasterClient . |
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect()
This method is called after the connection is made to the remote.
|
FileInfo |
getFileInfo(long fileId) |
Set<Long> |
getPinList() |
protected ServiceType |
getRemoteServiceType() |
protected String |
getServiceName() |
protected long |
getServiceVersion() |
UfsInfo |
getUfsInfo(long mountId) |
FileSystemCommand |
heartbeat(long workerId,
List<Long> persistedFiles)
Heartbeats to the master.
|
FileSystemCommand |
heartbeat(long workerId,
List<Long> persistedFiles,
FileSystemHeartbeatPOptions options)
Heartbeats to the master.
|
getAddress, getConfAddress
afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, isConnected, retryRPC, retryRPC
public FileSystemMasterClient(MasterClientContext conf)
FileSystemMasterClient
.conf
- master client configurationprotected ServiceType getRemoteServiceType()
getRemoteServiceType
in class AbstractClient
protected String getServiceName()
getServiceName
in class AbstractClient
protected long getServiceVersion()
getServiceVersion
in class AbstractClient
protected void afterConnect() throws IOException
AbstractClient
afterConnect
in class AbstractClient
IOException
public FileInfo getFileInfo(long fileId) throws IOException
fileId
- the id of the file for which to get the FileInfo
IOException
public Set<Long> getPinList() throws IOException
IOException
public UfsInfo getUfsInfo(long mountId) throws IOException
mountId
- the id of the mountIOException
- if an I/O error occurspublic FileSystemCommand heartbeat(long workerId, List<Long> persistedFiles) throws IOException
workerId
- the id of the worker that heartbeatspersistedFiles
- the files which have been persisted since the last heartbeatIOException
public FileSystemCommand heartbeat(long workerId, List<Long> persistedFiles, FileSystemHeartbeatPOptions options) throws IOException
workerId
- the id of the worker that heartbeatspersistedFiles
- the files which have been persisted since the last heartbeatoptions
- heartbeat optionsIOException
Copyright © 2023. All Rights Reserved.