Package org.apache.hadoop.hbase.replication.regionserver

Class DefaultSourceFSConfigurationProvider

java.lang.Object

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

All Implemented Interfaces:

SourceFSConfigurationProvider

@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	Description
private static final org.slf4j.Logger	LOG
private final Map<String,org.apache.hadoop.conf.Configuration>	sourceClustersConfs
private static final String	XML

Constructor Summary

Constructors

Constructor	Description
DefaultSourceFSConfigurationProvider()

Method Summary

Modifier and Type	Method	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 Details

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 Details

DefaultSourceFSConfigurationProvider

public DefaultSourceFSConfigurationProvider()

Method Details

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.