[Refactor](meta) Delete useless classes and write methods (apache#36894)

Co-authored-by: zhangpeicheng <[email protected]>

Author: 2 people

fe/fe-common/src/main/java/org/apache/doris/common/io/DeepCopy.java

@@ -39,6 +39,7 @@ public class DeepCopy {
     // deep copy orig to dest.
     // the param "c" is the implementation class of "dest".
     // And the "dest" class must has method "readFields(DataInput)"
+    @Deprecated
     public static boolean copy(Writable orig, Writable dest, Class c, int metaVersion) {
         MetaContext metaContext = new MetaContext();
         metaContext.setMetaVersion(metaVersion);

fe/fe-core/src/main/java/org/apache/doris/backup/BackupMeta.java

@@ -140,6 +140,7 @@ public void write(DataOutput out) throws IOException {
         Text.writeString(out, GsonUtils.GSON.toJson(this));
     }
 
+    @Deprecated
     public void readFields(DataInput in) throws IOException {
         int size = in.readInt();
         for (int i = 0; i < size; i++) {

fe/fe-core/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java

@@ -1305,6 +1305,7 @@ public void gsonPostProcess() throws IOException {
         updateDbInfoForLowerVersion();
     }
 
+    @Deprecated
     public void readFields(DataInput in) throws IOException {
         int count = in.readInt();
         for (int i = 0; i < count; i++) {
@@ -1439,6 +1440,7 @@ public Table getTable() {
             return table;
         }
 
+        @Deprecated
         public void readFields(DataInput in) throws IOException {
             dbId = in.readLong();
             table = Table.read(in);

fe/fe-core/src/main/java/org/apache/doris/catalog/Column.java

@@ -29,7 +29,6 @@
 import org.apache.doris.common.Config;
 import org.apache.doris.common.DdlException;
 import org.apache.doris.common.io.Text;
-import org.apache.doris.common.io.Writable;
 import org.apache.doris.common.util.SqlUtils;
 import org.apache.doris.persist.gson.GsonPostProcessable;
 import org.apache.doris.persist.gson.GsonUtils;
@@ -48,7 +47,6 @@
 import org.apache.logging.log4j.Logger;
 
 import java.io.DataInput;
-import java.io.DataOutput;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashSet;
@@ -60,7 +58,7 @@
 /**
  * This class represents the column-related metadata.
  */
-public class Column implements Writable, GsonPostProcessable {
+public class Column implements GsonPostProcessable {
     private static final Logger LOG = LogManager.getLogger(Column.class);
     public static final String DELETE_SIGN = "__DORIS_DELETE_SIGN__";
     public static final String WHERE_SIGN = "__DORIS_WHERE_SIGN__";
@@ -1065,33 +1063,7 @@ name, getDefaultValue(), aggregationType, isAggregationTypeImplicit, isKey, isAl
         return ok;
     }
 
-    @Override
-    public void write(DataOutput out) throws IOException {
-        String json = GsonUtils.GSON.toJson(this);
-        Text.writeString(out, json);
-    }
-
     @Deprecated
-    private void readFields(DataInput in) throws IOException {
-        name = Text.readString(in);
-        type = ColumnType.read(in);
-        boolean notNull = in.readBoolean();
-        if (notNull) {
-            aggregationType = AggregateType.valueOf(Text.readString(in));
-            isAggregationTypeImplicit = in.readBoolean();
-        }
-        isKey = in.readBoolean();
-        isAllowNull = in.readBoolean();
-        notNull = in.readBoolean();
-        if (notNull) {
-            defaultValue = Text.readString(in);
-            realDefaultValue = defaultValue;
-        }
-        stats = ColumnStats.read(in);
-
-        comment = Text.readString(in);
-    }
-
     public static Column read(DataInput in) throws IOException {
         String json = Text.readString(in);
         return GsonUtils.GSON.fromJson(json, Column.class);

fe/fe-core/src/main/java/org/apache/doris/catalog/ColumnStats.java

@@ -19,23 +19,19 @@
 
 import org.apache.doris.analysis.Expr;
 import org.apache.doris.analysis.SlotRef;
-import org.apache.doris.common.io.Writable;
 
 import com.google.common.base.MoreObjects;
 import com.google.common.base.Preconditions;
 import com.google.gson.annotations.SerializedName;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
 import java.util.Objects;
 
 /**
  * Statistics for a single column.
  */
-public class ColumnStats implements Writable {
+public class ColumnStats {
     private static final Logger LOG = LogManager.getLogger(ColumnStats.class);
 
     @SerializedName(value = "avgSerializedSize")
@@ -120,26 +116,6 @@ public String toString() {
           "numNulls", numNulls).toString();
     }
 
-    public void write(DataOutput out) throws IOException {
-        out.writeLong(numDistinctValues);
-        out.writeFloat(avgSerializedSize);
-        out.writeLong(maxSize);
-        out.writeLong(numNulls);
-    }
-
-    public void readFields(DataInput in) throws IOException {
-        numDistinctValues = in.readLong();
-        avgSerializedSize = in.readFloat();
-        maxSize = in.readLong();
-        numNulls = in.readLong();
-    }
-
-    public static ColumnStats read(DataInput in) throws IOException {
-        ColumnStats columnStats = new ColumnStats();
-        columnStats.readFields(in);
-        return columnStats;
-    }
-
     @Override
     public int hashCode() {
         return Objects.hash(avgSerializedSize, maxSize, numDistinctValues, numNulls);

fe/fe-core/src/main/java/org/apache/doris/catalog/DistributionInfo.java

@@ -84,6 +84,7 @@ public DistributionDesc toDistributionDesc() {
         throw new NotImplementedException("toDistributionDesc not implemented");
     }
 
+    @Deprecated
     public void readFields(DataInput in) throws IOException {
         type = DistributionInfoType.valueOf(Text.readString(in));
     }

fe/fe-core/src/main/java/org/apache/doris/catalog/HashDistributionInfo.java

@@ -66,6 +66,7 @@ public void setBucketNum(int bucketNum) {
         this.bucketNum = bucketNum;
     }
 
+    @Deprecated
     @Override
     public void readFields(DataInput in) throws IOException {
         super.readFields(in);

fe/fe-core/src/main/java/org/apache/doris/catalog/ListPartitionInfo.java

@@ -67,6 +67,7 @@ public ListPartitionInfo(boolean isAutoCreatePartitions, ArrayList<Expr> exprs,
         }
     }
 
+    @Deprecated
     public static PartitionInfo read(DataInput in) throws IOException {
         if (Env.getCurrentEnvJournalVersion() >= FeMetaVersion.VERSION_136) {
             return GsonUtils.GSON.fromJson(Text.readString(in), ListPartitionInfo.class);

fe/fe-core/src/main/java/org/apache/doris/catalog/MaterializedIndex.java

@@ -19,15 +19,13 @@
 
 import org.apache.doris.common.FeMetaVersion;
 import org.apache.doris.common.io.Text;
-import org.apache.doris.common.io.Writable;
 import org.apache.doris.persist.gson.GsonPostProcessable;
 import org.apache.doris.persist.gson.GsonUtils;
 
 import com.google.common.collect.Lists;
 import com.google.gson.annotations.SerializedName;
 
 import java.io.DataInput;
-import java.io.DataOutput;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -37,7 +35,7 @@
 /**
  * The OlapTraditional table is a materialized table which stored as rowcolumnar file or columnar file
  */
-public class MaterializedIndex extends MetaObject implements Writable, GsonPostProcessable {
+public class MaterializedIndex extends MetaObject implements GsonPostProcessable {
     public enum IndexState {
         NORMAL,
         @Deprecated
@@ -208,11 +206,7 @@ public int getTabletOrderIdx(long tabletId) {
         return -1;
     }
 
-    @Override
-    public void write(DataOutput out) throws IOException {
-        Text.writeString(out, GsonUtils.GSON.toJson(this));
-    }
-
+    @Deprecated
     public void readFields(DataInput in) throws IOException {
         super.readFields(in);
 
@@ -232,6 +226,7 @@ public void readFields(DataInput in) throws IOException {
         rollupFinishedVersion = in.readLong();
     }
 
+    @Deprecated
     public static MaterializedIndex read(DataInput in) throws IOException {
         if (Env.getCurrentEnvJournalVersion() < FeMetaVersion.VERSION_136) {
             MaterializedIndex mi = new MaterializedIndex();

fe/fe-core/src/main/java/org/apache/doris/catalog/OlapTable.java

@@ -1559,6 +1559,7 @@ public void write(DataOutput out) throws IOException {
         Text.writeString(out, GsonUtils.GSON.toJson(this));
     }
 
+    @Deprecated
     @Override
     public void readFields(DataInput in) throws IOException {
         super.readFields(in);
@@ -1796,7 +1797,7 @@ public static OlapTable read(DataInput in) throws IOException {
             t.readFields(in);
             return t;
         }
-        return (OlapTable) GsonUtils.GSON.fromJson(Text.readString(in), OlapTable.class);
+        return GsonUtils.GSON.fromJson(Text.readString(in), OlapTable.class);
     }
 
     /*