Skip to content

Commit 9fba72e

Browse files
committed
tidy up
1 parent df081d5 commit 9fba72e

File tree

3 files changed

+38
-24
lines changed

3 files changed

+38
-24
lines changed

solr/core/src/java/org/apache/solr/handler/admin/LukeRequestHandler.java

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -251,7 +251,8 @@ private record FieldOrigin(String shardAddr, LukeResponse.FieldInfo fieldInfo) {
251251
* short-circuited (e.g. single-shard collection) and the caller should fall through to local
252252
* logic.
253253
*/
254-
private boolean handleDistributed(SolrQueryRequest req, SolrQueryResponse rsp) throws IOException {
254+
private boolean handleDistributed(SolrQueryRequest req, SolrQueryResponse rsp)
255+
throws IOException {
255256
ShardHandler shardHandler = shardHandlerFactory.getShardHandler();
256257
ResponseBuilder rb = new ResponseBuilder(req, rsp, Collections.emptyList());
257258
shardHandler.prepDistributed(rb);
@@ -321,9 +322,13 @@ private void mergeDistributedResponses(SolrQueryResponse rsp, List<ShardResponse
321322
"Unexpected empty response from shard: " + shardAddress(firstRsp));
322323
}
323324
Object schema = firstShardRsp.get(RSP_SCHEMA);
324-
if (schema != null) rsp.add(RSP_SCHEMA, schema);
325+
if (schema != null) {
326+
rsp.add(RSP_SCHEMA, schema);
327+
}
325328
Object info = firstShardRsp.get(RSP_INFO);
326-
if (info != null) rsp.add(RSP_INFO, info);
329+
if (info != null) {
330+
rsp.add(RSP_INFO, info);
331+
}
327332
}
328333

329334
for (ShardResponse srsp : responses) {
@@ -335,8 +340,7 @@ private void mergeDistributedResponses(SolrQueryResponse rsp, List<ShardResponse
335340
NamedList<Object> shardIndex = lukeRsp.getIndexInfo();
336341
if (shardIndex != null) {
337342
totalNumDocs += Optional.ofNullable(lukeRsp.getNumDocsAsLong()).orElse(0L);
338-
totalMaxDoc =
339-
Math.max(totalMaxDoc, Optional.ofNullable(lukeRsp.getMaxDoc()).orElse(0));
343+
totalMaxDoc = Math.max(totalMaxDoc, Optional.ofNullable(lukeRsp.getMaxDoc()).orElse(0));
340344
totalDeletedDocs += Optional.ofNullable(lukeRsp.getDeletedDocsAsLong()).orElse(0L);
341345
Number segCount = (Number) shardIndex.get(KEY_SEGMENT_COUNT);
342346
totalSegmentCount += segCount != null ? segCount.intValue() : 0;

solr/core/src/test/org/apache/solr/handler/admin/LukeRequestHandlerDistribTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,7 @@ private LukeResponse requestLuke(String collection, ModifiableSolrParams extra)
6666
params.set("qt", "/admin/luke");
6767
params.set("numTerms", "0");
6868
if (extra != null) {
69-
for (Map.Entry<String, String[]> entry :
70-
extra.getMap().entrySet()) {
69+
for (Map.Entry<String, String[]> entry : extra.getMap().entrySet()) {
7170
params.set(entry.getKey(), entry.getValue());
7271
}
7372
}

solr/solrj/src/java/org/apache/solr/client/solrj/response/LukeResponse.java

Lines changed: 28 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -130,21 +130,26 @@ public FieldInfo(String n) {
130130
@SuppressWarnings("unchecked")
131131
public void read(NamedList<Object> nl) {
132132
for (Map.Entry<String, Object> entry : nl) {
133-
String key = entry.getKey();
134-
switch (key) {
135-
case "type" -> type = (String) entry.getValue();
136-
case "flags" -> flags = parseFlags((String) entry.getValue());
137-
case "schema" -> schema = (String) entry.getValue();
138-
case "docs" -> {
139-
docs = (Integer) entry.getValue();
140-
docsAsLong = (long) docs; // widen, lossless
141-
}
142-
case "docsAsLong" -> docsAsLong = (Long) entry.getValue();
133+
if ("type".equals(entry.getKey())) {
134+
type = (String) entry.getValue();
135+
} else if ("flags".equals(entry.getKey())) {
136+
flags = parseFlags((String) entry.getValue());
137+
} else if ("schema".equals(entry.getKey())) {
138+
schema = (String) entry.getValue();
139+
} else if ("docs".equals(entry.getKey())) {
140+
docs = (Integer) entry.getValue();
141+
docsAsLong = (long) docs; // widen, lossless
142+
} else if ("docsAsLong".equals(entry.getKey())) {
143143
// Don't set docs — narrowing Long→int is lossy
144-
case "distinct" -> distinct = (Integer) entry.getValue();
145-
case "cacheableFaceting" -> cacheableFaceting = (Boolean) entry.getValue();
146-
case "topTerms" -> topTerms = (NamedList<Integer>) entry.getValue();
147-
default -> extras.put(key, entry.getValue());
144+
docsAsLong = (Long) entry.getValue();
145+
} else if ("distinct".equals(entry.getKey())) {
146+
distinct = (Integer) entry.getValue();
147+
} else if ("cacheableFaceting".equals(entry.getKey())) {
148+
cacheableFaceting = (Boolean) entry.getValue();
149+
} else if ("topTerms".equals(entry.getKey())) {
150+
topTerms = (NamedList<Integer>) entry.getValue();
151+
} else {
152+
extras.put(entry.getKey(), entry.getValue());
148153
}
149154
}
150155
}
@@ -287,7 +292,9 @@ private Long getIndexLong(String key) {
287292
}
288293

289294
public Integer getNumDocs() {
290-
if (indexInfo == null) return null;
295+
if (indexInfo == null) {
296+
return null;
297+
}
291298
Object val = indexInfo.get("numDocs");
292299
return val instanceof Integer i ? i : null;
293300
}
@@ -297,7 +304,9 @@ public Long getNumDocsAsLong() {
297304
}
298305

299306
public Integer getMaxDoc() {
300-
if (indexInfo == null) return null;
307+
if (indexInfo == null) {
308+
return null;
309+
}
301310
Object val = indexInfo.get("maxDoc");
302311
return val instanceof Integer i ? i : null;
303312
}
@@ -307,7 +316,9 @@ public Long getDeletedDocsAsLong() {
307316
}
308317

309318
public Integer getNumTerms() {
310-
if (indexInfo == null) return null;
319+
if (indexInfo == null) {
320+
return null;
321+
}
311322
Object val = indexInfo.get("numTerms");
312323
return val instanceof Integer i ? i : null;
313324
}

0 commit comments

Comments
 (0)