This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch rc/2.0.6
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 914430555c4 Correct the dependencies.json
new 93efc0a078b Implemented the alter encoding compression function for
tree model (#16672)
new 06ca819daca Changed the SQL of AlterEncodingCompressor statement &
banned the "root" timeSeries & handled the empty intersection path & refactored
the IT (#16725)
new 8763d9a7da2 Fixed the procedure has_more_state bug & Fixed the IT for
encoding & compressor (#16729)
new 096d9eb8965 Optimized the lock for encoding & compressor's invalidate
cache (#16733)
new 09d526ced1a Pipe: Improved the total performance by disable some
useless logic
new 5854babbcbe Solved the compilation problem
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/daily-it.yml | 900 ---------------------
.github/workflows/pipe-it.yml | 872 --------------------
.../it/schema/IoTDBAlterEncodingCompressorIT.java | 199 +++++
.../manual/basic/IoTDBPipeProtocolIT.java | 16 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 16 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 75 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../client/async/CnToDnAsyncRequestType.java | 2 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/ConfigPhysicalPlanVisitor.java | 8 +
...n.java => PipeAlterEncodingCompressorPlan.java} | 71 +-
.../iotdb/confignode/manager/ConfigManager.java | 18 +
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 41 +
.../plugin/PipeConfigRegionSinkConstructor.java | 6 -
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 49 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 11 +
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 2 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 6 +-
.../pipe/source/ConfigRegionListeningFilter.java | 3 +
...eConfigPhysicalPlanTreePatternParseVisitor.java | 25 +
.../persistence/executor/ConfigPlanExecutor.java | 1 +
.../schema/AlterEncodingCompressorProcedure.java | 336 ++++++++
.../impl/schema/DataNodeTSStatusTaskExecutor.java | 74 ++
.../impl/schema/DeactivateTemplateProcedure.java | 26 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 26 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 49 +-
.../table/AbstractAlterOrDropTableProcedure.java | 29 +-
...tate.java => AlterEncodingCompressorState.java} | 7 +-
.../procedure/store/ProcedureFactory.java | 9 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../pipe/receiver/PipeEnrichedProcedureTest.java | 28 +
...a => AlterEncodingCompressorProcedureTest.java} | 26 +-
.../schemaregion/SchemaExecutionVisitor.java | 15 +
.../PipeDataRegionProcessorConstructor.java | 30 -
.../dataregion/PipeDataRegionSinkConstructor.java | 12 -
.../PipeSchemaRegionSinkConstructor.java | 6 -
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 6 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 6 +-
.../source/dataregion/IoTDBDataRegionSource.java | 49 +-
.../realtime/PipeRealtimeDataRegionSource.java | 19 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../impl/DataNodeInternalRPCServiceImpl.java | 47 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 2 +-
.../execution/config/TreeConfigTaskVisitor.java | 14 +-
.../config/executor/ClusterConfigTaskExecutor.java | 62 ++
.../config/executor/IConfigTaskExecutor.java | 4 +
...eTask.java => AlterEncodingCompressorTask.java} | 17 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 71 +-
.../plan/planner/plan/node/PlanNodeType.java | 4 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../write/AlterEncodingCompressorNode.java | 146 ++++
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 10 +-
.../metadata/AlterEncodingCompressorStatement.java | 160 ++++
.../metadata/DeleteDatabaseStatement.java | 2 +-
.../statement/metadata/ShowDatabaseStatement.java | 2 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 3 +
.../schemaregion/SchemaRegionPlanType.java | 2 +
.../schemaregion/SchemaRegionPlanVisitor.java | 6 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 37 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 8 +
.../visitor/SchemaRegionPlanDeserializer.java | 7 +
.../visitor/SchemaRegionPlanSerializer.java | 8 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 33 +
.../write/req/SchemaRegionWritePlanFactory.java | 3 +
.../iotdb/commons/exception/MetadataException.java | 2 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 7 +
.../apache/iotdb/commons/path/PathPatternTree.java | 13 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 40 -
.../commons/pipe/receiver/IoTDBFileReceiver.java | 6 +
.../pipe/sink/client/IoTDBClientManager.java | 5 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../commons/pipe/sink/protocol/IoTDBSink.java | 3 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 6 +-
.../iotdb/commons/pipe/source/IoTDBSource.java | 19 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 18 +
.../src/main/thrift/confignode.thrift | 12 +
.../src/main/thrift/datanode.thrift | 14 +
89 files changed, 1788 insertions(+), 2162 deletions(-)
delete mode 100644 .github/workflows/pipe-it.yml
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBAlterEncodingCompressorIT.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/{PipeDeleteLogicalViewPlan.java
=> PipeAlterEncodingCompressorPlan.java} (56%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterEncodingCompressorProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeTSStatusTaskExecutor.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{RemoveAINodeState.java
=> AlterEncodingCompressorState.java} (91%)
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/{table/view/DropViewProcedureTest.java
=> AlterEncodingCompressorProcedureTest.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ShowDatabaseTask.java
=> AlterEncodingCompressorTask.java} (68%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/AlterEncodingCompressorNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java
