Examples of stateModelDef()

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

106
107
108
109
110
111
112
113
114
115
116
    HelixDataAccessor accessor = manager.getHelixDataAccessor();

    StateModelDefinition stateModelDef =
        new StateModelDefinition(StateModelConfigGenerator.generateConfigForMasterSlave());
    Builder keyBuilder = accessor.keyBuilder();
    accessor.setProperty(keyBuilder.stateModelDef("MasterSlave"), stateModelDef);

    context = new NotificationContext(manager);

    CurrentState currentStateDelta = new CurrentState("TestDB");
    currentStateDelta.setState(PartitionId.from("TestDB_0"), State.from("OFFLINE"));
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

166
167
168
169
170
171
172
173
174
175
176
    // check if the state model definition exists and cache it
    if (!_stateModelDefs.containsKey(stateModelId)) {
      HelixDataAccessor accessor = _manager.getHelixDataAccessor();
      Builder keyBuilder = accessor.keyBuilder();
      StateModelDefinition stateModelDef =
          accessor.getProperty(keyBuilder.stateModelDef(stateModelId.stringify()));
      if (stateModelDef == null) {
        throw new HelixException("fail to create msg-handler because stateModelDef for "
            + stateModelId + " does NOT exist");
      }
      _stateModelDefs.put(stateModelId, stateModelDef);
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

249
250
251
252
253
254
255
256
257
258
259
      }

      int numberOfPartitions = idealState.getRecord().getListFields().size();
      String stateModelDefName = idealState.getStateModelDefId().stringify();
      StateModelDefinition stateModelDef =
          accessor.getProperty(keyBuilder.stateModelDef(stateModelDefName));
      State masterValue = stateModelDef.getTypedStatesPriorityList().get(0);
      int replicas = Integer.parseInt(idealState.getReplicas());

      String instanceGroupTag = idealState.getInstanceGroupTag();
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

144
145
146
147
148
149
150
151
152
153
154
        new HashMap<StateModelDefId, StateModelDefinition>();

    ZNRecord masterSlave = StateModelConfigGenerator.generateConfigForMasterSlave();
    StateModelDefinition masterSlaveDef = new StateModelDefinition(masterSlave);
    defs.put(StateModelDefId.from(masterSlaveDef.getId()), masterSlaveDef);
    accessor.setProperty(keyBuilder.stateModelDef(masterSlave.getId()), masterSlaveDef);

    ZNRecord leaderStandby = StateModelConfigGenerator.generateConfigForLeaderStandby();
    StateModelDefinition leaderStandbyDef = new StateModelDefinition(leaderStandby);
    defs.put(StateModelDefId.from(leaderStandbyDef.getId()), leaderStandbyDef);
    accessor.setProperty(keyBuilder.stateModelDef(leaderStandby.getId()), leaderStandbyDef);
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

149
150
151
152
153
154
155
156
157
158
159
    accessor.setProperty(keyBuilder.stateModelDef(masterSlave.getId()), masterSlaveDef);

    ZNRecord leaderStandby = StateModelConfigGenerator.generateConfigForLeaderStandby();
    StateModelDefinition leaderStandbyDef = new StateModelDefinition(leaderStandby);
    defs.put(StateModelDefId.from(leaderStandbyDef.getId()), leaderStandbyDef);
    accessor.setProperty(keyBuilder.stateModelDef(leaderStandby.getId()), leaderStandbyDef);

    ZNRecord onlineOffline = StateModelConfigGenerator.generateConfigForOnlineOffline();
    StateModelDefinition onlineOfflineDef = new StateModelDefinition(onlineOffline);
    defs.put(StateModelDefId.from(onlineOfflineDef.getId()), onlineOfflineDef);
    accessor.setProperty(keyBuilder.stateModelDef(onlineOffline.getId()), onlineOfflineDef);
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

