Skip to content

Commit 58df37d

Browse files
committed
Add index join related nodes to plan matcher
1 parent d6a136c commit 58df37d

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

presto-main-base/src/test/java/com/facebook/presto/sql/planner/assertions/PlanMatchPattern.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@
6161
import com.facebook.presto.sql.planner.plan.EnforceSingleRowNode;
6262
import com.facebook.presto.sql.planner.plan.ExchangeNode;
6363
import com.facebook.presto.sql.planner.plan.GroupIdNode;
64+
import com.facebook.presto.sql.planner.plan.IndexJoinNode;
6465
import com.facebook.presto.sql.planner.plan.LateralJoinNode;
6566
import com.facebook.presto.sql.planner.plan.OffsetNode;
6667
import com.facebook.presto.sql.planner.plan.RemoteSourceNode;
@@ -180,6 +181,12 @@ public static PlanMatchPattern constrainedTableScanWithTableLayout(String expect
180181
return result.addColumnReferences(expectedTableName, columnReferences);
181182
}
182183

184+
public static PlanMatchPattern indexSource(String expectedTableName)
185+
{
186+
return node(IndexSourceNode.class)
187+
.with(new IndexSourceMatcher(expectedTableName));
188+
}
189+
183190
public static PlanMatchPattern constrainedIndexSource(String expectedTableName, Map<String, Domain> constraint, Map<String, String> columnReferences)
184191
{
185192
return node(IndexSourceNode.class)
@@ -449,6 +456,11 @@ public static PlanMatchPattern join(
449456
.with(joinMatcher);
450457
}
451458

459+
public static PlanMatchPattern indexJoin(PlanMatchPattern left, PlanMatchPattern right)
460+
{
461+
return node(IndexJoinNode.class, left, right);
462+
}
463+
452464
public static PlanMatchPattern cteConsumer(String cteName)
453465
{
454466
CteConsumerMatcher cteConsumerMatcher = new CteConsumerMatcher(cteName);

0 commit comments

Comments
 (0)