Remove unused classes from TableWriterNode

trinodb · Sep 19, 2024 · fe242fa · fe242fa
1 parent 4e0969a
commit fe242fa
Showing 1 changed file with 0 additions and 136 deletions.
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
@@ -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<TableHandle> handle;
-        private final SchemaTableName schemaTableName;
-
-        @JsonCreator
-        public DeleteTarget(
-                @JsonProperty("handle") Optional<TableHandle> handle,
-                @JsonProperty("schemaTableName") SchemaTableName schemaTableName)
-        {
-            this.handle = requireNonNull(handle, "handle is null");
-            this.schemaTableName = requireNonNull(schemaTableName, "schemaTableName is null");
-        }
-
-        @JsonProperty
-        public Optional<TableHandle> 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<TableHandle> handle;
-        private final SchemaTableName schemaTableName;
-        private final List<String> updatedColumns;
-        private final List<ColumnHandle> updatedColumnHandles;
-
-        @JsonCreator
-        public UpdateTarget(
-                @JsonProperty("handle") Optional<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");
-            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<TableHandle> 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<String> getUpdatedColumns()
-        {
-            return updatedColumns;
-        }
-
-        @JsonProperty
-        public List<ColumnHandle> 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
     {