@ThreadSafe public class RetryHandlingMetaMasterConfigClient extends AbstractMasterClient implements MetaMasterConfigClient
AbstractClient.RpcCallable<V>
mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService
Constructor and Description |
---|
RetryHandlingMetaMasterConfigClient(MasterClientContext conf)
Creates a new meta master client.
|
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect()
This method is called after the connection is made to the remote.
|
ConfigHash |
getConfigHash() |
Configuration |
getConfiguration(GetConfigurationPOptions options) |
protected ServiceType |
getRemoteServiceType() |
protected String |
getServiceName() |
protected long |
getServiceVersion() |
void |
removePathConfiguration(AlluxioURI path)
Removes all properties for a path.
|
void |
removePathConfiguration(AlluxioURI path,
Set<PropertyKey> keys)
Removes properties for a path.
|
void |
setPathConfiguration(AlluxioURI path,
Map<PropertyKey,String> properties)
Sets properties for a path.
|
getAddress, getConfAddress
afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, isConnected, retryRPC
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setPathConfiguration
connect, disconnect, getAddress, getConfAddress, isClosed, isConnected
public RetryHandlingMetaMasterConfigClient(MasterClientContext conf)
conf
- master client configurationprotected ServiceType getRemoteServiceType()
getRemoteServiceType
in class AbstractClient
protected String getServiceName()
getServiceName
in class AbstractClient
protected long getServiceVersion()
getServiceVersion
in class AbstractClient
protected void afterConnect()
AbstractClient
afterConnect
in class AbstractClient
public Configuration getConfiguration(GetConfigurationPOptions options) throws IOException
getConfiguration
in interface MetaMasterConfigClient
options
- the optionsIOException
public ConfigHash getConfigHash() throws IOException
getConfigHash
in interface MetaMasterConfigClient
IOException
public void setPathConfiguration(AlluxioURI path, Map<PropertyKey,String> properties) throws IOException
MetaMasterConfigClient
setPathConfiguration
in interface MetaMasterConfigClient
path
- the pathproperties
- the propertiesIOException
public void removePathConfiguration(AlluxioURI path, Set<PropertyKey> keys) throws IOException
MetaMasterConfigClient
removePathConfiguration
in interface MetaMasterConfigClient
path
- the pathkeys
- the property keysIOException
public void removePathConfiguration(AlluxioURI path) throws IOException
MetaMasterConfigClient
removePathConfiguration
in interface MetaMasterConfigClient
path
- the pathIOException
Copyright © 2023. All Rights Reserved.