@ThreadSafe public final class RetryHandlingBlockMasterClient extends AbstractMasterClient implements BlockMasterClient
AbstractClient.RpcCallable<V>
BlockMasterClient.Factory
mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService
Constructor and Description |
---|
RetryHandlingBlockMasterClient(MasterClientContext conf)
Creates a new block master client.
|
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect()
This method is called after the connection is made to the remote.
|
BlockInfo |
getBlockInfo(long blockId)
Returns the
BlockInfo for a block id. |
BlockMasterInfo |
getBlockMasterInfo(Set<BlockMasterInfo.BlockMasterInfoField> fields) |
long |
getCapacityBytes()
Gets the total Alluxio capacity in bytes, on all the tiers of all the workers.
|
protected ServiceType |
getRemoteServiceType() |
protected String |
getServiceName() |
protected long |
getServiceVersion() |
long |
getUsedBytes()
Gets the total amount of used space in bytes, on all the tiers of all the workers.
|
List<WorkerInfo> |
getWorkerInfoList()
Gets the worker information of live workers(support older version Alluxio server).
|
List<WorkerLostStorageInfo> |
getWorkerLostStorage() |
List<WorkerInfo> |
getWorkerReport(GetWorkerReportOptions options)
Gets the worker information of selected workers and selected fields for report CLI.
|
getAddress, getConfAddress
afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, isConnected, retryRPC, retryRPC
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect, disconnect, getAddress, getConfAddress, isClosed, isConnected
public RetryHandlingBlockMasterClient(MasterClientContext conf)
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()
AbstractClient
afterConnect
in class AbstractClient
public List<WorkerInfo> getWorkerInfoList() throws IOException
BlockMasterClient
getWorkerInfoList
in interface BlockMasterClient
IOException
public List<WorkerInfo> getWorkerReport(GetWorkerReportOptions options) throws IOException
BlockMasterClient
getWorkerReport
in interface BlockMasterClient
options
- the client defined worker and field rangesIOException
public List<WorkerLostStorageInfo> getWorkerLostStorage() throws IOException
getWorkerLostStorage
in interface BlockMasterClient
IOException
public BlockInfo getBlockInfo(long blockId) throws IOException
BlockInfo
for a block id.getBlockInfo
in interface BlockMasterClient
blockId
- the block id to get the BlockInfo forBlockInfo
IOException
public BlockMasterInfo getBlockMasterInfo(Set<BlockMasterInfo.BlockMasterInfoField> fields) throws IOException
getBlockMasterInfo
in interface BlockMasterClient
fields
- optional list of fields to query; if null all fields will be queriedBlockMasterInfo
block master informationIOException
public long getCapacityBytes() throws IOException
getCapacityBytes
in interface BlockMasterClient
IOException
public long getUsedBytes() throws IOException
getUsedBytes
in interface BlockMasterClient
IOException
Copyright © 2023. All Rights Reserved.