diff --git a/core/trino-main/src/main/java/io/trino/sql/planner/plan/TableWriterNode.java b/core/trino-main/src/main/java/io/trino/sql/planner/plan/TableWriterNode.java index 318bae41fd377..ee25cf5f12f23 100644 --- a/core/trino-main/src/main/java/io/trino/sql/planner/plan/TableWriterNode.java +++ b/core/trino-main/src/main/java/io/trino/sql/planner/plan/TableWriterNode.java @@ -14,7 +14,6 @@ package io.trino.sql.planner.plan; 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; @@ -647,141 +646,6 @@ public WriterScalingOptions getWriterScalingOptions(Metadata metadata, Session s } } - public static class DeleteTarget - extends WriterTarget - { - private final Optional handle; - private final SchemaTableName schemaTableName; - - @JsonCreator - public DeleteTarget( - @JsonProperty("handle") Optional handle, - @JsonProperty("schemaTableName") SchemaTableName schemaTableName) - { - this.handle = requireNonNull(handle, "handle is null"); - this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null"); - } - - @JsonProperty - public Optional getHandle() - { - return handle; - } - - @JsonIgnore - public TableHandle getHandleOrElseThrow() - { - return handle.orElseThrow(() -> new IllegalStateException("DeleteTarget does not contain handle")); - } - - @JsonProperty - public SchemaTableName getSchemaTableName() - { - return schemaTableName; - } - - @Override - public String toString() - { - return handle.map(Object::toString).orElse("[]"); - } - - @Override - public boolean supportsMultipleWritersPerPartition(Metadata metadata, Session session) - { - throw new UnsupportedOperationException(); - } - - @Override - public OptionalInt getMaxWriterTasks(Metadata metadata, Session session) - { - throw new UnsupportedOperationException(); - } - - @Override - public WriterScalingOptions getWriterScalingOptions(Metadata metadata, Session session) - { - throw new UnsupportedOperationException(); - } - } - - public static class UpdateTarget - extends WriterTarget - { - private final Optional handle; - private final SchemaTableName schemaTableName; - private final List updatedColumns; - private final List updatedColumnHandles; - - @JsonCreator - public UpdateTarget( - @JsonProperty("handle") Optional handle, - @JsonProperty("schemaTableName") SchemaTableName schemaTableName, - @JsonProperty("updatedColumns") List updatedColumns, - @JsonProperty("updatedColumnHandles") List updatedColumnHandles) - { - this.handle = requireNonNull(handle, "handle is null"); - this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null"); - checkArgument(updatedColumns.size() == updatedColumnHandles.size(), "updatedColumns size %s must equal updatedColumnHandles size %s", updatedColumns.size(), updatedColumnHandles.size()); - this.updatedColumns = requireNonNull(updatedColumns, "updatedColumns is null"); - this.updatedColumnHandles = requireNonNull(updatedColumnHandles, "updatedColumnHandles is null"); - } - - @JsonProperty - public Optional getHandle() - { - return handle; - } - - @JsonIgnore - public TableHandle getHandleOrElseThrow() - { - return handle.orElseThrow(() -> new IllegalStateException("UpdateTarge does not contain handle")); - } - - @JsonProperty - public SchemaTableName getSchemaTableName() - { - return schemaTableName; - } - - @JsonProperty - public List getUpdatedColumns() - { - return updatedColumns; - } - - @JsonProperty - public List getUpdatedColumnHandles() - { - return updatedColumnHandles; - } - - @Override - public String toString() - { - return handle.map(Object::toString).orElse("[]"); - } - - @Override - public boolean supportsMultipleWritersPerPartition(Metadata metadata, Session session) - { - throw new UnsupportedOperationException(); - } - - @Override - public OptionalInt getMaxWriterTasks(Metadata metadata, Session session) - { - throw new UnsupportedOperationException(); - } - - @Override - public WriterScalingOptions getWriterScalingOptions(Metadata metadata, Session session) - { - throw new UnsupportedOperationException(); - } - } - public static class TableExecuteTarget extends WriterTarget {