[IOTDB-4941] Prevent compatibility problems in PipeData

integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncSenderIT.java

@@ -268,7 +268,7 @@ private void checkResult(List<String> resultString, List<PipeData> list) {
     int cnt = 0;
     for (String string : resultString) {
       for (PipeData pipeData : resultMap.get(string)) {
-        Assert.assertEquals(pipeData.getType(), list.get(cnt++).getType());
+        Assert.assertEquals(pipeData.getPipeDataType(), list.get(cnt++).getPipeDataType());
       }
     }
   }

server/src/main/java/org/apache/iotdb/db/sync/pipedata/DeletionPipeData.java

@@ -54,7 +54,7 @@ public DeletionPipeData(String sgName, Deletion deletion, long serialNumber) {
   }
 
   @Override
-  public PipeDataType getType() {
+  public PipeDataType getPipeDataType() {
     return PipeDataType.DELETION;
   }
 

server/src/main/java/org/apache/iotdb/db/sync/pipedata/PipeData.java

@@ -50,11 +50,11 @@ public void setSerialNumber(long serialNumber) {
     this.serialNumber = serialNumber;
   }
 
-  public abstract PipeDataType getType();
+  public abstract PipeDataType getPipeDataType();
 
   public long serialize(DataOutputStream stream) throws IOException {
     long serializeSize = 0;
-    stream.writeByte((byte) getType().ordinal());
+    stream.writeByte(getPipeDataType().getType());
     serializeSize += Byte.BYTES;
     stream.writeLong(serialNumber);
     serializeSize += Long.BYTES;
@@ -74,7 +74,7 @@ public void deserialize(DataInputStream stream) throws IOException, IllegalPathE
   public static PipeData createPipeData(DataInputStream stream)
       throws IOException, IllegalPathException {
     PipeData pipeData;
-    PipeDataType type = PipeDataType.values()[stream.readByte()];
+    PipeDataType type = PipeDataType.getPipeDataType(stream.readByte());
     switch (type) {
       case TSFILE:
         pipeData = new TsFilePipeData();
@@ -98,7 +98,28 @@ public static PipeData createPipeData(byte[] bytes) throws IllegalPathException,
   public abstract ILoader createLoader();
 
   public enum PipeDataType {
-    TSFILE,
-    DELETION,
+    TSFILE((byte) 0),
+    DELETION((byte) 1);
+
+    private final byte type;
+
+    PipeDataType(byte type) {
+      this.type = type;
+    }
+
+    public byte getType() {
+      return type;
+    }
+
+    public static PipeDataType getPipeDataType(byte type) {
+      switch (type) {
+        case 0:
+          return PipeDataType.TSFILE;
+        case 1:
+          return PipeDataType.DELETION;
+        default:
+          throw new IllegalArgumentException("Invalid input: " + type);
+      }
+    }
   }
 }

server/src/main/java/org/apache/iotdb/db/sync/pipedata/TsFilePipeData.java

@@ -121,7 +121,7 @@ public String getStorageGroupName() {
   }
 
   @Override
-  public PipeDataType getType() {
+  public PipeDataType getPipeDataType() {
     return PipeDataType.TSFILE;
   }
 

server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/BufferedPipeDataQueue.java

@@ -311,7 +311,7 @@ private void deletePipeData(long serialNumber) {
         if (commitData == null) {
           return;
         }
-        if (PipeData.PipeDataType.TSFILE.equals(commitData.getType())) {
+        if (PipeData.PipeDataType.TSFILE.equals(commitData.getPipeDataType())) {
           List<File> tsFiles = ((TsFilePipeData) commitData).getTsFiles(false);
           for (File file : tsFiles) {
             Files.deleteIfExists(file.toPath());

server/src/main/java/org/apache/iotdb/db/sync/transport/server/ReceiverManager.java

@@ -242,7 +242,7 @@ public TSStatus transportPipeData(ByteBuffer buff) throws TException {
     logger.info(
         "Start load pipeData with serialize number {} and type {},value={}",
         pipeData.getSerialNumber(),
-        pipeData.getType(),
+        pipeData.getPipeDataType(),
         pipeData);
     try {
       pipeData.createLoader().load();