This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch Force-update-system-parameter
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 961bfa5de94 Finish
add 807d9e07fc8 Fix show latest alias series (#10168)
add 68a8247ec35 Refactor alter view (#10166)
add c1b4cbffbe3 [IOTDB-6000] Control the RegionGroup number of system
Database
add e161f2528b9 [IOTDB-6001] Pipe: a non-blocking iotdb connector
(iotdb_thrift_connector_v2) (#10174)
add 0b22ec33656 Validate tsfiles after compaction (#10146)
add ffa3460e4a1 Merge branch 'master' into Force-update-system-parameter
add 02a4acbc79b merge master and fix compile bug
No new revisions were added by this update.
Summary of changes:
.../confignode/client/DataNodeRequestType.java | 2 +
.../client/async/AsyncDataNodeClientPool.java | 29 +-
.../client/async/handlers/AsyncClientHandler.java | 5 +-
...RPCHandler.java => SchemaUpdateRPCHandler.java} | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 11 +
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 52 +++-
.../manager/schema/ClusterSchemaManager.java | 11 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 2 +-
...ocedure.java => AlterLogicalViewProcedure.java} | 288 ++++++++++---------
.../impl/schema/DeleteLogicalViewProcedure.java | 3 +-
...alViewState.java => AlterLogicalViewState.java} | 5 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 24 +-
.../db/it/schema/view/IoTDBAliasSeriesIT.java | 13 +-
.../iotdb/db/it/schema/view/IoTDBAlterViewIT.java | 117 ++++++++
.../apache/iotdb/pipe/api/access/RowIterator.java | 75 -----
.../src/main/thrift/confignode.thrift | 7 +
.../thrift/src/main/thrift/datanode.thrift | 7 +
.../resources/conf/iotdb-common.properties | 10 +-
.../iotdb/commons/client/ClientPoolFactory.java | 24 ++
...ava => AsyncPipeDataTransferServiceClient.java} | 56 ++--
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 4 +
.../builtin/connector/IoTDBThriftConnector.java | 16 +-
.../builtin/connector/IoTDBThriftConnectorV1.java | 5 +-
.../builtin/connector/IoTDBThriftConnectorV2.java | 5 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 22 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +-
...askType.java => CompactionValidationLevel.java} | 10 +-
.../execute/task/CrossSpaceCompactionTask.java | 8 +-
.../execute/task/InnerSpaceCompactionTask.java | 8 +-
.../compaction/execute/utils/CompactionUtils.java | 116 ++++++++
.../utils/validator/CompactionValidator.java} | 44 +--
.../validator/NoneCompactionValidator.java} | 25 +-
.../ResourceAndTsfileCompactionValidator.java | 52 ++++
.../validator/ResourceOnlyCompactionValidator.java | 51 ++++
.../metadata/view/ViewNotExistException.java | 25 --
.../plan/schemaregion/SchemaRegionPlanType.java | 1 +
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 5 +
.../impl/SchemaRegionPlanDeserializer.java | 9 +
.../impl/SchemaRegionPlanSerializer.java | 13 +
.../impl/SchemaRegionPlanTxtSerializer.java | 11 +
...PlanImpl.java => AlterLogicalViewPlanImpl.java} | 32 ++-
.../impl/write/SchemaRegionWritePlanFactory.java | 8 +
...calViewPlan.java => IAlterLogicalViewPlan.java} | 16 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 3 +
.../schemaregion/SchemaRegionMemoryImpl.java | 23 ++
.../schemaregion/SchemaRegionSchemaFileImpl.java | 7 +
.../metadata/visitor/SchemaExecutionVisitor.java | 20 ++
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 1 +
.../config/executor/ClusterConfigTaskExecutor.java | 74 ++---
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 10 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 6 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
...icalViewNode.java => AlterLogicalViewNode.java} | 92 +-----
.../metadata/view/AlterLogicalViewStatement.java | 11 -
.../metadata/view/CreateLogicalViewStatement.java | 4 +
.../pipe/agent/receiver/IoTDBThriftReceiver.java | 6 +-
.../db/pipe/agent/receiver/PipeReceiverAgent.java | 10 +-
.../config/constant/PipeConnectorConstant.java | 2 +
...ava => IoTDBThriftConnectorRequestVersion.java} | 7 +-
...orImplV1_1.java => IoTDBSyncConnectorV1_1.java} | 12 +-
.../{ => v1}/IoTDBThriftConnectorClient.java | 2 +-
.../pipe/connector/v1/IoTDBThriftConnectorV1.java | 5 +-
.../pipe/connector/v1/IoTDBThriftReceiverV1.java | 8 +-
.../v1/request/PipeTransferFilePieceReq.java | 4 +-
.../v1/request/PipeTransferFileSealReq.java | 4 +-
.../v1/request/PipeTransferHandshakeReq.java | 4 +-
.../v1/request/PipeTransferInsertNodeReq.java | 4 +-
.../v1/request/PipeTransferTabletReq.java | 6 +-
.../pipe/connector/v2/IoTDBThriftConnectorV2.java | 313 +++++++++++++++++++++
...nsferInsertNodeTabletInsertionEventHandler.java | 51 ++++
...ipeTransferRawTabletInsertionEventHandler.java} | 29 +-
.../PipeTransferTabletInsertionEventHandler.java | 131 +++++++++
.../PipeTransferTsFileInsertionEventHandler.java | 222 +++++++++++++++
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 8 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 4 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +-
.../event/realtime/PipeRealtimeCollectEvent.java | 8 +-
.../task/subtask/PipeConnectorSubtaskManager.java | 20 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 35 +++
.../compaction/CompactionValidationTest.java | 224 +++++++++++++++
86 files changed, 2063 insertions(+), 588 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{DeleteSchemaRPCHandler.java
=> SchemaUpdateRPCHandler.java} (93%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/{DeleteLogicalViewProcedure.java
=> AlterLogicalViewProcedure.java} (51%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeleteLogicalViewState.java
=> AlterLogicalViewState.java} (91%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/view/IoTDBAlterViewIT.java
delete mode 100644
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/access/RowIterator.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/client/async/{AsyncDataNodeInternalServiceClient.java
=> AsyncPipeDataTransferServiceClient.java} (74%)
copy
server/src/main/java/org/apache/iotdb/db/service/InfluxDBRPCServiceMBean.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftConnectorV1.java
(86%)
copy
server/src/main/java/org/apache/iotdb/db/service/InfluxDBRPCServiceMBean.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftConnectorV2.java
(86%)
copy
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/{CompactionTaskType.java
=> CompactionValidationLevel.java} (85%)
copy
server/src/main/java/org/apache/iotdb/db/engine/compaction/{selector/constant/InnerUnsequenceCompactionSelector.java
=> execute/utils/validator/CompactionValidator.java} (50%)
copy
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/{performer/IUnseqCompactionPerformer.java
=> utils/validator/NoneCompactionValidator.java} (56%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/validator/ResourceAndTsfileCompactionValidator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/validator/ResourceOnlyCompactionValidator.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/{DeleteLogicalViewPlanImpl.java
=> AlterLogicalViewPlanImpl.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/view/{IDeleteLogicalViewPlan.java
=> IAlterLogicalViewPlan.java} (75%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/view/{CreateLogicalViewNode.java
=> AlterLogicalViewNode.java} (65%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/connector/{IoTDBThriftConnectorVersion.java
=> IoTDBThriftConnectorRequestVersion.java} (87%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/connector/lagacy/{IoTDBSyncConnectorImplV1_1.java
=> IoTDBSyncConnectorV1_1.java} (97%)
rename server/src/main/java/org/apache/iotdb/db/pipe/connector/{ =>
v1}/IoTDBThriftConnectorClient.java (97%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/IoTDBThriftConnectorV2.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferInsertNodeTabletInsertionEventHandler.java
copy
server/src/main/java/org/apache/iotdb/db/pipe/{agent/receiver/IoTDBThriftReceiver.java
=> connector/v2/handler/PipeTransferRawTabletInsertionEventHandler.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferTabletInsertionEventHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/handler/PipeTransferTsFileInsertionEventHandler.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/CompactionValidationTest.java
