You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yu...@apache.org on 2020/11/01 08:21:40 UTC

[iotdb] branch kyy updated: create (multi)timeseries plan toString()

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

yuyuankang pushed a commit to branch kyy
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/kyy by this push:
     new 3e4d958  create (multi)timeseries plan toString()
3e4d958 is described below

commit 3e4d958eac5866c55e7261049ff4a9468ed20912
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Sun Nov 1 16:21:10 2020 +0800

    create (multi)timeseries plan toString()
---
 .../db/qp/physical/sys/CreateMultiTimeSeriesPlan.java   | 17 +++++++++++++----
 .../iotdb/db/qp/physical/sys/CreateTimeSeriesPlan.java  |  2 +-
 2 files changed, 14 insertions(+), 5 deletions(-)

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 8ae4a65..bc354e6 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
@@ -36,9 +36,11 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
 import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
 
 /**
- * create multiple timeSeries, could be split to several sub Plans to execute in different DataGroup
+ * create multiple timeSeries, could be split to several sub Plans to execute in different
+ * DataGroup
  */
 public class CreateMultiTimeSeriesPlan extends PhysicalPlan {
+
   private List<PartialPath> paths;
   private List<TSDataType> dataTypes;
   private List<TSEncoding> encodings;
@@ -59,6 +61,12 @@ public class CreateMultiTimeSeriesPlan extends PhysicalPlan {
   }
 
   @Override
+  public String toString() {
+    return String.format("CreateMultiTimeseriesPlan: seriesPaths: %s, resultDataTypes: %s, encodings: %s, compressions: %s", paths,
+        dataTypes, encodings, compressors);
+  }
+
+  @Override
   public List<PartialPath> getPaths() {
     return paths;
   }
@@ -312,6 +320,7 @@ public class CreateMultiTimeSeriesPlan extends PhysicalPlan {
 
     this.index = buffer.getLong();
   }
+
   @Override
   public boolean equals(Object o) {
     if (this == o) {
@@ -322,9 +331,9 @@ public class CreateMultiTimeSeriesPlan extends PhysicalPlan {
     }
     CreateMultiTimeSeriesPlan that = (CreateMultiTimeSeriesPlan) o;
     return Objects.equals(paths, that.paths) &&
-        Objects.equals(dataTypes,that.dataTypes) &&
-        Objects.equals(encodings,that.encodings) &&
-        Objects.equals(compressors,that.compressors);
+        Objects.equals(dataTypes, that.dataTypes) &&
+        Objects.equals(encodings, that.encodings) &&
+        Objects.equals(compressors, that.compressors);
   }
 
   @Override
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 41e2807..ed18fdb 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
@@ -131,7 +131,7 @@ public class CreateTimeSeriesPlan extends PhysicalPlan {
 
   @Override
   public String toString() {
-    return String.format("seriesPath: %s, resultDataType: %s, encoding: %s, compression: %s", path,
+    return String.format("CreateTimeseriesPlan: seriesPath: %s, resultDataType: %s, encoding: %s, compression: %s", path,
         dataType, encoding, compressor);
   }