@InterfaceAudience.Private public class DefaultSourceFSConfigurationProvider extends Object implements SourceFSConfigurationProvider
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 and Description |
---|
DefaultSourceFSConfigurationProvider() |
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.
|
private static final org.slf4j.Logger LOG
private final Map<String,org.apache.hadoop.conf.Configuration> sourceClustersConfs
private static final String XML
public DefaultSourceFSConfigurationProvider()
public org.apache.hadoop.conf.Configuration getConf(org.apache.hadoop.conf.Configuration sinkConf, String replicationClusterId) throws IOException
SourceFSConfigurationProvider
getConf
in interface SourceFSConfigurationProvider
sinkConf
- sink cluster configurationreplicationClusterId
- unique ID which identifies the source clusterIOException
- for invalid directory or for a bad disk.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.