alluxio.client.block

Class RetryHandlingBlockMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.block.RetryHandlingBlockMasterClient

All Implemented Interfaces:

Client, BlockMasterClient, java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public final class RetryHandlingBlockMasterClient
extends AbstractMasterClient
implements BlockMasterClient

A wrapper for the gRPC client to interact with the block master, used by alluxio clients.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Nested classes/interfaces inherited from interface alluxio.client.block.BlockMasterClient

BlockMasterClient.Factory

Field Summary

Fields inherited from class alluxio.AbstractClient

mChannel, mClosed, mConnected, mContext, mServerAddress, mServiceVersion, mVersionService

Constructor Summary

Constructors

Constructor and Description
RetryHandlingBlockMasterClient(MasterClientContext conf) Creates a new block master client.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect()
BlockInfo	getBlockInfo(long blockId) Returns the BlockInfo for a block id.
BlockMasterInfo	getBlockMasterInfo(java.util.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 java.lang.String	getServiceName()
protected long	getServiceVersion()
long	getUsedBytes() Gets the total amount of used space in bytes, on all the tiers of all the workers.
java.util.List<WorkerInfo>	getWorkerInfoList() Gets the worker information of live workers(support older version Alluxio server).
java.util.List<WorkerLostStorageInfo>	getWorkerLostStorage()
java.util.List<WorkerInfo>	getWorkerReport(GetWorkerReportOptions options) Gets the worker information of selected workers and selected fields for report CLI.

Methods inherited from class alluxio.AbstractMasterClient

afterDisconnect, beforeConnect, getConfAddress, queryGrpcServerAddress

Methods inherited from class alluxio.AbstractClient

beforeDisconnect, checkVersion, close, connect, connectWithRuntimeException, disconnect, getRemoteHostName, getRemoteServiceVersion, getRemoteSockAddress, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface alluxio.Client

connect, disconnect, getConfAddress, getRemoteHostName, getRemoteSockAddress, isClosed, isConnected

Methods inherited from interface java.io.Closeable

close

Constructor Detail

RetryHandlingBlockMasterClient

public RetryHandlingBlockMasterClient(MasterClientContext conf)

Creates a new block master client.

Parameters:

conf - master client configuration

Method Detail

getRemoteServiceType

protected ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class AbstractClient

getServiceName

protected java.lang.String getServiceName()

Specified by:

getServiceName in class AbstractClient

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class AbstractClient

afterConnect

protected void afterConnect()

Overrides:

afterConnect in class AbstractClient

getWorkerInfoList

public java.util.List<WorkerInfo> getWorkerInfoList()
                                             throws java.io.IOException

Description copied from interface: BlockMasterClient

Gets the worker information of live workers(support older version Alluxio server).

Specified by:

getWorkerInfoList in interface BlockMasterClient

Returns:

a list of worker information

Throws:

java.io.IOException

getWorkerReport

public java.util.List<WorkerInfo> getWorkerReport(GetWorkerReportOptions options)
                                           throws java.io.IOException

Description copied from interface: BlockMasterClient

Gets the worker information of selected workers and selected fields for report CLI.

Specified by:

getWorkerReport in interface BlockMasterClient

Parameters:

options - the client defined worker and field ranges

Returns:

a list of worker information

Throws:

java.io.IOException

getWorkerLostStorage

public java.util.List<WorkerLostStorageInfo> getWorkerLostStorage()
                                                           throws java.io.IOException

Specified by:

getWorkerLostStorage in interface BlockMasterClient

Returns:

a list of worker lost storage information

Throws:

java.io.IOException

getBlockInfo

public BlockInfo getBlockInfo(long blockId)
                       throws java.io.IOException

Description copied from interface: BlockMasterClient

Returns the BlockInfo for a block id.

Specified by:

getBlockInfo in interface BlockMasterClient

Parameters:

blockId - the block id to get the BlockInfo for

Returns:

the BlockInfo

Throws:

java.io.IOException

getBlockMasterInfo

public BlockMasterInfo getBlockMasterInfo(java.util.Set<BlockMasterInfo.BlockMasterInfoField> fields)
                                   throws java.io.IOException

Specified by:

getBlockMasterInfo in interface BlockMasterClient

Parameters:

fields - optional list of fields to query; if null all fields will be queried

Returns:

the BlockMasterInfo block master information

Throws:

java.io.IOException

getCapacityBytes

public long getCapacityBytes()
                      throws java.io.IOException

Description copied from interface: BlockMasterClient

Gets the total Alluxio capacity in bytes, on all the tiers of all the workers.

Specified by:

getCapacityBytes in interface BlockMasterClient

Returns:

total capacity in bytes

Throws:

java.io.IOException

getUsedBytes

public long getUsedBytes()
                  throws java.io.IOException

Description copied from interface: BlockMasterClient

Gets the total amount of used space in bytes, on all the tiers of all the workers.

Specified by:

getUsedBytes in interface BlockMasterClient

Returns:

amount of used space in bytes

Throws:

java.io.IOException