@InterfaceAudience.LimitedPrivate(value="Replication") public interface SourceFSConfigurationProvider
DefaultSourceFSConfigurationProvider| 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.
|
Configuration getConf(Configuration sinkConf,
java.lang.String replicationClusterId)
throws java.io.IOException
sinkConf - sink cluster configurationreplicationClusterId - unique ID which identifies the source clusterjava.io.IOException - for invalid directory or for a bad disk.