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/20 11:41:28 UTC
[iotdb] branch master updated: Fix go ci (#8039)
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new b88f23361a Fix go ci (#8039)
b88f23361a is described below
commit b88f23361ab0aac9a7ba1c1660eb05c0aee0afbb
Author: Liu Xuxin <37...@users.noreply.github.com>
AuthorDate: Sun Nov 20 19:41:23 2022 +0800
Fix go ci (#8039)
---
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../mtree/store/disk/schemafile/RecordUtils.java | 2 +-
.../store/disk/schemafile/WrappedSegment.java | 2 +-
.../impl/SchemaRegionPlanDeserializer.java | 4 ++--
.../db/mpp/plan/parser/StatementGenerator.java | 22 +++++++++++-----------
.../write/CreateAlignedTimeSeriesNode.java | 6 +++---
.../node/metedata/write/CreateTimeSeriesNode.java | 6 +++---
.../plan/node/metedata/write/MeasurementGroup.java | 6 +++---
.../db/qp/physical/sys/AppendTemplatePlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 8 ++++----
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 6 +++---
.../db/qp/physical/sys/CreateTemplatePlan.java | 7 ++++---
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 6 +++---
.../db/service/thrift/impl/TSServiceImpl.java | 8 ++++----
.../java/org/apache/iotdb/session/Session.java | 6 +++---
15 files changed, 47 insertions(+), 46 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogWriter.java b/server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogWriter.java
index b335a338d4..86e15ecde9 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogWriter.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogWriter.java
@@ -281,7 +281,7 @@ public class MLogWriter implements AutoCloseable {
words[1],
TSDataType.values()[Integer.parseInt(words[3])],
TSEncoding.values()[Integer.parseInt(words[4])],
- CompressionType.values()[Integer.parseInt(words[5])]));
+ CompressionType.deserialize((byte) Integer.parseInt(words[5]))));
case "1":
return new StorageGroupMNodePlan(
words[1], Long.parseLong(words[2]), Integer.parseInt(words[3]));
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/RecordUtils.java b/server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/RecordUtils.java
index 545bd3481d..6570ce1e33 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/RecordUtils.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/RecordUtils.java
@@ -353,7 +353,7 @@ public class RecordUtils {
nodeName,
TSDataType.values()[dataType],
TSEncoding.values()[encoding],
- CompressionType.values()[compressor]);
+ CompressionType.deserialize(compressor));
IMNode res = MeasurementMNode.getMeasurementMNode(null, nodeName, schema, alias);
res.getAsMeasurementMNode().setOffset(tagIndex);
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/WrappedSegment.java b/server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/WrappedSegment.java
index 4c599af1ef..55551d6104 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/WrappedSegment.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/WrappedSegment.java
@@ -422,7 +422,7 @@ public class WrappedSegment extends Segment<IMNode> {
pair.left,
TSDataType.values()[schemaBytes[0]],
TSEncoding.values()[schemaBytes[1]],
- CompressionType.values()[schemaBytes[2]],
+ CompressionType.deserialize(schemaBytes[2]),
RecordUtils.getRecordAlias(bufferR)));
} else {
throw new BufferUnderflowException();
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SchemaRegionPlanDeserializer.java b/server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SchemaRegionPlanDeserializer.java
index 95d9c76396..6588ebf2f9 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SchemaRegionPlanDeserializer.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SchemaRegionPlanDeserializer.java
@@ -185,7 +185,7 @@ public class SchemaRegionPlanDeserializer implements IDeserializer<ISchemaRegion
List<CompressionType> compressors = new ArrayList<>();
for (int i = 0; i < size; i++) {
- compressors.add(CompressionType.values()[buffer.get()]);
+ compressors.add(CompressionType.deserialize(buffer.get()));
}
createAlignedTimeSeriesPlan.setCompressors(compressors);
@@ -242,7 +242,7 @@ public class SchemaRegionPlanDeserializer implements IDeserializer<ISchemaRegion
createTimeSeriesPlan.setDataType(TSDataType.values()[buffer.get()]);
createTimeSeriesPlan.setEncoding(TSEncoding.values()[buffer.get()]);
- createTimeSeriesPlan.setCompressor(CompressionType.values()[buffer.get()]);
+ createTimeSeriesPlan.setCompressor(CompressionType.deserialize(buffer.get()));
createTimeSeriesPlan.setTagOffset(buffer.getLong());
// alias
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);
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java
index d3891e8b27..7e129fba26 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java
@@ -229,7 +229,7 @@ public class CreateAlignedTimeSeriesNode extends WritePlanNode
compressors = new ArrayList<>();
for (int i = 0; i < size; i++) {
- compressors.add(CompressionType.values()[byteBuffer.get()]);
+ compressors.add(CompressionType.deserialize(byteBuffer.get()));
}
byte label = byteBuffer.get();
@@ -321,7 +321,7 @@ public class CreateAlignedTimeSeriesNode extends WritePlanNode
// compressors
for (CompressionType compressor : compressors) {
- byteBuffer.put((byte) compressor.ordinal());
+ byteBuffer.put(compressor.serialize());
}
// alias
@@ -386,7 +386,7 @@ public class CreateAlignedTimeSeriesNode extends WritePlanNode
// compressors
for (CompressionType compressor : compressors) {
- stream.write((byte) compressor.ordinal());
+ stream.write(compressor.serialize());
}
// alias
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateTimeSeriesNode.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
index 0880ec2676..8903308d75 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
@@ -204,7 +204,7 @@ public class CreateTimeSeriesNode extends WritePlanNode implements ICreateTimeSe
}
dataType = TSDataType.values()[byteBuffer.get()];
encoding = TSEncoding.values()[byteBuffer.get()];
- compressor = CompressionType.values()[byteBuffer.get()];
+ compressor = CompressionType.deserialize(byteBuffer.get());
// alias
if (byteBuffer.get() == 1) {
@@ -249,7 +249,7 @@ public class CreateTimeSeriesNode extends WritePlanNode implements ICreateTimeSe
byteBuffer.put(bytes);
byteBuffer.put((byte) dataType.ordinal());
byteBuffer.put((byte) encoding.ordinal());
- byteBuffer.put((byte) compressor.ordinal());
+ byteBuffer.put(compressor.serialize());
// alias
if (alias != null) {
@@ -299,7 +299,7 @@ public class CreateTimeSeriesNode extends WritePlanNode implements ICreateTimeSe
stream.write(bytes);
stream.write((byte) dataType.ordinal());
stream.write((byte) encoding.ordinal());
- stream.write((byte) compressor.ordinal());
+ stream.write(compressor.serialize());
// alias
if (alias != null) {
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/MeasurementGroup.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/MeasurementGroup.java
index 3084844ab2..f5bd2ccc52 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/MeasurementGroup.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/MeasurementGroup.java
@@ -254,7 +254,7 @@ public class MeasurementGroup {
// compressors
for (CompressionType compressor : compressors) {
- byteBuffer.put((byte) compressor.ordinal());
+ byteBuffer.put(compressor.serialize());
}
// alias
@@ -313,7 +313,7 @@ public class MeasurementGroup {
// compressors
for (CompressionType compressor : compressors) {
- stream.write((byte) compressor.ordinal());
+ stream.write(compressor.serialize());
}
// alias
@@ -372,7 +372,7 @@ public class MeasurementGroup {
compressors = new ArrayList<>();
for (int i = 0; i < size; i++) {
- compressors.add(CompressionType.values()[byteBuffer.get()]);
+ compressors.add(CompressionType.deserialize(byteBuffer.get()));
}
byte label = byteBuffer.get();
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AppendTemplatePlan.java b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AppendTemplatePlan.java
index f185f00a88..691a537202 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AppendTemplatePlan.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AppendTemplatePlan.java
@@ -171,7 +171,7 @@ public class AppendTemplatePlan extends PhysicalPlan {
size = ReadWriteIOUtils.readInt(buffer);
compressors = new CompressionType[size];
for (int i = 0; i < size; i++) {
- compressors[i] = CompressionType.values()[ReadWriteIOUtils.readInt(buffer)];
+ compressors[i] = CompressionType.deserialize((byte) ReadWriteIOUtils.readInt(buffer));
}
this.index = buffer.getLong();
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
index 99af3ad2a4..c2810efe9d 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
@@ -215,7 +215,7 @@ public class CreateAlignedTimeSeriesPlan extends PhysicalPlan
stream.write(encoding.ordinal());
}
for (CompressionType compressor : compressors) {
- stream.write(compressor.ordinal());
+ stream.write(compressor.serialize());
}
if (tagOffsets == null) {
tagOffsets = new ArrayList<>();
@@ -282,7 +282,7 @@ public class CreateAlignedTimeSeriesPlan extends PhysicalPlan
buffer.put((byte) encoding.ordinal());
}
for (CompressionType compressor : compressors) {
- buffer.put((byte) compressor.ordinal());
+ buffer.put(compressor.serialize());
}
for (Long tagOffset : getTagOffsets()) {
buffer.putLong(tagOffset);
@@ -339,7 +339,7 @@ public class CreateAlignedTimeSeriesPlan extends PhysicalPlan
buffer.put((byte) encoding.ordinal());
}
for (CompressionType compressor : compressors) {
- buffer.put((byte) compressor.ordinal());
+ buffer.put(compressor.serialize());
}
// alias
@@ -383,7 +383,7 @@ public class CreateAlignedTimeSeriesPlan extends PhysicalPlan
}
compressors = new ArrayList<>();
for (int i = 0; i < size; i++) {
- compressors.add(CompressionType.values()[buffer.get()]);
+ compressors.add(CompressionType.deserialize(buffer.get()));
}
if (!isOldVersion) {
tagOffsets = new ArrayList<>();
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateMultiTimeSeriesPlan.java b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateMultiTimeSeriesPlan.java
index fb6f504ed0..fd6c9850e8 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateMultiTimeSeriesPlan.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateMultiTimeSeriesPlan.java
@@ -184,7 +184,7 @@ public class CreateMultiTimeSeriesPlan extends PhysicalPlan implements BatchPlan
}
for (CompressionType compressor : compressors) {
- stream.write(compressor.ordinal());
+ stream.write(compressor.serialize());
}
serializeOptional(stream);
@@ -242,7 +242,7 @@ public class CreateMultiTimeSeriesPlan extends PhysicalPlan implements BatchPlan
}
for (CompressionType compressor : compressors) {
- buffer.put((byte) compressor.ordinal());
+ buffer.put(compressor.serialize());
}
serializeOptional(buffer);
@@ -298,7 +298,7 @@ public class CreateMultiTimeSeriesPlan extends PhysicalPlan implements BatchPlan
}
compressors = new ArrayList<>(totalSize);
for (int i = 0; i < totalSize; i++) {
- compressors.add(CompressionType.values()[buffer.get()]);
+ compressors.add(CompressionType.deserialize(buffer.get()));
}
deserializeOptional(buffer, totalSize);
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTemplatePlan.java b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTemplatePlan.java
index 34059acd35..79fca5349a 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTemplatePlan.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTemplatePlan.java
@@ -221,7 +221,8 @@ public class CreateTemplatePlan extends PhysicalPlan {
String measurementName = ReadWriteIOUtils.readString(buffer);
TSDataType dataType = TSDataType.values()[ReadWriteIOUtils.readByte(buffer)];
TSEncoding encoding = TSEncoding.values()[ReadWriteIOUtils.readByte(buffer)];
- CompressionType compressionType = CompressionType.values()[ReadWriteIOUtils.readByte(buffer)];
+ CompressionType compressionType =
+ CompressionType.deserialize(ReadWriteIOUtils.readByte(buffer));
if (alignedPrefix.containsKey(prefix) && !isAlign) {
throw new MetadataException("Align designation incorrect at: " + prefix);
@@ -390,7 +391,7 @@ public class CreateTemplatePlan extends PhysicalPlan {
int listSize = ReadWriteIOUtils.readInt(buffer);
compressors[i] = new CompressionType[listSize];
for (int j = 0; j < listSize; j++) {
- compressors[i][j] = CompressionType.values()[ReadWriteIOUtils.readInt(buffer)];
+ compressors[i][j] = CompressionType.deserialize((byte) ReadWriteIOUtils.readInt(buffer));
}
}
} else {
@@ -400,7 +401,7 @@ public class CreateTemplatePlan extends PhysicalPlan {
int listSize = measurements[i].length;
compressors[i] = new CompressionType[listSize];
CompressionType alignedCompressionType =
- CompressionType.values()[ReadWriteIOUtils.readInt(buffer)];
+ CompressionType.deserialize((byte) ReadWriteIOUtils.readInt(buffer));
for (int j = 0; j < listSize; j++) {
compressors[i][j] = alignedCompressionType;
}
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTimeSeriesPlan.java b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTimeSeriesPlan.java
index c54d29d95f..08d8c5284e 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTimeSeriesPlan.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTimeSeriesPlan.java
@@ -180,7 +180,7 @@ public class CreateTimeSeriesPlan extends PhysicalPlan implements ICreateTimeSer
stream.write(bytes);
stream.write(dataType.ordinal());
stream.write(encoding.ordinal());
- stream.write(compressor.ordinal());
+ stream.write(compressor.serialize());
stream.writeLong(tagOffset);
// alias
@@ -226,7 +226,7 @@ public class CreateTimeSeriesPlan extends PhysicalPlan implements ICreateTimeSer
buffer.put(bytes);
buffer.put((byte) dataType.ordinal());
buffer.put((byte) encoding.ordinal());
- buffer.put((byte) compressor.ordinal());
+ buffer.put(compressor.serialize());
buffer.putLong(tagOffset);
// alias
@@ -272,7 +272,7 @@ public class CreateTimeSeriesPlan extends PhysicalPlan implements ICreateTimeSer
path = new PartialPath(new String(bytes));
dataType = TSDataType.values()[buffer.get()];
encoding = TSEncoding.values()[buffer.get()];
- compressor = CompressionType.values()[buffer.get()];
+ compressor = CompressionType.deserialize(buffer.get());
tagOffset = buffer.getLong();
// alias
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
index b217450312..995d597188 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
@@ -1108,7 +1108,7 @@ public class TSServiceImpl implements IClientRPCServiceWithHandler {
new PartialPath(req.path),
TSDataType.values()[req.dataType],
TSEncoding.values()[req.encoding],
- CompressionType.values()[req.compressor],
+ CompressionType.deserialize((byte) req.compressor),
req.props,
req.tags,
req.attributes,
@@ -1154,7 +1154,7 @@ public class TSServiceImpl implements IClientRPCServiceWithHandler {
}
List<CompressionType> compressors = new ArrayList<>();
for (int compressor : req.compressors) {
- compressors.add(CompressionType.values()[compressor]);
+ compressors.add(CompressionType.deserialize((byte) compressor));
}
CreateAlignedTimeSeriesPlan plan =
@@ -1230,7 +1230,7 @@ public class TSServiceImpl implements IClientRPCServiceWithHandler {
}
paths.add(new PartialPath(req.paths.get(i)));
- compressors.add(CompressionType.values()[req.compressors.get(i)]);
+ compressors.add(CompressionType.deserialize(req.compressors.get(i).byteValue()));
if (alias != null) {
alias.add(req.measurementAliasList.get(i));
}
@@ -1346,7 +1346,7 @@ public class TSServiceImpl implements IClientRPCServiceWithHandler {
measurements[i] = req.getMeasurements().get(i);
dataTypes[i] = TSDataType.values()[req.getDataTypes().get(i)];
encodings[i] = TSEncoding.values()[req.getEncodings().get(i)];
- compressionTypes[i] = CompressionType.values()[req.getCompressors().get(i)];
+ compressionTypes[i] = CompressionType.deserialize(req.getCompressors().get(i).byteValue());
}
AppendTemplatePlan plan =
diff --git a/session/src/main/java/org/apache/iotdb/session/Session.java b/session/src/main/java/org/apache/iotdb/session/Session.java
index e04aa8af03..5d78893b64 100644
--- a/session/src/main/java/org/apache/iotdb/session/Session.java
+++ b/session/src/main/java/org/apache/iotdb/session/Session.java
@@ -522,7 +522,7 @@ public class Session implements ISession {
request.setPath(path);
request.setDataType(dataType.ordinal());
request.setEncoding(encoding.ordinal());
- request.setCompressor(compressor.ordinal());
+ request.setCompressor(compressor.serialize());
request.setProps(props);
request.setTags(tags);
request.setAttributes(attributes);
@@ -3003,7 +3003,7 @@ public class Session implements ISession {
req.setMeasurements(Collections.singletonList(measurementPath));
req.setDataTypes(Collections.singletonList(dataType.ordinal()));
req.setEncodings(Collections.singletonList(encoding.ordinal()));
- req.setCompressors(Collections.singletonList(compressor.ordinal()));
+ req.setCompressors(Collections.singletonList((int) compressor.serialize()));
req.setIsAligned(true);
defaultSessionConnection.appendSchemaTemplate(req);
}
@@ -3048,7 +3048,7 @@ public class Session implements ISession {
req.setMeasurements(Collections.singletonList(measurementPath));
req.setDataTypes(Collections.singletonList(dataType.ordinal()));
req.setEncodings(Collections.singletonList(encoding.ordinal()));
- req.setCompressors(Collections.singletonList(compressor.ordinal()));
+ req.setCompressors(Collections.singletonList((int) compressor.serialize()));
req.setIsAligned(false);
defaultSessionConnection.appendSchemaTemplate(req);
}