Add JSON to WriterTarget

tanjialiang · tanjialiang · commit 3c0ca5e615e9 · 2025-10-29T14:50:52.000-07:00
diff --git a/presto-spi/pom.xml b/presto-spi/pom.xml
@@ -146,5 +146,11 @@
             <artifactId>commons-math3</artifactId>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>javax.inject</groupId>
+            <artifactId>javax.inject</artifactId>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 </project>
diff --git a/presto-spi/src/main/java/com/facebook/presto/spi/ColumnMetadata.java b/presto-spi/src/main/java/com/facebook/presto/spi/ColumnMetadata.java
@@ -89,6 +89,7 @@ public Map<String, Object> getProperties()
     {
         return properties;
     }
+
     public Builder toBuilder()
     {
         return ColumnMetadata.builder()
diff --git a/presto-spi/src/main/java/com/facebook/presto/spi/plan/TableWriterNode.java b/presto-spi/src/main/java/com/facebook/presto/spi/plan/TableWriterNode.java
@@ -25,6 +25,8 @@
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSubTypes;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
 import com.google.errorprone.annotations.Immutable;
 
 import java.util.ArrayList;
@@ -144,7 +146,7 @@ public PlanNode getSource()
         return source;
     }
 
-    @JsonIgnore
+    @JsonProperty
     public Optional<WriterTarget> getTarget()
     {
         return target;
@@ -276,6 +278,14 @@ public boolean isSingleWriterPerPartitionRequired()
 
     // only used during planning -- will not be serialized
     @SuppressWarnings({"EmptyClass", "ClassMayBeInterface"})
+    @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "@type")
+    @JsonSubTypes({
+            @JsonSubTypes.Type(value = CreateName.class, name = "createName"),
+            @JsonSubTypes.Type(value = InsertReference.class, name = "insertReference"),
+            @JsonSubTypes.Type(value = DeleteHandle.class, name = "deleteHandle"),
+            @JsonSubTypes.Type(value = RefreshMaterializedViewReference.class, name = "refreshMaterializedView"),
+            @JsonSubTypes.Type(value = UpdateTarget.class, name = "updateTarget")
+    })
     public abstract static class WriterTarget
     {
         public abstract ConnectorId getConnectorId();
@@ -296,7 +306,11 @@ public static class CreateName
         private final Optional<NewTableLayout> layout;
         private final Optional<List<OutputColumnMetadata>> columns;
 
-        public CreateName(ConnectorId connectorId, ConnectorTableMetadata tableMetadata, Optional<NewTableLayout> layout, Optional<List<OutputColumnMetadata>> columns)
+        @JsonCreator
+        public CreateName(@JsonProperty("connectorId") ConnectorId connectorId,
+                @JsonProperty("tableMetadata") ConnectorTableMetadata tableMetadata,
+                @JsonProperty("layout") Optional<NewTableLayout> layout,
+                @JsonProperty("columns") Optional<List<OutputColumnMetadata>> columns)
         {
             this.connectorId = requireNonNull(connectorId, "connectorId is null");
             this.tableMetadata = requireNonNull(tableMetadata, "tableMetadata is null");
@@ -305,38 +319,42 @@ public CreateName(ConnectorId connectorId, ConnectorTableMetadata tableMetadata,
         }
 
         @Override
+        @JsonIgnore
         public ConnectorId getConnectorId()
         {
             return connectorId;
         }
 
+        @JsonIgnore
         public ConnectorTableMetadata getTableMetadata()
         {
             return tableMetadata;
         }
 
+        @JsonIgnore
         public Optional<NewTableLayout> getLayout()
         {
             return layout;
         }
 
         @Override
+        @JsonIgnore
         public SchemaTableName getSchemaTableName()
-
         {
             return tableMetadata.getTable();
         }
 
         @Override
-        public String toString()
+        @JsonIgnore
+        public Optional<List<OutputColumnMetadata>> getOutputColumns()
         {
-            return connectorId + "." + tableMetadata.getTable();
+            return columns;
         }
 
         @Override
-        public Optional<List<OutputColumnMetadata>> getOutputColumns()
+        public String toString()
         {
-            return columns;
+            return connectorId + "." + tableMetadata.getTable();
         }
     }
 
@@ -347,31 +365,39 @@ public static class InsertReference
         private final SchemaTableName schemaTableName;
         private final Optional<List<OutputColumnMetadata>> columns;
 
-        public InsertReference(TableHandle handle, SchemaTableName schemaTableName, Optional<List<OutputColumnMetadata>> columns)
+        @JsonCreator
+        public InsertReference(
+                @JsonProperty("handle") TableHandle handle,
+                @JsonProperty("schemaTableName") SchemaTableName schemaTableName,
+                @JsonProperty("columns") Optional<List<OutputColumnMetadata>> columns)
         {
             this.handle = requireNonNull(handle, "handle is null");
             this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");
             this.columns = requireNonNull(columns, "columns is null");
         }
 
+        @JsonProperty
         public TableHandle getHandle()
         {
             return handle;
         }
 
         @Override
-        public ConnectorId getConnectorId()
+        @JsonProperty
+        public SchemaTableName getSchemaTableName()
         {
-            return handle.getConnectorId();
+            return schemaTableName;
         }
 
         @Override
-        public SchemaTableName getSchemaTableName()
+        @JsonIgnore
+        public ConnectorId getConnectorId()
         {
-            return schemaTableName;
+            return handle.getConnectorId();
         }
 
         @Override
+        @JsonIgnore
         public Optional<List<OutputColumnMetadata>> getOutputColumns()
         {
             return columns;
@@ -390,32 +416,37 @@ public static class DeleteHandle
         private final TableHandle handle;
         private final SchemaTableName schemaTableName;
 
+        @JsonCreator
         public DeleteHandle(
-                TableHandle handle,
-                SchemaTableName schemaTableName)
+                @JsonProperty("handle") TableHandle handle,
+                @JsonProperty("schemaTableName") SchemaTableName schemaTableName)
         {
             this.handle = requireNonNull(handle, "handle is null");
             this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");
         }
 
+        @JsonProperty
         public TableHandle getHandle()
         {
             return handle;
         }
 
         @Override
-        public ConnectorId getConnectorId()
+        @JsonProperty
+        public SchemaTableName getSchemaTableName()
         {
-            return handle.getConnectorId();
+            return schemaTableName;
         }
 
         @Override
-        public SchemaTableName getSchemaTableName()
+        @JsonIgnore
+        public ConnectorId getConnectorId()
         {
-            return schemaTableName;
+            return handle.getConnectorId();
         }
 
         @Override
+        @JsonIgnore
         public Optional<List<OutputColumnMetadata>> getOutputColumns()
         {
             return Optional.empty();
@@ -433,30 +464,37 @@ public static class RefreshMaterializedViewReference
         private final TableHandle handle;
         private final SchemaTableName schemaTableName;
 
-        public RefreshMaterializedViewReference(TableHandle handle, SchemaTableName schemaTableName)
+        @JsonCreator
+        public RefreshMaterializedViewReference(
+                @JsonProperty("handle") TableHandle handle,
+                @JsonProperty("schemaTableName") SchemaTableName schemaTableName)
         {
             this.handle = requireNonNull(handle, "handle is null");
             this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");
         }
 
+        @JsonProperty
         public TableHandle getHandle()
         {
             return handle;
         }
 
         @Override
-        public ConnectorId getConnectorId()
+        @JsonProperty
+        public SchemaTableName getSchemaTableName()
         {
-            return handle.getConnectorId();
+            return schemaTableName;
         }
 
         @Override
-        public SchemaTableName getSchemaTableName()
+        @JsonIgnore
+        public ConnectorId getConnectorId()
         {
-            return schemaTableName;
+            return handle.getConnectorId();
         }
 
         @Override
+        @JsonIgnore
         public Optional<List<OutputColumnMetadata>> getOutputColumns()
         {
             return Optional.empty();
@@ -477,11 +515,12 @@ public static class UpdateTarget
         private final List<String> updatedColumns;
         private final List<ColumnHandle> updatedColumnHandles;
 
+        @JsonCreator
         public UpdateTarget(
-                TableHandle handle,
-                SchemaTableName schemaTableName,
-                List<String> updatedColumns,
-                List<ColumnHandle> updatedColumnHandles)
+                @JsonProperty("handle") TableHandle handle,
+                @JsonProperty("schemaTableName") SchemaTableName schemaTableName,
+                @JsonProperty("updatedColumns") List<String> updatedColumns,
+                @JsonProperty("updatedColumnHandles") List<ColumnHandle> updatedColumnHandles)
         {
             this.handle = requireNonNull(handle, "handle is null");
             this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");
@@ -490,32 +529,40 @@ public UpdateTarget(
             this.updatedColumnHandles = requireNonNull(updatedColumnHandles, "updatedColumnHandles is null");
         }
 
+        @JsonProperty
         public TableHandle getHandle()
         {
             return handle;
         }
 
-        public ConnectorId getConnectorId()
+        @Override
+        @JsonProperty
+        public SchemaTableName getSchemaTableName()
         {
-            return handle.getConnectorId();
+            return schemaTableName;
         }
 
-        public SchemaTableName getSchemaTableName()
+        @Override
+        @JsonIgnore
+        public ConnectorId getConnectorId()
         {
-            return schemaTableName;
+            return handle.getConnectorId();
         }
 
         @Override
+        @JsonIgnore
         public Optional<List<OutputColumnMetadata>> getOutputColumns()
         {
             return Optional.empty();
         }
 
+        @JsonIgnore
         public List<String> getUpdatedColumns()
         {
             return updatedColumns;
         }
 
+        @JsonIgnore
         public List<ColumnHandle> getUpdatedColumnHandles()
         {
             return updatedColumnHandles;
diff --git a/presto-spi/src/test/java/com/facebook/presto/spi/plan/TestTableWriterNode.java b/presto-spi/src/test/java/com/facebook/presto/spi/plan/TestTableWriterNode.java

Original file line number	Diff line number	Diff line change
`@@ -89,6 +89,7 @@ public Map<String, Object> getProperties()`
`89`	`89`	`{`
`90`	`90`	`return properties;`
`91`	`91`	`}`
	`92`	`+`
`92`	`93`	`public Builder toBuilder()`
`93`	`94`	`{`
`94`	`95`	`return ColumnMetadata.builder()`
Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,8 @@`
`25`	`25`	`import com.fasterxml.jackson.annotation.JsonCreator;`
`26`	`26`	`import com.fasterxml.jackson.annotation.JsonIgnore;`
`27`	`27`	`import com.fasterxml.jackson.annotation.JsonProperty;`
	`28`	`+import com.fasterxml.jackson.annotation.JsonSubTypes;`
	`29`	`+import com.fasterxml.jackson.annotation.JsonTypeInfo;`
`28`	`30`	`import com.google.errorprone.annotations.Immutable;`
`29`	`31`
`30`	`32`	`import java.util.ArrayList;`
`@@ -144,7 +146,7 @@ public PlanNode getSource()`
`144`	`146`	`return source;`
`145`	`147`	`}`
`146`	`148`
`147`		`- @JsonIgnore`
	`149`	`+ @JsonProperty`
`148`	`150`	`public Optional<WriterTarget> getTarget()`
`149`	`151`	`{`
`150`	`152`	`return target;`
`@@ -276,6 +278,14 @@ public boolean isSingleWriterPerPartitionRequired()`
`276`	`278`
`277`	`279`	`// only used during planning -- will not be serialized`
`278`	`280`	`@SuppressWarnings({"EmptyClass", "ClassMayBeInterface"})`
	`281`	`+ @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "@type")`
	`282`	`+ @JsonSubTypes({`
	`283`	`+ @JsonSubTypes.Type(value = CreateName.class, name = "createName"),`
	`284`	`+ @JsonSubTypes.Type(value = InsertReference.class, name = "insertReference"),`
	`285`	`+ @JsonSubTypes.Type(value = DeleteHandle.class, name = "deleteHandle"),`
	`286`	`+ @JsonSubTypes.Type(value = RefreshMaterializedViewReference.class, name = "refreshMaterializedView"),`
	`287`	`+ @JsonSubTypes.Type(value = UpdateTarget.class, name = "updateTarget")`
	`288`	`+ })`
`279`	`289`	`public abstract static class WriterTarget`
`280`	`290`	`{`
`281`	`291`	`public abstract ConnectorId getConnectorId();`
`@@ -296,7 +306,11 @@ public static class CreateName`
`296`	`306`	`private final Optional<NewTableLayout> layout;`
`297`	`307`	`private final Optional<List<OutputColumnMetadata>> columns;`
`298`	`308`
`299`		`- public CreateName(ConnectorId connectorId, ConnectorTableMetadata tableMetadata, Optional<NewTableLayout> layout, Optional<List<OutputColumnMetadata>> columns)`
	`309`	`+ @JsonCreator`
	`310`	`+ public CreateName(@JsonProperty("connectorId") ConnectorId connectorId,`
	`311`	`+ @JsonProperty("tableMetadata") ConnectorTableMetadata tableMetadata,`
	`312`	`+ @JsonProperty("layout") Optional<NewTableLayout> layout,`
	`313`	`+ @JsonProperty("columns") Optional<List<OutputColumnMetadata>> columns)`
`300`	`314`	`{`
`301`	`315`	`this.connectorId = requireNonNull(connectorId, "connectorId is null");`
`302`	`316`	`this.tableMetadata = requireNonNull(tableMetadata, "tableMetadata is null");`
`@@ -305,38 +319,42 @@ public CreateName(ConnectorId connectorId, ConnectorTableMetadata tableMetadata,`
`305`	`319`	`}`
`306`	`320`
`307`	`321`	`@Override`
	`322`	`+ @JsonIgnore`
`308`	`323`	`public ConnectorId getConnectorId()`
`309`	`324`	`{`
`310`	`325`	`return connectorId;`
`311`	`326`	`}`
`312`	`327`
	`328`	`+ @JsonIgnore`
`313`	`329`	`public ConnectorTableMetadata getTableMetadata()`
`314`	`330`	`{`
`315`	`331`	`return tableMetadata;`
`316`	`332`	`}`
`317`	`333`
	`334`	`+ @JsonIgnore`
`318`	`335`	`public Optional<NewTableLayout> getLayout()`
`319`	`336`	`{`
`320`	`337`	`return layout;`
`321`	`338`	`}`
`322`	`339`
`323`	`340`	`@Override`
	`341`	`+ @JsonIgnore`
`324`	`342`	`public SchemaTableName getSchemaTableName()`
`325`		`-`
`326`	`343`	`{`
`327`	`344`	`return tableMetadata.getTable();`
`328`	`345`	`}`
`329`	`346`
`330`	`347`	`@Override`
`331`		`- public String toString()`
	`348`	`+ @JsonIgnore`
	`349`	`+ public Optional<List<OutputColumnMetadata>> getOutputColumns()`
`332`	`350`	`{`
`333`		`- return connectorId + "." + tableMetadata.getTable();`
	`351`	`+ return columns;`
`334`	`352`	`}`
`335`	`353`
`336`	`354`	`@Override`
`337`		`- public Optional<List<OutputColumnMetadata>> getOutputColumns()`
	`355`	`+ public String toString()`
`338`	`356`	`{`
`339`		`- return columns;`
	`357`	`+ return connectorId + "." + tableMetadata.getTable();`
`340`	`358`	`}`
`341`	`359`	`}`
`342`	`360`
`@@ -347,31 +365,39 @@ public static class InsertReference`
`347`	`365`	`private final SchemaTableName schemaTableName;`
`348`	`366`	`private final Optional<List<OutputColumnMetadata>> columns;`
`349`	`367`
`350`		`- public InsertReference(TableHandle handle, SchemaTableName schemaTableName, Optional<List<OutputColumnMetadata>> columns)`
	`368`	`+ @JsonCreator`
	`369`	`+ public InsertReference(`
	`370`	`+ @JsonProperty("handle") TableHandle handle,`
	`371`	`+ @JsonProperty("schemaTableName") SchemaTableName schemaTableName,`
	`372`	`+ @JsonProperty("columns") Optional<List<OutputColumnMetadata>> columns)`
`351`	`373`	`{`
`352`	`374`	`this.handle = requireNonNull(handle, "handle is null");`
`353`	`375`	`this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");`
`354`	`376`	`this.columns = requireNonNull(columns, "columns is null");`
`355`	`377`	`}`
`356`	`378`
	`379`	`+ @JsonProperty`
`357`	`380`	`public TableHandle getHandle()`
`358`	`381`	`{`
`359`	`382`	`return handle;`
`360`	`383`	`}`
`361`	`384`
`362`	`385`	`@Override`
`363`		`- public ConnectorId getConnectorId()`
	`386`	`+ @JsonProperty`
	`387`	`+ public SchemaTableName getSchemaTableName()`
`364`	`388`	`{`
`365`		`- return handle.getConnectorId();`
	`389`	`+ return schemaTableName;`
`366`	`390`	`}`
`367`	`391`
`368`	`392`	`@Override`
`369`		`- public SchemaTableName getSchemaTableName()`
	`393`	`+ @JsonIgnore`
	`394`	`+ public ConnectorId getConnectorId()`
`370`	`395`	`{`
`371`		`- return schemaTableName;`
	`396`	`+ return handle.getConnectorId();`
`372`	`397`	`}`
`373`	`398`
`374`	`399`	`@Override`
	`400`	`+ @JsonIgnore`
`375`	`401`	`public Optional<List<OutputColumnMetadata>> getOutputColumns()`
`376`	`402`	`{`
`377`	`403`	`return columns;`
`@@ -390,32 +416,37 @@ public static class DeleteHandle`
`390`	`416`	`private final TableHandle handle;`
`391`	`417`	`private final SchemaTableName schemaTableName;`
`392`	`418`
	`419`	`+ @JsonCreator`
`393`	`420`	`public DeleteHandle(`
`394`		`- TableHandle handle,`
`395`		`- SchemaTableName schemaTableName)`
	`421`	`+ @JsonProperty("handle") TableHandle handle,`
	`422`	`+ @JsonProperty("schemaTableName") SchemaTableName schemaTableName)`
`396`	`423`	`{`
`397`	`424`	`this.handle = requireNonNull(handle, "handle is null");`
`398`	`425`	`this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");`
`399`	`426`	`}`
`400`	`427`
	`428`	`+ @JsonProperty`
`401`	`429`	`public TableHandle getHandle()`
`402`	`430`	`{`
`403`	`431`	`return handle;`
`404`	`432`	`}`
`405`	`433`
`406`	`434`	`@Override`
`407`		`- public ConnectorId getConnectorId()`
	`435`	`+ @JsonProperty`
	`436`	`+ public SchemaTableName getSchemaTableName()`
`408`	`437`	`{`
`409`		`- return handle.getConnectorId();`
	`438`	`+ return schemaTableName;`
`410`	`439`	`}`
`411`	`440`
`412`	`441`	`@Override`
`413`		`- public SchemaTableName getSchemaTableName()`
	`442`	`+ @JsonIgnore`
	`443`	`+ public ConnectorId getConnectorId()`
`414`	`444`	`{`
`415`		`- return schemaTableName;`
	`445`	`+ return handle.getConnectorId();`
`416`	`446`	`}`
`417`	`447`
`418`	`448`	`@Override`
	`449`	`+ @JsonIgnore`
`419`	`450`	`public Optional<List<OutputColumnMetadata>> getOutputColumns()`
`420`	`451`	`{`
`421`	`452`	`return Optional.empty();`
`@@ -433,30 +464,37 @@ public static class RefreshMaterializedViewReference`
`433`	`464`	`private final TableHandle handle;`
`434`	`465`	`private final SchemaTableName schemaTableName;`
`435`	`466`
`436`		`- public RefreshMaterializedViewReference(TableHandle handle, SchemaTableName schemaTableName)`
	`467`	`+ @JsonCreator`
	`468`	`+ public RefreshMaterializedViewReference(`
	`469`	`+ @JsonProperty("handle") TableHandle handle,`
	`470`	`+ @JsonProperty("schemaTableName") SchemaTableName schemaTableName)`
`437`	`471`	`{`
`438`	`472`	`this.handle = requireNonNull(handle, "handle is null");`
`439`	`473`	`this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");`
`440`	`474`	`}`
`441`	`475`
	`476`	`+ @JsonProperty`
`442`	`477`	`public TableHandle getHandle()`
`443`	`478`	`{`
`444`	`479`	`return handle;`
`445`	`480`	`}`
`446`	`481`
`447`	`482`	`@Override`
`448`		`- public ConnectorId getConnectorId()`
	`483`	`+ @JsonProperty`
	`484`	`+ public SchemaTableName getSchemaTableName()`
`449`	`485`	`{`
`450`		`- return handle.getConnectorId();`
	`486`	`+ return schemaTableName;`
`451`	`487`	`}`
`452`	`488`
`453`	`489`	`@Override`
`454`		`- public SchemaTableName getSchemaTableName()`
	`490`	`+ @JsonIgnore`
	`491`	`+ public ConnectorId getConnectorId()`
`455`	`492`	`{`
`456`		`- return schemaTableName;`
	`493`	`+ return handle.getConnectorId();`
`457`	`494`	`}`
`458`	`495`
`459`	`496`	`@Override`
	`497`	`+ @JsonIgnore`
`460`	`498`	`public Optional<List<OutputColumnMetadata>> getOutputColumns()`
`461`	`499`	`{`
`462`	`500`	`return Optional.empty();`
`@@ -477,11 +515,12 @@ public static class UpdateTarget`
`477`	`515`	`private final List<String> updatedColumns;`
`478`	`516`	`private final List<ColumnHandle> updatedColumnHandles;`
`479`	`517`
	`518`	`+ @JsonCreator`
`480`	`519`	`public UpdateTarget(`
`481`		`- TableHandle handle,`
`482`		`- SchemaTableName schemaTableName,`
`483`		`- List<String> updatedColumns,`
`484`		`- List<ColumnHandle> updatedColumnHandles)`
	`520`	`+ @JsonProperty("handle") TableHandle handle,`
	`521`	`+ @JsonProperty("schemaTableName") SchemaTableName schemaTableName,`
	`522`	`+ @JsonProperty("updatedColumns") List<String> updatedColumns,`
	`523`	`+ @JsonProperty("updatedColumnHandles") List<ColumnHandle> updatedColumnHandles)`
`485`	`524`	`{`
`486`	`525`	`this.handle = requireNonNull(handle, "handle is null");`
`487`	`526`	`this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");`
`@@ -490,32 +529,40 @@ public UpdateTarget(`
`490`	`529`	`this.updatedColumnHandles = requireNonNull(updatedColumnHandles, "updatedColumnHandles is null");`
`491`	`530`	`}`
`492`	`531`
	`532`	`+ @JsonProperty`
`493`	`533`	`public TableHandle getHandle()`
`494`	`534`	`{`
`495`	`535`	`return handle;`
`496`	`536`	`}`
`497`	`537`
`498`		`- public ConnectorId getConnectorId()`
	`538`	`+ @Override`
	`539`	`+ @JsonProperty`
	`540`	`+ public SchemaTableName getSchemaTableName()`
`499`	`541`	`{`
`500`		`- return handle.getConnectorId();`
	`542`	`+ return schemaTableName;`
`501`	`543`	`}`
`502`	`544`
`503`		`- public SchemaTableName getSchemaTableName()`
	`545`	`+ @Override`
	`546`	`+ @JsonIgnore`
	`547`	`+ public ConnectorId getConnectorId()`
`504`	`548`	`{`
`505`		`- return schemaTableName;`
	`549`	`+ return handle.getConnectorId();`
`506`	`550`	`}`
`507`	`551`
`508`	`552`	`@Override`
	`553`	`+ @JsonIgnore`
`509`	`554`	`public Optional<List<OutputColumnMetadata>> getOutputColumns()`
`510`	`555`	`{`
`511`	`556`	`return Optional.empty();`
`512`	`557`	`}`
`513`	`558`
	`559`	`+ @JsonIgnore`
`514`	`560`	`public List<String> getUpdatedColumns()`
`515`	`561`	`{`
`516`	`562`	`return updatedColumns;`
`517`	`563`	`}`
`518`	`564`
	`565`	`+ @JsonIgnore`
`519`	`566`	`public List<ColumnHandle> getUpdatedColumnHandles()`
`520`	`567`	`{`
`521`	`568`	`return updatedColumnHandles;`