From 94dd98db86d730102452f66577e9ec47f556b8ab Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Osipiuk?= Date: Fri, 13 Sep 2024 12:21:11 +0200 Subject: [PATCH] Rename rewriter --- .../src/main/java/io/trino/sql/planner/AdaptivePlanner.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/trino-main/src/main/java/io/trino/sql/planner/AdaptivePlanner.java b/core/trino-main/src/main/java/io/trino/sql/planner/AdaptivePlanner.java index aff02c6d17d3..ff1ec4ddf0a7 100644 --- a/core/trino-main/src/main/java/io/trino/sql/planner/AdaptivePlanner.java +++ b/core/trino-main/src/main/java/io/trino/sql/planner/AdaptivePlanner.java @@ -129,7 +129,7 @@ public SubPlan optimize(SubPlan root, RuntimeInfoProvider runtimeInfoProvider) // rewrite remote source nodes to exchange nodes, except for fragments which are finisher or whose stats are // estimated by progress. - ReplaceUnchangedFragmentsWithRemoteSourcesRewriter rewriter = new ReplaceUnchangedFragmentsWithRemoteSourcesRewriter(runtimeInfoProvider); + ReplaceRemoteSourcesWithExchanges rewriter = new ReplaceRemoteSourcesWithExchanges(runtimeInfoProvider); PlanNode currentAdaptivePlan = rewriteWith(rewriter, root.getFragment().getRoot(), root.getChildren()); // Remove the adaptive plan node and replace it with initial plan @@ -306,12 +306,12 @@ private Stream traverse(SubPlan subPlan) return StreamSupport.stream(iterable.spliterator(), false); } - private static class ReplaceUnchangedFragmentsWithRemoteSourcesRewriter + private static class ReplaceRemoteSourcesWithExchanges extends SimplePlanRewriter> { private final RuntimeInfoProvider runtimeInfoProvider; - private ReplaceUnchangedFragmentsWithRemoteSourcesRewriter(RuntimeInfoProvider runtimeInfoProvider) + private ReplaceRemoteSourcesWithExchanges(RuntimeInfoProvider runtimeInfoProvider) { this.runtimeInfoProvider = requireNonNull(runtimeInfoProvider, "runtimeInfoProvider is null"); }