This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 17caad3 Cleanup the console output in OfflineClusterIntegrationTest
(#5536)
17caad3 is described below
commit 17caad3910183c91535b8c6754c6403acb07211f
Author: Xiaotian (Jackie) Jiang <17555551+jackie-ji...@users.noreply.github.com>
AuthorDate: Wed Jun 10 15:09:22 2020 -0700
Cleanup the console output in OfflineClusterIntegrationTest (#5536)
---
.../tests/OfflineClusterIntegrationTest.java | 22 +++++++---------------
1 file changed, 7 insertions(+), 15 deletions(-)
diff --git
a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java
b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java
index ef030eb..c4506b5 100644
---
a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java
+++
b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterIntegrationTest.java
@@ -720,7 +720,6 @@ public class OfflineClusterIntegrationTest extends
BaseClusterIntegrationTestSet
String pqlQuery;
pqlQuery = "SELECT count(*) FROM mytable WHERE DaysSinceEpoch = " +
daysSinceEpoch;
long expectedResult =
postQuery(pqlQuery).get("aggregationResults").get(0).get("value").asLong();
- System.out.println(expectedResult);
pqlQuery = "SELECT count(*) FROM mytable WHERE
timeConvert(DaysSinceEpoch,'DAYS','SECONDS') = " + secondsSinceEpoch;
assertEquals(postQuery(pqlQuery).get("aggregationResults").get(0).get("value").asLong(),
expectedResult);
@@ -754,17 +753,16 @@ public class OfflineClusterIntegrationTest extends
BaseClusterIntegrationTestSet
List<String> origins = Arrays
.asList("ATL", "ORD", "DFW", "DEN", "LAX", "IAH", "SFO", "PHX", "LAS",
"EWR", "MCO", "BOS", "SLC", "SEA", "MSP",
"CLT", "LGA", "DTW", "JFK", "BWI");
- String whenThenStatement = "";
+ StringBuilder caseStatementBuilder = new StringBuilder("CASE ");
for (int i = 0; i < origins.size(); i++) {
// WHEN origin = 'ATL' THEN 1
// WHEN origin = 'ORD' THEN 2
// WHEN origin = 'DFW' THEN 3
// ....
- whenThenStatement += String.format("WHEN origin = '%s' THEN %d ",
origins.get(i), i + 1);
+ caseStatementBuilder.append(String.format("WHEN origin = '%s' THEN %d ",
origins.get(i), i + 1));
}
- String sqlQuery = String.format(
- "SELECT origin, " + "CASE " + whenThenStatement + "ELSE 0 END " + "AS
origin_code " + "FROM mytable "
- + "LIMIT 1000");
+ caseStatementBuilder.append("ELSE 0 END");
+ String sqlQuery = "SELECT origin, " + caseStatementBuilder + " AS
origin_code FROM mytable LIMIT 1000";
JsonNode response = postSqlQuery(sqlQuery, _brokerBaseApiUrl);
JsonNode rows = response.get("resultTable").get("rows");
assertEquals(response.get("exceptions").size(), 0);
@@ -774,7 +772,7 @@ public class OfflineClusterIntegrationTest extends
BaseClusterIntegrationTestSet
if (originCode > 0) {
assertEquals(origin, origins.get(originCode - 1));
} else {
- assertTrue(!origins.contains(origin));
+ assertFalse(origins.contains(origin));
}
}
}
@@ -782,10 +780,9 @@ public class OfflineClusterIntegrationTest extends
BaseClusterIntegrationTestSet
@Test
public void testCaseStatementInSelectionWithTransformFunctionInThen()
throws Exception {
- String sqlQuery = String.format(
- "SELECT ArrDelay, CASE WHEN ArrDelay > 0 THEN ArrDelay WHEN ArrDelay <
0 THEN ArrDelay * -1 ELSE 0 END AS ArrTimeDiff FROM mytable LIMIT 1000");
+ String sqlQuery =
+ "SELECT ArrDelay, CASE WHEN ArrDelay > 0 THEN ArrDelay WHEN ArrDelay <
0 THEN ArrDelay * -1 ELSE 0 END AS ArrTimeDiff FROM mytable LIMIT 1000";
JsonNode response = postSqlQuery(sqlQuery, _brokerBaseApiUrl);
- System.out.println("response = " + response);
JsonNode rows = response.get("resultTable").get("rows");
assertEquals(response.get("exceptions").size(), 0);
for (int i = 0; i < rows.size(); i++) {
@@ -815,14 +812,11 @@ public class OfflineClusterIntegrationTest extends
BaseClusterIntegrationTestSet
private void testCountVsCaseQuery(String predicate)
throws Exception {
- // System.out.println("predicate = " + predicate);
String sqlQuery = String.format("SELECT COUNT(*) FROM mytable WHERE %s",
predicate);
JsonNode response = postSqlQuery(sqlQuery, _brokerBaseApiUrl);
- // System.out.println(String.format("query = %s, response = %s",sqlQuery,
response));
long countValue =
response.get("resultTable").get("rows").get(0).get(0).asLong();
sqlQuery = String.format("SELECT SUM(CASE WHEN %s THEN 1 ELSE 0 END) as
sum1 FROM mytable", predicate);
response = postSqlQuery(sqlQuery, _brokerBaseApiUrl);
- // System.out.println(String.format("query = %s, response = %s",sqlQuery,
response));
long caseSum =
response.get("resultTable").get("rows").get(0).get(0).asLong();
assertEquals(caseSum, countValue);
}
@@ -840,11 +834,9 @@ public class OfflineClusterIntegrationTest extends
BaseClusterIntegrationTestSet
pqlQuery =
"SELECT count(*) FROM mytable WHERE Origin = \"" + origin + "\" AND
DaysSinceEpoch = " + daysSinceEpoch;
JsonNode response1 = postQuery(pqlQuery);
- //System.out.println(response1);
pqlQuery = "SELECT count(*) FROM mytable WHERE Origin = \"" + origin
+ "\" AND timeConvert(DaysSinceEpoch,'DAYS','SECONDS') = " +
secondsSinceEpoch;
JsonNode response2 = postQuery(pqlQuery);
- //System.out.println(response2);
double val1 =
response1.get("aggregationResults").get(0).get("value").asDouble();
double val2 =
response2.get("aggregationResults").get(0).get("value").asDouble();
assertEquals(val1, val2);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
