alluxio.client.file

Class ConfigHashSync

java.lang.Object

alluxio.client.file.ConfigHashSync

All Implemented Interfaces:

alluxio.heartbeat.HeartbeatExecutor, Closeable, AutoCloseable

@ThreadSafe
public final class ConfigHashSync
extends Object
implements alluxio.heartbeat.HeartbeatExecutor

Heartbeat task for getting the latest configuration versions from meta master, if versions change, then re-initialize the filesystem context. If a heartbeat fails, the internal meta master client will disconnect and try to reconnect. The passed in client will not be closed by this class.

Constructor Summary

Constructors

Constructor and Description
ConfigHashSync(FileSystemContext context) Constructs a new ConfigHashSync.

Method Summary

Modifier and Type	Method and Description
void	close()
Optional<IOException>	getException()
void	heartbeat()
void	resetMetaMasterConfigClient(alluxio.master.MasterClientContext context) Resets the internal meta master client based on the new configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfigHashSync

public ConfigHashSync(FileSystemContext context)

Constructs a new ConfigHashSync.

Parameters:

context - the filesystem context

Method Detail

resetMetaMasterConfigClient

public void resetMetaMasterConfigClient(alluxio.master.MasterClientContext context)

Resets the internal meta master client based on the new configuration.

Parameters:

context - the context containing the new configuration

getException

public Optional<IOException> getException()

Returns:

empty if there is no exception during reinitialization, otherwise, return the exception

heartbeat

public void heartbeat()

Specified by:

heartbeat in interface alluxio.heartbeat.HeartbeatExecutor

close

public void close()

Specified by:

close in interface alluxio.heartbeat.HeartbeatExecutor

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable