Skip to content

Commit 16f71c8

Browse files
authored
Support show-queries and kill-query
1 parent 903c359 commit 16f71c8

File tree

245 files changed

+3012
-1238
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

245 files changed

+3012
-1238
lines changed

integration-test/src/main/java/org/apache/iotdb/itbase/constant/TestConstant.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919

2020
package org.apache.iotdb.itbase.constant;
2121

22-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
22+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2323

2424
import org.apache.tsfile.utils.FilePathUtils;
2525
import org.apache.tsfile.write.record.TSRecord;

integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBTimePartitionIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,11 @@
2222
import org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient;
2323
import org.apache.iotdb.commons.path.PartialPath;
2424
import org.apache.iotdb.commons.schema.SchemaConstant;
25+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2526
import org.apache.iotdb.commons.utils.TimePartitionUtils;
2627
import org.apache.iotdb.confignode.rpc.thrift.TGetDatabaseReq;
2728
import org.apache.iotdb.confignode.rpc.thrift.TShowDatabaseResp;
2829
import org.apache.iotdb.consensus.ConsensusFactory;
29-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
3030
import org.apache.iotdb.db.queryengine.plan.statement.metadata.ShowDatabaseStatement;
3131
import org.apache.iotdb.db.utils.constant.SqlConstant;
3232
import org.apache.iotdb.it.env.EnvFactory;

integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/IoTDBRegionMigrateReliabilityITFramework.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,14 +23,14 @@
2323
import org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient;
2424
import org.apache.iotdb.commons.concurrent.IoTDBThreadPoolFactory;
2525
import org.apache.iotdb.commons.conf.IoTDBConstant;
26+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2627
import org.apache.iotdb.commons.utils.KillPoint.KillNode;
2728
import org.apache.iotdb.commons.utils.KillPoint.KillPoint;
2829
import org.apache.iotdb.confignode.rpc.thrift.TRegionInfo;
2930
import org.apache.iotdb.confignode.rpc.thrift.TShowRegionReq;
3031
import org.apache.iotdb.confignode.rpc.thrift.TShowRegionResp;
3132
import org.apache.iotdb.consensus.ConsensusFactory;
3233
import org.apache.iotdb.consensus.iot.IoTConsensusServerImpl;
33-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
3434
import org.apache.iotdb.it.env.EnvFactory;
3535
import org.apache.iotdb.it.env.cluster.env.AbstractEnv;
3636
import org.apache.iotdb.it.env.cluster.node.AbstractNodeWrapper;

integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/IoTDBRemoveDataNodeITFramework.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@
2222
import org.apache.iotdb.common.rpc.thrift.TDataNodeConfiguration;
2323
import org.apache.iotdb.common.rpc.thrift.TDataNodeLocation;
2424
import org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient;
25+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2526
import org.apache.iotdb.confignode.rpc.thrift.TDataNodeRemoveReq;
2627
import org.apache.iotdb.confignode.rpc.thrift.TDataNodeRemoveResp;
2728
import org.apache.iotdb.consensus.ConsensusFactory;
28-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
2929
import org.apache.iotdb.it.env.EnvFactory;
3030
import org.apache.iotdb.it.env.cluster.node.DataNodeWrapper;
3131
import org.apache.iotdb.itbase.exception.InconsistentDataException;

integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919

2020
package org.apache.iotdb.db.it;
2121

22-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
22+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2323
import org.apache.iotdb.it.env.EnvFactory;
2424
import org.apache.iotdb.it.framework.IoTDBTestRunner;
2525
import org.apache.iotdb.itbase.category.ClusterIT;

integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExecuteBatchIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
*/
1919
package org.apache.iotdb.db.it;
2020

21-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
21+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2222
import org.apache.iotdb.it.env.EnvFactory;
2323
import org.apache.iotdb.it.framework.IoTDBTestRunner;
2424
import org.apache.iotdb.itbase.category.ClusterIT;

integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterBetweenIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919

2020
package org.apache.iotdb.db.it;
2121

22-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
22+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2323
import org.apache.iotdb.it.env.EnvFactory;
2424
import org.apache.iotdb.it.framework.IoTDBTestRunner;
2525
import org.apache.iotdb.itbase.category.ClusterIT;

integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFilterNullIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
*/
1919
package org.apache.iotdb.db.it;
2020

21-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
21+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2222
import org.apache.iotdb.it.env.EnvFactory;
2323
import org.apache.iotdb.it.framework.IoTDBTestRunner;
2424
import org.apache.iotdb.itbase.category.ClusterIT;

integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBInsertNaNIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
*/
1919
package org.apache.iotdb.db.it;
2020

21-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
21+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2222
import org.apache.iotdb.it.env.EnvFactory;
2323
import org.apache.iotdb.it.framework.IoTDBTestRunner;
2424
import org.apache.iotdb.itbase.category.ClusterIT;

integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
package org.apache.iotdb.db.it;
2121

2222
import org.apache.iotdb.commons.auth.entity.PrivilegeType;
23-
import org.apache.iotdb.db.queryengine.common.header.ColumnHeaderConstant;
23+
import org.apache.iotdb.commons.schema.column.ColumnHeaderConstant;
2424
import org.apache.iotdb.it.env.EnvFactory;
2525
import org.apache.iotdb.it.framework.IoTDBTestRunner;
2626
import org.apache.iotdb.it.utils.TsFileGenerator;

0 commit comments

Comments
 (0)