alluxio.client.block.util

Class WorkerInfoUtil

java.lang.Object

alluxio.client.block.util.WorkerInfoUtil

public class WorkerInfoUtil
extends Object

The util class for getting the worker info.

Constructor Summary

Constructors

Constructor and Description
WorkerInfoUtil()

Method Summary

Modifier and Type	Method and Description
static AllMastersWorkerInfo	getWorkerReportsFromAllMasters(AlluxioConfiguration configuration, BlockMasterClient primaryMasterClient, GetWorkerReportOptions options) Get worker reports from all masters, including standby masters.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerInfoUtil

public WorkerInfoUtil()

Method Detail

getWorkerReportsFromAllMasters

public static AllMastersWorkerInfo getWorkerReportsFromAllMasters(AlluxioConfiguration configuration,
                                                                  BlockMasterClient primaryMasterClient,
                                                                  GetWorkerReportOptions options)
                                                           throws IOException

Get worker reports from all masters, including standby masters. Can only be called when worker all master registration feature is enabled.

Parameters:

configuration - the cluster configuration

primaryMasterClient - the block master client connecting to the primary

options - the options to make the GetWorkerReport rpc

Returns:

the aggregated worker info

Throws:

IOException