本文整理了Java中org.apache.solr.common.cloud.ZkNodeProps类的一些代码示例，展示了ZkNodeProps类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkNodeProps类的具体详情如下：
包路径：org.apache.solr.common.cloud.ZkNodeProps
类名称：ZkNodeProps

ZkNodeProps介绍

[英]ZkNodeProps contains generic immutable properties.
[中]ZkNodeProps包含通用的不可变属性。

代码示例

代码示例来源：origin: com.hynnet/solr-solrj

public String getBaseUrl() {
 return nodeProps.getStr(ZkStateReader.BASE_URL_PROP);
}

代码示例来源：origin: org.apache.solr/solr-solrj

public ZkNodeProps plus(Map<String, Object> newVals) {
 LinkedHashMap<String, Object> copy = new LinkedHashMap<>(propMap);
 if (newVals == null || newVals.isEmpty()) return new ZkNodeProps(copy);
 copy.putAll(newVals);
 return new ZkNodeProps(copy);
}

代码示例来源：origin: org.apache.solr/solr-solrj

public boolean isLeader() {
 return nodeProps.containsKey(ZkStateReader.LEADER_PROP);
}

代码示例来源：origin: org.apache.solr/solr-solrj

public static Map<String, Object> getRouterSpec(ZkNodeProps props) {
 Map<String, Object> map = new LinkedHashMap<>();
 for (String s : props.keySet()) {
  if (s.startsWith("router.")) {
   map.put(s.substring(7), props.get(s));
  }
 }
 if (map.get("name") == null)  {
  map.put("name", DEFAULT_NAME);
 }
 return map;
}

代码示例来源：origin: cloudera/search

ZkNodeProps props = ZkNodeProps.load(data);
configName = props.getStr(ZkController.CONFIGNAME_PROP);

代码示例来源：origin: org.apache.solr/solr-test-framework

@Override
public void distribSetUp() throws Exception {
 super.distribSetUp();
 // ignoreException(".*");
 if (sliceCount > 0) {
  System.setProperty("numShards", Integer.toString(sliceCount));
 } else {
  System.clearProperty("numShards");
 }
 if (isSSLMode()) {
  System.clearProperty("urlScheme");
  try (ZkStateReader zkStateReader = new ZkStateReader(zkServer.getZkAddress(),
    AbstractZkTestCase.TIMEOUT, AbstractZkTestCase.TIMEOUT)) {
   try {
    zkStateReader.getZkClient().create(ZkStateReader.CLUSTER_PROPS,
      Utils.toJSON(Collections.singletonMap("urlScheme", "https")),
      CreateMode.PERSISTENT, true);
   } catch (KeeperException.NodeExistsException e) {
    ZkNodeProps props = ZkNodeProps.load(zkStateReader.getZkClient().getData(ZkStateReader.CLUSTER_PROPS,
      null, null, true));
    zkStateReader.getZkClient().setData(ZkStateReader.CLUSTER_PROPS, Utils.toJSON(props.plus("urlScheme", "https")), true);
   }
  }
 }
 if (useTlogReplicas()) {
  log.info("Will use {} replicas unless explicitly asked otherwise", Replica.Type.TLOG);
 } else {
  log.info("Will use {} replicas unless explicitly asked otherwise", Replica.Type.NRT);
 }
}

代码示例来源：origin: org.apache.solr/solr-solrj

@Override
public String toString() {
 return nodeProps.toString();
}

代码示例来源：origin: org.apache.solr/solr-solrj

public ZkNodeProps plus(String key , Object val) {
 return plus(Collections.singletonMap(key,val));
}

代码示例来源：origin: com.cloudera.search/search-mr

ZkNodeProps props = ZkNodeProps.load(data);
configName = props.getStr(ZkController.CONFIGNAME_PROP);

代码示例来源：origin: com.hynnet/solr-solrj

public static Map<String,Object> getRouterSpec(ZkNodeProps props){
 Map<String,Object> map =  new LinkedHashMap<>();
 for (String s : props.keySet()) {
  if(s.startsWith("router.")){
   map.put(s.substring(7), props.get(s));
  }
 }
 Object o = props.get("router");
 if (o instanceof String) {
  map.put("name", o);
 } else if (map.get("name") == null) {
  map.put("name", DEFAULT_NAME);
 }
 return  map;
}

代码示例来源：origin: com.hynnet/solr-solrj

@Override
public String toString() {
 return nodeProps.toString();
}

代码示例来源：origin: kite-sdk/kite

ZkNodeProps props = ZkNodeProps.load(data);
configName = props.getStr(ZkController.CONFIGNAME_PROP);

代码示例来源：origin: org.apache.solr/solr-solrj

public String getState() {
 return nodeProps.getStr(ZkStateReader.STATE_PROP);
}

代码示例来源：origin: org.apache.solr/solr-solrj

/**
 * Create Replica from json string that is typically stored in zookeeper.
 */
public static ZkNodeProps load(byte[] bytes) {
 Map<String, Object> props = (Map<String, Object>) Utils.fromJSON(bytes);
 return new ZkNodeProps(props);
}

代码示例来源：origin: com.hynnet/solr-solrj

public boolean isLeader() {
 return nodeProps.containsKey(ZkStateReader.LEADER_PROP);
}

代码示例来源：origin: com.cloudera.cdk/cdk-morphlines-solr-core

ZkNodeProps props = ZkNodeProps.load(data);
configName = props.getStr(ZkController.CONFIGNAME_PROP);

代码示例来源：origin: org.apache.solr/solr-solrj

public String getBaseUrl() {
 return nodeProps.getStr(ZkStateReader.BASE_URL_PROP);
}

代码示例来源：origin: com.hynnet/solr-solrj

/**
 * Create Replica from json string that is typically stored in zookeeper.
 */
public static ZkNodeProps load(byte[] bytes) {
 Map<String, Object> props = (Map<String, Object>) Utils.fromJSON(bytes);
 return new ZkNodeProps(props);
}

代码示例来源：origin: org.kitesdk/kite-morphlines-solr-core

ZkNodeProps props = ZkNodeProps.load(data);
configName = props.getStr(ZkController.CONFIGNAME_PROP);

代码示例来源：origin: org.apache.solr/solr-solrj

public String getNodeName() {
 return nodeProps.getStr(ZkStateReader.NODE_NAME_PROP);
}