Repository: samza Updated Branches: refs/heads/master 5a31be92e -> 1c2d6effb
Print the logical plan during query planning Minor fix to print the logical plan. Author: Srinivasulu Punuru <[email protected]> Reviewers: Aditya Toomula <[email protected]> Closes #763 from srinipunuru/print.1 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1c2d6eff Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/1c2d6eff Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/1c2d6eff Branch: refs/heads/master Commit: 1c2d6effba097202e4ab9bddf9dc060683f0110c Parents: 5a31be9 Author: Srinivasulu Punuru <[email protected]> Authored: Thu Oct 25 14:32:38 2018 -0700 Committer: Srinivasulu Punuru <[email protected]> Committed: Thu Oct 25 14:32:38 2018 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/samza/sql/planner/QueryPlanner.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/1c2d6eff/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java ---------------------------------------------------------------------- diff --git a/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java b/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java index 7b0dd51..f36d990 100644 --- a/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java +++ b/samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java @@ -30,6 +30,7 @@ import org.apache.calcite.config.Lex; import org.apache.calcite.jdbc.CalciteConnection; import org.apache.calcite.plan.Contexts; import org.apache.calcite.plan.ConventionTraitDef; +import org.apache.calcite.plan.RelOptUtil; import org.apache.calcite.plan.RelTraitDef; import org.apache.calcite.rel.RelCollationTraitDef; import org.apache.calcite.rel.RelNode; @@ -136,7 +137,7 @@ public class QueryPlanner { SqlNode sql = planner.parse(query); SqlNode validatedSql = planner.validate(sql); RelRoot relRoot = planner.rel(validatedSql); - LOG.info("query plan:\n" + sql.toString()); + LOG.info("query plan:\n" + RelOptUtil.toString(relRoot.rel)); return relRoot; } catch (Exception e) { LOG.error("Query planner failed with exception.", e);
