PHOENIX-2100 Indicate in explain plan when round robin iterator is being used
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
index 9f3b3e6..c36a72b 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
@@ -882,6 +882,13 @@
}
}
buf.append(getName()).append(" ").append(size()).append("-WAY ");
+ try {
+ if (plan.useRoundRobinIterator()) {
+ buf.append("ROUND ROBIN ");
+ }
+ } catch (SQLException e) {
+ throw new RuntimeException(e);
+ }
explain(buf.toString(),planSteps);
}
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/QueryPlanTest.java b/phoenix-core/src/test/java/org/apache/phoenix/query/QueryPlanTest.java
index 4ba4d16..b00ccc0 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/query/QueryPlanTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/query/QueryPlanTest.java
@@ -252,5 +252,30 @@
conn.close();
}
}
+
+ @Test
+ public void testUseOfRoundRobinIteratorSurfaced() throws Exception {
+ Properties props = PropertiesUtil.deepCopy(new Properties());
+ props.put(QueryServices.FORCE_ROW_KEY_ORDER_ATTRIB, Boolean.toString(false));
+ Connection conn = DriverManager.getConnection(getUrl(), props);
+ String tableName = "testUseOfRoundRobinIteratorSurfaced".toUpperCase();
+ try {
+ conn.createStatement().execute("CREATE TABLE " + tableName + "(\n" +
+ " a VARCHAR NOT NULL,\n" +
+ " b TIMESTAMP NOT NULL,\n" +
+ " c VARCHAR,\n" +
+ " CONSTRAINT pk PRIMARY KEY (a, b DESC, c)\n" +
+ " ) IMMUTABLE_ROWS=true\n" +
+ " ,SALT_BUCKETS=20");
+ String query = "select * from " + tableName + " where a = 'a' and b >= timestamp '2016-01-28 00:00:00' and b < timestamp '2016-01-29 00:00:00'";
+ ResultSet rs = conn.createStatement().executeQuery("EXPLAIN " + query);
+ String queryPlan = QueryUtil.getExplainPlan(rs);
+ assertEquals(
+ "CLIENT PARALLEL 20-WAY ROUND ROBIN RANGE SCAN OVER " + tableName + " [0,'a',~'2016-01-28 23:59:59.999'] - [0,'a',~'2016-01-28 00:00:00.000']\n" +
+ " SERVER FILTER BY FIRST KEY ONLY", queryPlan);
+ } finally {
+ conn.close();
+ }
+ }
}
