alluxio.worker.block

Class RegisterStreamer

java.lang.Object

alluxio.worker.block.RegisterStreamer

All Implemented Interfaces:

Iterator<RegisterWorkerPRequest>

public class RegisterStreamer
extends Object
implements Iterator<RegisterWorkerPRequest>

This class oversees the logic of registering with the master using a stream of RegisterWorkerPRequest. The stream lifecycle management lives internal to this instance.

Constructor Summary

Constructors

Constructor and Description
RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient, long workerId, List<String> storageTierAliases, Map<String,Long> totalBytesOnTiers, Map<String,Long> usedBytesOnTiers, Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation, Map<String,List<String>> lostStorage, List<ConfigProperty> configList) Constructor.
RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient, long workerId, List<String> storageTierAliases, Map<String,Long> totalBytesOnTiers, Map<String,Long> usedBytesOnTiers, Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation, Map<String,List<String>> lostStorage, List<ConfigProperty> configList, BuildVersion version) Constructor.
RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient, long workerId, List<String> storageTierAliases, Map<String,Long> totalBytesOnTiers, Map<String,Long> usedBytesOnTiers, Map<String,List<String>> lostStorage, List<ConfigProperty> configList, BlockMapIterator blockListIterator) Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
RegisterWorkerPRequest	next()
void	registerWithMaster() Manages the logic of registering with the master in a stream.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

RegisterStreamer

public RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient,
                        long workerId,
                        List<String> storageTierAliases,
                        Map<String,Long> totalBytesOnTiers,
                        Map<String,Long> usedBytesOnTiers,
                        Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation,
                        Map<String,List<String>> lostStorage,
                        List<ConfigProperty> configList)

Constructor.

Parameters:

asyncClient - the grpc client

workerId - the worker ID

storageTierAliases - storage/tier setup from the configuration

totalBytesOnTiers - the capacity of each tier

usedBytesOnTiers - the current usage of each tier

currentBlocksOnLocation - the blocks in each tier/dir

lostStorage - the lost storage paths

configList - the configuration properties

RegisterStreamer

public RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient,
                        long workerId,
                        List<String> storageTierAliases,
                        Map<String,Long> totalBytesOnTiers,
                        Map<String,Long> usedBytesOnTiers,
                        Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation,
                        Map<String,List<String>> lostStorage,
                        List<ConfigProperty> configList,
                        BuildVersion version)

Constructor.

Parameters:

asyncClient - the grpc client

workerId - the worker ID

storageTierAliases - storage/tier setup from the configuration

totalBytesOnTiers - the capacity of each tier

usedBytesOnTiers - the current usage of each tier

currentBlocksOnLocation - the blocks in each tier/dir

lostStorage - the lost storage paths

configList - the configuration properties

version - the version info

RegisterStreamer

public RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient,
                        long workerId,
                        List<String> storageTierAliases,
                        Map<String,Long> totalBytesOnTiers,
                        Map<String,Long> usedBytesOnTiers,
                        Map<String,List<String>> lostStorage,
                        List<ConfigProperty> configList,
                        BlockMapIterator blockListIterator)

Constructor.

Parameters:

asyncClient - the grpc client

workerId - the worker ID

storageTierAliases - storage/tier setup from the configuration

totalBytesOnTiers - the capacity of each tier

usedBytesOnTiers - the current usage of each tier

lostStorage - the lost storage paths

configList - the configuration properties

blockListIterator - an iterator used to iterate the blocks

Method Detail

registerWithMaster

public void registerWithMaster()
                        throws CancelledException,
                               InternalException,
                               DeadlineExceededException,
                               InterruptedException

Manages the logic of registering with the master in a stream.

Throws:

CancelledException

InternalException

DeadlineExceededException

InterruptedException

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<RegisterWorkerPRequest>

next

public RegisterWorkerPRequest next()

Specified by:

next in interface Iterator<RegisterWorkerPRequest>