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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
