You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by wa...@apache.org on 2022/04/26 10:29:31 UTC
[iotdb] branch master updated: [IOTDB-2803]fix some UT code smell and refine plannode serialize (#5667)
This is an automated email from the ASF dual-hosted git repository.
wangchao316 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 90d417fe7b [IOTDB-2803]fix some UT code smell and refine plannode serialize (#5667)
90d417fe7b is described below
commit 90d417fe7b63165b20c2ea0c4b8068ede39616a7
Author: Yifu Zhou <ef...@outlook.com>
AuthorDate: Tue Apr 26 18:29:26 2022 +0800
[IOTDB-2803]fix some UT code smell and refine plannode serialize (#5667)
[IOTDB-2803]fix some UT code smell and refine plannode serialize (#5667)
---
.../node/metedata/write/AlterTimeSeriesNode.java | 99 +++++++--------
.../write/CreateAlignedTimeSeriesNode.java | 135 ++++++++++-----------
.../node/metedata/write/CreateTimeSeriesNode.java | 14 +--
.../db/mpp/sql/plan/DistributionPlannerTest.java | 16 +--
.../db/mpp/sql/plan/FragmentInstanceIdTest.java | 2 +-
.../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 4 +-
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 23 ++--
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 2 +-
.../read/DeviceSchemaScanNodeSerdeTest.java | 2 +-
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 2 +-
.../plan/node/process/AggregateNodeSerdeTest.java | 2 +-
.../node/process/DeviceMergeNodeSerdeTest.java | 2 +-
.../plan/node/process/ExchangeNodeSerdeTest.java | 2 +-
.../sql/plan/node/process/FillNodeSerdeTest.java | 2 +-
.../sql/plan/node/process/FilterNodeSerdeTest.java | 2 +-
.../plan/node/process/FilterNullNodeSerdeTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 2 +-
.../sql/plan/node/process/LimitNodeSerdeTest.java | 2 +-
.../sql/plan/node/process/OffsetNodeSerdeTest.java | 4 +-
.../sql/plan/node/process/SortNodeSerdeTest.java | 2 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 2 +-
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 2 +-
.../source/SeriesAggregateScanNodeSerdeTest.java | 2 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 2 +-
.../plan/node/write/InsertRowNodeSerdeTest.java | 2 +-
.../plan/node/write/InsertTabletNodeSerdeTest.java | 2 +-
.../iotdb/db/service/InternalServiceImplTest.java | 4 +-
27 files changed, 157 insertions(+), 180 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AlterTimeSeriesNode.java b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AlterTimeSeriesNode.java
index 2df87c8b44..08cfd01fe8 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AlterTimeSeriesNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AlterTimeSeriesNode.java
@@ -153,57 +153,6 @@ public class AlterTimeSeriesNode extends PlanNode {
return null;
}
- @Override
- public void serialize(ByteBuffer byteBuffer) {
- byteBuffer.putShort((short) PlanNodeType.ALTER_TIME_SERIES.ordinal());
- ReadWriteIOUtils.write(this.getPlanNodeId().getId(), byteBuffer);
- byte[] bytes = path.getFullPath().getBytes();
- byteBuffer.putInt(bytes.length);
- byteBuffer.put(bytes);
- byteBuffer.put((byte) alterType.ordinal());
-
- // alias
- if (alias != null) {
- byteBuffer.put((byte) 1);
- ReadWriteIOUtils.write(alias, byteBuffer);
- } else {
- byteBuffer.put((byte) 0);
- }
-
- // alterMap
- if (alterMap == null) {
- byteBuffer.put((byte) -1);
- } else if (alterMap.isEmpty()) {
- byteBuffer.put((byte) 0);
- } else {
- byteBuffer.put((byte) 1);
- ReadWriteIOUtils.write(alterMap, byteBuffer);
- }
-
- // tagsMap
- if (tagsMap == null) {
- byteBuffer.put((byte) -1);
- } else if (tagsMap.isEmpty()) {
- byteBuffer.put((byte) 0);
- } else {
- byteBuffer.put((byte) 1);
- ReadWriteIOUtils.write(tagsMap, byteBuffer);
- }
-
- // attributesMap
- if (attributesMap == null) {
- byteBuffer.put((byte) -1);
- } else if (attributesMap.isEmpty()) {
- byteBuffer.put((byte) 0);
- } else {
- byteBuffer.put((byte) 1);
- ReadWriteIOUtils.write(attributesMap, byteBuffer);
- }
-
- // no children node, need to set 0
- byteBuffer.putInt(0);
- }
-
public static AlterTimeSeriesNode deserialize(ByteBuffer byteBuffer) {
String id;
PartialPath path = null;
@@ -213,7 +162,6 @@ public class AlterTimeSeriesNode extends PlanNode {
Map<String, String> tagsMap = null;
Map<String, String> attributesMap = null;
- id = ReadWriteIOUtils.readString(byteBuffer);
int length = byteBuffer.getInt();
byte[] bytes = new byte[length];
byteBuffer.get(bytes);
@@ -252,6 +200,8 @@ public class AlterTimeSeriesNode extends PlanNode {
} else if (label == 1) {
attributesMap = ReadWriteIOUtils.readMap(byteBuffer);
}
+
+ id = ReadWriteIOUtils.readString(byteBuffer);
return new AlterTimeSeriesNode(
new PlanNodeId(id), path, alterType, alterMap, alias, tagsMap, attributesMap);
}
@@ -263,8 +213,49 @@ public class AlterTimeSeriesNode extends PlanNode {
@Override
protected void serializeAttributes(ByteBuffer byteBuffer) {
- throw new NotImplementedException(
- "serializeAttributes of AlterTimeSeriesNode is not implemented");
+ PlanNodeType.ALTER_TIME_SERIES.serialize(byteBuffer);
+ byte[] bytes = path.getFullPath().getBytes();
+ byteBuffer.putInt(bytes.length);
+ byteBuffer.put(bytes);
+ byteBuffer.put((byte) alterType.ordinal());
+
+ // alias
+ if (alias != null) {
+ byteBuffer.put((byte) 1);
+ ReadWriteIOUtils.write(alias, byteBuffer);
+ } else {
+ byteBuffer.put((byte) 0);
+ }
+
+ // alterMap
+ if (alterMap == null) {
+ byteBuffer.put((byte) -1);
+ } else if (alterMap.isEmpty()) {
+ byteBuffer.put((byte) 0);
+ } else {
+ byteBuffer.put((byte) 1);
+ ReadWriteIOUtils.write(alterMap, byteBuffer);
+ }
+
+ // tagsMap
+ if (tagsMap == null) {
+ byteBuffer.put((byte) -1);
+ } else if (tagsMap.isEmpty()) {
+ byteBuffer.put((byte) 0);
+ } else {
+ byteBuffer.put((byte) 1);
+ ReadWriteIOUtils.write(tagsMap, byteBuffer);
+ }
+
+ // attributesMap
+ if (attributesMap == null) {
+ byteBuffer.put((byte) -1);
+ } else if (attributesMap.isEmpty()) {
+ byteBuffer.put((byte) 0);
+ } else {
+ byteBuffer.put((byte) 1);
+ ReadWriteIOUtils.write(attributesMap, byteBuffer);
+ }
}
public boolean equals(Object o) {
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java
index d90e79f8c9..90bf6a934c 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java
@@ -180,75 +180,6 @@ public class CreateAlignedTimeSeriesNode extends PlanNode {
return visitor.visitCreateAlignedTimeSeries(this, schemaRegion);
}
- @Override
- public void serialize(ByteBuffer byteBuffer) {
- byteBuffer.putShort((short) PlanNodeType.CREATE_ALIGNED_TIME_SERIES.ordinal());
- ReadWriteIOUtils.write(this.getPlanNodeId().getId(), byteBuffer);
- byte[] bytes = devicePath.getFullPath().getBytes();
- byteBuffer.putInt(bytes.length);
- byteBuffer.put(bytes);
-
- // measurements
- byteBuffer.putInt(measurements.size());
- for (String measurement : measurements) {
- ReadWriteIOUtils.write(measurement, byteBuffer);
- }
-
- // dataTypes
- for (TSDataType dataType : dataTypes) {
- byteBuffer.put((byte) dataType.ordinal());
- }
-
- // encodings
- for (TSEncoding encoding : encodings) {
- byteBuffer.put((byte) encoding.ordinal());
- }
-
- // compressors
- for (CompressionType compressor : compressors) {
- byteBuffer.put((byte) compressor.ordinal());
- }
-
- // alias
- if (aliasList == null) {
- byteBuffer.put((byte) -1);
- } else if (aliasList.isEmpty()) {
- byteBuffer.put((byte) 0);
- } else {
- byteBuffer.put((byte) 1);
- for (String alias : aliasList) {
- ReadWriteIOUtils.write(alias, byteBuffer);
- }
- }
-
- // tags
- if (tagsList == null) {
- byteBuffer.put((byte) -1);
- } else if (tagsList.isEmpty()) {
- byteBuffer.put((byte) 0);
- } else {
- byteBuffer.put((byte) 1);
- for (Map<String, String> tags : tagsList) {
- ReadWriteIOUtils.write(tags, byteBuffer);
- }
- }
-
- // attributes
- if (attributesList == null) {
- byteBuffer.put((byte) -1);
- } else if (attributesList.isEmpty()) {
- byteBuffer.put((byte) 0);
- } else {
- byteBuffer.put((byte) 1);
- for (Map<String, String> attributes : attributesList) {
- ReadWriteIOUtils.write(attributes, byteBuffer);
- }
- }
-
- // no children node, need to set 0
- byteBuffer.putInt(0);
- }
-
public static CreateAlignedTimeSeriesNode deserialize(ByteBuffer byteBuffer) {
String id;
PartialPath devicePath = null;
@@ -260,7 +191,6 @@ public class CreateAlignedTimeSeriesNode extends PlanNode {
List<Map<String, String>> tagsList = null;
List<Map<String, String>> attributesList = null;
- id = ReadWriteIOUtils.readString(byteBuffer);
int length = byteBuffer.getInt();
byte[] bytes = new byte[length];
byteBuffer.get(bytes);
@@ -321,6 +251,8 @@ public class CreateAlignedTimeSeriesNode extends PlanNode {
}
}
+ id = ReadWriteIOUtils.readString(byteBuffer);
+
return new CreateAlignedTimeSeriesNode(
new PlanNodeId(id),
devicePath,
@@ -356,8 +288,67 @@ public class CreateAlignedTimeSeriesNode extends PlanNode {
@Override
protected void serializeAttributes(ByteBuffer byteBuffer) {
- throw new NotImplementedException(
- "serializeAttributes of CreateAlignedTimeSeriesNode is not implemented");
+ PlanNodeType.CREATE_ALIGNED_TIME_SERIES.serialize(byteBuffer);
+ byte[] bytes = devicePath.getFullPath().getBytes();
+ byteBuffer.putInt(bytes.length);
+ byteBuffer.put(bytes);
+
+ // measurements
+ byteBuffer.putInt(measurements.size());
+ for (String measurement : measurements) {
+ ReadWriteIOUtils.write(measurement, byteBuffer);
+ }
+
+ // dataTypes
+ for (TSDataType dataType : dataTypes) {
+ byteBuffer.put((byte) dataType.ordinal());
+ }
+
+ // encodings
+ for (TSEncoding encoding : encodings) {
+ byteBuffer.put((byte) encoding.ordinal());
+ }
+
+ // compressors
+ for (CompressionType compressor : compressors) {
+ byteBuffer.put((byte) compressor.ordinal());
+ }
+
+ // alias
+ if (aliasList == null) {
+ byteBuffer.put((byte) -1);
+ } else if (aliasList.isEmpty()) {
+ byteBuffer.put((byte) 0);
+ } else {
+ byteBuffer.put((byte) 1);
+ for (String alias : aliasList) {
+ ReadWriteIOUtils.write(alias, byteBuffer);
+ }
+ }
+
+ // tags
+ if (tagsList == null) {
+ byteBuffer.put((byte) -1);
+ } else if (tagsList.isEmpty()) {
+ byteBuffer.put((byte) 0);
+ } else {
+ byteBuffer.put((byte) 1);
+ for (Map<String, String> tags : tagsList) {
+ ReadWriteIOUtils.write(tags, byteBuffer);
+ }
+ }
+
+ // attributes
+ if (attributesList == null) {
+ byteBuffer.put((byte) -1);
+ } else if (attributesList.isEmpty()) {
+ byteBuffer.put((byte) 0);
+ } else {
+ byteBuffer.put((byte) 1);
+ for (Map<String, String> attributes : attributesList) {
+ ReadWriteIOUtils.write(attributes, byteBuffer);
+ }
+ }
}
public int hashCode() {
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateTimeSeriesNode.java b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
index dcbea17148..cc1121a6d2 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
@@ -198,7 +198,6 @@ public class CreateTimeSeriesNode extends WritePlanNode {
Map<String, String> tags = null;
Map<String, String> attributes = null;
- id = ReadWriteIOUtils.readString(byteBuffer);
int length = byteBuffer.getInt();
byte[] bytes = new byte[length];
byteBuffer.get(bytes);
@@ -241,14 +240,15 @@ public class CreateTimeSeriesNode extends WritePlanNode {
attributes = ReadWriteIOUtils.readMap(byteBuffer);
}
+ id = ReadWriteIOUtils.readString(byteBuffer);
return new CreateTimeSeriesNode(
new PlanNodeId(id), path, dataType, encoding, compressor, props, tags, attributes, alias);
}
@Override
- public void serialize(ByteBuffer byteBuffer) {
- byteBuffer.putShort((short) PlanNodeType.CREATE_TIME_SERIES.ordinal());
- ReadWriteIOUtils.write(this.getPlanNodeId().getId(), byteBuffer);
+ protected void serializeAttributes(ByteBuffer byteBuffer) {
+ PlanNodeType.CREATE_TIME_SERIES.serialize(byteBuffer);
+
byte[] bytes = path.getFullPath().getBytes();
byteBuffer.putInt(bytes.length);
byteBuffer.put(bytes);
@@ -294,14 +294,8 @@ public class CreateTimeSeriesNode extends WritePlanNode {
byteBuffer.put((byte) 1);
ReadWriteIOUtils.write(attributes, byteBuffer);
}
-
- // no children node, need to set 0
- byteBuffer.putInt(0);
}
- @Override
- protected void serializeAttributes(ByteBuffer byteBuffer) {}
-
@Override
public <R, C> R accept(PlanVisitor<R, C> visitor, C schemaRegion) {
return visitor.visitCreateTimeSeries(this, schemaRegion);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java
index 08d80476cb..8aab414107 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java
@@ -69,7 +69,7 @@ import static org.junit.Assert.assertEquals;
public class DistributionPlannerTest {
@Test
- public void TestSingleSeriesScan() throws IllegalPathException {
+ public void testSingleSeriesScan() throws IllegalPathException {
QueryId queryId = new QueryId("test_query");
SeriesScanNode root =
new SeriesScanNode(
@@ -89,7 +89,7 @@ public class DistributionPlannerTest {
}
@Test
- public void TestSingleSeriesScanRewriteSource() throws IllegalPathException {
+ public void testSingleSeriesScanRewriteSource() throws IllegalPathException {
QueryId queryId = new QueryId("test_query");
SeriesScanNode root =
new SeriesScanNode(
@@ -108,7 +108,7 @@ public class DistributionPlannerTest {
}
@Test
- public void TestRewriteSourceNode() throws IllegalPathException {
+ public void testRewriteSourceNode() throws IllegalPathException {
QueryId queryId = new QueryId("test_query");
TimeJoinNode timeJoinNode = new TimeJoinNode(queryId.genPlanNodeId(), OrderBy.TIMESTAMP_ASC);
@@ -190,7 +190,7 @@ public class DistributionPlannerTest {
}
@Test
- public void TestAddExchangeNode() throws IllegalPathException {
+ public void testAddExchangeNode() throws IllegalPathException {
QueryId queryId = new QueryId("test_query");
TimeJoinNode timeJoinNode = new TimeJoinNode(queryId.genPlanNodeId(), OrderBy.TIMESTAMP_ASC);
@@ -230,7 +230,7 @@ public class DistributionPlannerTest {
}
@Test
- public void TestSplitFragment() throws IllegalPathException {
+ public void testSplitFragment() throws IllegalPathException {
QueryId queryId = new QueryId("test_query");
TimeJoinNode timeJoinNode = new TimeJoinNode(queryId.genPlanNodeId(), OrderBy.TIMESTAMP_ASC);
@@ -267,7 +267,7 @@ public class DistributionPlannerTest {
}
@Test
- public void TestParallelPlan() throws IllegalPathException {
+ public void testParallelPlan() throws IllegalPathException {
QueryId queryId = new QueryId("test_query");
TimeJoinNode timeJoinNode = new TimeJoinNode(queryId.genPlanNodeId(), OrderBy.TIMESTAMP_ASC);
@@ -302,7 +302,7 @@ public class DistributionPlannerTest {
}
@Test
- public void TestInsertRowNodeParallelPlan() throws IllegalPathException {
+ public void testInsertRowNodeParallelPlan() throws IllegalPathException {
QueryId queryId = new QueryId("test_write");
InsertRowNode insertRowNode =
new InsertRowNode(
@@ -328,7 +328,7 @@ public class DistributionPlannerTest {
}
@Test
- public void TestInsertRowsNodeParallelPlan() throws IllegalPathException {
+ public void testInsertRowsNodeParallelPlan() throws IllegalPathException {
QueryId queryId = new QueryId("test_write");
InsertRowNode insertRowNode1 =
new InsertRowNode(
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceIdTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceIdTest.java
index e3b02b8f03..e06418df5a 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceIdTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceIdTest.java
@@ -27,7 +27,7 @@ import org.junit.Test;
public class FragmentInstanceIdTest {
@Test
- public void TestFromThrift() {
+ public void testFromThrift() {
String queryId = "test_query";
TFragmentInstanceId tId = new TFragmentInstanceId(queryId, 1, "0");
FragmentInstanceId id = FragmentInstanceId.fromThrift(tId);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceSerdeTest.java
index ddc4945f87..0779afe4b2 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceSerdeTest.java
@@ -57,7 +57,7 @@ import static org.junit.Assert.assertEquals;
public class FragmentInstanceSerdeTest {
@Test
- public void TestSerializeAndDeserializeForTree1() throws IllegalPathException {
+ public void testSerializeAndDeserializeForTree1() throws IllegalPathException {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setExternalEndPoint(new TEndPoint("0.0.0.0", 6667));
@@ -86,7 +86,7 @@ public class FragmentInstanceSerdeTest {
}
@Test
- public void TestSerializeAndDeserializeWithNullFilter() throws IllegalPathException {
+ public void testSerializeAndDeserializeWithNullFilter() throws IllegalPathException {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setExternalEndPoint(new TEndPoint("0.0.0.0", 6667));
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlannerTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlannerTest.java
index 1c87095810..e8d5f0ec65 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlannerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlannerTest.java
@@ -28,6 +28,7 @@ import org.apache.iotdb.db.mpp.sql.analyze.Analyzer;
import org.apache.iotdb.db.mpp.sql.analyze.FakePartitionFetcherImpl;
import org.apache.iotdb.db.mpp.sql.analyze.FakeSchemaFetcherImpl;
import org.apache.iotdb.db.mpp.sql.parser.StatementGenerator;
+import org.apache.iotdb.db.mpp.sql.plan.node.PlanNodeDeserializeHelper;
import org.apache.iotdb.db.mpp.sql.planner.LogicalPlanner;
import org.apache.iotdb.db.mpp.sql.planner.plan.node.PlanNode;
import org.apache.iotdb.db.mpp.sql.planner.plan.node.PlanNodeType;
@@ -63,14 +64,14 @@ public class LogicalPlannerTest {
@Test
@Ignore // TODO: @zyk implement getBelongedStorageGroup() in SchemaTree
- public void queryPlanTest() {
+ public void testQueryPlan() {
for (String sql : querySQLs) {
Assert.assertEquals(sqlToPlanMap.get(sql), parseSQLToPlanNode(sql));
}
}
@Test
- public void createTimeseriesPlanTest() {
+ public void testCreateTimeseriesPlan() {
String sql =
"CREATE TIMESERIES root.ln.wf01.wt01.status(状态) BOOLEAN ENCODING=PLAIN COMPRESSOR=SNAPPY TAGS(tag1=v1, tag2=v2) ATTRIBUTES(attr1=v1, attr2=v2)";
try {
@@ -105,7 +106,7 @@ public class LogicalPlannerTest {
}
@Test
- public void createAlignedTimeseriesPlanTest() {
+ public void testCreateAlignedTimeseriesPlan() {
String sql =
"CREATE ALIGNED TIMESERIES root.ln.wf01.GPS(latitude(meter1) FLOAT encoding=PLAIN compressor=SNAPPY tags(tag1=t1) attributes(attr1=a1), longitude FLOAT encoding=PLAIN compressor=SNAPPY)";
try {
@@ -179,7 +180,7 @@ public class LogicalPlannerTest {
byteBuffer.flip();
CreateAlignedTimeSeriesNode createAlignedTimeSeriesNode1 =
- (CreateAlignedTimeSeriesNode) PlanNodeType.deserialize(byteBuffer);
+ (CreateAlignedTimeSeriesNode) PlanNodeDeserializeHelper.deserialize(byteBuffer);
Assert.assertTrue(createAlignedTimeSeriesNode.equals(createAlignedTimeSeriesNode1));
} catch (IllegalPathException e) {
e.printStackTrace();
@@ -188,7 +189,7 @@ public class LogicalPlannerTest {
}
@Test
- public void alterTimeseriesPlanTest() {
+ public void testAlterTimeseriesPlan() {
String sql = "ALTER timeseries root.turbine.d1.s1 RENAME tag1 TO newTag1";
try {
AlterTimeSeriesNode alterTimeSeriesNode = (AlterTimeSeriesNode) parseSQLToPlanNode(sql);
@@ -210,7 +211,7 @@ public class LogicalPlannerTest {
byteBuffer.flip();
AlterTimeSeriesNode alterTimeSeriesNode1 =
- (AlterTimeSeriesNode) PlanNodeType.deserialize(byteBuffer);
+ (AlterTimeSeriesNode) PlanNodeDeserializeHelper.deserialize(byteBuffer);
Assert.assertTrue(alterTimeSeriesNode.equals(alterTimeSeriesNode1));
} catch (IllegalPathException e) {
e.printStackTrace();
@@ -239,7 +240,7 @@ public class LogicalPlannerTest {
byteBuffer.flip();
AlterTimeSeriesNode alterTimeSeriesNode1 =
- (AlterTimeSeriesNode) PlanNodeType.deserialize(byteBuffer);
+ (AlterTimeSeriesNode) PlanNodeDeserializeHelper.deserialize(byteBuffer);
Assert.assertTrue(alterTimeSeriesNode.equals(alterTimeSeriesNode1));
} catch (IllegalPathException e) {
e.printStackTrace();
@@ -268,7 +269,7 @@ public class LogicalPlannerTest {
byteBuffer.flip();
AlterTimeSeriesNode alterTimeSeriesNode1 =
- (AlterTimeSeriesNode) PlanNodeType.deserialize(byteBuffer);
+ (AlterTimeSeriesNode) PlanNodeDeserializeHelper.deserialize(byteBuffer);
Assert.assertTrue(alterTimeSeriesNode.equals(alterTimeSeriesNode1));
} catch (IllegalPathException e) {
e.printStackTrace();
@@ -297,7 +298,7 @@ public class LogicalPlannerTest {
byteBuffer.flip();
AlterTimeSeriesNode alterTimeSeriesNode1 =
- (AlterTimeSeriesNode) PlanNodeType.deserialize(byteBuffer);
+ (AlterTimeSeriesNode) PlanNodeDeserializeHelper.deserialize(byteBuffer);
Assert.assertTrue(alterTimeSeriesNode.equals(alterTimeSeriesNode1));
} catch (IllegalPathException e) {
e.printStackTrace();
@@ -326,7 +327,7 @@ public class LogicalPlannerTest {
byteBuffer.flip();
AlterTimeSeriesNode alterTimeSeriesNode1 =
- (AlterTimeSeriesNode) PlanNodeType.deserialize(byteBuffer);
+ (AlterTimeSeriesNode) PlanNodeDeserializeHelper.deserialize(byteBuffer);
Assert.assertTrue(alterTimeSeriesNode.equals(alterTimeSeriesNode1));
} catch (IllegalPathException e) {
e.printStackTrace();
@@ -364,7 +365,7 @@ public class LogicalPlannerTest {
byteBuffer.flip();
AlterTimeSeriesNode alterTimeSeriesNode1 =
- (AlterTimeSeriesNode) PlanNodeType.deserialize(byteBuffer);
+ (AlterTimeSeriesNode) PlanNodeDeserializeHelper.deserialize(byteBuffer);
Assert.assertTrue(alterTimeSeriesNode.equals(alterTimeSeriesNode1));
} catch (IllegalPathException e) {
e.printStackTrace();
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryPlannerTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryPlannerTest.java
index f10596f775..7640a45224 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryPlannerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryPlannerTest.java
@@ -41,7 +41,7 @@ public class QueryPlannerTest {
@Ignore
@Test
- public void TestSqlToDistributedPlan() {
+ public void testSqlToDistributedPlan() {
String querySql = "SELECT d1.*, d333.s1 FROM root.sg LIMIT 10";
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java
index 185ba5a4bc..166150ffb8 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java
@@ -40,7 +40,7 @@ import java.nio.ByteBuffer;
public class DeviceSchemaScanNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
OffsetNode offsetNode = new OffsetNode(new PlanNodeId("offset"), 10);
LimitNode limitNode = new LimitNode(new PlanNodeId("limit"), 10);
SchemaMergeNode schemaMergeNode = new SchemaMergeNode(new PlanNodeId("schemaMerge"));
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java
index e3c49ffa92..5d322a751f 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java
@@ -40,7 +40,7 @@ import java.nio.ByteBuffer;
public class TimeSeriesSchemaScanNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
OffsetNode offsetNode = new OffsetNode(new PlanNodeId("offset"), 10);
LimitNode limitNode = new LimitNode(new PlanNodeId("limit"), 10);
SchemaMergeNode schemaMergeNode = new SchemaMergeNode(new PlanNodeId("schemaMerge"));
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java
index 4f1c52508d..54f576385e 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java
@@ -46,7 +46,7 @@ import static org.junit.Assert.assertEquals;
public class AggregateNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
Map<PartialPath, Set<AggregationType>> aggregateFuncMap = new HashMap<>();
Set<AggregationType> aggregationTypes = new HashSet<>();
aggregationTypes.add(AggregationType.MAX_TIME);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/DeviceMergeNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/DeviceMergeNodeSerdeTest.java
index fcf3221a9f..579db3d152 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/DeviceMergeNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/DeviceMergeNodeSerdeTest.java
@@ -47,7 +47,7 @@ import static org.junit.Assert.assertEquals;
public class DeviceMergeNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
Map<PartialPath, Set<AggregationType>> aggregateFuncMap = new HashMap<>();
Set<AggregationType> aggregationTypes = new HashSet<>();
aggregationTypes.add(AggregationType.MAX_TIME);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/ExchangeNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/ExchangeNodeSerdeTest.java
index ae25b60799..4010640da6 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/ExchangeNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/ExchangeNodeSerdeTest.java
@@ -53,7 +53,7 @@ import static org.junit.Assert.assertEquals;
public class ExchangeNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
Map<PartialPath, Set<AggregationType>> aggregateFuncMap = new HashMap<>();
Set<AggregationType> aggregationTypes = new HashSet<>();
aggregationTypes.add(AggregationType.MAX_TIME);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FillNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FillNodeSerdeTest.java
index 55a4ebc2fd..19f1e5dc7c 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FillNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FillNodeSerdeTest.java
@@ -50,7 +50,7 @@ import static org.junit.Assert.assertEquals;
public class FillNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FillNode fillNode = new FillNode(new PlanNodeId("TestFillNode"), FillPolicy.PREVIOUS);
DeviceMergeNode deviceMergeNode =
new DeviceMergeNode(new PlanNodeId("TestDeviceMergeNode"), OrderBy.TIMESTAMP_ASC);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNodeSerdeTest.java
index 686f8ce8bc..2c796cbbb7 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNodeSerdeTest.java
@@ -55,7 +55,7 @@ import static org.junit.Assert.assertEquals;
public class FilterNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FilterNode filterNode =
new FilterNode(
new PlanNodeId("TestFilterNode"),
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNullNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNullNodeSerdeTest.java
index ae8650840d..847354726b 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNullNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNullNodeSerdeTest.java
@@ -57,7 +57,7 @@ import static org.junit.Assert.assertEquals;
public class FilterNullNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FilterNode filterNode =
new FilterNode(
new PlanNodeId("TestFilterNode"),
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/GroupByLevelNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/GroupByLevelNodeSerdeTest.java
index bbe4f15dd6..b1689b9c21 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/GroupByLevelNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/GroupByLevelNodeSerdeTest.java
@@ -59,7 +59,7 @@ import static org.junit.Assert.assertEquals;
public class GroupByLevelNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FilterNode filterNode =
new FilterNode(
new PlanNodeId("TestFilterNode"),
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/LimitNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/LimitNodeSerdeTest.java
index 0084cf9545..99ebb27c0f 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/LimitNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/LimitNodeSerdeTest.java
@@ -60,7 +60,7 @@ import static org.junit.Assert.assertEquals;
public class LimitNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FilterNode filterNode =
new FilterNode(
new PlanNodeId("TestFilterNode"),
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/OffsetNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/OffsetNodeSerdeTest.java
index b15e8705af..219fe51ecf 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/OffsetNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/OffsetNodeSerdeTest.java
@@ -66,7 +66,7 @@ import static org.junit.Assert.assertEquals;
public class OffsetNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FilterNode filterNode =
new FilterNode(
new PlanNodeId("TestFilterNode"),
@@ -137,7 +137,7 @@ public class OffsetNodeSerdeTest {
}
@Test
- public void TestSerializeAndDeserializeForTree1() throws IllegalPathException {
+ public void testSerializeAndDeserializeForTree1() throws IllegalPathException {
// create node
OffsetNode offsetNode = new OffsetNode(new PlanNodeId("OffsetNode"), 100);
LimitNode limitNode = new LimitNode(new PlanNodeId("LimitNode"), 100);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/SortNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/SortNodeSerdeTest.java
index 9f914493bc..063e0fe860 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/SortNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/SortNodeSerdeTest.java
@@ -62,7 +62,7 @@ import static org.junit.Assert.assertEquals;
public class SortNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FilterNode filterNode =
new FilterNode(
new PlanNodeId("TestFilterNode"),
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/TimeJoinNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/TimeJoinNodeSerdeTest.java
index 5f752c1061..2d85f154e6 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/TimeJoinNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/TimeJoinNodeSerdeTest.java
@@ -63,7 +63,7 @@ import static org.junit.Assert.assertEquals;
public class TimeJoinNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FilterNode filterNode =
new FilterNode(
new PlanNodeId("TestFilterNode"),
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/sink/FragmentSinkNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/sink/FragmentSinkNodeSerdeTest.java
index cde85f4e97..f194983239 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/sink/FragmentSinkNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/sink/FragmentSinkNodeSerdeTest.java
@@ -37,7 +37,7 @@ import static org.junit.Assert.assertEquals;
public class FragmentSinkNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
FragmentSinkNode fragmentSinkNode =
new FragmentSinkNode(new PlanNodeId("TestFragmentSinkNode"));
fragmentSinkNode.addChild(
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesAggregateScanNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesAggregateScanNodeSerdeTest.java
index 7271a366fa..a502686f27 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesAggregateScanNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesAggregateScanNodeSerdeTest.java
@@ -47,7 +47,7 @@ import static org.junit.Assert.assertEquals;
public class SeriesAggregateScanNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws QueryProcessException, IllegalPathException {
+ public void testSerializeAndDeserialize() throws QueryProcessException, IllegalPathException {
Set<String> st = new HashSet<>();
st.add("s1");
st.add("s2");
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesScanNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesScanNodeSerdeTest.java
index 8ddc7ebf5b..cf51c7f5ef 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesScanNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesScanNodeSerdeTest.java
@@ -40,7 +40,7 @@ import static org.junit.Assert.assertEquals;
public class SeriesScanNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws QueryProcessException, IllegalPathException {
+ public void testSerializeAndDeserialize() throws QueryProcessException, IllegalPathException {
SeriesScanNode seriesScanNode =
new SeriesScanNode(
new PlanNodeId("TestSeriesScanNode"),
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowNodeSerdeTest.java
index ccbe06f31e..03cc69769c 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowNodeSerdeTest.java
@@ -35,7 +35,7 @@ import java.nio.ByteBuffer;
public class InsertRowNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
InsertRowNode insertRowNode = getInsertRowNode();
ByteBuffer byteBuffer = ByteBuffer.allocate(10000);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertTabletNodeSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertTabletNodeSerdeTest.java
index b71fc44f40..46abaec468 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertTabletNodeSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertTabletNodeSerdeTest.java
@@ -35,7 +35,7 @@ import java.nio.ByteBuffer;
public class InsertTabletNodeSerdeTest {
@Test
- public void TestSerializeAndDeserialize() throws IllegalPathException {
+ public void testSerializeAndDeserialize() throws IllegalPathException {
InsertTabletNode insertTabletNode = getInsertTabletNode();
ByteBuffer byteBuffer = ByteBuffer.allocate(10000);
diff --git a/server/src/test/java/org/apache/iotdb/db/service/InternalServiceImplTest.java b/server/src/test/java/org/apache/iotdb/db/service/InternalServiceImplTest.java
index 20e2ab626b..bdedbbf4d2 100644
--- a/server/src/test/java/org/apache/iotdb/db/service/InternalServiceImplTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/service/InternalServiceImplTest.java
@@ -107,7 +107,7 @@ public class InternalServiceImplTest {
}
@Test
- public void createTimeseriesTest() throws MetadataException {
+ public void testCreateTimeseries() throws MetadataException {
CreateTimeSeriesNode createTimeSeriesNode =
new CreateTimeSeriesNode(
new PlanNodeId("0"),
@@ -164,7 +164,7 @@ public class InternalServiceImplTest {
}
@Test
- public void createAlignedTimeseriesTest() throws MetadataException {
+ public void testCreateAlignedTimeseries() throws MetadataException {
CreateAlignedTimeSeriesNode createAlignedTimeSeriesNode =
new CreateAlignedTimeSeriesNode(
new PlanNodeId("0"),