You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ma...@apache.org on 2016/02/12 20:00:04 UTC
[2/2] phoenix git commit: PHOENIX-2090 Refine
PhoenixTableScan.computeSelfCost() when scanRanges is available
PHOENIX-2090 Refine PhoenixTableScan.computeSelfCost() when scanRanges is available
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/8b68b1c4
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/8b68b1c4
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/8b68b1c4
Branch: refs/heads/calcite
Commit: 8b68b1c4e8a68ac70c058e9d568d98af95073fc9
Parents: 751d134
Author: maryannxue <ma...@gmail.com>
Authored: Fri Feb 12 13:59:54 2016 -0500
Committer: maryannxue <ma...@gmail.com>
Committed: Fri Feb 12 13:59:54 2016 -0500
----------------------------------------------------------------------
.../apache/phoenix/calcite/BaseCalciteIT.java | 102 ++++----
.../org/apache/phoenix/calcite/CalciteIT.java | 234 ++++++++++---------
.../apache/phoenix/calcite/CalciteIndexIT.java | 155 ++++++------
.../apache/phoenix/calcite/PhoenixTable.java | 68 +++++-
.../calcite/metadata/PhoenixRelMdSize.java | 75 ++++++
.../metadata/PhoenixRelMetadataProvider.java | 1 +
.../calcite/rel/PhoenixAbstractSort.java | 16 +-
.../calcite/rel/PhoenixCompactClientSort.java | 2 +-
.../apache/phoenix/calcite/rel/PhoenixRel.java | 7 +-
.../phoenix/calcite/rel/PhoenixServerJoin.java | 4 +-
.../calcite/rel/PhoenixServerSemiJoin.java | 4 +-
.../phoenix/calcite/rel/PhoenixTableScan.java | 86 +++++--
.../coprocessor/MetaDataEndpointImpl.java | 20 +-
.../phoenix/schema/stats/StatisticsUtil.java | 18 +-
.../phoenix/schema/stats/StatisticsWriter.java | 2 +-
15 files changed, 510 insertions(+), 284 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/8b68b1c4/phoenix-core/src/it/java/org/apache/phoenix/calcite/BaseCalciteIT.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/calcite/BaseCalciteIT.java b/phoenix-core/src/it/java/org/apache/phoenix/calcite/BaseCalciteIT.java
index 9afddab..35c46e7 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/calcite/BaseCalciteIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/calcite/BaseCalciteIT.java
@@ -32,6 +32,7 @@ import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
+import java.text.DecimalFormat;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
@@ -39,6 +40,7 @@ import java.util.Properties;
import org.apache.calcite.avatica.util.ArrayImpl;
import org.apache.calcite.config.CalciteConnectionProperty;
+import org.apache.phoenix.calcite.rel.PhoenixRel;
import org.apache.phoenix.end2end.BaseClientManagedTimeIT;
import org.apache.phoenix.query.QueryServices;
import org.apache.phoenix.schema.TableAlreadyExistsException;
@@ -59,8 +61,8 @@ public class BaseCalciteIT extends BaseClientManagedTimeIT {
setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
}
- public static Start start(boolean materializationEnabled) {
- return new Start(getConnectionProps(materializationEnabled));
+ public static Start start(boolean materializationEnabled, float rowCountFactor) {
+ return new Start(getConnectionProps(materializationEnabled, rowCountFactor));
}
public static Start start(Properties props) {
@@ -308,7 +310,7 @@ public class BaseCalciteIT extends BaseClientManagedTimeIT {
return connection;
}
- protected static Properties getConnectionProps(boolean enableMaterialization) {
+ protected static Properties getConnectionProps(boolean enableMaterialization, float rowCountFactor) {
Properties props = new Properties();
props.setProperty(
CalciteConnectionProperty.MATERIALIZATIONS_ENABLED.camelName(),
@@ -316,6 +318,7 @@ public class BaseCalciteIT extends BaseClientManagedTimeIT {
props.setProperty(
CalciteConnectionProperty.CREATE_MATERIALIZATIONS.camelName(),
Boolean.toString(false));
+ props.setProperty(PhoenixRel.ROW_COUNT_FACTOR, Float.toString(rowCountFactor));
return props;
}
@@ -364,21 +367,13 @@ public class BaseCalciteIT extends BaseClientManagedTimeIT {
PreparedStatement stmt = conn.prepareStatement(
"UPSERT INTO " + NOSALT_TABLE_NAME
+ " VALUES(?, ?, ?, ?)");
- stmt.setInt(1, 1);
- stmt.setInt(2, 2);
- stmt.setInt(3, 3);
- stmt.setInt(4, 4);
- stmt.execute();
- stmt.setInt(1, 2);
- stmt.setInt(2, 3);
- stmt.setInt(3, 4);
- stmt.setInt(4, 5);
- stmt.execute();
- stmt.setInt(1, 3);
- stmt.setInt(2, 4);
- stmt.setInt(3, 5);
- stmt.setInt(4, 6);
- stmt.execute();
+ for (int i = 0; i < 1000; i++) {
+ stmt.setInt(1, i + 1);
+ stmt.setInt(2, i + 2);
+ stmt.setInt(3, i + 3);
+ stmt.setInt(4, i + 4);
+ stmt.execute();
+ }
conn.commit();
if (index != null) {
@@ -391,21 +386,13 @@ public class BaseCalciteIT extends BaseClientManagedTimeIT {
stmt = conn.prepareStatement(
"UPSERT INTO " + SALTED_TABLE_NAME
+ " VALUES(?, ?, ?, ?)");
- stmt.setInt(1, 1);
- stmt.setInt(2, 2);
- stmt.setInt(3, 3);
- stmt.setInt(4, 4);
- stmt.execute();
- stmt.setInt(1, 2);
- stmt.setInt(2, 3);
- stmt.setInt(3, 4);
- stmt.setInt(4, 5);
- stmt.execute();
- stmt.setInt(1, 3);
- stmt.setInt(2, 4);
- stmt.setInt(3, 5);
- stmt.setInt(4, 6);
- stmt.execute();
+ for (int i = 0; i < 1000; i++) {
+ stmt.setInt(1, i + 1);
+ stmt.setInt(2, i + 2);
+ stmt.setInt(3, i + 3);
+ stmt.setInt(4, i + 4);
+ stmt.execute();
+ }
conn.commit();
if (index != null) {
@@ -434,30 +421,31 @@ public class BaseCalciteIT extends BaseClientManagedTimeIT {
PreparedStatement stmt = conn.prepareStatement(
"UPSERT INTO " + MULTI_TENANT_TABLE
+ " VALUES(?, ?, ?, ?, ?)");
- stmt.setString(1, "10");
- stmt.setString(2, "2");
- stmt.setInt(3, 3);
- stmt.setInt(4, 4);
- stmt.setInt(5, 5);
- stmt.execute();
- stmt.setString(1, "15");
- stmt.setString(2, "3");
- stmt.setInt(3, 4);
- stmt.setInt(4, 5);
- stmt.setInt(5, 6);
- stmt.execute();
- stmt.setString(1, "20");
- stmt.setString(2, "4");
- stmt.setInt(3, 5);
- stmt.setInt(4, 6);
- stmt.setInt(5, 7);
- stmt.execute();
- stmt.setString(1, "20");
- stmt.setString(2, "5");
- stmt.setInt(3, 6);
- stmt.setInt(4, 7);
- stmt.setInt(5, 8);
- stmt.execute();
+ DecimalFormat formatter = new DecimalFormat("0000");
+ for (int i = 0; i < 1000; i++) {
+ stmt.setString(1, "10");
+ stmt.setString(2, formatter.format(2 + i));
+ stmt.setInt(3, 3 + i);
+ stmt.setInt(4, 4 + i);
+ stmt.setInt(5, 5 + i);
+ stmt.execute();
+ }
+ for (int i = 0; i < 1000; i++) {
+ stmt.setString(1, "15");
+ stmt.setString(2, formatter.format(3 + i));
+ stmt.setInt(3, 4 + i);
+ stmt.setInt(4, 5 + i);
+ stmt.setInt(5, 6 + i);
+ stmt.execute();
+ }
+ for (int i = 0; i < 1000; i++) {
+ stmt.setString(1, "20");
+ stmt.setString(2, formatter.format(4 + i));
+ stmt.setInt(3, 5 + i);
+ stmt.setInt(4, 6 + i);
+ stmt.setInt(5, 7 + i);
+ stmt.execute();
+ }
conn.commit();
if (index != null) {
http://git-wip-us.apache.org/repos/asf/phoenix/blob/8b68b1c4/phoenix-core/src/it/java/org/apache/phoenix/calcite/CalciteIT.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/calcite/CalciteIT.java b/phoenix-core/src/it/java/org/apache/phoenix/calcite/CalciteIT.java
index 0d9e789..df6ac81 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/calcite/CalciteIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/calcite/CalciteIT.java
@@ -61,7 +61,7 @@ public class CalciteIT extends BaseCalciteIT {
private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@Test public void testTableScan() throws Exception {
- start(false).sql("select * from aTable where a_string = 'a'")
+ start(false, 1000f).sql("select * from aTable where a_string = 'a'")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], filter=[=($2, 'a')])\n")
.resultIs(false, new Object[][] {
@@ -72,12 +72,12 @@ public class CalciteIT extends BaseCalciteIT {
.close();
// FIXME: Should be 14:22:56 instead. Wrong due to time zone.
- start(false).sql("select \"DATE\" from " + JOIN_ORDER_TABLE_FULL_NAME + " where \"order_id\" = '000000000000001'")
+ start(false, 1000f).sql("select \"DATE\" from " + JOIN_ORDER_TABLE_FULL_NAME + " where \"order_id\" = '000000000000001'")
.resultIs(false, new Object[][]{
{new Timestamp(format.parse("2013-11-22 19:22:56").getTime())}})
.close();
- start(false).sql("select student_id, scores from " + SCORES_TABLE_NAME)
+ start(false, 1000f).sql("select student_id, scores from " + SCORES_TABLE_NAME)
.resultIs(false, new Object[][] {
{1, new Integer[] {85, 80, 82}},
{2, null},
@@ -86,7 +86,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testProject() throws Exception {
- start(false).sql("select entity_id, a_string, organization_id from aTable where a_string = 'a'")
+ start(false, 1000f).sql("select entity_id, a_string, organization_id from aTable where a_string = 'a'")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerProject(ENTITY_ID=[$1], A_STRING=[$2], ORGANIZATION_ID=[$0])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], filter=[=($2, 'a')])\n")
@@ -99,7 +99,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testJoin() throws Exception {
- start(false).sql("select t1.entity_id, t2.a_string, t1.organization_id from aTable t1 join aTable t2 on t1.entity_id = t2.entity_id and t1.organization_id = t2.organization_id where t1.a_string = 'a'")
+ start(false, 1000f).sql("select t1.entity_id, t2.a_string, t1.organization_id from aTable t1 join aTable t2 on t1.entity_id = t2.entity_id and t1.organization_id = t2.organization_id where t1.a_string = 'a'")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(ENTITY_ID=[$4], A_STRING=[$2], ORGANIZATION_ID=[$3])\n" +
" PhoenixServerJoin(condition=[AND(=($4, $1), =($3, $0))], joinType=[inner])\n" +
@@ -114,7 +114,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00A423122312312", "a", "00D300000000XHP"}})
.close();
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$0], NAME=[$1], supplier_id=[$3], NAME0=[$4])\n" +
" PhoenixServerJoin(condition=[=($2, $3)], joinType=[inner])\n" +
@@ -131,7 +131,7 @@ public class CalciteIT extends BaseCalciteIT {
{"0000000006", "T6", "0000000006", "S6"}})
.close();
- start(false).sql("SELECT * FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" AND supp.name = 'S5'")
+ start(false, 1000f).sql("SELECT * FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" AND supp.name = 'S5'")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$0], NAME=[$1], PRICE=[$2], DISCOUNT1=[$3], DISCOUNT2=[$4], supplier_id=[$5], DESCRIPTION=[$6], supplier_id0=[$7], NAME0=[$8], PHONE=[$9], ADDRESS=[$10], LOC_ID=[$11])\n" +
" PhoenixServerJoin(condition=[=($5, $7)], joinType=[inner])\n" +
@@ -142,7 +142,7 @@ public class CalciteIT extends BaseCalciteIT {
{"0000000005", "T5", 500, 8, 15, "0000000005", "Item T5", "0000000005", "S5", "888-888-5555", "505 YYY Street", "10005"}})
.close();
- start(false).sql("SELECT \"order_id\", i.name, i.price, discount2, quantity FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o INNER JOIN "
+ start(false, 1000f).sql("SELECT \"order_id\", i.name, i.price, discount2, quantity FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o INNER JOIN "
+ JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" AND o.price = (i.price * (100 - discount2)) / 100.0 WHERE quantity < 5000")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(order_id=[$5], NAME=[$1], PRICE=[$2], DISCOUNT2=[$3], QUANTITY=[$7])\n" +
@@ -157,7 +157,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testRightOuterJoin() throws Exception {
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item RIGHT OUTER JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item RIGHT OUTER JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$2], NAME=[$3], supplier_id=[$0], NAME0=[$1])\n" +
" PhoenixServerJoin(condition=[=($4, $0)], joinType=[left])\n" +
@@ -178,7 +178,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testClientJoin() throws Exception {
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item FULL OUTER JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by \"item_id\", supp.name")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item FULL OUTER JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by \"item_id\", supp.name")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientSort(sort0=[$0], sort1=[$3], dir0=[ASC], dir1=[ASC])\n" +
" PhoenixClientProject(item_id=[$0], NAME=[$1], supplier_id=[$3], NAME0=[$4])\n" +
@@ -200,7 +200,7 @@ public class CalciteIT extends BaseCalciteIT {
{null, null, "0000000004", "S4"}})
.close();
- start(false).sql("select t1.entity_id, t2.a_string, t1.organization_id from aTable t1 join aTable t2 on t1.organization_id = t2.organization_id and t1.entity_id = t2.entity_id")
+ start(false, 1000f).sql("select t1.entity_id, t2.a_string, t1.organization_id from aTable t1 join aTable t2 on t1.organization_id = t2.organization_id and t1.entity_id = t2.entity_id")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(ENTITY_ID=[$1], A_STRING=[$4], ORGANIZATION_ID=[$0])\n" +
" PhoenixClientJoin(condition=[AND(=($0, $2), =($1, $3))], joinType=[inner])\n" +
@@ -223,7 +223,7 @@ public class CalciteIT extends BaseCalciteIT {
@Test public void testJoinPlanningWithCollation() throws Exception {
// Server-join with LHS sorted on order-by fields
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by supp.\"supplier_id\"")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by supp.\"supplier_id\"")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$2], NAME=[$3], supplier_id=[$0], NAME0=[$1])\n" +
" PhoenixServerJoin(condition=[=($4, $0)], joinType=[inner])\n" +
@@ -234,7 +234,7 @@ public class CalciteIT extends BaseCalciteIT {
.close();
// Server-join with LHS reversely sorted on order-by fields
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by supp.\"supplier_id\" DESC")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by supp.\"supplier_id\" DESC")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$2], NAME=[$3], supplier_id=[$0], NAME0=[$1])\n" +
" PhoenixServerJoin(condition=[=($4, $0)], joinType=[inner])\n" +
@@ -245,7 +245,7 @@ public class CalciteIT extends BaseCalciteIT {
.close();
// Join key being order-by fields with the other side sorted on order-by fields
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by item.\"supplier_id\"")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by item.\"supplier_id\"")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$0], NAME=[$1], supplier_id=[$3], NAME0=[$4], supplier_id0=[$2])\n" +
" PhoenixClientJoin(condition=[=($2, $3)], joinType=[inner])\n" +
@@ -256,7 +256,7 @@ public class CalciteIT extends BaseCalciteIT {
" PhoenixTableScan(table=[[phoenix, Join, SupplierTable]], scanOrder=[FORWARD])\n")
.close();
- start(false).sql("SELECT \"order_id\", i.name, i.price, discount2, quantity FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ start(false, 1000f).sql("SELECT \"order_id\", i.name, i.price, discount2, quantity FROM " + JOIN_ORDER_TABLE_FULL_NAME + " o LEFT JOIN "
+ JOIN_ITEM_TABLE_FULL_NAME + " i ON o.\"item_id\" = i.\"item_id\" limit 2")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(order_id=[$0], NAME=[$4], PRICE=[$5], DISCOUNT2=[$6], QUANTITY=[$2])\n" +
@@ -272,18 +272,18 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testMultiJoin() throws Exception {
- start(false).sql("select t1.entity_id, t2.a_string, t3.organization_id from aTable t1 join aTable t2 on t1.entity_id = t2.entity_id and t1.organization_id = t2.organization_id join atable t3 on t1.entity_id = t3.entity_id and t1.organization_id = t3.organization_id where t1.a_string = 'a'")
+ start(false, 1000f).sql("select t1.entity_id, t2.a_string, t3.organization_id from aTable t1 join aTable t2 on t1.entity_id = t2.entity_id and t1.organization_id = t2.organization_id join atable t3 on t1.entity_id = t3.entity_id and t1.organization_id = t3.organization_id where t1.a_string = 'a' and t1.b_string > 'a' and t2.a_string = 'a'")
.explainIs("PhoenixToEnumerableConverter\n" +
- " PhoenixClientProject(ENTITY_ID=[$4], A_STRING=[$2], ORGANIZATION_ID=[$6])\n" +
- " PhoenixServerJoin(condition=[AND(=($4, $1), =($3, $0))], joinType=[inner])\n" +
- " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
+ " PhoenixClientProject(ENTITY_ID=[$3], A_STRING=[$8], ORGANIZATION_ID=[$0])\n" +
+ " PhoenixServerJoin(condition=[AND(=($3, $1), =($2, $0))], joinType=[inner])\n" +
+ " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]])\n" +
- " PhoenixClientProject(ORGANIZATION_ID=[$2], ENTITY_ID=[$3], A_STRING=[$4], ORGANIZATION_ID0=[$0], ENTITY_ID0=[$1])\n" +
- " PhoenixServerJoin(condition=[AND(=($3, $1), =($2, $0))], joinType=[inner])\n" +
- " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1])\n" +
- " PhoenixTableScan(table=[[phoenix, ATABLE]])\n" +
+ " PhoenixClientProject(ORGANIZATION_ID=[$3], ENTITY_ID=[$4], A_STRING=[$5], B_STRING=[$6], ORGANIZATION_ID0=[$0], ENTITY_ID0=[$1], A_STRING0=[$2])\n" +
+ " PhoenixServerJoin(condition=[AND(=($4, $1), =($3, $0))], joinType=[inner])\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
- " PhoenixTableScan(table=[[phoenix, ATABLE]], filter=[=($2, 'a')])\n")
+ " PhoenixTableScan(table=[[phoenix, ATABLE]], filter=[=($2, 'a')])\n" +
+ " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2], B_STRING=[$3])\n" +
+ " PhoenixTableScan(table=[[phoenix, ATABLE]], filter=[AND(=($2, 'a'), >($3, 'a'))])\n")
.resultIs(false, new Object[][] {
{"00A123122312312", "a", "00D300000000XHP"},
{"00A223122312312", "a", "00D300000000XHP"},
@@ -291,16 +291,19 @@ public class CalciteIT extends BaseCalciteIT {
{"00A423122312312", "a", "00D300000000XHP"}})
.close();
- start(false).sql("select t1.entity_id, t2.a_string, t3.organization_id from aTable t1 join aTable t2 on t1.entity_id = t2.entity_id and t1.organization_id = t2.organization_id join atable t3 on t1.entity_id = t3.entity_id and t1.organization_id = t3.organization_id")
+ start(false, 1000f).sql("select t1.entity_id, t2.a_string, t3.organization_id from aTable t1 join aTable t2 on t1.entity_id = t2.entity_id and t1.organization_id = t2.organization_id join atable t3 on t1.entity_id = t3.entity_id and t1.organization_id = t3.organization_id")
.explainIs("PhoenixToEnumerableConverter\n" +
- " PhoenixClientProject(ENTITY_ID=[$4], A_STRING=[$2], ORGANIZATION_ID=[$5])\n" +
- " PhoenixServerJoin(condition=[AND(=($4, $1), =($3, $0))], joinType=[inner])\n" +
- " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
- " PhoenixTableScan(table=[[phoenix, ATABLE]])\n" +
- " PhoenixServerJoin(condition=[AND(=($1, $3), =($0, $2))], joinType=[inner])\n" +
- " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1])\n" +
- " PhoenixTableScan(table=[[phoenix, ATABLE]])\n" +
- " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1])\n" +
+ " PhoenixClientProject(ENTITY_ID=[$1], A_STRING=[$6], ORGANIZATION_ID=[$2])\n" +
+ " PhoenixClientJoin(condition=[AND(=($1, $5), =($0, $4))], joinType=[inner])\n" +
+ " PhoenixClientJoin(condition=[AND(=($1, $3), =($0, $2))], joinType=[inner])\n" +
+ " PhoenixServerSort(sort0=[$1], sort1=[$0], dir0=[ASC], dir1=[ASC])\n" +
+ " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1])\n" +
+ " PhoenixTableScan(table=[[phoenix, ATABLE]])\n" +
+ " PhoenixServerSort(sort0=[$1], sort1=[$0], dir0=[ASC], dir1=[ASC])\n" +
+ " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1])\n" +
+ " PhoenixTableScan(table=[[phoenix, ATABLE]])\n" +
+ " PhoenixServerSort(sort0=[$1], sort1=[$0], dir0=[ASC], dir1=[ASC])\n" +
+ " PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]])\n")
.resultIs(false, new Object[][] {
{"00A123122312312", "a", "00D300000000XHP"},
@@ -316,7 +319,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testAggregate() throws Exception {
- start(false).sql("select count(b_string) from atable")
+ start(false, 1000f).sql("select count(b_string) from atable")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerAggregate(group=[{}], EXPR$0=[COUNT($3)])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]])\n")
@@ -324,7 +327,7 @@ public class CalciteIT extends BaseCalciteIT {
{9L}})
.close();
- start(false).sql("select organization_id, count(b_string) from atable group by organization_id")
+ start(false, 1000f).sql("select organization_id, count(b_string) from atable group by organization_id")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerAggregate(group=[{0}], EXPR$1=[COUNT($3)], isOrdered=[true])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], scanOrder=[FORWARD])\n")
@@ -332,7 +335,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", 9L}})
.close();
- start(false).sql("select organization_id, entity_id, count(b_string) from atable group by entity_id ,organization_id")
+ start(false, 1000f).sql("select organization_id, entity_id, count(b_string) from atable group by entity_id ,organization_id")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerAggregate(group=[{0, 1}], EXPR$2=[COUNT($3)], isOrdered=[true])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], scanOrder=[FORWARD])\n")
@@ -348,7 +351,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00C923122312312", 1L}})
.close();
- start(false).sql("select entity_id, count(b_string) from atable group by entity_id")
+ start(false, 1000f).sql("select entity_id, count(b_string) from atable group by entity_id")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerAggregate(group=[{1}], EXPR$1=[COUNT($3)], isOrdered=[false])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]])\n")
@@ -364,7 +367,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00C923122312312", 1L}})
.close();
- start(false).sql("select a_string, count(b_string) from atable group by a_string")
+ start(false, 1000f).sql("select a_string, count(b_string) from atable group by a_string")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerAggregate(group=[{2}], EXPR$1=[COUNT($3)], isOrdered=[false])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]])\n")
@@ -374,7 +377,7 @@ public class CalciteIT extends BaseCalciteIT {
{"c", 1L}})
.close();
- start(false).sql("select count(entity_id), a_string from atable group by a_string")
+ start(false, 1000f).sql("select count(entity_id), a_string from atable group by a_string")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(EXPR$0=[$1], A_STRING=[$0])\n" +
" PhoenixServerAggregate(group=[{2}], EXPR$0=[COUNT()], isOrdered=[false])\n" +
@@ -385,14 +388,14 @@ public class CalciteIT extends BaseCalciteIT {
{1L, "c"}})
.close();
- start(false).sql("select s.name, count(\"item_id\") from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.name")
+ start(false, 1000f).sql("select s.name, count(\"item_id\") from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.name")
.explainIs("PhoenixToEnumerableConverter\n" +
- " PhoenixServerAggregate(group=[{2}], EXPR$1=[COUNT()], isOrdered=[false])\n" +
- " PhoenixServerJoin(condition=[=($1, $0)], joinType=[inner])\n" +
- " PhoenixServerProject(supplier_id=[$5])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n" +
+ " PhoenixServerAggregate(group=[{1}], EXPR$1=[COUNT()], isOrdered=[false])\n" +
+ " PhoenixServerJoin(condition=[=($0, $2)], joinType=[inner])\n" +
" PhoenixServerProject(supplier_id=[$0], NAME=[$1])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, SupplierTable]])\n")
+ " PhoenixTableScan(table=[[phoenix, Join, SupplierTable]])\n" +
+ " PhoenixServerProject(supplier_id=[$5])\n" +
+ " PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n")
.resultIs(false, new Object[][] {
{"S1", 2L},
{"S2", 2L},
@@ -401,11 +404,11 @@ public class CalciteIT extends BaseCalciteIT {
.close();
// test PhoenixOrderedAggregateRule
- start(false).sql("select s.\"supplier_id\", count(*) from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.\"supplier_id\"")
+ start(false, 1000f).sql("select s.\"supplier_id\", count(s.name) from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.\"supplier_id\"")
.explainIs("PhoenixToEnumerableConverter\n" +
- " PhoenixServerAggregate(group=[{0}], EXPR$1=[COUNT()], isOrdered=[true])\n" +
- " PhoenixServerJoin(condition=[=($0, $1)], joinType=[inner])\n" +
- " PhoenixServerProject(supplier_id=[$0])\n" +
+ " PhoenixServerAggregate(group=[{0}], EXPR$1=[COUNT($1)], isOrdered=[true])\n" +
+ " PhoenixServerJoin(condition=[=($0, $2)], joinType=[inner])\n" +
+ " PhoenixServerProject(supplier_id=[$0], NAME=[$1])\n" +
" PhoenixTableScan(table=[[phoenix, Join, SupplierTable]], scanOrder=[FORWARD])\n" +
" PhoenixServerProject(supplier_id=[$5])\n" +
" PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n")
@@ -416,7 +419,7 @@ public class CalciteIT extends BaseCalciteIT {
{"0000000006", 1L}})
.close();
- start(false).sql("select a_string, sum(a_integer) from aTable group by a_string")
+ start(false, 1000f).sql("select a_string, sum(a_integer) from aTable group by a_string")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerAggregate(group=[{2}], EXPR$1=[SUM($4)], isOrdered=[false])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]])\n")
@@ -426,20 +429,22 @@ public class CalciteIT extends BaseCalciteIT {
{"c", 9L}})
.close();
- start(false).sql("select mypk0, avg(mypk1) from " + SALTED_TABLE_NAME + " group by mypk0")
+ Object[][] expectedResult = new Object[1000][2];
+ for (int i = 0; i < 1000; i++) {
+ expectedResult[i][0] = i + 1;
+ expectedResult[i][1] = i + 2;
+ }
+ start(false, 1000f).sql("select mypk0, avg(mypk1) from " + SALTED_TABLE_NAME + " group by mypk0")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(MYPK0=[$0], EXPR$1=[CAST(/($1, $2)):INTEGER NOT NULL])\n" +
" PhoenixServerAggregate(group=[{0}], agg#0=[$SUM0($1)], agg#1=[COUNT()], isOrdered=[true])\n" +
" PhoenixTableScan(table=[[phoenix, SALTED_TEST_TABLE]], scanOrder=[FORWARD])\n")
- .resultIs(false, new Object[][] {
- {1, 2},
- {2, 3},
- {3, 4}})
+ .resultIs(false, expectedResult)
.close();
}
@Test public void testDistinct() throws Exception {
- start(false).sql("select distinct a_string from aTable")
+ start(false, 1000f).sql("select distinct a_string from aTable")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerAggregate(group=[{2}], isOrdered=[false])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]])\n")
@@ -451,7 +456,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testSort() throws Exception {
- start(false).sql("select organization_id, entity_id, a_string from aTable order by a_string, entity_id")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by a_string, entity_id")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerSort(sort0=[$2], sort1=[$1], dir0=[ASC], dir1=[ASC])\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
@@ -468,7 +473,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00C923122312312", "c"}})
.close();
- start(false).sql("select organization_id, entity_id, a_string from aTable order by organization_id, entity_id")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by organization_id, entity_id")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], scanOrder=[FORWARD])\n")
@@ -484,7 +489,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00C923122312312", "c"}})
.close();
- start(false).sql("select organization_id, entity_id, a_string from aTable order by organization_id DESC")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by organization_id DESC")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], scanOrder=[REVERSE])\n")
@@ -500,7 +505,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00A123122312312", "a"}})
.close();
- start(false).sql("select organization_id, entity_id, a_string from aTable order by organization_id DESC, entity_id DESC")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by organization_id DESC, entity_id DESC")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], scanOrder=[REVERSE])\n")
@@ -516,7 +521,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00A123122312312", "a"}})
.close();
- start(false).sql("select organization_id, entity_id, a_string from aTable order by organization_id ASC, entity_id DESC")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by organization_id ASC, entity_id DESC")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerSort(sort0=[$0], sort1=[$1], dir0=[ASC], dir1=[DESC])\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
@@ -533,7 +538,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00A123122312312", "a"}})
.close();
- start(false).sql("select count(entity_id), a_string from atable group by a_string order by count(entity_id), a_string desc")
+ start(false, 1000f).sql("select count(entity_id), a_string from atable group by a_string order by count(entity_id), a_string desc")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(EXPR$0=[$1], A_STRING=[$0])\n" +
" PhoenixCompactClientSort(sort0=[$1], sort1=[$0], dir0=[ASC], dir1=[DESC])\n" +
@@ -545,15 +550,15 @@ public class CalciteIT extends BaseCalciteIT {
{4L, "a"}})
.close();
- start(false).sql("select s.name, count(\"item_id\") from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.name order by count(\"item_id\"), s.name desc")
+ start(false, 1000f).sql("select s.name, count(\"item_id\") from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.name order by count(\"item_id\"), s.name desc")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixCompactClientSort(sort0=[$1], sort1=[$0], dir0=[ASC], dir1=[DESC])\n" +
- " PhoenixServerAggregate(group=[{2}], EXPR$1=[COUNT()], isOrdered=[false])\n" +
- " PhoenixServerJoin(condition=[=($1, $0)], joinType=[inner])\n" +
- " PhoenixServerProject(supplier_id=[$5])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n" +
+ " PhoenixServerAggregate(group=[{1}], EXPR$1=[COUNT()], isOrdered=[false])\n" +
+ " PhoenixServerJoin(condition=[=($0, $2)], joinType=[inner])\n" +
" PhoenixServerProject(supplier_id=[$0], NAME=[$1])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, SupplierTable]])\n")
+ " PhoenixTableScan(table=[[phoenix, Join, SupplierTable]])\n" +
+ " PhoenixServerProject(supplier_id=[$5])\n" +
+ " PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n")
.resultIs(true, new Object[][] {
{"S6", 1L},
{"S5", 1L},
@@ -561,7 +566,7 @@ public class CalciteIT extends BaseCalciteIT {
{"S1", 2L}})
.close();
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by item.name desc")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by item.name desc")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$0], NAME=[$1], supplier_id=[$3], NAME0=[$4])\n" +
" PhoenixServerSort(sort0=[$1], dir0=[DESC])\n" +
@@ -581,7 +586,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testSortWithLimit() throws Exception {
- start(false).sql("select organization_id, entity_id, a_string from aTable order by a_string, entity_id limit 5")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by a_string, entity_id limit 5")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[5])\n" +
" PhoenixServerSort(sort0=[$2], sort1=[$1], dir0=[ASC], dir1=[ASC])\n" +
@@ -595,7 +600,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00B523122312312", "b"}})
.close();
- start(false).sql("select organization_id, entity_id, a_string from aTable order by organization_id, entity_id limit 5")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by organization_id, entity_id limit 5")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[5])\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
@@ -608,7 +613,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00B523122312312", "b"}})
.close();
- start(false).sql("select organization_id, entity_id, a_string from aTable order by organization_id DESC limit 5")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by organization_id DESC limit 5")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[5])\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
@@ -621,7 +626,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00B523122312312", "b"}})
.close();
- start(false).sql("select organization_id, entity_id, a_string from aTable order by organization_id DESC, entity_id DESC limit 5")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by organization_id DESC, entity_id DESC limit 5")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[5])\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
@@ -634,7 +639,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00B523122312312", "b"}})
.close();
- start(false).sql("select organization_id, entity_id, a_string from aTable order by organization_id ASC, entity_id DESC limit 5")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable order by organization_id ASC, entity_id DESC limit 5")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[5])\n" +
" PhoenixServerSort(sort0=[$0], sort1=[$1], dir0=[ASC], dir1=[DESC])\n" +
@@ -648,7 +653,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00B523122312312", "b"}})
.close();
- start(false).sql("select count(entity_id), a_string from atable group by a_string order by count(entity_id), a_string desc limit 2")
+ start(false, 1000f).sql("select count(entity_id), a_string from atable group by a_string order by count(entity_id), a_string desc limit 2")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(EXPR$0=[$1], A_STRING=[$0])\n" +
" PhoenixLimit(fetch=[2])\n" +
@@ -660,23 +665,23 @@ public class CalciteIT extends BaseCalciteIT {
{4L, "b"}})
.close();
- start(false).sql("select s.name, count(\"item_id\") from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.name order by count(\"item_id\"), s.name desc limit 3")
+ start(false, 1000f).sql("select s.name, count(\"item_id\") from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.name order by count(\"item_id\"), s.name desc limit 3")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[3])\n" +
" PhoenixCompactClientSort(sort0=[$1], sort1=[$0], dir0=[ASC], dir1=[DESC])\n" +
- " PhoenixServerAggregate(group=[{2}], EXPR$1=[COUNT()], isOrdered=[false])\n" +
- " PhoenixServerJoin(condition=[=($1, $0)], joinType=[inner])\n" +
- " PhoenixServerProject(supplier_id=[$5])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n" +
+ " PhoenixServerAggregate(group=[{1}], EXPR$1=[COUNT()], isOrdered=[false])\n" +
+ " PhoenixServerJoin(condition=[=($0, $2)], joinType=[inner])\n" +
" PhoenixServerProject(supplier_id=[$0], NAME=[$1])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, SupplierTable]])\n")
+ " PhoenixTableScan(table=[[phoenix, Join, SupplierTable]])\n" +
+ " PhoenixServerProject(supplier_id=[$5])\n" +
+ " PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n")
.resultIs(true, new Object[][] {
{"S6", 1L},
{"S5", 1L},
{"S2", 2L}})
.close();
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by item.name desc limit 3")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" order by item.name desc limit 3")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$0], NAME=[$1], supplier_id=[$3], NAME0=[$4])\n" +
" PhoenixLimit(fetch=[3])\n" +
@@ -694,7 +699,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testLimit() throws Exception {
- start(false).sql("select organization_id, entity_id, a_string from aTable limit 5")
+ start(false, 1000f).sql("select organization_id, entity_id, a_string from aTable limit 5")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[5])\n" +
" PhoenixServerProject(ORGANIZATION_ID=[$0], ENTITY_ID=[$1], A_STRING=[$2])\n" +
@@ -707,7 +712,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00D300000000XHP", "00B523122312312", "b"}})
.close();
- start(false).sql("select count(entity_id), a_string from atable group by a_string limit 2")
+ start(false, 1000f).sql("select count(entity_id), a_string from atable group by a_string limit 2")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(EXPR$0=[$1], A_STRING=[$0])\n" +
" PhoenixLimit(fetch=[2])\n" +
@@ -718,22 +723,22 @@ public class CalciteIT extends BaseCalciteIT {
{4L, "b"}})
.close();
- start(false).sql("select s.name, count(\"item_id\") from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.name limit 3")
+ start(false, 1000f).sql("select s.name, count(\"item_id\") from " + JOIN_SUPPLIER_TABLE_FULL_NAME + " s join " + JOIN_ITEM_TABLE_FULL_NAME + " i on s.\"supplier_id\" = i.\"supplier_id\" group by s.name limit 3")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[3])\n" +
- " PhoenixServerAggregate(group=[{2}], EXPR$1=[COUNT()], isOrdered=[false])\n" +
- " PhoenixServerJoin(condition=[=($1, $0)], joinType=[inner])\n" +
- " PhoenixServerProject(supplier_id=[$5])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n" +
+ " PhoenixServerAggregate(group=[{1}], EXPR$1=[COUNT()], isOrdered=[false])\n" +
+ " PhoenixServerJoin(condition=[=($0, $2)], joinType=[inner])\n" +
" PhoenixServerProject(supplier_id=[$0], NAME=[$1])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, SupplierTable]])\n")
+ " PhoenixTableScan(table=[[phoenix, Join, SupplierTable]])\n" +
+ " PhoenixServerProject(supplier_id=[$5])\n" +
+ " PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n")
.resultIs(false, new Object[][] {
{"S1", 2L},
{"S2", 2L},
{"S5", 1L}})
.close();
- start(false).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" limit 3")
+ start(false, 1000f).sql("SELECT item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\" limit 3")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(item_id=[$0], NAME=[$1], supplier_id=[$3], NAME0=[$4])\n" +
" PhoenixLimit(fetch=[3])\n" +
@@ -748,7 +753,7 @@ public class CalciteIT extends BaseCalciteIT {
{"0000000003", "T3", "0000000002", "S2"}})
.close();
- start(false).sql("SELECT x from (values (1, 2), (2, 4), (3, 6)) as t(x, y) limit 2")
+ start(false, 1000f).sql("SELECT x from (values (1, 2), (2, 4), (3, 6)) as t(x, y) limit 2")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(X=[$0])\n" +
" PhoenixLimit(fetch=[2])\n" +
@@ -759,7 +764,7 @@ public class CalciteIT extends BaseCalciteIT {
@Ignore // CALCITE-1045
@Test public void testScalarSubquery() throws Exception {
- start(false).sql("select \"item_id\", name, (select max(quantity) sq \n"
+ start(false, 1000f).sql("select \"item_id\", name, (select max(quantity) sq \n"
+ "from " + JOIN_ORDER_TABLE_FULL_NAME + " o where o.\"item_id\" = i.\"item_id\")\n"
+ "from " + JOIN_ITEM_TABLE_FULL_NAME + " i")
.explainIs("PhoenixToEnumerableConverter\n" +
@@ -781,7 +786,7 @@ public class CalciteIT extends BaseCalciteIT {
new Object[] {"invalid001", "INVALID-1", null}})
.close();
- start(false).sql("select \"item_id\", name, (select quantity sq \n"
+ start(false, 1000f).sql("select \"item_id\", name, (select quantity sq \n"
+ "from " + JOIN_ORDER_TABLE_FULL_NAME + " o where o.\"item_id\" = i.\"item_id\")\n"
+ "from " + JOIN_ITEM_TABLE_FULL_NAME + " i where \"item_id\" < '0000000006'")
.explainIs("PhoenixToEnumerableConverter\n" +
@@ -803,12 +808,12 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testValues() throws Exception {
- start(false).sql("select p0+p1 from (values (2, 1)) as t(p0, p1)")
+ start(false, 1000f).sql("select p0+p1 from (values (2, 1)) as t(p0, p1)")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(EXPR$0=[+($0, $1)])\n" +
" PhoenixValues(tuples=[[{ 2, 1 }]])\n")
.close();
- start(false).sql("select count(p0), max(p1) from (values (2, 1), (3, 4), (5, 2)) as t(p0, p1)")
+ start(false, 1000f).sql("select count(p0), max(p1) from (values (2, 1), (3, 4), (5, 2)) as t(p0, p1)")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientAggregate(group=[{}], EXPR$0=[COUNT()], EXPR$1=[MAX($1)])\n" +
" PhoenixValues(tuples=[[{ 2, 1 }, { 3, 4 }, { 5, 2 }]])\n")
@@ -817,7 +822,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testUnion() throws Exception {
- start(false).sql("select entity_id from atable where a_string = 'a' union all select entity_id from atable where a_string = 'b'")
+ start(false, 1000f).sql("select entity_id from atable where a_string = 'a' union all select entity_id from atable where a_string = 'b'")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixUnion(all=[true])\n" +
" PhoenixServerProject(ENTITY_ID=[$1])\n" +
@@ -835,7 +840,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00B823122312312"}})
.close();
- start(false).sql("select entity_id, a_string from atable where a_string = 'a' union all select entity_id, a_string from atable where a_string = 'c' order by entity_id desc limit 3")
+ start(false, 1000f).sql("select entity_id, a_string from atable where a_string = 'a' union all select entity_id, a_string from atable where a_string = 'c' order by entity_id desc limit 3")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixLimit(fetch=[3])\n" +
" PhoenixMergeSortUnion(all=[true])\n" +
@@ -853,7 +858,7 @@ public class CalciteIT extends BaseCalciteIT {
{"00A323122312312", "a"}})
.close();
- start(false).sql("select entity_id, a_string from atable where a_string = 'a' union all select entity_id, a_string from atable where a_string = 'c' order by entity_id desc")
+ start(false, 1000f).sql("select entity_id, a_string from atable where a_string = 'a' union all select entity_id, a_string from atable where a_string = 'c' order by entity_id desc")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixMergeSortUnion(all=[true])\n" +
" PhoenixServerSort(sort0=[$0], dir0=[DESC])\n" +
@@ -872,7 +877,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testUnnest() throws Exception {
- start(false).sql("SELECT t.s FROM UNNEST((SELECT scores FROM " + SCORES_TABLE_NAME + ")) AS t(s)")
+ start(false, 1000f).sql("SELECT t.s FROM UNNEST((SELECT scores FROM " + SCORES_TABLE_NAME + ")) AS t(s)")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixUncollect\n" +
" PhoenixServerProject(EXPR$0=[$2])\n" +
@@ -885,7 +890,7 @@ public class CalciteIT extends BaseCalciteIT {
{88},
{80}})
.close();
- start(false).sql("SELECT s.student_id, t.score FROM " + SCORES_TABLE_NAME + " s, UNNEST((SELECT scores FROM " + SCORES_TABLE_NAME + " s2 where s.student_id = s2.student_id)) AS t(score)")
+ start(false, 1000f).sql("SELECT s.student_id, t.score FROM " + SCORES_TABLE_NAME + " s, UNNEST((SELECT scores FROM " + SCORES_TABLE_NAME + " s2 where s.student_id = s2.student_id)) AS t(score)")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(STUDENT_ID=[$0], SCORE=[$3])\n" +
" PhoenixCorrelate(correlation=[$cor0], joinType=[INNER], requiredColumns=[{0}])\n" +
@@ -904,9 +909,9 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testCorrelateAndDecorrelation() throws Exception {
- Properties correlProps = getConnectionProps(false);
+ Properties correlProps = getConnectionProps(false, 1000f);
correlProps.setProperty("forceDecorrelate", Boolean.FALSE.toString());
- Properties decorrelProps = getConnectionProps(false);
+ Properties decorrelProps = getConnectionProps(false, 1000f);
decorrelProps.setProperty("forceDecorrelate", Boolean.TRUE.toString());
String q1 = "select \"order_id\", quantity from " + JOIN_ORDER_TABLE_FULL_NAME + " o where quantity = (select max(quantity) from " + JOIN_ORDER_TABLE_FULL_NAME + " o2 where o.\"item_id\" = o2.\"item_id\")";
@@ -1008,10 +1013,11 @@ public class CalciteIT extends BaseCalciteIT {
{"0000000006", "T6"}};
String p4Decorrelated =
"PhoenixToEnumerableConverter\n" +
- " PhoenixServerSemiJoin(condition=[=($0, $4)], joinType=[inner])\n" +
+ " PhoenixServerSemiJoin(condition=[=($0, $2)], joinType=[inner])\n" +
" PhoenixServerProject(item_id=[$0], NAME=[$1])\n" +
" PhoenixTableScan(table=[[phoenix, Join, ItemTable]])\n" +
- " PhoenixTableScan(table=[[phoenix, Join, OrderTable]])\n";
+ " PhoenixServerProject(item_id=[$2])\n" +
+ " PhoenixTableScan(table=[[phoenix, Join, OrderTable]])\n";
start(decorrelProps).sql(q4).explainIs(p4Decorrelated).resultIs(false, r4).close();
String q5 = "select \"order_id\" from " + JOIN_ITEM_TABLE_FULL_NAME + " i JOIN " + JOIN_ORDER_TABLE_FULL_NAME + " o on o.\"item_id\" = i.\"item_id\" where quantity = (select max(quantity) from " + JOIN_ORDER_TABLE_FULL_NAME + " o2 JOIN " + JOIN_ITEM_TABLE_FULL_NAME + " i2 on o2.\"item_id\" = i2.\"item_id\" where i.\"supplier_id\" = i2.\"supplier_id\")";
@@ -1091,7 +1097,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testInValueList() throws Exception {
- start(false).sql("select entity_id from aTable where organization_id = '00D300000000XHP' and entity_id in ('00A123122312312', '00A223122312312', '00B523122312312', '00B623122312312', '00C923122312312')")
+ start(false, 1000f).sql("select entity_id from aTable where organization_id = '00D300000000XHP' and entity_id in ('00A123122312312', '00A223122312312', '00B523122312312', '00B623122312312', '00C923122312312')")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixServerProject(ENTITY_ID=[$1])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], filter=[AND(=($0, '00D300000000XHP'), OR(=($1, '00A123122312312'), =($1, '00A223122312312'), =($1, '00B523122312312'), =($1, '00B623122312312'), =($1, '00C923122312312')))])\n")
@@ -1105,7 +1111,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testSelectFromView() throws Exception {
- start(false).sql("select * from v")
+ start(false, 1000f).sql("select * from v")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], filter=[=($2, 'a')])\n")
.resultIs(false, new Object[][] {
@@ -1117,7 +1123,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testSequence() throws Exception {
- start(false).sql("select NEXT VALUE FOR seq0, c0 from (values (1), (1)) as t(c0)")
+ start(false, 1000f).sql("select NEXT VALUE FOR seq0, c0 from (values (1), (1)) as t(c0)")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(EXPR$0=[NEXT_VALUE('\"SEQ0\"')], C0=[$0])\n" +
" PhoenixValues(tuples=[[{ 1 }, { 1 }]])\n")
@@ -1126,7 +1132,7 @@ public class CalciteIT extends BaseCalciteIT {
{2L, 1}})
.close();
- start(false).sql("select NEXT VALUE FOR my.seq1, entity_id from aTable where a_string = 'a'")
+ start(false, 1000f).sql("select NEXT VALUE FOR my.seq1, entity_id from aTable where a_string = 'a'")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(EXPR$0=[NEXT_VALUE('\"MY\".\"SEQ1\"')], ENTITY_ID=[$1])\n" +
" PhoenixTableScan(table=[[phoenix, ATABLE]], filter=[=($2, 'a')])\n")
@@ -1137,7 +1143,7 @@ public class CalciteIT extends BaseCalciteIT {
{8L, "00A423122312312"}})
.close();
- start(false).sql("SELECT NEXT VALUE FOR seq0, item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"")
+ start(false, 1000f).sql("SELECT NEXT VALUE FOR seq0, item.\"item_id\", item.name, supp.\"supplier_id\", supp.name FROM " + JOIN_ITEM_TABLE_FULL_NAME + " item JOIN " + JOIN_SUPPLIER_TABLE_FULL_NAME + " supp ON item.\"supplier_id\" = supp.\"supplier_id\"")
.explainIs("PhoenixToEnumerableConverter\n" +
" PhoenixClientProject(EXPR$0=[NEXT_VALUE('\"SEQ0\"')], item_id=[$0], NAME=[$1], supplier_id=[$3], NAME0=[$4])\n" +
" PhoenixServerJoin(condition=[=($2, $3)], joinType=[inner])\n" +
@@ -1159,16 +1165,16 @@ public class CalciteIT extends BaseCalciteIT {
* @throws Exception */
@Ignore
@Test public void testCommit() throws Exception {
- start(false).sql("commit").execute();
+ start(false, 1000f).sql("commit").execute();
}
@Test public void testCreateView() throws Exception {
- start(false).sql("create view v as select * from (values (1, 'a'), (2, 'b')) as t(x, y)").execute();
+ start(false, 1000f).sql("create view v as select * from (values (1, 'a'), (2, 'b')) as t(x, y)").execute();
}
@Ignore // CALCITE-1045
@Test public void testConnectJoinHsqldb() throws Exception {
- final Start start = new Start(getConnectionProps(false)) {
+ final Start start = new Start(getConnectionProps(false, 1000f)) {
@Override
Connection createConnection() throws Exception {
return connectWithHsqldbUsingModel(props);
@@ -1200,7 +1206,7 @@ public class CalciteIT extends BaseCalciteIT {
}
@Test public void testConnectUsingModel() throws Exception {
- final Start start = new Start(getConnectionProps(false)) {
+ final Start start = new Start(getConnectionProps(false, 1000f)) {
@Override
Connection createConnection() throws Exception {
return connectUsingModel(props);