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 java.lang.Object
implements SourceFSConfigurationProvider

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

Constructor Summary

Constructors

Constructor and Description
DefaultSourceFSConfigurationProvider()

Method Summary

Modifier and Type	Method and Description
Configuration	getConf(Configuration sinkConf, java.lang.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

Constructor Detail

DefaultSourceFSConfigurationProvider

public DefaultSourceFSConfigurationProvider()

Method Detail

getConf

public Configuration getConf(Configuration sinkConf,
                             java.lang.String replicationClusterId)
                      throws java.io.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:

java.io.IOException - for invalid directory or for a bad disk.