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

Reply via email to