org.apache.hadoop.hbase.replication.regionserver

Class DefaultSourceFSConfigurationProvider

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.DefaultSourceFSConfigurationProvider

All Implemented Interfaces:

SourceFSConfigurationProvider

@InterfaceAudience.Private
public class DefaultSourceFSConfigurationProvider
extends Object
implements SourceFSConfigurationProvider

This will load all the xml configuration files for the source cluster replication ID from user configured replication configuration directory.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private Map<String,org.apache.hadoop.conf.Configuration>	sourceClustersConfs
private static String	XML

Constructor Summary

Constructors

Constructor and Description
DefaultSourceFSConfigurationProvider()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.conf.Configuration	getConf(org.apache.hadoop.conf.Configuration sinkConf, String replicationClusterId) Returns the source cluster file system configuration for the given source cluster replication ID.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

sourceClustersConfs

private final Map<String,org.apache.hadoop.conf.Configuration> sourceClustersConfs

XML

private static final String XML

See Also:

Constant Field Values

Constructor Detail

DefaultSourceFSConfigurationProvider

public DefaultSourceFSConfigurationProvider()

Method Detail

getConf

public org.apache.hadoop.conf.Configuration getConf(org.apache.hadoop.conf.Configuration sinkConf,
                                                    String replicationClusterId)
                                             throws IOException

Description copied from interface: SourceFSConfigurationProvider

Returns the source cluster file system configuration for the given source cluster replication ID.

Specified by:

getConf in interface SourceFSConfigurationProvider

Parameters:

sinkConf - sink cluster configuration

replicationClusterId - unique ID which identifies the source cluster

Returns:

source cluster file system configuration

Throws:

IOException - for invalid directory or for a bad disk.