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);
}