This is an automated email from the ASF dual-hosted git repository. xiangfu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push: new 0fe7ef8 Remove PQL response parser in quickstart (#8081) 0fe7ef8 is described below commit 0fe7ef89127b9e920ef369cd9adad9c8b817dde9 Author: Xiang Fu <xiangfu.1...@gmail.com> AuthorDate: Thu Jan 27 22:40:22 2022 -0800 Remove PQL response parser in quickstart (#8081) --- .../java/org/apache/pinot/tools/Quickstart.java | 61 ---------------------- 1 file changed, 61 deletions(-) diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java b/pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java index a8efabc..a7c019e 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/Quickstart.java @@ -85,67 +85,6 @@ public class Quickstart extends QuickStartBase { } responseBuilder.append(NEW_LINE); } - return responseBuilder.toString(); - } - - // Selection query - if (response.has("selectionResults")) { - JsonNode columns = response.get("selectionResults").get("columns"); - int numColumns = columns.size(); - for (int i = 0; i < numColumns; i++) { - responseBuilder.append(columns.get(i).asText()).append(TAB); - } - responseBuilder.append(NEW_LINE); - JsonNode rows = response.get("selectionResults").get("results"); - int numRows = rows.size(); - for (int i = 0; i < numRows; i++) { - JsonNode row = rows.get(i); - for (int j = 0; j < numColumns; j++) { - responseBuilder.append(row.get(j).asText()).append(TAB); - } - responseBuilder.append(NEW_LINE); - } - return responseBuilder.toString(); - } - - // Aggregation only query - if (!response.get("aggregationResults").get(0).has("groupByResult")) { - JsonNode aggregationResults = response.get("aggregationResults"); - int numAggregations = aggregationResults.size(); - for (int i = 0; i < numAggregations; i++) { - responseBuilder.append(aggregationResults.get(i).get("function").asText()).append(TAB); - } - responseBuilder.append(NEW_LINE); - for (int i = 0; i < numAggregations; i++) { - responseBuilder.append(aggregationResults.get(i).get("value").asText()).append(TAB); - } - responseBuilder.append(NEW_LINE); - return responseBuilder.toString(); - } - - // Aggregation group-by query - JsonNode groupByResults = response.get("aggregationResults"); - int numGroupBys = groupByResults.size(); - for (int i = 0; i < numGroupBys; i++) { - JsonNode groupByResult = groupByResults.get(i); - responseBuilder.append(groupByResult.get("function").asText()).append(TAB); - JsonNode columns = groupByResult.get("groupByColumns"); - int numColumns = columns.size(); - for (int j = 0; j < numColumns; j++) { - responseBuilder.append(columns.get(j).asText()).append(TAB); - } - responseBuilder.append(NEW_LINE); - JsonNode rows = groupByResult.get("groupByResult"); - int numRows = rows.size(); - for (int j = 0; j < numRows; j++) { - JsonNode row = rows.get(j); - responseBuilder.append(row.get("value").asText()).append(TAB); - JsonNode columnValues = row.get("group"); - for (int k = 0; k < numColumns; k++) { - responseBuilder.append(columnValues.get(k).asText()).append(TAB); - } - responseBuilder.append(NEW_LINE); - } } return responseBuilder.toString(); } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org