Uses of Class
alluxio.wire.WorkerNetAddress

Packages that use WorkerNetAddress

Package	Description
alluxio.client.block
alluxio.client.block.policy
alluxio.client.block.stream
alluxio.client.file
alluxio.client.file.policy
alluxio.client.keyvalue
alluxio.master
alluxio.master.block
alluxio.master.block.meta
alluxio.util
alluxio.util.network
alluxio.wire
alluxio.worker	Worker process and utils for working with the worker remotely.
alluxio.worker.block
alluxio.worker.file
alluxio.worker.keyvalue

Uses of WorkerNetAddress in alluxio.client.block

Methods in alluxio.client.block that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	BlockWorkerInfo.getNetAddress()

Methods in alluxio.client.block with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
BlockOutStream	AlluxioBlockStore.getOutStream(long blockId, long blockSize, WorkerNetAddress address, OutStreamOptions options) Gets a stream to write data to a block.

Method parameters in alluxio.client.block with type arguments of type WorkerNetAddress

Modifier and Type	Method and Description
BlockInStream	AlluxioBlockStore.getInStream(long blockId, InStreamOptions options, Map<WorkerNetAddress,Long> failedWorkers) Gets a stream to read the data of a block.

Constructors in alluxio.client.block with parameters of type WorkerNetAddress

Constructor and Description
BlockWorkerInfo(WorkerNetAddress netAddress, long capacityBytes, long usedBytes) Constructs the block worker information.

Uses of WorkerNetAddress in alluxio.client.block.policy

Methods in alluxio.client.block.policy that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	DeterministicHashPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	BlockLocationPolicy.getWorker(GetWorkerOptions options) Gets the worker's network address for serving operations requested for the block.

Uses of WorkerNetAddress in alluxio.client.block.stream

Methods in alluxio.client.block.stream that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	BlockOutStream.getAddress()
WorkerNetAddress	BlockInStream.getAddress()

Methods in alluxio.client.block.stream with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
static BlockInStream	BlockInStream.create(FileSystemContext context, BlockInfo info, WorkerNetAddress dataSource, BlockInStream.BlockInStreamSource dataSourceType, InStreamOptions options) Creates a BlockInStream.
static PacketWriter	PacketWriter.Factory.create(FileSystemContext context, long blockId, long blockSize, WorkerNetAddress address, OutStreamOptions options)
static BlockOutStream	BlockOutStream.create(FileSystemContext context, long blockId, long blockSize, WorkerNetAddress address, OutStreamOptions options) Creates an BlockOutStream.
static NettyPacketWriter	NettyPacketWriter.create(FileSystemContext context, WorkerNetAddress address, long id, long length, Protocol.RequestType type, OutStreamOptions options)
static LocalFilePacketWriter	LocalFilePacketWriter.create(FileSystemContext context, WorkerNetAddress address, long blockId, OutStreamOptions options) Creates an instance of LocalFilePacketWriter.
static UnderFileSystemFileOutStream	UnderFileSystemFileOutStream.create(FileSystemContext context, WorkerNetAddress address, OutStreamOptions options) Creates an instance of UnderFileSystemFileOutStream that writes to a UFS file.
static BlockInStream	BlockInStream.createRemoteBlockInStream(FileSystemContext context, long blockId, WorkerNetAddress address, BlockInStream.BlockInStreamSource blockSource, long blockSize, Protocol.OpenUfsBlockOptions ufsOptions) Creates a BlockInStream to read from a specific remote server.

Constructors in alluxio.client.block.stream with parameters of type WorkerNetAddress

Constructor and Description
BlockInStream(PacketReader.Factory packetReaderFactory, WorkerNetAddress address, BlockInStream.BlockInStreamSource blockSource, long id, long length) Creates an instance of BlockInStream.
BlockOutStream(PacketWriter packetWriter, long length, WorkerNetAddress address) Constructs a new BlockOutStream with only one PacketWriter.
Factory(FileSystemContext context, WorkerNetAddress address, long blockId, long packetSize, InStreamOptions options) Creates an instance of LocalFilePacketReader.Factory.
Factory(FileSystemContext context, WorkerNetAddress address, Protocol.ReadRequest readRequestPartial) Creates an instance of NettyPacketReader.Factory for block reads.
UnderFileSystemFileOutStream(PacketWriter packetWriter, WorkerNetAddress address) Constructs a new UnderFileSystemFileOutStream with only one PacketWriter.

Uses of WorkerNetAddress in alluxio.client.file

Methods in alluxio.client.file that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	FileSystemContext.getLocalWorker()

Methods in alluxio.client.file with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
io.netty.channel.Channel	FileSystemContext.acquireNettyChannel(WorkerNetAddress workerNetAddress) Acquires a netty channel from the channel pools.
void	FileSystemContext.releaseNettyChannel(WorkerNetAddress workerNetAddress, io.netty.channel.Channel channel) Releases a netty channel to the channel pools.

Uses of WorkerNetAddress in alluxio.client.file.policy

