Package | Description |
---|---|
alluxio | |
alluxio.cli | |
alluxio.client.file | |
alluxio.client.metrics | |
alluxio.master | |
alluxio.worker.job |
Modifier and Type | Field and Description |
---|---|
protected ClientContext |
AbstractClient.mContext
Context of the client.
|
Modifier and Type | Method and Description |
---|---|
static ClientContext |
ClientContext.create() |
static ClientContext |
ClientContext.create(AlluxioConfiguration alluxioConf) |
static ClientContext |
ClientContext.create(Subject subject,
AlluxioConfiguration alluxioConf)
A client context with information about the subject and configuration of the client.
|
ClientContext |
ClientContext.setUriValidationEnabled(boolean uriValidationEnabled) |
Constructor and Description |
---|
AbstractClient(ClientContext context)
Creates a new client base with default retry policy supplier.
|
AbstractClient(ClientContext context,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier)
Creates a new client base with specified retry policy supplier.
|
ClientContext(ClientContext ctx)
This constructor does not create a copy of the configuration.
|
Modifier and Type | Method and Description |
---|---|
static int |
GetConf.getConf(ClientContext ctx,
String... args)
Implements get configuration.
|
Modifier and Type | Method and Description |
---|---|
ClientContext |
FileSystemContext.getClientContext() |
Modifier and Type | Method and Description |
---|---|
static FileSystem |
FileSystem.Factory.create(ClientContext ctx) |
static FileSystemContext |
FileSystemContext.create(ClientContext clientContext) |
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker) |
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker,
List<InetSocketAddress> masterAddresses) |
Modifier and Type | Method and Description |
---|---|
static void |
MetricsHeartbeatContext.addHeartbeat(ClientContext ctx,
MasterInquireClient inquireClient)
Sets up a new metrics heartbeat with the given client information.
|
static void |
MetricsHeartbeatContext.removeHeartbeat(ClientContext ctx)
Removes an application from the metrics heartbeat.
|
Constructor and Description |
---|
ClientMasterSync(String appId,
ClientContext ctx,
MasterInquireClient inquireClient)
Constructs a new
ClientMasterSync . |
Modifier and Type | Class and Description |
---|---|
class |
MasterClientContext
Configuration for constructing an Alluxio master client.
|
Modifier and Type | Field and Description |
---|---|
protected ClientContext |
MasterClientContextBuilder.mContext |
Modifier and Type | Method and Description |
---|---|
static MasterClientContextBuilder |
MasterClientContext.newBuilder(ClientContext ctx)
Create an instance of a
MasterClientContextBuilder which can be used to obtain and
instance of MasterClientContext . |
Constructor and Description |
---|
MasterClientContext(ClientContext ctx,
MasterInquireClient masterInquireClient) |
MasterClientContextBuilder(ClientContext ctx)
Create an instance of a
MasterClientContextBuilder . |
Modifier and Type | Class and Description |
---|---|
class |
JobMasterClientContext
Extension of MasterClientContext with defaults that make sense for job master clients.
|
Modifier and Type | Method and Description |
---|---|
static JobMasterClientContextBuilder |
JobMasterClientContext.newBuilder(ClientContext context)
Create a builder for
JobMasterClientContext . |
Constructor and Description |
---|
JobMasterClientContext(ClientContext context,
MasterInquireClient masterInquireClient,
MasterInquireClient confMasterInquireClient) |
Copyright © 2023. All Rights Reserved.