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.block.util
alluxio.client.file
alluxio.grpc
alluxio.job.meta
alluxio.master
alluxio.master.block
alluxio.master.block.meta
alluxio.master.job
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.job
alluxio.worker.job.command

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(BlockInfo info, InStreamOptions options, Map<WorkerNetAddress,Long> failedWorkers) AlluxioBlockStore.getInStream(long, InStreamOptions, Map).
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	RoundRobinPolicy.getWorker(GetWorkerOptions options) 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	DeterministicHashPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	MostAvailableFirstPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	SpecificHostPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	LocalFirstPolicy.getWorker(GetWorkerOptions options)
WorkerNetAddress	LocalFirstAvoidEvictionPolicy.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 BlockOutStream	BlockOutStream.create(FileSystemContext context, long blockId, long blockSize, WorkerNetAddress address, OutStreamOptions options) Creates an BlockOutStream.
static DataWriter	DataWriter.Factory.create(FileSystemContext context, long blockId, long blockSize, WorkerNetAddress address, OutStreamOptions options)
static UfsFallbackLocalFileDataWriter	UfsFallbackLocalFileDataWriter.create(FileSystemContext context, WorkerNetAddress address, long blockId, long blockSize, OutStreamOptions options)
static GrpcDataWriter	GrpcDataWriter.create(FileSystemContext context, WorkerNetAddress address, long id, long length, RequestType type, OutStreamOptions options)
static LocalFileDataWriter	LocalFileDataWriter.create(FileSystemContext context, WorkerNetAddress address, long blockId, OutStreamOptions options) Creates an instance of LocalFileDataWriter.
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.

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

Modifier and Type	Method and Description
static BlockOutStream	BlockOutStream.createReplicatedBlockOutStream(FileSystemContext context, long blockId, long blockSize, List<WorkerNetAddress> workerNetAddresses, OutStreamOptions options) Creates a new remote block output stream.

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

Constructor and Description
BlockInStream(DataReader.Factory dataReaderFactory, WorkerNetAddress address, BlockInStream.BlockInStreamSource blockSource, long id, long length) Creates an instance of BlockInStream.
BlockOutStream(DataWriter dataWriter, long length, WorkerNetAddress address) Constructs a new BlockOutStream with only one DataWriter.
Factory(FileSystemContext context, WorkerNetAddress address, long blockId, long localReaderChunkSize, InStreamOptions options) Creates an instance of LocalFileDataReader.Factory.
Factory(FileSystemContext context, WorkerNetAddress address, ReadRequest readRequestPartial) Creates an instance of GrpcDataReader.Factory for block reads.
UnderFileSystemFileOutStream(DataWriter dataWriter, WorkerNetAddress address) Constructs a new UnderFileSystemFileOutStream with only one DataWriter.

Constructor parameters in alluxio.client.block.stream with type arguments of type WorkerNetAddress

Constructor and Description
BlockOutStream(List<DataWriter> dataWriters, long length, List<WorkerNetAddress> workerNetAddresses) Constructs a new BlockOutStream with only one DataWriter.

Uses of WorkerNetAddress in alluxio.client.block.util

Methods in alluxio.client.block.util that return types with arguments of type WorkerNetAddress

Modifier and Type	Method and Description
static Optional<Pair<WorkerNetAddress,Boolean>>	BlockLocationUtils.nearest(TieredIdentity tieredIdentity, List<WorkerNetAddress> addresses, AlluxioConfiguration conf)

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

Modifier and Type	Method and Description
static Optional<Pair<WorkerNetAddress,Boolean>>	BlockLocationUtils.nearest(TieredIdentity tieredIdentity, List<WorkerNetAddress> addresses, AlluxioConfiguration conf)

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
CloseableResource<BlockWorkerClient>	FileSystemContext.acquireBlockWorkerClient(WorkerNetAddress workerNetAddress) Acquires a block worker client from the client pools.

Uses of WorkerNetAddress in alluxio.grpc

Methods in alluxio.grpc that return WorkerNetAddress

Modifier and Type	Method and Description
static WorkerNetAddress	GrpcUtils.fromProto(WorkerNetAddress workerNetPAddress) Converts a proto type to a wire type.

Methods in alluxio.grpc with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
static WorkerNetAddress	GrpcUtils.toProto(WorkerNetAddress workerNetAddress) Converts wire type to proto type.

Uses of WorkerNetAddress in alluxio.job.meta

Methods in alluxio.job.meta that return WorkerNetAddress

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

Constructors in alluxio.job.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.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.master.job

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

Modifier and Type	Method and Description
long	JobMaster.registerWorker(WorkerNetAddress workerNetAddress) Returns a worker id for the given worker.

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, AlluxioConfiguration conf)

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, AlluxioConfiguration conf) 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.isDomainSocketAccessible(WorkerNetAddress workerNetAddress, AlluxioConfiguration conf)
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
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 that return types with arguments of type WorkerNetAddress

Modifier and Type	Method and Description
List<WorkerNetAddress>	BlockLocationInfo.getLocations()

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)

Constructor parameters in alluxio.wire with type arguments of type WorkerNetAddress

Constructor and Description
BlockLocationInfo(FileBlockInfo blockInfo, List<WorkerNetAddress> locations)

Uses of WorkerNetAddress in alluxio.worker

Methods in alluxio.worker that return WorkerNetAddress

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

Methods in alluxio.worker with parameters of type WorkerNetAddress

Modifier and Type	Method and Description
static void	JobWorkerIdRegistry.registerWorker(JobMasterClient jobMasterClient, WorkerNetAddress workerAddress) Registers with JobMaster to get a new job worker id.
void	JobWorker.start(WorkerNetAddress address)

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.job

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

Modifier and Type	Method and Description
long	JobMasterClient.registerWorker(WorkerNetAddress address) Returns a worker id for a workers net address.
long	RetryHandlingJobMasterClient.registerWorker(WorkerNetAddress address)

Uses of WorkerNetAddress in alluxio.worker.job.command

Constructors in alluxio.worker.job.command with parameters of type WorkerNetAddress

Constructor and Description
CommandHandlingExecutor(JobServerContext jobServerContext, TaskExecutorManager taskExecutorManager, JobMasterClient masterClient, WorkerNetAddress workerNetAddress) Creates a new instance of CommandHandlingExecutor.