alluxio.client.meta

Class RetryHandlingMetaMasterConfigClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.meta.RetryHandlingMetaMasterConfigClient

All Implemented Interfaces:

Client, MetaMasterConfigClient, Closeable, AutoCloseable

@ThreadSafe
public class RetryHandlingMetaMasterConfigClient
extends AbstractMasterClient
implements MetaMasterConfigClient

A wrapper for the gRPC client to interact with the meta master.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractClient

mAlwaysEnableTLS, mChannel, mClosed, mConnected, mContext, mServerAddress, mServiceVersion, mVersionService

Constructor Summary

Constructors

Constructor and Description
RetryHandlingMetaMasterConfigClient(MasterClientContext conf) Creates a new meta master client.

Method Summary

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.
Map<PropertyKey,Boolean>	updateConfiguration(Map<PropertyKey,String> propertiesMap) Updates properties.

Methods inherited from class alluxio.AbstractMasterClient

afterDisconnect, beforeConnect, getConfAddress, queryGrpcServerAddress

Methods inherited from class alluxio.AbstractClient

beforeDisconnect, checkVersion, close, connect, connectWithRuntimeException, createChannel, disconnect, getRemoteHostName, getRemoteServiceVersion, getRemoteSockAddress, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.client.meta.MetaMasterConfigClient

setPathConfiguration

Methods inherited from interface alluxio.Client

connect, disconnect, getConfAddress, getRemoteHostName, getRemoteSockAddress, isClosed, isConnected

Methods inherited from interface java.io.Closeable

close

Constructor Detail

RetryHandlingMetaMasterConfigClient

public RetryHandlingMetaMasterConfigClient(MasterClientContext conf)

Creates a new meta master client.

Parameters:

conf - master client configuration

Method Detail

getRemoteServiceType

protected ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class AbstractClient

Returns:

the expected type of remote service

getServiceName

protected String getServiceName()

Specified by:

getServiceName in class AbstractClient

Returns:

a string representing the specific service

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class AbstractClient

Returns:

the client service version

afterConnect

protected void afterConnect()

Description copied from class: AbstractClient

This method is called after the connection is made to the remote. Implementations should create internal state to finish the connection process.

Overrides:

afterConnect in class AbstractClient

getConfiguration

public Configuration getConfiguration(GetConfigurationPOptions options)
                               throws IOException

Specified by:

getConfiguration in interface MetaMasterConfigClient

Parameters:

options - the options

Returns:

the runtime configuration

Throws:

IOException

getConfigHash

public ConfigHash getConfigHash()
                         throws IOException

Specified by:

getConfigHash in interface MetaMasterConfigClient

Returns:

hashes of cluster and path level configurations

Throws:

IOException

setPathConfiguration

public void setPathConfiguration(AlluxioURI path,
                                 Map<PropertyKey,String> properties)
                          throws IOException

Description copied from interface: MetaMasterConfigClient

Sets properties for a path.

Specified by:

setPathConfiguration in interface MetaMasterConfigClient

Parameters:

path - the path

properties - the properties

Throws:

IOException

removePathConfiguration

public void removePathConfiguration(AlluxioURI path,
                                    Set<PropertyKey> keys)
                             throws IOException

Description copied from interface: MetaMasterConfigClient

Removes properties for a path.

Specified by:

removePathConfiguration in interface MetaMasterConfigClient

Parameters:

path - the path

keys - the property keys

Throws:

IOException

removePathConfiguration

public void removePathConfiguration(AlluxioURI path)
                             throws IOException

Description copied from interface: MetaMasterConfigClient

Removes all properties for a path.

Specified by:

removePathConfiguration in interface MetaMasterConfigClient

Parameters:

path - the path

Throws:

IOException

updateConfiguration

public Map<PropertyKey,Boolean> updateConfiguration(Map<PropertyKey,String> propertiesMap)
                                             throws IOException

Description copied from interface: MetaMasterConfigClient

Updates properties.

Specified by:

updateConfiguration in interface MetaMasterConfigClient

Parameters:

propertiesMap - the properties map to be updated

Returns:

the update properties status map

Throws:

IOException