[iotdb] branch fix-go-ci created (now f544c5579c)

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

marklau99 pushed a change to branch fix-go-ci
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at f544c5579c use deserialize instead of array index when parsing compression type and data type

This branch includes the following new commits:

     new f544c5579c use deserialize instead of array index when parsing compression type and data type

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[iotdb] 01/01: use deserialize instead of array index when parsing compression type and data type

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

marklau99 pushed a commit to branch fix-go-ci
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit f544c5579c8a27340b40ce4cd2b054c579f5f4b5
Author: Liu Xuxin <li...@outlook.com>
AuthorDate: Fri Nov 18 11:05:35 2022 +0800

    use deserialize instead of array index when parsing compression type and data type
---
 .../db/mpp/plan/parser/StatementGenerator.java     | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
index ab74714580..bd85626786 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
@@ -221,7 +221,7 @@ public class StatementGenerator {
     insertStatement.setRowCount(insertTabletReq.size);
     TSDataType[] dataTypes = new TSDataType[insertTabletReq.types.size()];
     for (int i = 0; i < insertTabletReq.types.size(); i++) {
-      dataTypes[i] = TSDataType.values()[insertTabletReq.types.get(i)];
+      dataTypes[i] = TSDataType.deserialize((byte) insertTabletReq.types.get(i).intValue());
     }
     insertStatement.setDataTypes(dataTypes);
     insertStatement.setAligned(insertTabletReq.isAligned);
@@ -250,7 +250,7 @@ public class StatementGenerator {
       insertTabletStatement.setRowCount(req.sizeList.get(i));
       TSDataType[] dataTypes = new TSDataType[req.typesList.get(i).size()];
       for (int j = 0; j < dataTypes.length; j++) {
-        dataTypes[j] = TSDataType.values()[req.typesList.get(i).get(j)];
+        dataTypes[j] = TSDataType.deserialize((byte) req.typesList.get(i).get(j).intValue());
       }
       insertTabletStatement.setDataTypes(dataTypes);
       insertTabletStatement.setAligned(req.isAligned);
@@ -370,9 +370,9 @@ public class StatementGenerator {
     // construct create timeseries statement
     CreateTimeSeriesStatement statement = new CreateTimeSeriesStatement();
     statement.setPath(new PartialPath(req.path));
-    statement.setDataType(TSDataType.values()[req.dataType]);
-    statement.setEncoding(TSEncoding.values()[req.encoding]);
-    statement.setCompressor(CompressionType.values()[req.compressor]);
+    statement.setDataType(TSDataType.deserialize((byte) req.dataType));
+    statement.setEncoding(TSEncoding.deserialize((byte) req.encoding));
+    statement.setCompressor(CompressionType.deserialize((byte) req.compressor));
     statement.setProps(req.props);
     statement.setTags(req.tags);
     statement.setAttributes(req.attributes);
@@ -387,15 +387,15 @@ public class StatementGenerator {
     statement.setDevicePath(new PartialPath(req.prefixPath));
     List<TSDataType> dataTypes = new ArrayList<>();
     for (int dataType : req.dataTypes) {
-      dataTypes.add(TSDataType.values()[dataType]);
+      dataTypes.add(TSDataType.deserialize((byte) dataType));
     }
     List<TSEncoding> encodings = new ArrayList<>();
     for (int encoding : req.encodings) {
-      encodings.add(TSEncoding.values()[encoding]);
+      encodings.add(TSEncoding.deserialize((byte) encoding));
     }
     List<CompressionType> compressors = new ArrayList<>();
     for (int compressor : req.compressors) {
-      compressors.add(CompressionType.values()[compressor]);
+      compressors.add(CompressionType.deserialize((byte) compressor));
     }
     statement.setMeasurements(req.measurements);
     statement.setDataTypes(dataTypes);
@@ -416,15 +416,15 @@ public class StatementGenerator {
     }
     List<TSDataType> dataTypes = new ArrayList<>();
     for (int dataType : req.dataTypes) {
-      dataTypes.add(TSDataType.values()[dataType]);
+      dataTypes.add(TSDataType.deserialize((byte) dataType));
     }
     List<TSEncoding> encodings = new ArrayList<>();
     for (int encoding : req.encodings) {
-      encodings.add(TSEncoding.values()[encoding]);
+      encodings.add(TSEncoding.deserialize((byte) encoding));
     }
     List<CompressionType> compressors = new ArrayList<>();
     for (int compressor : req.compressors) {
-      compressors.add(CompressionType.values()[compressor]);
+      compressors.add(CompressionType.deserialize((byte) compressor));
     }
     CreateMultiTimeSeriesStatement statement = new CreateMultiTimeSeriesStatement();
     statement.setPaths(paths);