Skip to content

Commit 1bbac14

Browse files
committed
fix yaml test
Signed-off-by: Lantao Jin <ltjin@amazon.com>
1 parent 8b3e8d2 commit 1bbac14

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

opensearch/src/main/java/org/opensearch/sql/opensearch/planner/rules/DedupPushdownRule.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,14 @@ protected void apply(
8888
.toList();
8989
List<String> dedupColumnNames =
9090
dedupColumnIndicesInWindowProject.stream()
91-
.map(i -> projectWithWindow.getInput().getRowType().getFieldNames().get(i))
91+
.map(
92+
i ->
93+
projectWithWindow.getNamedProjects().stream()
94+
.filter(pair -> pair.getKey().isA(SqlKind.INPUT_REF))
95+
.filter(pair -> ((RexInputRef) pair.getKey()).getIndex() == i)
96+
.map(Pair::getValue)
97+
.findFirst()
98+
.get())
9299
.toList();
93100

94101
// must be row_number <= number

0 commit comments

Comments
 (0)