Skip to content

Commit

Permalink
Provide all stats metadata to queries run by pinot-java-client
Browse files Browse the repository at this point in the history
  • Loading branch information
soumitra-st committed Mar 23, 2023
1 parent f3c2c0d commit 2af21d9
Showing 1 changed file with 1 addition and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,6 @@
package org.apache.pinot.client;

import com.fasterxml.jackson.databind.JsonNode;
import java.util.HashMap;
import java.util.Map;


/**
Expand Down Expand Up @@ -115,20 +113,6 @@ public long getTimeUsedMs() {

@Override
public String toString() {
Map<String, Object> map = new HashMap<>();
map.put(NUM_SERVERS_QUERIED, getNumServersQueried());
map.put(NUM_SERVERS_RESPONDED, getNumServersResponded());
map.put(NUM_DOCS_SCANNED, getNumDocsScanned());
map.put(NUM_ENTRIES_SCANNED_IN_FILTER, getNumEntriesScannedInFilter());
map.put(NUM_ENTRIES_SCANNED_POST_FILTER, getNumEntriesScannedPostFilter());
map.put(NUM_SEGMENTS_QUERIED, getNumSegmentsQueried());
map.put(NUM_SEGMENTS_PROCESSED, getNumSegmentsProcessed());
map.put(NUM_SEGMENTS_MATCHED, getNumSegmentsMatched());
map.put(NUM_CONSUMING_SEGMENTS_QUERIED, getNumConsumingSegmentsQueried());
map.put(MIN_CONSUMING_FRESHNESS_TIME_MS, getMinConsumingFreshnessTimeMs() + "ms");
map.put(TOTAL_DOCS, getTotalDocs());
map.put(NUM_GROUPS_LIMIT_REACHED, isNumGroupsLimitReached());
map.put(TIME_USED_MS, getTimeUsedMs() + "ms");
return map.toString();
return _brokerResponse.toString();
}
}

0 comments on commit 2af21d9

Please sign in to comment.