|
@@ -161,6 +161,32 @@ public class ConfigUtil {
|
|
|
targets);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ *
|
|
|
+ * @param conf
|
|
|
+ * @param mountTableName
|
|
|
+ * @param src
|
|
|
+ * @param settings
|
|
|
+ * @param targets
|
|
|
+ */
|
|
|
+ public static void addLinkNfly(Configuration conf, String mountTableName,
|
|
|
+ String src, String settings, final URI ... targets) {
|
|
|
+
|
|
|
+ settings = settings == null
|
|
|
+ ? "minReplication=2,repairOnRead=true"
|
|
|
+ : settings;
|
|
|
+
|
|
|
+ conf.set(getConfigViewFsPrefix(mountTableName) + "." +
|
|
|
+ Constants.CONFIG_VIEWFS_LINK_NFLY + "." + settings + "." + src,
|
|
|
+ StringUtils.uriToString(targets));
|
|
|
+ }
|
|
|
+
|
|
|
+ public static void addLinkNfly(final Configuration conf, final String src,
|
|
|
+ final URI ... targets) {
|
|
|
+ addLinkNfly(conf, Constants.CONFIG_VIEWFS_DEFAULT_MOUNT_TABLE, src, null,
|
|
|
+ targets);
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* Add config variable for homedir for default mount table
|
|
|
* @param conf - add to this conf
|