Examples of resourceConfig()

Examples of com.linkedin.helix.PropertyKey.Builder.resourceConfig()

92
93
94
95
96
97
98
99
100
101
102
     
      String resourceName = "TestDB_0";
      value = new HelixProperty(resourceName);
      value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
      listener._configChanged = false;
      accessor.setProperty(keyBuilder.resourceConfig(resourceName), value);
      Thread.sleep(1000);  // wait zk callback
      Assert.assertTrue(listener._configChanged, "Should get resourceConfig callback invoked since we add resourceConfig");

      value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
      listener._configChanged = false;
View Full Code Here

Examples of com.linkedin.helix.PropertyKey.Builder.resourceConfig()

98
99
100
101
102
103
104
105
106
107
108
      Thread.sleep(1000);  // wait zk callback
      Assert.assertTrue(listener._configChanged, "Should get resourceConfig callback invoked since we add resourceConfig");

      value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
      listener._configChanged = false;
      accessor.setProperty(keyBuilder.resourceConfig(resourceName), value);
      Thread.sleep(1000);  // wait zk callback
      Assert.assertTrue(listener._configChanged, "Should get resourceConfig callback invoked since we change resourceConfig");

      listener._configChanged = false;
      accessor.removeProperty(keyBuilder.resourceConfig(resourceName));
View Full Code Here

Examples of com.linkedin.helix.PropertyKey.Builder.resourceConfig()

103
104
105
106
107
108
109
110
111
112
113
      accessor.setProperty(keyBuilder.resourceConfig(resourceName), value);
      Thread.sleep(1000);  // wait zk callback
      Assert.assertTrue(listener._configChanged, "Should get resourceConfig callback invoked since we change resourceConfig");

      listener._configChanged = false;
      accessor.removeProperty(keyBuilder.resourceConfig(resourceName));
      Thread.sleep(1000);  // wait zk callback
      Assert.assertTrue(listener._configChanged, "Should get resourceConfig callback invoked since we delete resourceConfig");

      System.out.println("END " + clusterName + " at "
              + new Date(System.currentTimeMillis()));
View Full Code Here

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

110
111
112
113
114
115
116
117
118
119
120
    String resourceName = "TestDB_0";
    value = new HelixProperty(resourceName);
    value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
    listener._configChanged = false;
    accessor.setProperty(keyBuilder.resourceConfig(resourceName), value);
    Thread.sleep(1000); // wait zk callback
    Assert.assertTrue(listener._configChanged,
        "Should get resourceConfig callback invoked since we add resourceConfig");

    value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
View Full Code Here

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

117
118
119
120
121
122
123
124
125
126
127
    Assert.assertTrue(listener._configChanged,
        "Should get resourceConfig callback invoked since we add resourceConfig");

    value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
    listener._configChanged = false;
    accessor.setProperty(keyBuilder.resourceConfig(resourceName), value);
    Thread.sleep(1000); // wait zk callback
    Assert.assertTrue(listener._configChanged,
        "Should get resourceConfig callback invoked since we change resourceConfig");

    listener._configChanged = false;
View Full Code Here

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

123
124
125
126
127
128
129
130
131
132
133
    Thread.sleep(1000); // wait zk callback
    Assert.assertTrue(listener._configChanged,
        "Should get resourceConfig callback invoked since we change resourceConfig");

    listener._configChanged = false;
    accessor.removeProperty(keyBuilder.resourceConfig(resourceName));
    Thread.sleep(1000); // wait zk callback
    Assert.assertTrue(listener._configChanged,
        "Should get resourceConfig callback invoked since we delete resourceConfig");

    System.out.println("END " + clusterName + " at " + new Date(System.currentTimeMillis()));
View Full Code Here

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

703
704
705
706
707
708
709
710
711
712
713
    ZKHelixDataAccessor accessor =
        new ZKHelixDataAccessor(clusterName, new ZkBaseDataAccessor<ZNRecord>(_zkClient));
    Builder keyBuilder = accessor.keyBuilder();

    accessor.removeProperty(keyBuilder.idealStates(resourceName));
    accessor.removeProperty(keyBuilder.resourceConfig(resourceName));
  }

  @Override
  public List<String> getStateModelDefs(String clusterName) {
    return _zkClient.getChildren(HelixUtil.getStateModelDefinitionPath(clusterName));
View Full Code Here

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

725
726
727
728
729
730
731
732
733
734
735
    HelixDataAccessor accessor =
        new ZKHelixDataAccessor(clusterName, new ZkBaseDataAccessor<ZNRecord>(_zkClient));
    Builder keyBuilder = accessor.keyBuilder();

    accessor.removeProperty(keyBuilder.idealStates(resourceName));
    accessor.removeProperty(keyBuilder.resourceConfig(resourceName));
  }

  @Override
  public List<String> getStateModelDefs(String clusterName) {
    return _zkClient.getChildren(HelixUtil.getStateModelDefinitionPath(clusterName));
View Full Code Here

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

111
112
113
114
115
116
117
118
119
120
121
    String resourceName = "TestDB_0";
    value = new HelixProperty(resourceName);
    value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
    listener._configChanged = false;
    accessor.setProperty(keyBuilder.resourceConfig(resourceName), value);
    Thread.sleep(1000); // wait zk callback
    Assert.assertTrue(listener._configChanged,
        "Should get resourceConfig callback invoked since we add resourceConfig");

    value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
View Full Code Here

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

118
119
120
121
122
123
124
125
126
127
128
    Assert.assertTrue(listener._configChanged,
        "Should get resourceConfig callback invoked since we add resourceConfig");

    value._record.setSimpleField("" + System.currentTimeMillis(), "newValue");
    listener._configChanged = false;
    accessor.setProperty(keyBuilder.resourceConfig(resourceName), value);
    Thread.sleep(1000); // wait zk callback
    Assert.assertTrue(listener._configChanged,
        "Should get resourceConfig callback invoked since we change resourceConfig");

    listener._configChanged = false;
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.