public class JobWorkerHealthCheckClient extends RpcPortHealthCheckClient
Constructor and Description |
---|
JobWorkerHealthCheckClient(InetSocketAddress jobWorkerAddress,
java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
AlluxioConfiguration alluxioConf)
Creates a worker health check client.
|
getConfiguration, getNodeAddress, getRetryPolicySupplier, getServiceType, getUserState, isServing
public JobWorkerHealthCheckClient(InetSocketAddress jobWorkerAddress, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf)
jobWorkerAddress
- The potential job_worker addressretryPolicySupplier
- the retry policy supplieralluxioConf
- Alluxio configurationCopyright © 2023. All Rights Reserved.