diff --git a/core/src/main/java/org/opensearch/sql/storage/write/TableWriteOperator.java b/core/src/main/java/org/opensearch/sql/storage/write/TableWriteOperator.java
index 007b725677..92cdc6eb41 100644
--- a/core/src/main/java/org/opensearch/sql/storage/write/TableWriteOperator.java
+++ b/core/src/main/java/org/opensearch/sql/storage/write/TableWriteOperator.java
@@ -19,8 +19,8 @@
 @RequiredArgsConstructor
 public abstract class TableWriteOperator extends PhysicalPlan {
 
-  /** Child physical node. */
-  private final PhysicalPlan child;
+  /** Input physical node. */
+  protected final PhysicalPlan input;
 
   @Override
   public <R, C> R accept(PhysicalPlanNodeVisitor<R, C> visitor, C context) {
@@ -29,7 +29,7 @@ public <R, C> R accept(PhysicalPlanNodeVisitor<R, C> visitor, C context) {
 
   @Override
   public List<PhysicalPlan> getChild() {
-    return Collections.singletonList(child);
+    return Collections.singletonList(input);
   }
 
   /**