This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch split_text_chunk
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 27808651d42 target chunk size count non binary
add e022f22b0c8 Implement last cache for table model & Fixed the bug that
the table conflict detection when creating timeseries in tree model does not
take effect
add 9c8c1ed5306 Push down completely when group-by Aggregation with only
one device entry
add 60c6fd9c5ef Fix some sort orders bug about AggTableScan
add e4b77248388 Fix insertRelationalTablet may cause sequence data
overlapped (#13778)
add 4558493e6b7 AINode: add retry logic in model status check in AINode IT
(#13774)
add 808f5752a9d Load: fix some minor issues (#13781)
add 8187498854a Split CnToDnRequestType to sync and async & Add check for
adding new request type (#13660)
add de8241b47a5 fix compaction logger no such file or directory (#13779)
add 049399ce7da Fix the cache invalidation logic in RouteBalancer
add 6510fb8be6a Fix aggregation dealing logic in no data situation
add 0fe56983088 Add order by to make the rightness of group by integration
test
add faf58883fee Pipe: Support syncing table model data between clusters
(skeleton) (#13731)
add 4d1552947cc IoTV2: Introduce pipeTaskRestartTimes for ensuring
replicate events as order (#13730)
add d6a64705d6f Subscription: improve event consistency by operating
within the `compute` method (#13787)
add 713e4e5f2c4 Update TreeDeviceSchemaCacheManager.java
add e20680cf053 Pipe: Support syncing table model data between clusters
(airgap) & Adjust the isTableModelEvent judgement for TsFileInsertionEvent
(#13792)
add 4d8d1c309f0 Subscription: declare the referenced code for timer in
license & fixup committable logic for ack (#13795)
add 47e928d71c8 Optimize write metric update for insertTablets and
insertRelationalTablet (#13793)
add 88ef922e996 Implement Attribute Security Service & Improved semantics
of "clear cache" SQL
add 600a79834f6 Add basic last aggregation support for table model
add b2f99d18430 Pipe: Support syncing table model data between clusters
(receiver fixup) & Add redirect info for PipeEnrich statements (#13797)
add c802367a4d7 Add max,min and first aggregation support for table model
add 4ccaf5fb384 Fix exception when casewhen function meets two conditions
add b13ac016331 Optimize alias failure log & reduce useless node
processing at show/count devices
add e854bd79011 Implement hash grouped aggregation in TableModel
add 85e0e152754 [Fix] fix writing fail in ratisConsensus due to retry
policy condition mismatch #13810
add 2a28e1006f6 Add some ITs for aggregation in Table Model
add 3ef4ac619a2 Add time chunk cache for batch column compaction (#13773)
add bd5b30bb50d Pipe: Support syncing table model data between clusters
(TsFileInsertionEventTableParser impl & following fixup) (#13806)
add 51bce3337e4 Fixed the bug of the second update of last cache by query
add 5f1287cf3c5 Active Load: Fix load tsfile failed when system is read
only and not have the error message. (#13805)
add 8ed83a81053 Fix compaction table schema collection (#13815)
add a613422c9e5 Do not add attr columns to TableSchema when registering to
TsFile (#13814)
add 7400e1b1145 Refactor alter table framework & Support Drop table schema
& Support show tables details
add dcde7f9e5c4 Add more ITs for Table Model Aggregation
add 82a77b6209e Pipe: Support table pattern matching when sync data
between clusters (#13817)
add 2b8d6c6eb70 Pipe: degrade progress index rebind log (#13821)
add 2e5b5f16abe Pipe: support new synonym pipe parameters for table model
(#13799)
add 9ea87df69b8 [Region Migration]: IoTV2 Support Region Migration (#13788)
add 48593d761ab Add last_by and first_by aggregation support for table
model
add b3a2142ed89 Pipe: Support syncing table model data between clusters
(airgap) (#13828)
add 4bd629ef239 Load: verify measurement datatype & register table schema
in split file (#13827)
add 0d8ad0c6790 Pipe: Support table pattern matching when sync data
between clusters (#13817 following fixup) (#13830)
add 4a1b0837630 PipeConsensus: Support deletion operation for
PipeConsensus (#13016)
add 5a25a0a46ba Implement some groupedAccumulators in TableModel
add e3de1b7964a Add max_by, min_by aggregation support
add a6cd2b07637 Add extreme aggregation for table model
add ae421537d54 Implement groupedAccumulators first_by, last_by, max_by,
min_by
add 37fe3864ad5 Fix calculation problem in first_by aggregation of table
model
add 502f64d15a0 Add IT for gapfill and fix some bugs
add 1944032b4fe Fix group by query that only exist group by key but no
aggregation functions (#13836)
add 113f99b09ce Fix calculation of extreme, max_by, min_by in grouped
Aggregation (#13838)
add a37d64606d7 Add some ITs for Aggregation in Table Model
add daf178ed3e7 Update GeneralRegionAttributeSecurityService.java
add c664a93c759 Add more ITs for Aggregation in table model
add 46a13352693 Fix bug of finished judge in HashAggregationOperator
(#13842)
add 84fe96b31d4 Metric: Discard Error Metric When Taking Snapthot (#13823)
add b74fcc1a376 Pipe: Fix the problem that pipe receiver fails to
construct RelationalInsertRow & RelationalInsertRows statements (#13847)
add 928e6b3d9a0 Active Load: Fix scan tsfile do not close the stream
resource (#13846)
add 23405935e63 Pipe: reduce Github FT runner (#13851)
add 931b5bd2811 Batch execute insertRelationalTablet (#13837)
add be4990920ed Fix return result of HashAggregationOperator
add 14abc3234e7 Add scan order optimization for last/first queries in
table model
add 8bf22945c15 Fix column length may be 0 when using cache fetch
add dc96146d7c1 Fixed the cache invalidation logic when delete time series
add 14a295ac825 Add Memory Control for HashAggregationOperator
add d1c54d40dcd Fix compaction task comparator bug & Modify target file
name of inner compaction task (#13848)
add 7c98db11e05 Print file path while meeting unknown version tsfile
add 516c32d527b Fix the issue that tasks with negative estimated memory
are executed (#13856)
add 7f5e5dc7bcd Fix timeout unit error in QueryExecution
add c65a3b219cf Fix wal node memory leak when using simple consensus
(#13864)
add 57e450c5b18 Pipe: Reduce Calculations for
PipeDataNodeRemainingEventAndTimeOperator when the events are too many (#13854)
add aea9f3a4128 Fix ignored bitmap of attribute in writeTablet (#13858)
add 574ba8ddd57 Active Load: Adjust the default execution thread to match
the number of CPU cores (#13865)
add bacde2f5b37 Support non-numeric type of max_by, min_by
GroupedAccumulators in TableModel
add ce53f9c160e Pipe: Remove already deleted tsfile resource from
historical extraction list to prevent FileNotFoundException (#13869)
add 576b6d57e05 Fixed the measurement invalidation logic in
TableDeviceLastCache
add 9e48f9cf391 Optimize the serialize method of intermedia result of
grouped aggregation
add 38f7219a302 Clean walnode after drop database when using simple
consensus (#13877)
add 14346dc4098 Optimize the serialize method of intermedia result of
aggregation
add c93bdb77c03 Remove use of canUseStatistics when judge aggregation
push-down level in TableModel
add bbfc2f834ba Keep all null rows in table model flush (#13883)
add 52b72edb689 Fix TimePartitionUtils Overflow (#13881)
add 0c7a9471f0e Pipe: fix calculations of
PipeDataNodeRemainingEventAndTimeOperator (#13876)
add 86469d32210 Pipe: Avoid constructing unnecessary pipe subtasks if db
and pattern dismatch (#13873)
add 9d9d6ea6eaa Pipe: add seperated thread pool for phantom reference
clean job (#13813)
add 207bbe8950b Keep the order of times after spliting
RelationalInsertTabletNode (#13886)
add e363388966a Add mode and variance aggregation support for table model
add ecacaa1be88 Load: Use IDeviceID in ChunkData (#13887)
add f61db4875e1 Active Load: Refactoring the code for handling exception
information after loading failure (#13880)
add 2eb060d1854 Pipe: Fix the Pipe receiver's LoadFile and
InsertRowsStatement NPE issues (#13871)
add dbb99bc88de Load: Parallelly load files into different target data
partitions (#13893)
add 4e792002b28 fix replace function error message
add 0393c75134a Merge branch 'master' into split_text_chunk
No new revisions were added by this update.
Summary of changes:
.github/workflows/pipe-it-2cluster.yml | 6 +-
LICENSE | 8 +
.../apache/iotdb/itbase/constant/TestConstant.java | 2 +-
.../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 39 +-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 23 +-
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 16 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 16 +-
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 10 +-
.../iotdb/db/it/query/IoTDBCaseWhenThenIT.java | 32 +
.../db/it/schema/IoTDBDeleteTimeSeriesIT.java | 13 +
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 14 +-
.../it/db/it/IoTDBCaseWhenThenTableIT.java | 8 +
.../relational/it/db/it/IoTDBInsertTableIT.java | 119 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 521 ++-
.../it/query/recent/IoTDBGapFillTableIT.java | 61 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 3611 ++++++++++++++++++++
.../iotdb/relational/it/schema/IoTDBTableIT.java | 18 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../CnToDnAsyncRequestType.java} | 30 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 174 +-
.../handlers/DataNodeAsyncRequestContext.java | 12 +-
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 4 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 4 +-
.../rpc/DataNodeAsyncRequestRPCHandler.java | 11 +-
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 4 +-
.../rpc/FetchSchemaBlackListRPCHandler.java | 4 +-
.../handlers/rpc/PipeHeartbeatRPCHandler.java | 4 +-
.../async/handlers/rpc/PipePushMetaRPCHandler.java | 4 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 4 +-
.../rpc/SubmitTestConnectionTaskRPCHandler.java | 4 +-
.../handlers/rpc/TransferLeaderRPCHandler.java | 4 +-
.../CheckSchemaRegionUsingTemplateRPCHandler.java | 4 +-
.../ConsumerGroupPushMetaRPCHandler.java | 4 +-
.../rpc/subscription/TopicPushMetaRPCHandler.java | 4 +-
.../client/sync/CnToDnSyncRequestType.java} | 50 +-
.../client/sync/SyncDataNodeClientPool.java | 141 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 9 +
.../consensus/request/ConfigPhysicalPlan.java | 12 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
.../request/read/table/ShowTablePlan.java | 9 +-
...CreateTablePlan.java => AbstractTablePlan.java} | 16 +-
.../request/write/table/AddTableColumnPlan.java | 39 +-
.../request/write/table/CommitCreateTablePlan.java | 40 +-
.../table/DropTablePlan.java} | 17 +-
.../request/write/table/PreCreateTablePlan.java | 6 +-
.../table/PreDeleteTablePlan.java} | 16 +-
...teTablePlan.java => RenameTableColumnPlan.java} | 45 +-
.../write/table/RollbackCreateTablePlan.java | 40 +-
.../write/table/SetTablePropertiesPlan.java | 27 +-
.../iotdb/confignode/manager/ClusterManager.java | 9 +-
.../confignode/manager/ClusterQuotaManager.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 28 +-
.../apache/iotdb/confignode/manager/IManager.java | 8 +-
.../iotdb/confignode/manager/ProcedureManager.java | 69 +-
.../iotdb/confignode/manager/TriggerManager.java | 4 +-
.../iotdb/confignode/manager/UDFManager.java | 6 +-
.../manager/consensus/ConsensusManager.java | 2 +-
.../manager/load/balancer/RouteBalancer.java | 27 +-
.../iotdb/confignode/manager/node/NodeManager.java | 36 +-
.../manager/partition/PartitionManager.java | 8 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 13 +
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 4 +-
.../ref/PipeConfigNodePhantomReferenceManager.java | 2 +-
.../manager/schema/ClusterSchemaManager.java | 61 +-
.../persistence/executor/ConfigPlanExecutor.java | 9 +
.../persistence/schema/ClusterSchemaInfo.java | 84 +-
.../confignode/persistence/schema/ConfigMTree.java | 43 +-
.../schema/mnode/impl/ConfigTableNode.java | 33 +-
.../schema/mnode/info/ConfigTableInfo.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 53 +-
.../procedure/env/RegionMaintainHandler.java | 19 +-
.../procedure/env/RemoveDataNodeHandler.java | 8 +-
.../procedure/impl/StateMachineProcedure.java | 2 +-
.../impl/schema/AlterLogicalViewProcedure.java | 8 +-
.../impl/schema/DataNodeRegionTaskExecutor.java | 79 +-
.../impl/schema/DeactivateTemplateProcedure.java | 16 +-
.../impl/schema/DeleteDatabaseProcedure.java | 4 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 104 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 30 +-
.../procedure/impl/schema/SchemaUtils.java | 32 +-
.../procedure/impl/schema/SetTTLProcedure.java | 4 +-
.../impl/schema/SetTemplateProcedure.java | 12 +-
.../impl/schema/UnsetTemplateProcedure.java | 10 +-
.../table/AbstractAlterOrDropTableProcedure.java | 176 +
.../impl/schema/table/AddTableColumnProcedure.java | 127 +-
.../impl/schema/table/CreateTableProcedure.java | 53 +-
.../schema/table/DropTableColumnProcedure.java | 112 +
.../impl/schema/table/DropTableProcedure.java | 331 ++
.../schema/table/RenameTableColumnProcedure.java | 219 ++
.../schema/table/SetTablePropertiesProcedure.java | 109 +-
.../impl/sync/AuthOperationProcedure.java | 4 +-
.../state/schema/DropTableColumnState.java} | 7 +-
.../procedure/state/schema/DropTableState.java} | 11 +-
.../state/schema/RenameTableColumnState.java} | 11 +-
.../procedure/store/ProcedureFactory.java | 18 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 16 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 40 +
.../schema/table/DropTableColumnProcedureTest.java | 53 +
.../impl/schema/table/DropTableProcedureTest.java | 52 +
.../table/RenameTableColumnProcedureTest.java | 53 +
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 42 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 44 +
.../pipe/consensuspipe/ConsensusPipeManager.java | 4 +
.../service/PipeConsensusRPCServiceProcessor.java | 20 +
.../iotdb/consensus/ratis/RatisConsensus.java | 8 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 80 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 53 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 +
.../dataregion/DataExecutionVisitor.java | 14 +-
.../schemaregion/SchemaExecutionVisitor.java | 45 +-
.../schemaregion/SchemaRegionStateMachine.java | 33 +-
.../metadata/DatabaseNotSetException.java | 8 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 21 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 8 +-
.../agent/task/builder/PipeDataNodeBuilder.java | 6 +-
.../agent/task/connection/PipeEventCollector.java | 41 +-
.../connector/PipeConnectorSubtaskManager.java | 6 -
.../subtask/processor/PipeProcessorSubtask.java | 6 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 48 +-
.../request/PipeTransferTabletBatchReqV2.java | 260 ++
.../request/PipeTransferTabletBinaryReq.java | 10 +-
.../request/PipeTransferTabletBinaryReqV2.java | 179 +
.../request/PipeTransferTabletInsertNodeReq.java | 12 +-
.../request/PipeTransferTabletInsertNodeReqV2.java | 178 +
.../request/PipeTransferTabletRawReq.java | 5 +-
...RawReq.java => PipeTransferTabletRawReqV2.java} | 88 +-
.../request/PipeTransferTsFileSealWithModReq.java | 62 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 44 -
.../airgap/IoTDBDataRegionAirGapConnector.java | 88 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 40 +
.../pipeconsensus/PipeConsensusAsyncConnector.java | 17 +-
.../pipeconsensus/PipeConsensusSyncConnector.java | 85 +-
.../PipeConsensusTabletBatchEventHandler.java | 2 +-
.../PipeConsensusTabletInsertNodeEventHandler.java | 2 +-
.../PipeConsensusTabletInsertionEventHandler.java | 2 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 2 +-
.../PipeConsensusTransferBatchReqBuilder.java | 1 +
.../request/PipeConsensusDeleteNodeReq.java | 126 +
.../async/IoTDBDataRegionAsyncConnector.java | 43 +-
.../async/handler/PipeTransferTsFileHandler.java | 16 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 67 -
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 110 +-
.../thrift/sync/IoTDBSchemaRegionConnector.java | 59 +
.../consensus/ProgressIndexDataNodeManager.java | 52 +-
.../pipe/consensus/deletion/DeletionResource.java | 198 ++
.../deletion/DeletionResourceManager.java | 331 ++
.../deletion/persist/DeletionBuffer.java} | 21 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 380 ++
.../consensus/deletion/recover/DeletionReader.java | 101 +
.../PipeConsensusConnectorMetrics.java | 2 +-
.../{ => metric}/PipeConsensusReceiverMetrics.java | 2 +-
.../db/pipe/event/common}/PipeInsertionEvent.java | 9 +-
.../common/deletion/PipeDeleteDataNodeEvent.java | 186 +
.../event/common/heartbeat/PipeHeartbeatEvent.java | 15 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 12 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 13 +-
.../TabletInsertionEventTablePatternParser.java | 1 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 14 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 16 +-
.../parser/TsFileInsertionEventParserProvider.java | 31 +-
.../query/TsFileInsertionEventQueryParser.java | 28 +-
.../scan/TsFileInsertionEventScanParser.java | 12 +-
.../table/TsFileInsertionEventTableParser.java | 147 +
...ileInsertionEventTableParserTabletIterator.java | 134 +
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 2 +-
.../event/realtime/PipeRealtimeEventFactory.java | 4 +-
.../dataregion/DataRegionListeningFilter.java | 36 +-
.../dataregion/IoTDBDataRegionExtractor.java | 248 +-
...ricalDataRegionTsFileAndDeletionExtractor.java} | 470 ++-
.../realtime/PipeRealtimeDataRegionExtractor.java | 26 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 6 +-
.../PipeRealtimeDataRegionLogExtractor.java | 6 +-
.../PipeRealtimeDataRegionTsFileExtractor.java | 6 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 32 +-
.../listener/PipeInsertionDataNodeListener.java | 33 +-
.../matcher/CachedSchemaPatternMatcher.java | 6 +-
.../pipe/metric/PipeDataNodeReceiverMetrics.java | 84 +
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 56 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 96 +-
.../twostage/plugin/TwoStageCountProcessor.java | 30 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 8 +
.../protocol/airgap/IoTDBAirGapReceiverAgent.java | 6 +-
.../pipeconsensus/PipeConsensusReceiver.java | 117 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 221 +-
.../PipeConvertedInsertTabletStatement.java | 2 +-
.../ref/PipeDataNodePhantomReferenceManager.java | 2 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 4 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 15 +-
.../client/dn/DataNodeAsyncRequestRPCHandler.java | 15 +-
.../DnToDnInternalServiceAsyncRequestManager.java | 11 +-
.../db/protocol/client/dn/DnToDnRequestType.java | 1 +
.../db/protocol/mqtt/PayloadFormatManager.java | 3 +-
.../iotdb/db/protocol/session/SessionManager.java | 12 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 5 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 173 +-
.../common/header/ColumnHeaderConstant.java | 7 +
.../common/header/DatasetHeaderFactory.java | 4 +
.../aggregation/LastValueDescAccumulator.java | 5 -
.../TableSingleTimeWindowIterator.java | 13 +-
.../execution/operator/AbstractOperator.java | 4 +
.../process/gapfill/AbstractGapFillOperator.java | 2 +
.../last/AbstractUpdateLastCacheOperator.java | 43 +-
.../last/AlignedUpdateLastCacheOperator.java | 11 +-
.../AlignedUpdateViewPathLastCacheOperator.java | 6 +-
.../operator/process/last/LastQueryUtil.java | 45 +-
.../process/last/UpdateLastCacheOperator.java | 15 +-
.../last/UpdateViewPathLastCacheOperator.java | 6 +-
.../operator/schema/source/ISchemaSource.java | 21 +-
.../schema/source/TableDeviceFetchSource.java | 36 +-
.../TableAggregationTableScanOperator.java | 281 +-
.../relational/aggregation/AccumulatorFactory.java | 172 +-
.../aggregation/AggregationOperator.java | 2 +-
.../relational/aggregation/AvgAccumulator.java | 105 +-
.../relational/aggregation/CountAccumulator.java | 7 +-
.../relational/aggregation/ExtremeAccumulator.java | 306 ++
.../relational/aggregation/FirstAccumulator.java | 342 ++
.../relational/aggregation/FirstByAccumulator.java | 491 +++
.../aggregation/FirstByDescAccumulator.java} | 19 +-
.../aggregation/FirstDescAccumulator.java} | 18 +-
.../relational/aggregation/LastAccumulator.java | 340 ++
.../relational/aggregation/LastByAccumulator.java | 491 +++
.../aggregation/LastByDescAccumulator.java} | 18 +-
.../aggregation/LastDescAccumulator.java} | 20 +-
.../relational/aggregation/MaxAccumulator.java | 332 ++
.../relational/aggregation/MinAccumulator.java | 332 ++
.../relational/aggregation/SumAccumulator.java | 11 +-
.../relational/aggregation/TableAccumulator.java | 2 +-
.../relational/aggregation/TableAggregator.java | 8 +-
.../aggregation/TableMaxByAccumulator.java | 73 +
.../aggregation/TableMaxMinByBaseAccumulator.java | 452 +++
.../aggregation/TableMinByAccumulator.java | 73 +
.../aggregation/TableModeAccumulator.java | 480 +++
.../aggregation/TableVarianceAccumulator.java | 231 ++
.../source/relational/aggregation/Utils.java | 130 +
.../GroupedAccumulator.java} | 30 +-
.../GroupedAggregator.java} | 38 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 177 +
.../grouped/GroupedCountAccumulator.java | 73 +
.../grouped/GroupedExtremeAccumulator.java | 322 ++
.../grouped/GroupedFirstAccumulator.java | 437 +++
.../grouped/GroupedFirstByAccumulator.java | 563 +++
.../grouped/GroupedLastAccumulator.java | 437 +++
.../grouped/GroupedLastByAccumulator.java | 564 +++
.../aggregation/grouped/GroupedMaxAccumulator.java | 386 +++
.../grouped/GroupedMaxByAccumulator.java | 60 +
.../grouped/GroupedMaxMinByBaseAccumulator.java | 692 ++++
.../aggregation/grouped/GroupedMinAccumulator.java | 386 +++
.../grouped/GroupedMinByAccumulator.java | 60 +
.../GroupedSumAccumulator.java} | 123 +-
.../grouped/HashAggregationOperator.java | 229 ++
.../aggregation/grouped/UpdateMemory.java | 26 +
.../aggregation/grouped/array/BigArrays.java | 56 +
.../aggregation/grouped/array/BinaryBigArray.java | 76 +
.../aggregation/grouped/array/BooleanBigArray.java | 156 +
.../aggregation/grouped/array/ByteBigArray.java | 152 +
.../aggregation/grouped/array/DoubleBigArray.java | 165 +
.../aggregation/grouped/array/FloatBigArray.java | 165 +
.../aggregation/grouped/array/IntBigArray.java | 182 +
.../aggregation/grouped/array/IntBigArrays.java | 188 +
.../aggregation/grouped/array/IntComparator.java | 27 +
.../aggregation/grouped/array/LongBigArray.java | 186 +
.../aggregation/grouped/array/ObjectBigArray.java | 173 +
.../aggregation/grouped/array/ShortBigArray.java | 176 +
.../grouped/builder/HashAggregationBuilder.java | 31 +
.../builder/InMemoryHashAggregationBuilder.java | 228 ++
.../grouped/hash/CombineHashFunction.java | 31 +
.../aggregation/grouped/hash/FlatGroupByHash.java | 204 ++
.../aggregation/grouped/hash/FlatHash.java | 599 ++++
.../aggregation/grouped/hash/FlatHashStrategy.java | 49 +
.../aggregation/grouped/hash/GroupByHash.java | 53 +
.../aggregation/grouped/hash/HashStrategy.java | 225 ++
.../grouped/hash/VariableWidthData.java | 191 ++
.../aggregation/grouped/hash/XxHash64.java | 276 ++
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +
.../analyze/cache/schema/DataNodeSchemaCache.java | 334 --
.../schema/DeviceUsingTemplateSchemaCache.java | 235 --
.../cache/schema/TimeSeriesSchemaCache.java | 436 ---
.../cache/schema/dualkeycache/IDualKeyCache.java | 71 +-
.../dualkeycache/impl/CacheEntryGroupImpl.java | 16 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 423 +--
.../dualkeycache/impl/FIFOCacheEntryManager.java | 77 +-
.../schema/dualkeycache/impl/ICacheEntryGroup.java | 9 +-
.../dualkeycache/impl/ICacheEntryManager.java | 13 +-
.../dualkeycache/impl/LRUCacheEntryManager.java | 57 +-
.../schema/lastcache/DataNodeLastCacheManager.java | 72 -
.../schema/lastcache/ILastCacheContainer.java | 45 -
.../cache/schema/lastcache/LastCacheContainer.java | 103 -
.../schema/lastcache/value/LastCacheValue.java | 74 -
.../plan/analyze/load/LoadTsFileAnalyzer.java | 6 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 102 +-
.../load/LoadTsFileToTreeModelAnalyzer.java | 2 +
.../plan/analyze/schema/ClusterSchemaFetcher.java | 5 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 6 +-
.../plan/analyze/schema/TemplateSchemaFetcher.java | 6 +-
.../queryengine/plan/execution/QueryExecution.java | 7 +-
.../execution/config/TableConfigTaskVisitor.java | 83 +-
.../config/executor/ClusterConfigTaskExecutor.java | 312 +-
.../config/executor/IConfigTaskExecutor.java | 32 +-
...Task.java => AbstractAlterOrDropTableTask.java} | 27 +-
.../relational/AlterTableAddColumnTask.java | 22 +-
...lumnTask.java => AlterTableDropColumnTask.java} | 36 +-
...mnTask.java => AlterTableRenameColumnTask.java} | 37 +-
...pDBTask.java => AlterTableRenameTableTask.java} | 21 +-
.../relational/AlterTableSetPropertiesTask.java | 22 +-
.../{DropDBTask.java => ClearCacheTask.java} | 14 +-
.../config/metadata/relational/DropDBTask.java | 4 +-
.../{DropDBTask.java => DropTableTask.java} | 18 +-
.../metadata/relational/ShowDataNodesTask.java | 12 +-
...wTablesTask.java => ShowTablesDetailsTask.java} | 17 +-
.../config/metadata/relational/ShowTablesTask.java | 2 +-
.../plan/execution/config/sys/ClearCacheTask.java | 7 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 21 +-
.../plan/planner/OperatorTreeGenerator.java | 176 +-
.../plan/planner/TableOperatorGenerator.java | 315 +-
.../plan/planner/plan/node/PlanNode.java | 1 +
.../plan/planner/plan/node/PlanNodeType.java | 22 +-
.../plan/planner/plan/node/PlanVisitor.java | 34 +-
.../planner/plan/node/load/LoadTsFileNode.java | 7 +-
.../node/metadata/read/TableDeviceSourceNode.java | 27 +-
.../ContinuousSameSearchIndexSeparatorNode.java | 11 +
.../planner/plan/node/write/DeleteDataNode.java | 188 +-
.../plan/planner/plan/node/write/InsertNode.java | 18 +-
.../planner/plan/node/write/InsertRowNode.java | 23 +-
.../planner/plan/node/write/InsertTabletNode.java | 35 +-
.../plan/node/write/RelationalInsertRowNode.java | 13 +
.../node/write/RelationalInsertTabletNode.java | 31 +
.../plan/planner/plan/node/write/SearchNode.java | 5 +-
.../plan/relational/analyzer/Analyzer.java | 9 +-
.../relational/analyzer/StatementAnalyzer.java | 9 +
.../predicate/ConvertPredicateToFilterVisitor.java | 2 +-
.../ConvertPredicateToTimeFilterVisitor.java | 8 +-
.../plan/relational/metadata/Metadata.java | 6 -
.../metadata/TableBuiltinAggregationFunction.java | 35 +-
.../relational/metadata/TableMetadataImpl.java | 33 +-
.../plan/relational/metadata/TableSchema.java | 93 +-
.../fetcher/TableDeviceCacheAttributeGuard.java | 158 +
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 164 +-
.../fetcher/TableDeviceSchemaValidator.java | 30 +-
.../metadata/fetcher/cache/IDeviceSchema.java} | 9 +-
.../metadata/fetcher/cache}/SchemaCacheEntry.java | 115 +-
.../fetcher/cache/TableAttributeSchema.java | 77 +
.../fetcher/cache/TableDeviceCacheEntry.java | 195 +-
.../fetcher/cache/TableDeviceLastCache.java | 266 ++
.../fetcher/cache/TableDeviceSchemaCache.java | 501 ++-
.../cache/TableDeviceSchemaCacheMetrics.java} | 30 +-
.../relational/metadata/fetcher/cache/TableId.java | 33 +-
.../fetcher/cache/TreeDeviceNormalSchema.java | 103 +
.../cache/TreeDeviceSchemaCacheManager.java | 449 +++
...DeviceId.java => TreeDeviceTemplateSchema.java} | 47 +-
.../plan/relational/planner/QueryPlanner.java | 14 +-
.../plan/relational/planner/RelationPlanner.java | 18 +
.../plan/relational/planner/SymbolAllocator.java | 7 +-
.../relational/planner/TableLogicalPlanner.java | 26 +-
.../plan/relational/planner/TableModelPlanner.java | 20 +-
.../planner/distribute/AddExchangeNodes.java | 6 +-
.../distribute/TableDistributedPlanGenerator.java | 257 +-
.../TableModelTypeProviderExtractor.java | 6 +-
.../iterative/rule/MergeLimitWithMergeSort.java | 55 +-
.../iterative/rule/PruneGapFillColumns.java | 13 +-
.../planner/node/AggregationTableScanNode.java | 9 +-
.../plan/relational/planner/node/GapFillNode.java | 1 -
.../node/schema}/AbstractTableDeviceQueryNode.java | 35 +-
...ctTableSchemaQueryAttributeSecurityVisitor.java | 69 +
.../CreateOrUpdateTableDeviceNode.java | 4 +-
.../planner/node/schema/DeleteTableDeviceNode.java | 114 +
.../TableDeviceAttributeCommitUpdateNode.java | 194 ++
.../schema}/TableDeviceAttributeUpdateNode.java | 6 +-
.../planner/node/schema}/TableDeviceFetchNode.java | 39 +-
.../node/schema}/TableDeviceQueryCountNode.java | 15 +-
.../node/schema}/TableDeviceQueryScanNode.java | 10 +-
.../node/schema/TableNodeLocationAddNode.java | 115 +
...TableSchemaQuerySuccessfulCallbackVisitor.java} | 25 +-
.../node/schema/TableSchemaQueryWriteVisitor.java | 46 +
.../PushAggregationIntoTableScan.java | 25 +-
.../optimizations/TransformSortToStreamSort.java | 30 +-
.../plan/relational/sql/ast/AddColumn.java | 2 +-
.../plan/relational/sql/ast/AstVisitor.java | 8 +
.../sql/ast/{DropTable.java => ClearCache.java} | 49 +-
.../plan/relational/sql/ast/DropColumn.java | 48 +-
.../plan/relational/sql/ast/DropTable.java | 11 +-
.../plan/relational/sql/ast/InsertRows.java | 19 +-
.../plan/relational/sql/ast/InsertTablet.java | 11 +-
.../plan/relational/sql/ast/LoadTsFile.java | 2 +-
.../sql/ast/{DropTable.java => PipeEnriched.java} | 51 +-
.../plan/relational/sql/ast/RenameColumn.java | 32 +-
.../plan/relational/sql/ast/RenameTable.java | 39 +-
.../plan/relational/sql/ast/ShowTables.java | 26 +-
.../relational/sql/ast/WrappedInsertStatement.java | 11 +-
.../plan/relational/sql/parser/AstBuilder.java | 144 +-
.../plan/relational/sql/util/SqlFormatter.java | 64 +-
.../plan/relational/utils/TypeUtil.java | 397 +++
.../scheduler/FragmentInstanceDispatcherImpl.java | 52 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 21 +-
.../plan/statement/crud/InsertRowsStatement.java | 8 +
.../plan/statement/crud/InsertTabletStatement.java | 44 +-
.../plan/statement/crud/LoadTsFileStatement.java | 29 +
.../plan/statement/pipe/PipeEnrichedStatement.java | 10 +
.../plan/statement/sys/ClearCacheStatement.java | 17 +-
.../AbstractCaseWhenThenColumnTransformer.java | 181 +-
.../column/binary/LogicAndColumnTransformer.java | 2 +-
.../column/binary/LogicOrColumnTransformer.java | 2 +-
.../dag/column/leaf/TimeColumnTransformer.java | 1 +
.../multi/LogicalAndMultiColumnTransformer.java | 2 +-
.../multi/LogicalOrMultiColumnTransformer.java | 2 +-
.../column/multi/MappableUDFColumnTransformer.java | 2 +-
.../rescon/MemSchemaEngineStatistics.java | 4 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 106 +-
.../schemaregion/SchemaRegionPlanType.java | 15 +-
.../schemaregion/SchemaRegionPlanVisitor.java | 23 +-
.../attribute/DeviceAttributeStore.java | 27 +-
.../attribute/IDeviceAttributeStore.java | 2 +
.../update/DeviceAttributeCacheUpdater.java | 433 +++
.../GeneralRegionAttributeSecurityService.java | 361 ++
.../update/RewritableByteArrayOutputStream.java | 58 +
.../attribute/update/UpdateClearContainer.java | 147 +
.../attribute/update/UpdateContainer.java | 53 +
.../attribute/update/UpdateDetailContainer.java | 345 ++
.../update/UpdateDetailContainerStatistics.java | 52 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 170 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 27 +-
.../visitor/SchemaRegionPlanDeserializer.java | 26 +-
.../visitor/SchemaRegionPlanSerializer.java | 41 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 49 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 18 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 19 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 8 +-
.../schemaregion/mtree/traverser/Traverser.java | 3 +-
.../mtree/traverser/collector/MNodeCollector.java | 14 +-
.../mtree/traverser/updater/EntityUpdater.java | 1 +
.../schemaengine/schemaregion/tag/TagManager.java | 17 +-
.../write/req/SchemaRegionWritePlanFactory.java | 62 +-
.../db/schemaengine/table/DataNodeTableCache.java | 20 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 2 +
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../db/service/DataNodeInternalRPCService.java | 4 +
.../iotdb/db/service/DataNodeShutdownHook.java | 4 +
.../iotdb/db/storageengine/StorageEngine.java | 49 +-
.../db/storageengine/dataregion/DataRegion.java | 455 ++-
.../execute/task/InnerSpaceCompactionTask.java | 9 +-
.../execute/utils/CompactionTableSchema.java | 2 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 22 +
...edReadChunkAlignedSeriesCompactionExecutor.java | 23 +
.../utils/AlignedSeriesBatchCompactionUtils.java | 5 +
.../executor/batch/utils/BatchCompactionPlan.java | 36 +
.../fast/FastAlignedSeriesCompactionExecutor.java | 15 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 2 +-
.../execute/utils/log/CompactionLogger.java | 3 +
.../compaction/schedule/CompactionTaskQueue.java | 3 +
.../DefaultCompactionTaskComparatorImpl.java | 8 +-
.../estimator/AbstractCompactionEstimator.java | 10 +-
.../FastCompactionInnerCompactionEstimator.java | 4 +-
.../FastCrossSpaceCompactionEstimator.java | 4 +-
.../ReadChunkInnerCompactionEstimator.java | 4 +-
.../dataregion/flush/MemTableFlushTask.java | 2 +-
.../memtable/AlignedWritableMemChunk.java | 6 +-
.../dataregion/memtable/IWritableMemChunk.java | 5 +-
.../dataregion/memtable/TsFileProcessor.java | 258 +-
.../dataregion/memtable/WritableMemChunk.java | 2 +-
.../dataregion/read/control/FileReaderManager.java | 4 +-
.../dataregion/tsfile/TsFileResource.java | 10 +-
.../tsfile/generator/TsFileNameGenerator.java | 4 +-
.../storageengine/dataregion/wal/WALManager.java | 21 +-
.../dataregion/wal/allocation/ElasticStrategy.java | 27 +-
.../dataregion/wal/buffer/WALBuffer.java | 2 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 55 +-
.../dataregion/wal/node/IWALNode.java | 4 +-
.../dataregion/wal/node/WALFakeNode.java | 4 +-
.../storageengine/dataregion/wal/node/WALNode.java | 4 +-
.../db/storageengine/load/LoadTsFileManager.java | 84 +-
.../load/active/ActiveLoadDirScanner.java | 25 +-
.../active/ActiveLoadFailedMessageHandler.java | 116 +
.../load/active/ActiveLoadTsFileLoader.java | 29 +-
.../load/config/LoadTsFileConfigurator.java | 6 +-
.../load/splitter/AlignedChunkData.java | 35 +-
.../splitter/BatchedAlignedValueChunkData.java | 3 +-
.../db/storageengine/load/splitter/ChunkData.java | 9 +-
.../storageengine/load/splitter/DeletionData.java | 6 +-
.../load/splitter/NonAlignedChunkData.java | 30 +-
.../db/storageengine/load/splitter/TsFileData.java | 13 +-
.../load/splitter/TsFileDataType.java} | 8 +-
.../load/splitter/TsFileSplitter.java | 9 +-
.../broker/SubscriptionPrefetchingQueue.java | 150 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 148 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 274 +-
.../SubscriptionConnectorSubtaskManager.java | 3 -
.../org/apache/iotdb/db/utils/SchemaUtils.java | 1 +
.../iotdb/db/utils/constant/SqlConstant.java | 8 +-
....java => TreeDeviceSchemaCacheManagerTest.java} | 239 +-
.../cache/dualkeycache/DualKeyCacheTest.java | 347 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 18 +-
.../SchemaRegionSimpleRecoverTest.java | 2 +-
.../schemaRegion/SchemaRegionTestUtil.java | 2 +-
.../connector/PipeDataNodeThriftRequestTest.java | 215 ++
.../db/pipe/consensus/DeletionRecoverTest.java | 85 +
.../db/pipe/consensus/DeletionResourceTest.java | 211 ++
.../pipe/event/TsFileInsertionEventParserTest.java | 23 +-
.../pipe/PipeEnrichedDeleteDataNodeSerdeTest.java | 4 +-
.../node/write/DeleteDataNodeSerdeTest.java | 4 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 57 +
.../plan/relational/analyzer/AggregationTest.java | 105 +-
.../plan/relational/analyzer/TSBSMetadata.java | 6 -
.../plan/relational/analyzer/TestMatadata.java | 6 -
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 478 ++-
.../plan/relational/sql/ast/InsertTabletTest.java | 130 +
.../storageengine/dataregion/DataRegionTest.java | 195 +-
.../BatchedCompactionWithTsFileSplitterTest.java | 3 +-
.../compaction/CompactionTaskComparatorTest.java | 12 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 55 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 55 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 18 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 18 +-
.../settle/SettleRequestHandlerTest.java | 10 +-
.../CompactionTableSchemaCollectorTest.java | 114 +
.../dataregion/memtable/TsFileProcessorTest.java | 110 +-
.../wal/allocation/ElasticStrategyTest.java | 11 +
.../wal/node/ConsensusReqReaderTest.java | 30 +-
.../dataregion/wal/node/WALFakeNodeTest.java | 12 +-
.../dataregion/wal/node/WALNodeTest.java | 10 +-
.../apache/iotdb/metrics/core/type/IoTDBTimer.java | 29 +-
.../reporter/prometheus/PrometheusReporter.java | 6 +
.../conf/iotdb-system.properties.template | 17 +-
.../client/request/AsyncRequestContext.java | 10 +-
.../client/request/AsyncRequestManager.java | 48 +-
.../iotdb/commons/concurrent/ThreadName.java | 9 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 2 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../consensus/index/impl/SimpleProgressIndex.java | 38 +-
.../UncheckedStartupException.java} | 31 +-
...java => AbstractPipePeriodicalJobExecutor.java} | 38 +-
.../agent/runtime/PipePeriodicalJobExecutor.java | 101 +-
.../PipePeriodicalPhantomReferenceCleaner.java} | 23 +-
.../config/constant/PipeExtractorConstant.java | 20 +-
.../config/constant/PipeProcessorConstant.java | 3 +-
.../request/PipeConsensusRequestType.java | 1 +
.../payload/thrift/request/PipeRequestType.java | 5 +
.../thrift/request/PipeTransferFileSealReqV2.java | 6 +-
.../datastructure/PersistentResource.java} | 20 +-
.../datastructure/pattern/IoTDBTreePattern.java | 9 +
.../datastructure/pattern/PrefixTreePattern.java | 9 +
.../pipe/datastructure/pattern/TablePattern.java | 2 +-
.../pipe/datastructure/pattern/TreePattern.java | 15 +-
.../resource/ref/PipePhantomReferenceManager.java | 20 +-
.../commons/schema/ClusterSchemaQuotaLevel.java | 1 +
.../apache/iotdb/commons/schema/MemUsageUtil.java | 2 +-
.../iotdb/commons/schema/SchemaConstant.java | 6 +-
.../commons/schema/cache/CacheClearOptions.java} | 10 +-
.../apache/iotdb/commons/schema/node/IMNode.java | 3 +-
...ype.java => AlterOrDropTableOperationType.java} | 20 +-
.../commons/schema/table}/TableNodeStatus.java | 8 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 17 +-
.../apache/iotdb/commons/service/ServiceType.java | 2 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 4 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 40 +-
.../iotdb/commons/utils/TimePartitionUtils.java | 104 +-
.../iotdb/commons/client/ClientManagerTest.java | 7 +-
.../commons/utils/TimePartitionUtilsTest.java | 16 +
.../db/relational/grammar/sql/RelationalSql.g4 | 16 +-
.../thrift-commons/src/main/thrift/common.thrift | 8 +-
.../src/main/thrift/confignode.thrift | 11 +-
.../src/main/thrift/pipeconsensus.thrift | 13 +-
.../src/main/thrift/datanode.thrift | 46 +-
pom.xml | 4 +-
564 files changed, 34805 insertions(+), 7298 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBTableAggregationIT.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/{CnToDnRequestType.java
=> async/CnToDnAsyncRequestType.java} (88%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/ITableCache.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/client/sync/CnToDnSyncRequestType.java}
(57%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{RollbackCreateTablePlan.java
=> AbstractTablePlan.java} (79%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/table/ShowTablePlan.java
=> write/table/DropTablePlan.java} (68%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/table/ShowTablePlan.java
=> write/table/PreDeleteTablePlan.java} (68%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{PreCreateTablePlan.java
=> RenameTableColumnPlan.java} (53%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AbstractAlterOrDropTableProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableColumnProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableColumnProcedure.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DnToDnRequestType.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DropTableColumnState.java}
(85%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DnToDnRequestType.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DropTableState.java}
(81%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DnToDnRequestType.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/RenameTableColumnState.java}
(79%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableColumnProcedureTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedureTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableColumnProcedureTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferTabletBatchReqV2.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferTabletBinaryReqV2.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferTabletInsertNodeReqV2.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferTabletRawReq.java
=> PipeTransferTabletRawReqV2.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusDeleteNodeReq.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/deletion/DeletionResource.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/deletion/DeletionResourceManager.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/analyze/cache/schema/lastcache/value/ILastCacheValue.java
=> pipe/consensus/deletion/persist/DeletionBuffer.java} (63%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/deletion/persist/PageCacheDeletionBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/deletion/recover/DeletionReader.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/{
=> metric}/PipeConsensusConnectorMetrics.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/{
=> metric}/PipeConsensusReceiverMetrics.java (99%)
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/event =>
datanode/src/main/java/org/apache/iotdb/db/pipe/event/common}/PipeInsertionEvent.java
(93%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/deletion/PipeDeleteDataNodeEvent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParser.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParserTabletIterator.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/historical/{PipeHistoricalDataRegionTsFileExtractor.java
=> PipeHistoricalDataRegionTsFileAndDeletionExtractor.java} (63%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/ExtremeAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/FirstAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/FirstByAccumulator.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/ClusterSchemaQuotaLevel.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/FirstByDescAccumulator.java}
(64%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/ClusterSchemaQuotaLevel.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/FirstDescAccumulator.java}
(70%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/LastAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/LastByAccumulator.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/ClusterSchemaQuotaLevel.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/LastByDescAccumulator.java}
(64%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/ClusterSchemaQuotaLevel.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/LastDescAccumulator.java}
(65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/MaxAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/MinAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/TableMaxByAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/TableMaxMinByBaseAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/TableMinByAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/TableModeAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/TableVarianceAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/Utils.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{TableAccumulator.java
=> grouped/GroupedAccumulator.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{TableAggregator.java
=> grouped/GroupedAggregator.java} (74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedAvgAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedCountAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedExtremeAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedFirstAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedFirstByAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedLastAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedLastByAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedMaxAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedMaxByAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedMaxMinByBaseAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedMinAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedMinByAccumulator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{SumAccumulator.java
=> grouped/GroupedSumAccumulator.java} (53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/HashAggregationOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/UpdateMemory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/BigArrays.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/BinaryBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/BooleanBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/ByteBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/DoubleBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/FloatBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/IntBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/IntBigArrays.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/IntComparator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/LongBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/ObjectBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/ShortBigArray.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/builder/HashAggregationBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/builder/InMemoryHashAggregationBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/CombineHashFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/FlatGroupByHash.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/FlatHash.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/FlatHashStrategy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/GroupByHash.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/HashStrategy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/VariableWidthData.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/XxHash64.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/DataNodeSchemaCache.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/DeviceUsingTemplateSchemaCache.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/TimeSeriesSchemaCache.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/DataNodeLastCacheManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/ILastCacheContainer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/LastCacheContainer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/value/LastCacheValue.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{DropDBTask.java
=> AbstractAlterOrDropTableTask.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AlterTableAddColumnTask.java
=> AlterTableDropColumnTask.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AlterTableAddColumnTask.java
=> AlterTableRenameColumnTask.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{DropDBTask.java
=> AlterTableRenameTableTask.java} (66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{DropDBTask.java
=> ClearCacheTask.java} (73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{DropDBTask.java
=> DropTableTask.java} (72%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{ShowTablesTask.java
=> ShowTablesDetailsTask.java} (84%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableDeviceCacheAttributeGuard.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{protocol/client/dn/DnToDnRequestType.java
=> queryengine/plan/relational/metadata/fetcher/cache/IDeviceSchema.java} (80%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{analyze/cache/schema
=> relational/metadata/fetcher/cache}/SchemaCacheEntry.java (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TableAttributeSchema.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TableDeviceLastCache.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{analyze/cache/schema/DataNodeSchemaCacheMetrics.java
=> relational/metadata/fetcher/cache/TableDeviceSchemaCacheMetrics.java} (70%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TreeDeviceNormalSchema.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TreeDeviceSchemaCacheManager.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/{TableDeviceId.java
=> TreeDeviceTemplateSchema.java} (52%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/metadata/read
=> relational/planner/node/schema}/AbstractTableDeviceQueryNode.java (85%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/AbstractTableSchemaQueryAttributeSecurityVisitor.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{
=> schema}/CreateOrUpdateTableDeviceNode.java (99%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/DeleteTableDeviceNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableDeviceAttributeCommitUpdateNode.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/metadata/read
=> relational/planner/node/schema}/TableDeviceAttributeUpdateNode.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/metadata/read
=> relational/planner/node/schema}/TableDeviceFetchNode.java (80%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/metadata/read
=> relational/planner/node/schema}/TableDeviceQueryCountNode.java (90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{planner/plan/node/metadata/read
=> relational/planner/node/schema}/TableDeviceQueryScanNode.java (93%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableNodeLocationAddNode.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/ShowTablePlan.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableSchemaQuerySuccessfulCallbackVisitor.java}
(53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableSchemaQueryWriteVisitor.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DropTable.java
=> ClearCache.java} (53%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DropTable.java
=> PipeEnriched.java} (50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/DeviceAttributeCacheUpdater.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/GeneralRegionAttributeSecurityService.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/RewritableByteArrayOutputStream.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/UpdateClearContainer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/UpdateContainer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/UpdateDetailContainer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/UpdateDetailContainerStatistics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandler.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{protocol/client/dn/DnToDnRequestType.java
=> storageengine/load/splitter/TsFileDataType.java} (85%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/cache/{DataNodeSchemaCacheTest.java
=> TreeDeviceSchemaCacheManagerTest.java} (53%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/consensus/DeletionRecoverTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/consensus/DeletionResourceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/InsertTabletTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tablemodel/CompactionTableSchemaCollectorTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{schema/table/AlterTableOperationType.java
=> exception/UncheckedStartupException.java} (54%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/runtime/{PipePeriodicalJobExecutor.java
=> AbstractPipePeriodicalJobExecutor.java} (75%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/ShowTablePlan.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/runtime/PipePeriodicalPhantomReferenceCleaner.java}
(58%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{schema/ClusterSchemaQuotaLevel.java
=> pipe/datastructure/PersistentResource.java} (65%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DnToDnRequestType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/cache/CacheClearOptions.java}
(85%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/{AlterTableOperationType.java
=> AlterOrDropTableOperationType.java} (71%)
rename
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/mnode/impl
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/table}/TableNodeStatus.java
(84%)
