@Test public void getMasterRpcAddresses() { AlluxioConfiguration conf = createConf(ImmutableMap.of(PropertyKey.MASTER_RPC_ADDRESSES, "host1:99,host2:100")); assertEquals( Arrays.asList(InetSocketAddress.createUnresolved("host1", 99), InetSocketAddress.createUnresolved("host2", 100)), ConfigurationUtils.getMasterRpcAddresses(conf)); }
public static List<InetSocketAddress> getMasterRpcAddresses(AlluxioConfiguration conf) { if (conf.isSet(PropertyKey.MASTER_RPC_ADDRESSES)) { return parseInetSocketAddresses(conf.getList(PropertyKey.MASTER_RPC_ADDRESSES, ",")); } int rpcPort = NetworkAddressUtils.getPort(NetworkAddressUtils.ServiceType.MASTER_RPC, conf); return overridePort(getEmbeddedJournalAddresses(conf, ServiceType.MASTER_RAFT), rpcPort); }
ConfigurationUtils { public static List<InetSocketAddress> getMasterRpcAddresses(AlluxioConfiguration conf) { if (conf.isSet(PropertyKey.MASTER_RPC_ADDRESSES)) { return parseInetSocketAddresses(conf.getList(PropertyKey.MASTER_RPC_ADDRESSES, ",")); } int rpcPort = NetworkAddressUtils.getPort(NetworkAddressUtils.ServiceType.MASTER_RPC, conf); return overridePort(getEmbeddedJournalAddresses(conf, ServiceType.MASTER_RAFT), rpcPort); } }
ConfigurationUtils { public static List<InetSocketAddress> getMasterRpcAddresses(AlluxioConfiguration conf) { if (conf.isSet(PropertyKey.MASTER_RPC_ADDRESSES)) { return parseInetSocketAddresses(conf.getList(PropertyKey.MASTER_RPC_ADDRESSES, ",")); } int rpcPort = NetworkAddressUtils.getPort(NetworkAddressUtils.ServiceType.MASTER_RPC, conf); return overridePort(getEmbeddedJournalAddresses(conf, ServiceType.MASTER_RAFT), rpcPort); } private  ConfigurationUtils(); }
ConfigurationUtils { public static List<InetSocketAddress> getMasterRpcAddresses(AlluxioConfiguration conf) { if (conf.isSet(PropertyKey.MASTER_RPC_ADDRESSES)) { return parseInetSocketAddresses(conf.getList(PropertyKey.MASTER_RPC_ADDRESSES, ",")); } int rpcPort = NetworkAddressUtils.getPort(NetworkAddressUtils.ServiceType.MASTER_RPC, conf); return overridePort(getEmbeddedJournalAddresses(conf, ServiceType.MASTER_RAFT), rpcPort); } private  ConfigurationUtils(); static List<InetSocketAddress> getEmbeddedJournalAddresses(AlluxioConfiguration conf,
      ServiceType serviceType); static List<InetSocketAddress> getMasterEmbeddedJournalAddresses(
      AlluxioConfiguration conf); static List<InetSocketAddress> getJobMasterEmbeddedJournalAddresses(
      AlluxioConfiguration conf); static List<InetSocketAddress> getMasterRpcAddresses(AlluxioConfiguration conf); static List<InetSocketAddress> getJobMasterRpcAddresses(AlluxioConfiguration conf); @Nullable static Properties loadPropertiesFromResource(URL resource); @Nullable static Properties loadPropertiesFromFile(String filePath); @Nullable static Properties loadProperties(InputStream stream); @Nullable static String searchPropertiesFile(String propertiesFile,
      String[] confPathList); static boolean jobMasterHostConfigured(AlluxioConfiguration conf); static String getMasterHostNotConfiguredMessage(String serviceName); static String getJobMasterHostNotConfiguredMessage(String serviceName); static float checkRatio(AlluxioConfiguration conf, PropertyKey key); static boolean masterHostConfigured(AlluxioConfiguration conf); static boolean isHaMode(AlluxioConfiguration conf); static List<ConfigProperty> getConfiguration(AlluxioConfiguration conf, Scope scope); static String valueAsString(String value); static AlluxioProperties defaults(); static void reloadProperties(); static AlluxioConfiguration merge(AlluxioConfiguration conf, Map<?, ?> properties,
      Source source); static GetConfigurationPResponse loadConfiguration(InetSocketAddress address,
      AlluxioConfiguration conf, boolean ignoreClusterConf, boolean ignorePathConf); static AlluxioConfiguration getClusterConf(GetConfigurationPResponse response,
      AlluxioConfiguration conf, Scope scope); static PathConfiguration getPathConf(GetConfigurationPResponse response,
      AlluxioConfiguration clusterConf); static String getSchemeAuthority(AlluxioConfiguration conf); static List<String> parseAsList(String value, String delimiter); static Set<String> getMasterHostnames(AlluxioConfiguration conf); static Set<String> getWorkerHostnames(AlluxioConfiguration conf); static Set<String> getServerHostnames(AlluxioConfiguration conf); }
