Package org.apache.helix.model

Examples of org.apache.helix.model.ClusterConfiguration.addNamespacedConfig()

159
160
161
162
163
164
165
166
167
168
169
    // allow auto join to cluster configuration
    ClusterId clusterId = ClusterId.from("clusterId");
    UserConfig userConfig = new UserConfig(Scope.cluster(clusterId));
    userConfig.setSimpleField(KEY1, VALUE1);
    ClusterConfiguration clusterConfiguration = new ClusterConfiguration(clusterId);
    clusterConfiguration.addNamespacedConfig(userConfig);
    clusterConfiguration.getRecord().setSimpleField(KEY2, VALUE2);
    clusterConfiguration.setAutoJoinAllowed(true);

    // there should be key1 and key2, but not auto join
    UserConfig result = clusterConfiguration.getUserConfig();
View Full Code Here
317
318
319
320
321
322
323
324
325
326
327
      // Update the main config
      final ClusterConfig deltaConfig = _builder.build();
      ClusterConfiguration config = new ClusterConfiguration(deltaConfig.getId());
      config.setAutoJoinAllowed(deltaConfig.autoJoinAllowed());
      if (deltaConfig.getUserConfig() != null) {
        config.addNamespacedConfig(deltaConfig.getUserConfig());
      }
      accessor.updateProperty(accessor.keyBuilder().clusterConfig(), config);

      // Update paused status
      if (_paused != null) {
View Full Code Here
162
163
164
165
166
167
168
169
170
171
172
    // allow auto join to cluster configuration
    ClusterId clusterId = ClusterId.from("clusterId");
    UserConfig userConfig = new UserConfig(Scope.cluster(clusterId));
    userConfig.setSimpleField(KEY1, VALUE1);
    ClusterConfiguration clusterConfiguration = new ClusterConfiguration(clusterId);
    clusterConfiguration.addNamespacedConfig(userConfig);
    clusterConfiguration.getRecord().setSimpleField(KEY2, VALUE2);
    clusterConfiguration.setAutoJoinAllowed(true);

    // there should be key1 and key2, but not auto join
    UserConfig result = clusterConfiguration.getUserConfig();
View Full Code Here
594
595
596
597
598
599
600
601
602
603
604
   * @param userConfig the user config key-value pairs to add
   * @return true if the user config was updated, false otherwise
   */
  public boolean updateUserConfig(UserConfig userConfig) {
    ClusterConfiguration clusterConfig = new ClusterConfiguration(_clusterId);
    clusterConfig.addNamespacedConfig(userConfig);
    return _accessor.updateProperty(_keyBuilder.clusterConfig(), clusterConfig);
  }

  /**
   * pause controller of cluster
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.