Examples of addNamespacedConfig()

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

239
240
241
242
243
244
245
246
247
248
249
      LOG.error("Resource not fully defined with a rebalancer context");
      return false;
    }
    ResourceId resourceId = resourceConfig.getId();
    ResourceConfiguration config = new ResourceConfiguration(resourceId);
    config.addNamespacedConfig(resourceConfig.getUserConfig());
    config.addNamespacedConfig(resourceConfig.getRebalancerConfig().toNamespacedConfig());
    config.setBucketSize(resourceConfig.getBucketSize());
    config.setBatchMessageMode(resourceConfig.getBatchMessageMode());
    setConfiguration(resourceId, config);
    return true;
View Full Code Here

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

240
241
242
243
244
245
246
247
248
249
250
      return false;
    }
    ResourceId resourceId = resourceConfig.getId();
    ResourceConfiguration config = new ResourceConfiguration(resourceId);
    config.addNamespacedConfig(resourceConfig.getUserConfig());
    config.addNamespacedConfig(resourceConfig.getRebalancerConfig().toNamespacedConfig());
    config.setBucketSize(resourceConfig.getBucketSize());
    config.setBatchMessageMode(resourceConfig.getBatchMessageMode());
    setConfiguration(resourceId, config);
    return true;
  }
View Full Code Here

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

108
109
110
111
112
113
114
115
116
117
118
    ResourceId resourceId = ResourceId.from("resourceId");
    UserConfig userConfig = new UserConfig(Scope.resource(resourceId));
    userConfig.setSimpleField(KEY1, VALUE1);
    ResourceConfiguration resourceConfig = new ResourceConfiguration(resourceId);
    resourceConfig.setType(ResourceType.DATA);
    resourceConfig.addNamespacedConfig(userConfig);
    resourceConfig.getRecord().setSimpleField(KEY2, VALUE2);
    IdealState idealState = new IdealState(resourceId);
    idealState.setRebalanceMode(RebalanceMode.USER_DEFINED);
    idealState.getRecord().setSimpleField(KEY3, VALUE3);
View Full Code Here

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

76
77
78
79
80
81
82
83
84
85
86
    Assert.assertEquals(deserialized.getStateModelDefId(), context.getStateModelDefId());
    Assert.assertEquals(deserialized.getResourceId(), context.getResourceId());

    // wrap in a physical config and then unwrap it
    ResourceConfiguration physicalConfig = new ResourceConfiguration(resourceId);
    physicalConfig.addNamespacedConfig(config.toNamespacedConfig());
    RebalancerConfig extractedConfig = new RebalancerConfig(physicalConfig);
    CustomRebalancerContext extractedContext =
        extractedConfig.getRebalancerContext(CustomRebalancerContext.class);

    // make sure the unwrapped data hasn't changed
View Full Code Here

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

653
654
655
656
657
658
659
660
661
662
663
    // Add resource user config
    if (resource.getUserConfig() != null) {
      ResourceConfiguration configuration = new ResourceConfiguration(resourceId);
      configuration.setType(resource.getType());
      configuration.addNamespacedConfig(resource.getUserConfig());
      configuration.addNamespacedConfig(resource.getRebalancerConfig().toNamespacedConfig());
      configuration.setBucketSize(resource.getBucketSize());
      configuration.setBatchMessageMode(resource.getBatchMessageMode());
      _accessor.setProperty(_keyBuilder.resourceConfig(resourceId.stringify()), configuration);
    }
View Full Code Here

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

654
655
656
657
658
659
660
661
662
663
664
    // Add resource user config
    if (resource.getUserConfig() != null) {
      ResourceConfiguration configuration = new ResourceConfiguration(resourceId);
      configuration.setType(resource.getType());
      configuration.addNamespacedConfig(resource.getUserConfig());
      configuration.addNamespacedConfig(resource.getRebalancerConfig().toNamespacedConfig());
      configuration.setBucketSize(resource.getBucketSize());
      configuration.setBatchMessageMode(resource.getBatchMessageMode());
      _accessor.setProperty(_keyBuilder.resourceConfig(resourceId.stringify()), configuration);
    }
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.