Inline tableFinishInfoSupplier

trinodb · Nov 28, 2024 · abdc4eb · abdc4eb
1 parent a5778d2
commit abdc4eb
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/core/trino-main/src/main/java/io/trino/operator/TableFinishOperator.java b/core/trino-main/src/main/java/io/trino/operator/TableFinishOperator.java
@@ -133,8 +133,6 @@ private enum State
     private final TableExecuteContext tableExecuteContext;
     private final boolean outputRowCount;
 
-    private final Supplier<TableFinishInfo> tableFinishInfoSupplier;
-
     public TableFinishOperator(
             OperatorContext operatorContext,
             TableFinisher tableFinisher,
@@ -150,9 +148,8 @@ public TableFinishOperator(
         this.descriptor = requireNonNull(descriptor, "descriptor is null");
         this.statisticsCpuTimerEnabled = statisticsCpuTimerEnabled;
         this.tableExecuteContext = requireNonNull(tableExecuteContext, "tableExecuteContext is null");
-        this.tableFinishInfoSupplier = createTableFinishInfoSupplier(outputMetadata, statisticsTiming);
         this.outputRowCount = outputRowCount;
-        operatorContext.setInfoSupplier(tableFinishInfoSupplier);
+        operatorContext.setInfoSupplier(createTableFinishInfoSupplier(outputMetadata, statisticsTiming));
     }
 
     @Override