Package org.apache.helix.manager.zk

Examples of org.apache.helix.manager.zk.ZKHelixManager.connect()

83
84
85
86
87
88
89
90
91
92
93
    TestHelper.setupEmptyCluster(_gZkClient, clusterName);

    controller.connect();
    AssertJUnit.assertTrue(controller.isConnected());
    controller.connect();
    AssertJUnit.assertTrue(controller.isConnected());

    MockListener listener = new MockListener();
    listener.reset();
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
    /////////////////////
    ZKHelixManager manager = new ZKHelixManager(clusterName, "localhost_0",
        InstanceType.PARTICIPANT,
        ZK_ADDR);
    manager.connect();
    HelixDataAccessor accessor = manager.getHelixDataAccessor();
   
    LiveInstance liveInstance = accessor.getProperty(accessor.keyBuilder().liveInstance("localhost_0"));
    Assert.assertTrue(liveInstance.getRecord().getListFields().size() == 0);
    Assert.assertTrue(liveInstance.getRecord().getMapFields().size() == 0);
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
    manager = new ZKHelixManager(clusterName, "localhost_1",
        InstanceType.PARTICIPANT,
        ZK_ADDR);
    manager.setLiveInstanceInfoProvider(new provider(false));
   
    manager.connect();
    accessor = manager.getHelixDataAccessor();
   
    liveInstance = accessor.getProperty(accessor.keyBuilder().liveInstance("localhost_1"));
    Assert.assertTrue(liveInstance.getRecord().getListFields().size() == 1);
    Assert.assertTrue(liveInstance.getRecord().getMapFields().size() == 1);
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
    manager = new ZKHelixManager(clusterName, "localhost_2",
        InstanceType.PARTICIPANT,
        ZK_ADDR);
    manager.setLiveInstanceInfoProvider(new provider(true));
   
    manager.connect();
    accessor = manager.getHelixDataAccessor();
   
    liveInstance = accessor.getProperty(accessor.keyBuilder().liveInstance("localhost_2"));
    Assert.assertTrue(liveInstance.getRecord().getListFields().size() == 1);
    Assert.assertTrue(liveInstance.getRecord().getMapFields().size() == 1);
View Full Code Here
254
255
256
257
258
259
260
261
262
263
264
                                              InstanceType.ADMINISTRATOR,
                                              ZK_ADDR);

    TestHelper.setupEmptyCluster(_gZkClient, clusterName);

    admin.connect();
    AssertJUnit.assertTrue(admin.isConnected());

    HelixAdmin adminTool = admin.getClusterManagmentTool();
//    ConfigScope scope = new ConfigScopeBuilder().forCluster(clusterName)
//        .forResource("testResource").forPartition("testPartition").build();
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.