haimeiguo commented on a change in pull request #2087:
URL: https://github.com/apache/iotdb/pull/2087#discussion_r528452627
##########
File path:
tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkWriterImpl.java
##########
@@ -97,18 +109,93 @@ public ChunkWriterImpl(MeasurementSchema schema) {
this.pageWriter = new PageWriter(measurementSchema);
this.pageWriter.setTimeEncoder(measurementSchema.getTimeEncoder());
this.pageWriter.setValueEncoder(measurementSchema.getValueEncoder());
+
+ //check if the measurement schema uses SDT
+ checkSdtEncoding();
+ }
+
+ public ChunkWriterImpl(MeasurementSchema schema, boolean isMerging) {
+ this(schema);
+ this.isMerging = isMerging;
+ }
+
+ private void checkSdtEncoding() {
+ if (measurementSchema.getProps() != null && !isMerging) {
+ for (Map.Entry<String, String> entry :
measurementSchema.getProps().entrySet()) {
Review comment:
will do. thank you.
For "The paper calculate the FV of the next segment but you just use the
endPoint of the last segment.", what do you mean by that? When ending segment0
and starting segment1, I use segment0's endpoint as segment1's startpoint. How
do you calculate segment1's first value..?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
