|
24 | 24 | import org.apache.iotdb.db.queryengine.plan.planner.node.PlanNodeDeserializeHelper; |
25 | 25 | import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNodeId; |
26 | 26 | import org.apache.iotdb.db.queryengine.plan.planner.plan.node.source.LastQueryScanNode; |
| 27 | +import org.apache.iotdb.db.queryengine.plan.planner.plan.node.source.ShowQueriesNode; |
27 | 28 |
|
28 | 29 | import org.apache.tsfile.enums.TSDataType; |
29 | 30 | import org.apache.tsfile.write.schema.MeasurementSchema; |
|
34 | 35 |
|
35 | 36 | import static org.junit.Assert.assertEquals; |
36 | 37 |
|
37 | | -public class LastQueryScanNodeSerdeTest { |
| 38 | +public class SourceNodeSerdeTest { |
38 | 39 | @Test |
39 | | - public void test() throws IllegalPathException { |
| 40 | + public void testLastQueryScanNode() throws IllegalPathException { |
40 | 41 | LastQueryScanNode node = |
41 | 42 | new LastQueryScanNode( |
42 | 43 | new PlanNodeId("test"), |
@@ -69,4 +70,19 @@ public void test() throws IllegalPathException { |
69 | 70 | byteBuffer.flip(); |
70 | 71 | assertEquals(PlanNodeDeserializeHelper.deserialize(byteBuffer), node); |
71 | 72 | } |
| 73 | + |
| 74 | + @Test |
| 75 | + public void testShowQueriesNode() throws IllegalPathException { |
| 76 | + ShowQueriesNode node = new ShowQueriesNode(new PlanNodeId("test"), null, "root"); |
| 77 | + |
| 78 | + ByteBuffer byteBuffer = ByteBuffer.allocate(2048); |
| 79 | + node.serialize(byteBuffer); |
| 80 | + byteBuffer.flip(); |
| 81 | + assertEquals(PlanNodeDeserializeHelper.deserialize(byteBuffer), node); |
| 82 | + node = new ShowQueriesNode(new PlanNodeId("test"), null, "root"); |
| 83 | + byteBuffer = ByteBuffer.allocate(2048); |
| 84 | + node.serialize(byteBuffer); |
| 85 | + byteBuffer.flip(); |
| 86 | + assertEquals(PlanNodeDeserializeHelper.deserialize(byteBuffer), node); |
| 87 | + } |
72 | 88 | } |
0 commit comments