ConfigurationUtils { public static List<InetSocketAddress> getMasterRpcAddresses(AlluxioConfiguration conf) { if (conf.isSet(PropertyKey.MASTER_RPC_ADDRESSES)) { return parseInetSocketAddresses(conf.getList(PropertyKey.MASTER_RPC_ADDRESSES, ",")); } int rpcPort = NetworkAddressUtils.getPort(NetworkAddressUtils.ServiceType.MASTER_RPC, conf); return overridePort(getEmbeddedJournalAddresses(conf, ServiceType.MASTER_RAFT), rpcPort); } private  ConfigurationUtils(); static List<InetSocketAddress> getEmbeddedJournalAddresses(AlluxioConfiguration conf,
      ServiceType serviceType); static List<InetSocketAddress> getMasterEmbeddedJournalAddresses(
      AlluxioConfiguration conf); static List<InetSocketAddress> getJobMasterEmbeddedJournalAddresses(
      AlluxioConfiguration conf); static List<InetSocketAddress> getMasterRpcAddresses(AlluxioConfiguration conf); static List<InetSocketAddress> getJobMasterRpcAddresses(AlluxioConfiguration conf); @Nullable static Properties loadPropertiesFromResource(URL resource); @Nullable static Properties loadPropertiesFromFile(String filePath); @Nullable static Properties loadProperties(InputStream stream); @Nullable static String searchPropertiesFile(String propertiesFile,
      String[] confPathList); static boolean jobMasterHostConfigured(AlluxioConfiguration conf); static String getMasterHostNotConfiguredMessage(String serviceName); static String getJobMasterHostNotConfiguredMessage(String serviceName); static float checkRatio(AlluxioConfiguration conf, PropertyKey key); static boolean masterHostConfigured(AlluxioConfiguration conf); static boolean isHaMode(AlluxioConfiguration conf); static List<ConfigProperty> getConfiguration(AlluxioConfiguration conf, Scope scope); static String valueAsString(String value); static AlluxioProperties defaults(); static void reloadProperties(); static AlluxioConfiguration merge(AlluxioConfiguration conf, Map<?, ?> properties,
      Source source); static GetConfigurationPResponse loadConfiguration(InetSocketAddress address,
      AlluxioConfiguration conf, boolean ignoreClusterConf, boolean ignorePathConf); static AlluxioConfiguration getClusterConf(GetConfigurationPResponse response,
      AlluxioConfiguration conf, Scope scope); static PathConfiguration getPathConf(GetConfigurationPResponse response,
      AlluxioConfiguration clusterConf); static String getSchemeAuthority(AlluxioConfiguration conf); static List<String> parseAsList(String value, String delimiter); static Set<String> getMasterHostnames(AlluxioConfiguration conf); static Set<String> getWorkerHostnames(AlluxioConfiguration conf); static Set<String> getServerHostnames(AlluxioConfiguration conf);  }