alluxio.client.file

Class ConfigHashSync

java.lang.Object

alluxio.client.file.ConfigHashSync

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@ThreadSafe
public class ConfigHashSync
extends Object
implements 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() Cleans up any resources used by the heartbeat executor.
protected RetryHandlingMetaMasterConfigClient	createMetaMasterConfigClient(MasterClientContext context)
Optional<IOException>	getException()
void	heartbeat(long timeLimitMs) Implements the heartbeat logic.
void	resetMetaMasterConfigClient(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(MasterClientContext context)

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

Parameters:

context - the context containing the new configuration

createMetaMasterConfigClient

protected RetryHandlingMetaMasterConfigClient createMetaMasterConfigClient(MasterClientContext context)

getException

public Optional<IOException> getException()

Returns:

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

heartbeat

public void heartbeat(long timeLimitMs)

Description copied from interface: HeartbeatExecutor

Implements the heartbeat logic.

Specified by:

heartbeat in interface HeartbeatExecutor

Parameters:

timeLimitMs - time limit in milliseconds this heartbeat should not exceed when running

close

public void close()

Description copied from interface: HeartbeatExecutor

Cleans up any resources used by the heartbeat executor.

Specified by:

close in interface HeartbeatExecutor

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable