From 658ce36185f10245b59aa05d1d93777021e94a59 Mon Sep 17 00:00:00 2001 From: Anukalp Date: Tue, 26 May 2026 22:59:26 +0530 Subject: [PATCH] Replace lambda expression with method reference --- .../relational/planner/iterative/rule/PruneFillColumns.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PruneFillColumns.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PruneFillColumns.java index d93953c695bd..d01eaf9068ed 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PruneFillColumns.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PruneFillColumns.java @@ -49,11 +49,11 @@ protected Optional pushDownProjectOff( if (fillNode instanceof PreviousFillNode) { PreviousFillNode previousFillNode = (PreviousFillNode) fillNode; previousFillNode.getHelperColumn().ifPresent(referencedInputs::add); - previousFillNode.getGroupingKeys().ifPresent(keys -> referencedInputs.addAll(keys)); + previousFillNode.getGroupingKeys().ifPresent(referencedInputs::addAll); } else if (fillNode instanceof LinearFillNode) { LinearFillNode linearFillNode = (LinearFillNode) fillNode; referencedInputs.add(linearFillNode.getHelperColumn()); - linearFillNode.getGroupingKeys().ifPresent(keys -> referencedInputs.addAll(keys)); + linearFillNode.getGroupingKeys().ifPresent(referencedInputs::addAll); } return restrictChildOutputs(context.getIdAllocator(), fillNode, referencedInputs.build()); }