You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ma...@apache.org on 2022/11/18 03:05:50 UTC
[iotdb] 01/01: use deserialize instead of array index when parsing compression type and data type
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);