@InterfaceAudience.Private public class TestSourceFSConfigurationProvider extends Object implements SourceFSConfigurationProvider
Constructor and Description |
---|
TestSourceFSConfigurationProvider() |
Modifier and Type | Method and Description |
---|---|
Configuration |
getConf(Configuration sinkConf,
String replicationClusterId)
Returns the source cluster file system configuration for the given source cluster replication
ID.
|
public Configuration getConf(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.