Methods in alluxio.client.file.policy that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	RoundRobinPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	MostAvailableFirstPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	SpecificHostPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	LocalFirstAvoidEvictionPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	LocalFirstPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	RoundRobinPolicy.getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList, long blockSizeBytes) The policy uses the first fetch of worker info list as the base, and visits each of them in a round-robin manner in the subsequent calls.
WorkerNetAddress	MostAvailableFirstPolicy.getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList, long blockSizeBytes)
WorkerNetAddress	SpecificHostPolicy.getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList, long blockSizeBytes)
WorkerNetAddress	LocalFirstAvoidEvictionPolicy.getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList, long blockSizeBytes)
WorkerNetAddress	LocalFirstPolicy.getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList, long blockSizeBytes)
WorkerNetAddress	FileWriteLocationPolicy.getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList, long blockSizeBytes) Gets the worker's host name for the next block to write to.

Uses of WorkerNetAddress in alluxio.client.keyvalue

Constructors in alluxio.client.keyvalue with parameters of type WorkerNetAddress

Constructor and Description
KeyValueWorkerClient(WorkerNetAddress workerNetAddress) Creates a KeyValueWorkerClient.

Uses of WorkerNetAddress in alluxio.master

Methods in alluxio.master that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	LocalAlluxioCluster.getWorkerAddress()

Uses of WorkerNetAddress in alluxio.master.block

Methods in alluxio.master.block with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
long	DefaultBlockMaster.getWorkerId(WorkerNetAddress workerNetAddress)
long	BlockMaster.getWorkerId(WorkerNetAddress workerNetAddress) Returns a worker id for the given worker, creating one if the worker is new.

Uses of WorkerNetAddress in alluxio.master.block.meta

Methods in alluxio.master.block.meta that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	MasterWorkerInfo.getWorkerAddress()

Constructors in alluxio.master.block.meta with parameters of type WorkerNetAddress

Constructor and Description
MasterWorkerInfo(long id, WorkerNetAddress address) Creates a new instance of MasterWorkerInfo.

Uses of WorkerNetAddress in alluxio.util

Methods in alluxio.util with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
static boolean	CommonUtils.isLocalHost(WorkerNetAddress address)

Uses of WorkerNetAddress in alluxio.util.network

Methods in alluxio.util.network with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
static SocketAddress	NetworkAddressUtils.getDataPortSocketAddress(WorkerNetAddress netAddress) Extracts dataPort socket address from Alluxio representation of network address.
static String	NetworkAddressUtils.getFqdnHost(WorkerNetAddress addr) Gets FQDN(Full Qualified Domain Name) from Alluxio representation of network address.
static InetSocketAddress	NetworkAddressUtils.getRpcPortSocketAddress(WorkerNetAddress netAddress) Extracts rpcPort InetSocketAddress from Alluxio representation of network address.
static boolean	NettyUtils.isDomainSocketSupported(WorkerNetAddress workerNetAddress)

Uses of WorkerNetAddress in alluxio.wire

Methods in alluxio.wire that return WorkerNetAddress

Modifier and Type	Method and Description
static WorkerNetAddress	WorkerNetAddress.fromThrift(WorkerNetAddress address) Creates a new instance of WorkerNetAddress from thrift representation.
WorkerNetAddress	WorkerInfo.getAddress()
WorkerNetAddress	BlockLocation.getWorkerAddress()
WorkerNetAddress	WorkerNetAddress.setDataPort(int dataPort)
WorkerNetAddress	WorkerNetAddress.setDomainSocketPath(String domainSocketPath)
WorkerNetAddress	WorkerNetAddress.setHost(String host)
WorkerNetAddress	WorkerNetAddress.setRpcPort(int rpcPort)
WorkerNetAddress	WorkerNetAddress.setTieredIdentity(TieredIdentity tieredIdentity)
WorkerNetAddress	WorkerNetAddress.setWebPort(int webPort)

Methods in alluxio.wire with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
WorkerInfo	WorkerInfo.setAddress(WorkerNetAddress address)
BlockLocation	BlockLocation.setWorkerAddress(WorkerNetAddress workerAddress)

Uses of WorkerNetAddress in alluxio.worker

Methods in alluxio.worker that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	AlluxioWorkerProcess.getAddress()
WorkerNetAddress	WorkerProcess.getAddress()

Uses of WorkerNetAddress in alluxio.worker.block

Methods in alluxio.worker.block with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
long	BlockMasterClient.getId(WorkerNetAddress address) Returns a worker id for a workers net address.
void	DefaultBlockWorker.start(WorkerNetAddress address) Runs the block worker.

Uses of WorkerNetAddress in alluxio.worker.file

Methods in alluxio.worker.file with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
void	DefaultFileSystemWorker.start(WorkerNetAddress address)

Uses of WorkerNetAddress in alluxio.worker.keyvalue

Methods in alluxio.worker.keyvalue with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
void	KeyValueWorker.start(WorkerNetAddress address)