alluxio.client.block.stream

Class BlockWorkerClient.Factory

java.lang.Object

alluxio.client.block.stream.BlockWorkerClient.Factory

Enclosing interface:

BlockWorkerClient

public static class BlockWorkerClient.Factory
extends Object

Factory for block worker client.

Constructor Summary

Constructors

Constructor and Description
Factory()

Method Summary

Modifier and Type	Method and Description
static BlockWorkerClient	create(Subject subject, alluxio.grpc.GrpcServerAddress address, alluxio.conf.AlluxioConfiguration alluxioConf, io.netty.channel.EventLoopGroup workerGroup) Creates a new block worker client.

Methods inherited from class java.lang.Object

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

Constructor Detail

Factory

public Factory()

Method Detail

create

public static BlockWorkerClient create(@Nullable
                                       Subject subject,
                                       alluxio.grpc.GrpcServerAddress address,
                                       alluxio.conf.AlluxioConfiguration alluxioConf,
                                       io.netty.channel.EventLoopGroup workerGroup)
                                throws IOException

Creates a new block worker client.

Parameters:

subject - the user subject

address - the address of the worker

Returns:

a new BlockWorkerClient

Throws:

IOException