This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch cp-206
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 914430555c4 Correct the dependencies.json
new 8b0aace0c8d Implemented the alter encoding compression function for
tree model (#16672)
new e4a529b297a priv-parser
new b99e2658702 [TIMECHODB] Compile
new 96545209e78 [TIMECHODB] Handle audit
new bdb17d61e0f Changed the SQL of AlterEncodingCompressor statement &
banned the "root" timeSeries & handled the empty intersection path & refactored
the IT (#16725)
new 7816ace0b43 Fixed the procedure has_more_state bug & Fixed the IT for
encoding & compressor (#16729)
new 5a16bddff5e Optimized the lock for encoding & compressor's invalidate
cache (#16733)
The 7 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:
.../it/schema/IoTDBAlterEncodingCompressorIT.java | 209 +++++++++++++
.../treemodel/manual/IoTDBPipeInclusionIT.java | 73 +++++
.../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 +++
.../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 +
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 6 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 6 +-
.../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 +-
.../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 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 18 ++
.../src/main/thrift/confignode.thrift | 12 +
.../src/main/thrift/datanode.thrift | 14 +
77 files changed, 1769 insertions(+), 204 deletions(-)
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
