PHOENIX-2100 Indicate in explain plan when round robin iterator is being used
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/6e7acaa4 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6e7acaa4 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6e7acaa4 Branch: refs/heads/calcite Commit: 6e7acaa4564e837dad3f54f79ac7a9b1e670d93a Parents: 952a01c Author: James Taylor <jtay...@salesforce.com> Authored: Wed Mar 2 15:27:05 2016 -0800 Committer: James Taylor <jtay...@salesforce.com> Committed: Wed Mar 2 15:58:27 2016 -0800 ---------------------------------------------------------------------- .../src/it/java/org/apache/phoenix/end2end/IndexToolIT.java | 6 +++--- .../it/java/org/apache/phoenix/end2end/MutableIndexToolIT.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/6e7acaa4/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java index fe95470..ef22094 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java @@ -144,7 +144,7 @@ public class IndexToolIT extends BaseOwnClusterHBaseManagedTimeIT { String actualExplainPlan = QueryUtil.getExplainPlan(rs); //assert we are pulling from data table. - assertEquals(String.format("CLIENT 1-CHUNK PARALLEL 1-WAY FULL SCAN OVER %s", fullTableName), actualExplainPlan); + assertEquals(String.format("CLIENT 1-CHUNK PARALLEL 1-WAY ROUND ROBIN FULL SCAN OVER %s", fullTableName), actualExplainPlan); rs = stmt1.executeQuery(selectSql); assertTrue(rs.next()); @@ -205,10 +205,10 @@ public class IndexToolIT extends BaseOwnClusterHBaseManagedTimeIT { String expectedExplainPlan = ""; if(isLocal) { final String localIndexName = MetaDataUtil.getLocalIndexTableName(SchemaUtil.getTableName(schemaName, dataTable)); - expectedExplainPlan = String.format("CLIENT 1-CHUNK PARALLEL 1-WAY RANGE SCAN OVER %s [-32768]" + expectedExplainPlan = String.format("CLIENT 1-CHUNK PARALLEL 1-WAY ROUND ROBIN RANGE SCAN OVER %s [-32768]" + "\n SERVER FILTER BY FIRST KEY ONLY", localIndexName); } else { - expectedExplainPlan = String.format("CLIENT 1-CHUNK PARALLEL 1-WAY FULL SCAN OVER %s" + expectedExplainPlan = String.format("CLIENT 1-CHUNK PARALLEL 1-WAY ROUND ROBIN FULL SCAN OVER %s" + "\n SERVER FILTER BY FIRST KEY ONLY",SchemaUtil.getTableName(schemaName, indxTable)); } assertEquals(expectedExplainPlan,actualExplainPlan); http://git-wip-us.apache.org/repos/asf/phoenix/blob/6e7acaa4/phoenix-core/src/it/java/org/apache/phoenix/end2end/MutableIndexToolIT.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MutableIndexToolIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MutableIndexToolIT.java index 8125007..c335ff8 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MutableIndexToolIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MutableIndexToolIT.java @@ -91,7 +91,7 @@ public class MutableIndexToolIT extends BaseOwnClusterHBaseManagedTimeIT { String actualExplainPlan = QueryUtil.getExplainPlan(rs); //assert we are pulling from data table. - assertEquals(String.format("CLIENT 1-CHUNK PARALLEL 1-WAY FULL SCAN OVER %s",dataTable),actualExplainPlan); + assertEquals(String.format("CLIENT 1-CHUNK PARALLEL 1-WAY ROUND ROBIN FULL SCAN OVER %s",dataTable),actualExplainPlan); rs = stmt1.executeQuery(selectSql); assertTrue(rs.next());
