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
alluxio.job.plan.load
alluxio.job.util
alluxio.job.wire
alluxio.master
alluxio.master.block
alluxio.master.block.meta
alluxio.master.job
alluxio.stress.cli.client
alluxio.util
alluxio.util.network
alluxio.wire
alluxio.worker	Worker process and utils for working with the worker remotely.
alluxio.worker.block
alluxio.worker.job
alluxio.worker.job.command
alluxio.worker.job.task

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 that return types with arguments of type WorkerNetAddress

Modifier and Type	Method and Description
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource>	BlockStoreClient.getDataSourceAndType(BlockInfo info, URIStatus status, BlockLocationPolicy policy, Map<WorkerNetAddress,Long> failedWorkers) Gets the data source and type of data source of a block.

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

Modifier and Type	Method and Description
BlockOutStream	BlockStoreClient.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
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource>	BlockStoreClient.getDataSourceAndType(BlockInfo info, URIStatus status, BlockLocationPolicy policy, Map<WorkerNetAddress,Long> failedWorkers) Gets the data source and type of data source of a block.
BlockInStream	BlockStoreClient.getInStream(BlockInfo info, InStreamOptions options, Map<WorkerNetAddress,Long> failedWorkers) BlockStoreClient.getInStream(long, InStreamOptions, Map).
BlockInStream	BlockStoreClient.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 types with arguments of type WorkerNetAddress

Modifier and Type	Method and Description
Optional<WorkerNetAddress>	CapacityBaseRandomPolicy.getWorker(GetWorkerOptions options)
Optional<WorkerNetAddress>	DeterministicHashPolicy.getWorker(GetWorkerOptions options)
Optional<WorkerNetAddress>	CapacityBasedDeterministicHashPolicy.getWorker(GetWorkerOptions options)
Optional<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.
Optional<WorkerNetAddress>	LocalFirstAvoidEvictionPolicy.getWorker(GetWorkerOptions options)
Optional<WorkerNetAddress>	MostAvailableFirstPolicy.getWorker(GetWorkerOptions options) The policy returns null if no worker is qualified.
Optional<WorkerNetAddress>	LocalFirstPolicy.getWorker(GetWorkerOptions options)
Optional<WorkerNetAddress>	SpecificHostPolicy.getWorker(GetWorkerOptions options) Returns null if no active worker matches the hostname provided in WORKER_HOSTNAME (alluxio.worker.hostname).
Optional<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 DataWriter	DataWriter.Factory.create(FileSystemContext context, long blockId, long blockSize, WorkerNetAddress address, OutStreamOptions options)
static LocalFileDataWriter	LocalFileDataWriter.create(FileSystemContext context, WorkerNetAddress address, long blockId, long blockSize, OutStreamOptions options) Creates an instance of LocalFileDataWriter.
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 UnderFileSystemFileOutStream	UnderFileSystemFileOutStream.create(FileSystemContext context, WorkerNetAddress address, OutStreamOptions options) Creates an instance of UnderFileSystemFileOutStream that writes to a UFS file.
static BufferCachingGrpcDataReader	BufferCachingGrpcDataReader.create(FileSystemContext context, WorkerNetAddress address, ReadRequest readRequest) Creates an instance of BufferCachingGrpcDataReader for block reads.
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.
BufferCachingGrpcDataReader(WorkerNetAddress address, CloseableResource<BlockWorkerClient> client, long dataTimeoutMs, ReadRequest readRequest, GrpcBlockingStream<ReadRequest,ReadResponse> stream) Creates an instance of BufferCachingGrpcDataReader.
Factory(FileSystemContext context, WorkerNetAddress address, long blockId, long localReaderChunkSize, InStreamOptions options) Creates an instance of LocalFileDataReader.Factory.
Factory(FileSystemContext context, WorkerNetAddress address, ReadRequest.Builder readRequestBuilder) Creates an instance of GrpcDataReader.Factory for block reads.
Factory(FileSystemContext context, WorkerNetAddress address, ReadRequest.Builder readRequestBuilder, long blockSize) Creates an instance of SharedGrpcDataReader.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.getNodeLocalWorker()

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

Methods in alluxio.job that return WorkerNetAddress

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

Constructors in alluxio.job with parameters of type WorkerNetAddress

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

Uses of WorkerNetAddress in alluxio.job.plan.load

Methods in alluxio.job.plan.load that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	LoadDefinition.LoadTask.getWorkerNetAddress()

Constructors in alluxio.job.plan.load with parameters of type WorkerNetAddress

Constructor and Description
LoadTask(long blockId, WorkerNetAddress workerNetAddress, String filePath)

Uses of WorkerNetAddress in alluxio.job.util

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