154
155
156
157
158
159
160
161
162
163
164
    accessor.setProperty(keyBuilder.stateModelDef(leaderStandby.getId()), leaderStandbyDef);

    ZNRecord onlineOffline = StateModelConfigGenerator.generateConfigForOnlineOffline();
    StateModelDefinition onlineOfflineDef = new StateModelDefinition(onlineOffline);
    defs.put(StateModelDefId.from(onlineOfflineDef.getId()), onlineOfflineDef);
    accessor.setProperty(keyBuilder.stateModelDef(onlineOffline.getId()), onlineOfflineDef);

    return defs;
  }

  protected Map<ResourceId, ResourceConfig> getResourceMap(List<IdealState> idealStates) {
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

148
149
150
151
152
153
154
155
156
157
158
        new HashMap<StateModelDefId, StateModelDefinition>();

    ZNRecord masterSlave = StateModelConfigGenerator.generateConfigForMasterSlave();
    StateModelDefinition masterSlaveDef = new StateModelDefinition(masterSlave);
    defs.put(StateModelDefId.from(masterSlaveDef.getId()), masterSlaveDef);
    accessor.setProperty(keyBuilder.stateModelDef(masterSlave.getId()), masterSlaveDef);

    ZNRecord leaderStandby = StateModelConfigGenerator.generateConfigForLeaderStandby();
    StateModelDefinition leaderStandbyDef = new StateModelDefinition(leaderStandby);
    defs.put(StateModelDefId.from(leaderStandbyDef.getId()), leaderStandbyDef);
    accessor.setProperty(keyBuilder.stateModelDef(leaderStandby.getId()), leaderStandbyDef);
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

153
154
155
156
157
158
159
160
161
162
163
    accessor.setProperty(keyBuilder.stateModelDef(masterSlave.getId()), masterSlaveDef);

    ZNRecord leaderStandby = StateModelConfigGenerator.generateConfigForLeaderStandby();
    StateModelDefinition leaderStandbyDef = new StateModelDefinition(leaderStandby);
    defs.put(StateModelDefId.from(leaderStandbyDef.getId()), leaderStandbyDef);
    accessor.setProperty(keyBuilder.stateModelDef(leaderStandby.getId()), leaderStandbyDef);

    ZNRecord onlineOffline = StateModelConfigGenerator.generateConfigForOnlineOffline();
    StateModelDefinition onlineOfflineDef = new StateModelDefinition(onlineOffline);
    defs.put(StateModelDefId.from(onlineOfflineDef.getId()), onlineOfflineDef);
    accessor.setProperty(keyBuilder.stateModelDef(onlineOffline.getId()), onlineOfflineDef);
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

158
159
160
161
162
163
164
165
166
167
168
    accessor.setProperty(keyBuilder.stateModelDef(leaderStandby.getId()), leaderStandbyDef);

    ZNRecord onlineOffline = StateModelConfigGenerator.generateConfigForOnlineOffline();
    StateModelDefinition onlineOfflineDef = new StateModelDefinition(onlineOffline);
    defs.put(StateModelDefId.from(onlineOfflineDef.getId()), onlineOfflineDef);
    accessor.setProperty(keyBuilder.stateModelDef(onlineOffline.getId()), onlineOfflineDef);

    return defs;
  }

  protected Map<ResourceId, ResourceConfig> getResourceMap(List<IdealState> idealStates) {
View Full Code Here

Examples of org.apache.helix.PropertyKey.Builder.stateModelDef()

254
255
256
257
258
259
260
261
262
263
264
        new ZKHelixDataAccessor(clusterName, new ZkBaseDataAccessor<ZNRecord>(_gZkClient));
    Builder keyBuilder = accessor.keyBuilder();

    StateModelDefinition masterSlave =
        new StateModelDefinition(StateModelConfigGenerator.generateConfigForMasterSlave());
    accessor.setProperty(keyBuilder.stateModelDef(masterSlave.getId()), masterSlave);

    StateModelDefinition leaderStandby =
        new StateModelDefinition(StateModelConfigGenerator.generateConfigForLeaderStandby());
    accessor.setProperty(keyBuilder.stateModelDef(leaderStandby.getId()), leaderStandby);
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.