Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.grpc |
Modifier and Type | Method and Description |
---|---|
static BlockWorkerClient |
BlockWorkerClient.Factory.create(Subject subject,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf,
io.netty.channel.EventLoopGroup workerGroup)
Creates a new block worker client.
|
Constructor and Description |
---|
BlockWorkerClientPool(Subject subject,
GrpcServerAddress address,
int maxCapacity,
AlluxioConfiguration alluxioConf,
io.netty.channel.EventLoopGroup workerGroup)
Creates a new block master client pool.
|
DefaultBlockWorkerClient(Subject subject,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf,
io.netty.channel.EventLoopGroup workerGroup)
Creates a client instance for communicating with block worker.
|
Modifier and Type | Method and Description |
---|---|
static GrpcServerAddress |
GrpcServerAddress.create(InetSocketAddress socketAddress) |
static GrpcServerAddress |
GrpcServerAddress.create(String hostName,
SocketAddress socketAddress) |
GrpcServerAddress |
GrpcChannelKey.getServerAddress() |
Modifier and Type | Method and Description |
---|---|
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AlluxioConfiguration conf,
UserState userState)
Create an new instance of
GrpcServerBuilder with authentication support. |
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AuthenticationServer authenticationServer,
AlluxioConfiguration conf,
UserState userState)
Create an new instance of
GrpcServerBuilder with authentication support. |
static GrpcChannelBuilder |
GrpcChannelBuilder.newBuilder(GrpcServerAddress address,
AlluxioConfiguration conf)
Create a channel builder for given address using the given configuration.
|
GrpcChannelKey |
GrpcChannelKey.setServerAddress(GrpcServerAddress address) |
Copyright © 2023. All Rights Reserved.