如何从 ClusterSearchShardsRequest 获取所有信息
How to get all the info from ClusterSearchShardsRequest
我设计了以下代码来获取类似于 ES 中的 _search_shards
rest API 的信息:
ClusterSearchShardsRequest clusterSearchShardsRequest
= new ClusterSearchShardsRequest();
clusterSearchShardsRequest.routing("route2");
try {
DiscoveryNode[] discoveryNodes = client().admin().cluster()
.searchShards(clusterSearchShardsRequest)
.get()
.getNodes();
for (int i=0; i<=discoveryNodes.length; i++){
System.out.print("\n\n\n"+discoveryNodes[i].toString()+"\n\n\n");
}
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
然而,这往往不会初始化实际的 clusterSearchShardsRequest
。
如何为给定的 client
和索引初始化 clusterSearchShardsRequest
?
只需创建索引名称为参数的 new ClusterSearchShardsRequest(BOOK_INDEX_NAME)
。
我设计了以下代码来获取类似于 ES 中的 _search_shards
rest API 的信息:
ClusterSearchShardsRequest clusterSearchShardsRequest
= new ClusterSearchShardsRequest();
clusterSearchShardsRequest.routing("route2");
try {
DiscoveryNode[] discoveryNodes = client().admin().cluster()
.searchShards(clusterSearchShardsRequest)
.get()
.getNodes();
for (int i=0; i<=discoveryNodes.length; i++){
System.out.print("\n\n\n"+discoveryNodes[i].toString()+"\n\n\n");
}
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
然而,这往往不会初始化实际的 clusterSearchShardsRequest
。
如何为给定的 client
和索引初始化 clusterSearchShardsRequest
?
只需创建索引名称为参数的 new ClusterSearchShardsRequest(BOOK_INDEX_NAME)
。