Modifier and Type	Method and Description
static void	JobUtils.loadBlock(URIStatus status, FileSystemContext context, long blockId, WorkerNetAddress address, boolean directCache) Loads a block into the local worker.

Uses of WorkerNetAddress in alluxio.job.wire

Constructors in alluxio.job.wire with parameters of type WorkerNetAddress

Constructor and Description
TaskInfo(long jobId, long taskId, Status status, WorkerNetAddress workerAddress, Object args) Constructs a new TaskInfo from jobId, taskId, Status, workerAddress, and arguments.

Uses of WorkerNetAddress in alluxio.master

Methods in alluxio.master that return WorkerNetAddress

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

Method parameters in alluxio.master with type arguments of type WorkerNetAddress

Modifier and Type	Method and Description
void	AbstractLocalAlluxioCluster.restartWorkers(Collection<WorkerNetAddress> addresses) Restarts workers with the addresses provided, so that the workers can restart with static addresses to simulate a worker restart in the cluster.

Uses of WorkerNetAddress in alluxio.master.block

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

Modifier and Type	Method and Description
Set<WorkerNetAddress>	DefaultBlockMaster.getWorkerAddresses()
Set<WorkerNetAddress>	BlockMaster.getWorkerAddresses()

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.
void	DefaultBlockMaster.notifyWorkerId(long workerId, WorkerNetAddress workerNetAddress)
void	BlockMaster.notifyWorkerId(long workerId, WorkerNetAddress workerNetAddress) Notify the worker id to a master.

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() StaticWorkerMeta is thread safe so the value can be read without locking.

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.
StaticWorkerMeta(long id, WorkerNetAddress address) Constructor.

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.stress.cli.client

Methods in alluxio.stress.cli.client that return types with arguments of type WorkerNetAddress

Modifier and Type	Method and Description
Optional<WorkerNetAddress>	ClientIOWritePolicy.getWorker(GetWorkerOptions options)

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 boolean	NettyUtils.isDomainSocketAccessible(WorkerNetAddress workerNetAddress, AlluxioConfiguration conf)
static boolean	NettyUtils.isDomainSocketSupported(WorkerNetAddress workerNetAddress)

Uses of WorkerNetAddress in alluxio.wire

Fields in alluxio.wire declared as WorkerNetAddress

Modifier and Type	Field and Description
static WorkerNetAddress	WorkerNetAddress.DUMMY

Methods in alluxio.wire that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	WorkerInfo.getAddress()
WorkerNetAddress	BlockLocation.getWorkerAddress()
WorkerNetAddress	WorkerNetAddress.setContainerHost(String containerHost)
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)
void	AbstractWorker.start(WorkerNetAddress address)

Uses of WorkerNetAddress in alluxio.worker.block

Fields in alluxio.worker.block declared as WorkerNetAddress

Modifier and Type	Field and Description
protected WorkerNetAddress	DefaultBlockWorker.mAddress

Methods in alluxio.worker.block that return WorkerNetAddress

Modifier and Type	Method and Description
WorkerNetAddress	DefaultBlockWorker.getWorkerAddress()
WorkerNetAddress	BlockWorker.getWorkerAddress()

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

Modifier and Type	Method and Description
void	DefaultBlockWorker.askForWorkerId(WorkerNetAddress address) Ask the master for a workerId.
long	BlockMasterClient.getId(WorkerNetAddress address) Returns a worker id for a workers net address.
void	BlockMasterClient.notifyWorkerId(long workerId, WorkerNetAddress address) Notify all masters about the worker ID.
void	AllMasterRegistrationBlockWorker.start(WorkerNetAddress address)
void	DefaultBlockWorker.start(WorkerNetAddress address) Runs the block worker.

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

Constructor and Description
BlockMasterSync(BlockWorker blockWorker, AtomicReference<Long> workerId, WorkerNetAddress workerAddress, BlockMasterClientPool masterClientPool) Creates a new instance of BlockMasterSync.

Uses of WorkerNetAddress in alluxio.worker.job

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

Modifier and Type	Method and Description
long	RetryHandlingJobMasterClient.registerWorker(WorkerNetAddress address)
long	JobMasterClient.registerWorker(WorkerNetAddress address) Returns a worker id for a workers net 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.
JobWorkerHealthReport(oshi.hardware.HardwareAbstractionLayer hardware, WorkerNetAddress workerNetAddress) Creates a new instance of JobWorkerHealthReporter.JobWorkerHealthReport.
JobWorkerHealthReporter(WorkerNetAddress workerNetAddress) Creates a new instance of JobWorkerHealthReporter.

Uses of WorkerNetAddress in alluxio.worker.job.task

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

Constructor and Description
TaskExecutorManager(int taskExecutorPoolSize, WorkerNetAddress address) Constructs a new instance of TaskExecutorManager.