org.apache.solr.common.cloud.ZkCoreNodeProps.getCoreUrl()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(10.5k)|赞(0)|评价(0)|浏览(72)

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

ZkCoreNodeProps.getCoreUrl介绍

暂无

代码示例

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

public String getCoreUrl() {
 return getCoreUrl(nodeProps.getStr(ZkStateReader.BASE_URL_PROP), nodeProps.getStr(ZkStateReader.CORE_NAME_PROP));
}

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

public String getCoreUrl() {
 return ZkCoreNodeProps.getCoreUrl(getStr(BASE_URL_PROP), getStr(CORE_NAME_PROP));
}

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

public String getLeaderUrl(String collection, String shard, int timeout) throws InterruptedException {
 ZkCoreNodeProps props = new ZkCoreNodeProps(getLeaderRetry(collection, shard, timeout));
 return props.getCoreUrl();
}

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

public String getLeaderUrl(String collection, String shard, int timeout)
  throws InterruptedException, KeeperException {
 ZkCoreNodeProps props = new ZkCoreNodeProps(getLeaderRetry(collection,
   shard, timeout));
 return props.getCoreUrl();
}

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

public String getCoreUrl() {
 return ZkCoreNodeProps.getCoreUrl(getStr(ZkStateReader.BASE_URL_PROP), getStr(ZkStateReader.CORE_NAME_PROP));
}
public String getBaseUrl(){

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

public static String getCoreUrl(ZkNodeProps nodeProps) {
 return getCoreUrl(nodeProps.getStr(ZkStateReader.BASE_URL_PROP), nodeProps.getStr(ZkStateReader.CORE_NAME_PROP));
}

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

public String getCoreUrl() {
 return getCoreUrl(nodeProps.getStr(ZkStateReader.BASE_URL_PROP), nodeProps.getStr(ZkStateReader.CORE_NAME_PROP));
}

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

public static String getCoreUrl(ZkNodeProps nodeProps) {
 return getCoreUrl(nodeProps.getStr(ZkStateReader.BASE_URL_PROP), nodeProps.getStr(ZkStateReader.CORE_NAME_PROP));
}

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

public List<List<String>> extractShardUrls(String zkHost, String collection) {
 DocCollection docCollection = extractDocCollection(zkHost, collection);
 List<Slice> slices = getSortedSlices(docCollection.getSlices());
 List<List<String>> solrUrls = new ArrayList<List<String>>(slices.size());
 for (Slice slice : slices) {
  if (slice.getLeader() == null) {
   throw new IllegalArgumentException("Cannot find SolrCloud slice leader. " +
     "It looks like not all of your shards are registered in ZooKeeper yet");
  }
  Collection<Replica> replicas = slice.getReplicas();
  List<String> urls = new ArrayList<String>(replicas.size());
  for (Replica replica : replicas) {
   ZkCoreNodeProps props = new ZkCoreNodeProps(replica);
   if (replica.getStr(Slice.LEADER) == null) {
    urls.add(props.getCoreUrl()); // add followers at tail
   } else {
    urls.add(0, props.getCoreUrl()); // insert leader at head
   }
  }
  solrUrls.add(urls);
 }
 return solrUrls;
}

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

public List<List<String>> extractShardUrls(String zkHost, String collection) {
 DocCollection docCollection = extractDocCollection(zkHost, collection);
 List<Slice> slices = getSortedSlices(docCollection.getSlices());
 List<List<String>> solrUrls = new ArrayList<List<String>>(slices.size());
 for (Slice slice : slices) {
  if (slice.getLeader() == null) {
   throw new IllegalArgumentException("Cannot find SolrCloud slice leader. " +
     "It looks like not all of your shards are registered in ZooKeeper yet");
  }
  Collection<Replica> replicas = slice.getReplicas();
  List<String> urls = new ArrayList<String>(replicas.size());
  for (Replica replica : replicas) {
   ZkCoreNodeProps props = new ZkCoreNodeProps(replica);
   urls.add(props.getCoreUrl());
  }
  solrUrls.add(urls);
 }
 return solrUrls;
}

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

protected List<String> getShardUrls() throws IOException {
 try {
  ZkStateReader zkStateReader = cloudSolrClient.getZkStateReader();
  Slice[] slices = CloudSolrStream.getSlices(this.collection, zkStateReader, false);
  ClusterState clusterState = zkStateReader.getClusterState();
  Set<String> liveNodes = clusterState.getLiveNodes();
  List<String> baseUrls = new ArrayList<>();
  for(Slice slice : slices) {
   Collection<Replica> replicas = slice.getReplicas();
   List<Replica> shuffler = new ArrayList<>();
   for(Replica replica : replicas) {
    if(replica.getState() == Replica.State.ACTIVE && liveNodes.contains(replica.getNodeName())) {
     shuffler.add(replica);
    }
   }
   Collections.shuffle(shuffler, new Random());
   Replica rep = shuffler.get(0);
   ZkCoreNodeProps zkProps = new ZkCoreNodeProps(rep);
   String url = zkProps.getCoreUrl();
   baseUrls.add(url);
  }
  return baseUrls;
 } catch (Exception e) {
  throw new IOException(e);
 }
}

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

/**
 * Retrieve all requests recorded by this queue which were sent to given collection and shard
 *
 * @param zkStateReader  the {@link org.apache.solr.common.cloud.ZkStateReader} from which cluster state is read
 * @param collectionName the given collection name for which requests have to be extracted
 * @param shardId        the given shard name for which requests have to be extracted
 * @return a list of {@link org.apache.solr.handler.component.TrackingShardHandlerFactory.ShardRequestAndParams}
 * or empty list if none are found
 */
public List<ShardRequestAndParams> getShardRequests(ZkStateReader zkStateReader, String collectionName, String shardId) {
 DocCollection collection = zkStateReader.getClusterState().getCollection(collectionName);
 assert collection != null;
 Slice slice = collection.getSlice(shardId);
 assert slice != null;
 for (Map.Entry<String, List<ShardRequestAndParams>> entry : requests.entrySet()) {
  // multiple shard addresses may be present separated by '|'
  List<String> list = StrUtils.splitSmart(entry.getKey(), '|');
  for (Map.Entry<String, Replica> replica : slice.getReplicasMap().entrySet()) {
   String coreUrl = new ZkCoreNodeProps(replica.getValue()).getCoreUrl();
   if (list.contains(coreUrl)) {
    return new ArrayList<>(entry.getValue());
   }
  }
 }
 return Collections.emptyList();
}

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

private List<String> getShardUrls() throws IOException {
 try {
  ZkStateReader zkStateReader = cloudSolrClient.getZkStateReader();
  Slice[] slices = CloudSolrStream.getSlices(this.collection, zkStateReader, false);
  ClusterState clusterState = zkStateReader.getClusterState();
  Set<String> liveNodes = clusterState.getLiveNodes();
  List<String> baseUrls = new ArrayList<>();
  for(Slice slice : slices) {
   Collection<Replica> replicas = slice.getReplicas();
   List<Replica> shuffler = new ArrayList<>();
   for(Replica replica : replicas) {
    if(replica.getState() == Replica.State.ACTIVE && liveNodes.contains(replica.getNodeName())) {
     shuffler.add(replica);
    }
   }
   Collections.shuffle(shuffler, new Random());
   Replica rep = shuffler.get(0);
   ZkCoreNodeProps zkProps = new ZkCoreNodeProps(rep);
   String url = zkProps.getCoreUrl();
   baseUrls.add(url);
  }
  return baseUrls;
 } catch (Exception e) {
  throw new IOException(e);
 }
}

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

String url = zkProps.getCoreUrl();
urls.add(url);
Collection<Replica> replicas = slice.getReplicas();
   !replica.getName().equals(leader.getName())) {
  ZkCoreNodeProps zkProps1 = new ZkCoreNodeProps(replica);
  String url1 = zkProps1.getCoreUrl();
  urls.add(url1);

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

public static String getUrlFromZk(ClusterState clusterState, String collection) {
 Map<String,Slice> slices = clusterState.getCollection(collection).getSlicesMap();
 if (slices == null) {
  throw new SolrException(SolrException.ErrorCode.BAD_REQUEST, "Could not find collection:" + collection);
 }
 for (Map.Entry<String,Slice> entry : slices.entrySet()) {
  Slice slice = entry.getValue();
  Map<String,Replica> shards = slice.getReplicasMap();
  Set<Map.Entry<String,Replica>> shardEntries = shards.entrySet();
  for (Map.Entry<String,Replica> shardEntry : shardEntries) {
   final ZkNodeProps node = shardEntry.getValue();
   if (clusterState.liveNodesContain(node.getStr(ZkStateReader.NODE_NAME_PROP))) {
    return ZkCoreNodeProps.getCoreUrl(node.getStr(ZkStateReader.BASE_URL_PROP), collection); //new ZkCoreNodeProps(node).getCoreUrl();
   }
  }
 }
 throw new RuntimeException("Could not find a live node for collection:" + collection);
}

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

protected void constructStreams() throws IOException {
 try {
  ZkStateReader zkStateReader = cloudSolrClient.getZkStateReader();
  ClusterState clusterState = zkStateReader.getClusterState();
  //System.out.println("Connected to zk an got cluster state.");
  Collection<Slice> slices = clusterState.getActiveSlices(this.collection);
  long time = System.currentTimeMillis();
  params.put("distrib","false"); // We are the aggregator.
  for(Slice slice : slices) {
   Collection<Replica> replicas = slice.getReplicas();
   List<Replica> shuffler = new ArrayList();
   for(Replica replica : replicas) {
    shuffler.add(replica);
   }
   Collections.shuffle(shuffler, new Random(time));
   Replica rep = shuffler.get(0);
   ZkCoreNodeProps zkProps = new ZkCoreNodeProps(rep);
   String url = zkProps.getCoreUrl();
   SolrStream solrStream = new SolrStream(url, params);
   if(streamContext != null) {
    solrStream.setStreamContext(streamContext);
   }
   solrStream.setFieldMappings(this.fieldMappings);
   solrStreams.add(solrStream);
  }
 } catch (Exception e) {
  throw new IOException(e);
 }
}

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

Replica rep = shuffler.get(0);
ZkCoreNodeProps zkProps = new ZkCoreNodeProps(rep);
String url = zkProps.getCoreUrl();
shards.add(url);

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

protected SolrStream constructStream(String sql) throws IOException {
 try {
  ZkStateReader zkStateReader = this.connection.getClient().getZkStateReader();
  Slice[] slices = CloudSolrStream.getSlices(this.connection.getCollection(), zkStateReader, true);
  List<Replica> shuffler = new ArrayList<>();
  for(Slice slice : slices) {
   Collection<Replica> replicas = slice.getReplicas();
   for (Replica replica : replicas) {
    shuffler.add(replica);
   }
  }
  Collections.shuffle(shuffler, new Random());
  ModifiableSolrParams params = new ModifiableSolrParams();
  params.set(CommonParams.QT, "/sql");
  params.set("stmt", sql);
  for(String propertyName : this.connection.getProperties().stringPropertyNames()) {
   params.set(propertyName, this.connection.getProperties().getProperty(propertyName));
  }
  Replica rep = shuffler.get(0);
  ZkCoreNodeProps zkProps = new ZkCoreNodeProps(rep);
  String url = zkProps.getCoreUrl();
  return new SolrStream(url, params);
 } catch (Exception e) {
  throw new IOException(e);
 }
}

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

String url = zkProps.getCoreUrl();
urls.add(url);
if (!directUpdatesToLeadersOnly) {
    !replica.getName().equals(leader.getName())) {
   ZkCoreNodeProps zkProps1 = new ZkCoreNodeProps(replica);
   String url1 = zkProps1.getCoreUrl();
   urls.add(url1);

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

String url = zkProps.getCoreUrl();
SolrStream solrStream = new SolrStream(url, localParams);
solrStream.setSlice(slice.getName());

内容来源于网络，如有侵权，请联系作者删除！

ZkCoreNodeProps

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com