This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch udsf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fbe6fde95d6 Merge branch 'table_udsf' into udsf
add 387b4bf3e43 [remove datanode] Identify and display invalid nodes
before removing #13987
add 710ef7d92eb SQL syntax support for WEEK
add bc4dd72eafb Print Dataset is closed error msg if user continues to
fetch from it
add 57b8a116942 Fixed the NPE of table device fetch caused by non-exist
device
add 3956861df35 Pipe: Fix the problem that SessionUtils calculates Tablet
without handling null pointers and update tsfile version (#13990)
add 78e6f3a0851 [remove datanode] Fixed jvm heap memory in remove datanode
script (#13983)
add db7c522d5e0 [remove datanode] Enhance remove message on environment
with only ConfigNode #14007
add 38f6d0f7cec Implement delete device && Removed some unnecessary
executions in multi replicasets by schema procedures && Fixed some minor bugs
related to dualKeyCache
add 74e4634dad3 Fix group by time in TableModel
add 23b914d8da9 Fix concurrent problem (NPE) of AsyncRequestManager
(#14004)
add f5d18323330 Modify errMsg of unsupported subquery
add 26a0da957d2 Support stream optimize for HashAggregation of TableModel
add caac6074643 Pipe: GC device2Measurements in PipeRealtimeEvent in time
to avoid OOM when insertion is in high load (#14018)
add cae7061e869 Adjustment of setString method in IoTDBPreparedStatement
add b39c3255ed6 Fix ConfignNode LoadManager NPE when removing datanodes
#14016
add dca2a0a6b16 [Region Migration] Fix Create ConsensusPipe On Coordinator
Failed #14021
add a7e2f09173f Pipe: Fixed the bug that the
PipeDataNodeRemainingEventAndTimeMetrics may generate NullPointerException
(#14015)
add 859d37f3a3e Pipe: CreatePipe and AlterPipe support now function
(#14014)
add 4b0ad40e7fb IoTConsensusV2: Support SyncLag And Buffer Control For
Deletion #14026
add 85d7b9c6b29 Pipe: Update tsfile version to fix the issue that the time
of the first data item written to TSFile by measurement cannot be a negative
number (#14032)
add 543b267c7d0 Support auto detecting the misuses of TestOnly annotation
(#14030)
add 02a85ffa215 Fixed the class cast exception of UpdateDetailContainer
add 34fc3cac38c Implement drop column for table model
add 8a92aaf56bf Remove useless log "datanodeId -1" #14035
add 4be1020bf1e [region migration] Fix tsfile error caused by target
DataNode's fast rebooting #14031
add f706fa95d02 Fix query resource clear async thread stuck bug
add 4ead41b35c4 Change typo in warn log for disk_space_warning_threshold
(#14041)
add 5cf18ed5a37 fix for cpp client checkTemplate exist (#14028)
add 3bd8af06571 bump ratis to 3.1.2 (#14044)
add 46af90ca211 modify stop node scripts (#14047)
add 12bc4f89d96 Fix exec remove-datanode.sh failed in jdk17 (#14036)
add 10b1220537d IoTConsensusV2: Fix Create DataRegion Failed. #14050
add e437ef3d056 [remove datanode] Log the node information when submitting
RegionMigrateProcedure (#14051)
add 7e08e68a0d4 IoTConsensusV2 X [Region Migration] Each component uses
an independent ClientManager && Filter out the consensus pipe when judging
resource release #14052
add 5db013aae64 Pipe: Fix the null pointer caused by uninitialized
TabletInsertionEventParser LocalDate and Binary arrays (#14058)
add de9645dde1b Pipe: avoid supply event with failed tsfile resource pin &
apply double-checked locking for exists-and-mkdirs operation (#13998)
add d723880394b Modify default heap dump path of datanode (#14060)
add 70006df9bbc When the thread is interrupted while retrying a
connection, the loop will exit early. (#14062)
add 57c668ca516 Pipe: atomically publish segment lock to avoid
uninitialized volatile variable (#14064)
add e1cc2294e7d Add or modify encryption related codes (#13364)
add 34221fb035f Subscription: avoid the file reading when the memory is
not enough for tsfile slicing & implement all-out effort global timeout control
& support client resume from breakpoint for tsfile consumption (#13992)
add 32e701eadd5 Pipe: Pin unpin log frequency decrease (#14049)
add 3aef6ada2cf Pipe: Fixed the bug that historical aligned timeseries'
attributes/tags/alias is not transferred (#14071)
add cf75abfd3f6 Fix flush command stack problem and clean old code in
DataRegion (#14027)
add d6377702c90 Add cache hit situation and actual io size for
BloomFilter, TimeSeriesMetadata(including ChunkMetadatList) and Chunk
add 6197bd0e32a Delete system.properties in a better way #14080
add 8ed855f8d4a Pipe: CI trigger condition ignores changes to query engine
directory (#14067)
add c2405ea388c Optimize the error log when data type mismatch / Fixed the
bug that attribute cannot be set to null in update statement (#14069)
add 431469fce31 Pipe/Load: Disable Pipe/Load when TSFile encryption is
enabled (#14070)
add c6fa44d3de1 Add ainode to distribution (#14090)
add 86a33773e8c Pipe IT: Add table model related IT (#14086)
add 442dc861f97 PipeConsensus: apply IoTConsensusV2 as cluster mode for
integration test (#13481)
add 7908cf720af Fix corner case of StreamAggOperator
add db1b897f2f9 Revert integration-test module change (#14096)
add 2a1dc883d73 Bump netty version to 4.1.115.Final (#14095)
add 978f14daaa3 Modify default heap dump path of confignode (#14088)
add f15ebf3dd3e [Region Migration] Support Migrate Unknown Node for IoTV2
&& Rename KillPoints to Fit IoTV2 (#14085)
add 44b348cdb06 [region migration] Fix IoTConsensus data consistency
during region member changes (#14084)
add e2788a242d7 Subscription: stream parsing tablets during the poll
process to reduce memory usage (#14101)
add cfb4c8ae30f Fix heap dump path (#14105)
add 7f56c1bc1a2 Modify env script comment #14118
add b14cdbef2ca Fix error message when there is no argument in sum, avg
and extreme
add de22d8ff928 Added version for dataNode table cache
add 0d6482789ab Support all push-able expressions in push down to metaData
& Optimized database-related error logs
add 63da4a42c94 Table model data deletion (#13878)
add 8a847870939 Fix intermediate output of MaxMinByAccumulator in
TableModel
add b5a8b47e8f6 Support using long to compare timestamp type in expression
add f3afc203633 [remove datanode] Enhance remove message on environment
with only ConfigNode #14123
add f9f23853a60 bump ratis to 3.1.2-2fe59d3-SNAPSHOT (#14120)
add 5fd2c9cd45c Implement schema quota for activation in table model
add 0fb31a70bca Make the root.__system database has a normal number of
replicas (no longer forcing the replica to be 1) (#14127)
add 921652a8c88 Fix error message when there is no argument in first,
last, first_by and last_by
add e85a7eaac69 Fix first_by and last_by with group by in TableModel
add 466c0d91326 fix trim (#14130)
add f8bcf2adec6 Fix that the row deletion mark is mistakenly use (#14138)
add 21af258bf0b Try to eliminate redundant Project and Sort For right
table of Join clause in some self-join cases
add 16c3f66519a Update release info after 1.3.3 released (#14151)
add 2dfe81feba9 Fixed the bug that limit is pushed down when there is a
filter node
add 51765342bcf Batch update inserted points metric for insertMultiTablets
(#14146)
add e37d2b9b0db Fix NPE of empty data aggregation query when there is no
push-down optimize in TableModel
add 4420f2160a9 Pipe IT: Ignore Pipe capture history TSFile test for table
model (#14153)
add 43ed86500d6 PipeConsensus: always execute flush for historical data
extraction of consensus pipe to reduce data sync delay (#14132)
add 4a76dfbabbd Fix ConfigNode Partition Metric NPE bug #14144
add 82a1dc3990a Fixed the bug that set table properties ttl='inf' cannot
be parsed && ttl='INF' does not take effect && set to default may generate NPE
on dataNodes && some minor bugs of delete devices && Enable "inf" in
databaseSchema / show ttl for databases in table model / table default ttl =
database ttl (#14147)
add 1b33c55153a Change LogicalOptimizer and DistributionOptimizer
singleton (#14158)
add 3cb544e39b2 Pipe: Reduce the memory usage & Enable insertNode memory
control for stream mode degrade and stuck restart (#14102)
add adcedc0bc57 [remove datanode] Refuse to remove when there are any
other unknown or readonly DataNodes in the consensus group (#14145)
add ec5d2ca1603 LOGGER.error(e.getMessage()) IS REALLY A BAD IDEA (#14137)
add 4edc42b97f8 Pipe: Fix the problem that the Aligned information of the
Tablet generated by TsFileInsertionEventScanParser is incorrect (#14136)
add 01a46eeab7e Bump tsfile version to 1.2.0-dd29bcc-SNAPSHOT #14163
add e66f3a8a727 Fixed bug where Ratis could not write large requests and
could not be configured (#14160)
add a7f2d6bb437 Load: Fix locally load v3 tsfile with PlainDeviceTimeIndex
(#14098)
add 22cf9449c40 Pipe: Improve performance when syncing table data between
clusters with param 'table-name' = '.*' or with param 'database-name' = '.*' by
reducing unnecessary tsfile parse & Fix data filter with both tree and table
patterns (#14150)
add 7852cb67411 ignore timeout exception for consensus pipe operate
procedures (#14116)
add 6242d939c22 remove procedure no longer acquire node lock (#14115)
add a7df2051915 Update README_ZH.md (#14171)
add 65ab3ea7b2c Distinguish database model in database drop / support
currentDatabase + currentUser expression in common query & updateStatement
add e2543f308bf Refactor Table session (#14157)
add 9466829bb16 Pipe: Reduce the amount of log information printed after a
batch fails (#14172)
add d171a53053e Make TsTable always store uppercase "INF" && Fixed the NPE
bug when TTL is set to "INF" && Distinguish database model in alter database
add 9b22f7c6304 Fix stopping cn leader stuck when region region migration
#14175
add 0ec59a3dbf7 Fix deleteDirectoryAndEmptyParent NPE (#14178)
add d82dffdbc8e IoTConsensusV2: Fix npe when data region is not existed
(#14180)
add a6897264a66 IoTConsensusV2: Support Table Model Replicate (#14169)
add 76066d41df0 Pipe: Fix filter issue when both tree extraction and table
extraction are enabled and one extraction has non default pattern (#14184)
add 63bcf6e874a Subscription: revert ScheduledExecutorService to
ExecutorService to avoid task queue oom & fix subscription task count (#14186)
add 24a00905ff2 Fix aggregation query of TableModel when there are
numerous regions in one device
add 6e41961c82c Fix multi table joins error and add more integration tests
add 34228a91cb9 Fix some query metric
add 8491391cafe Optimize first, last, first_by, last_by aggregation
process in table model
add 3ba0903a5d1 Allow time column specification in table creation &
Enhance table IT's TTL for insertion & disable SCHEMA_REPLICATION_FACTOR /
DATA_REPLICATION_FACTOR in table database definition
add c3bd12de2f2 Disable create/alter tree databases with
SCHEMA/DATA_REPLICATION_FACTOR & Refine tsTable get TTL logic (#14194)
add d107c2d2b3c Support EXPLAIN ANALYZE in table model (#14189)
add 559b58a2183 Enhance repair data file scan util (#14167)
add 68daea60b0a Pipe/Subscription: Filter out non-working DR PipeTasks in
CN & Reduce model judgement cost in
PipeHistoricalDataRegionTsFileAndDeletionExtractor (#14059)
add e0c6cf63821 Fix bug in inner join of table model (#14198)
add c7e2d8e67c5 Optimize insertRelationalTablet performance (#14197)
add 293746efae3 Refactor mod-file-related FileMetric (#14199)
add 95d06f6de16 Fix AsyncClientManager selector thread leak #14203
add 098306cbb9c Optimize the implantation of EXPLAIN ANALYZE
add bf2c5b134f6 Fix upper-case database name in TableSession error
add bb99334754f Pipe: implement RenameDatabaseProcessor &
WriteBackConnector for table model events (#14131)
add 0160b65d67b Pipe: make exception message more friendly when creating
data sync pipe failed (#14208)
add d9552365dc2 Set fetchSize to max_tsblock_line_number if it's equal to
or less than zero
add 8a6405cdfa7 [remove datanode] Do not allow regions to inherit the
Removing state from datanode (#14185)
add 77a21a71e7f Fixed the bugs of the table cache
add b072f9e861c Fix throw exception when compare with null
add d751364acb3 Refactor UDF management process to support table model
user-defined function
add 0ed1d8516af merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/pipe-it-2cluster.yml | 71 +-
LICENSE | 43 +-
LICENSE-binary | 118 ++-
README_ZH.md | 2 +-
RELEASE_NOTES.md | 363 +++++++
distribution/pom.xml | 58 ++
distribution/src/assembly/ainode.xml | 46 +
.../org/apache/iotdb/TableModelSessionExample.java | 107 +-
.../apache/iotdb/TableModelSessionPoolExample.java | 110 ++-
integration-test/pom.xml | 44 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 33 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 14 +
.../it/env/cluster/config/MppCommonConfig.java | 18 +
.../env/cluster/config/MppSharedCommonConfig.java | 21 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 106 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 60 ++
.../it/env/remote/config/RemoteCommonConfig.java | 15 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 93 +-
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 11 +-
.../itbase/category/MultiClusterIT2TableModel.java | 6 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 45 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../it/partition/IoTDBPartitionCreationIT.java | 59 +-
.../it/partition/IoTDBPartitionDurableIT.java | 130 ---
.../IoTDBRegionMigrateReliabilityITFramework.java | 1 +
...rateCoordinatorCrashWhenRemoveRemotePeerIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 207 ++--
.../db/it/query/IoTDBEncryptionValueQueryIT.java | 676 +++++++++++++
.../db/it/query/IoTDBLoadEncryptedTsFileIT.java | 204 ++++
.../iotdb/db/it/query/IoTDBLoadPlainTsFileIT.java | 145 +++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 141 ++-
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 48 +
.../pipe/it/autocreate/IoTDBPipeAutoDropIT.java | 80 +-
.../IoTDBPipeConnectorCompressionIT.java | 7 +-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 2 +-
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 20 +-
.../it/autocreate/IoTDBPipeSwitchStatusIT.java | 7 +-
.../it/autocreate/IoTDBTreePatternFormatIT.java | 3 +
.../pipe/it/autocreate/PipeNowFunctionIT.java | 286 ++++++
.../pipe/it/manual/AbstractPipeDualManualIT.java | 48 +
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 57 ++
.../pipe/it/manual/IoTDBPipePermissionIT.java | 1 +
.../AbstractPipeTableModelTestIT.java} | 4 +-
.../iotdb/pipe/it/tablemodel/IoTDBPipeAlterIT.java | 457 +++++++++
.../it/tablemodel/IoTDBPipeAutoConflictIT.java | 267 +++++
.../IoTDBPipeAutoDropIT.java | 46 +-
.../pipe/it/tablemodel/IoTDBPipeClusterIT.java | 909 +++++++++++++++++
.../IoTDBPipeConnectorCompressionIT.java | 54 +-
.../tablemodel/IoTDBPipeConnectorParallelIT.java | 99 ++
.../pipe/it/tablemodel/IoTDBPipeDataSinkIT.java | 278 ++++++
.../pipe/it/tablemodel/IoTDBPipeExtractorIT.java | 925 +++++++++++++++++
.../IoTDBPipeLifeCycleIT.java | 517 +++-------
.../pipe/it/tablemodel/IoTDBPipeNullValueIT.java | 169 ++++
.../pipe/it/tablemodel/IoTDBPipeProtocolIT.java | 466 +++++++++
.../IoTDBPipeSwitchStatusIT.java | 61 +-
.../pipe/it/tablemodel/IoTDBPipeSyntaxIT.java | 685 +++++++++++++
.../pipe/it/tablemodel/IoTDBPipeWithLoadIT.java | 120 +++
.../it/tablemodel/IoTDBTablePatternFormatIT.java | 572 +++++++++++
.../iotdb/pipe/it/tablemodel/TableModelUtils.java | 395 ++++++++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 754 ++++++++++++++
.../relational/it/db/it/IoTDBInsertTableIT.java | 66 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 140 ++-
.../it/query/old/IoTDBFilterTableIT.java | 24 +
.../scalar/IoTDBScalarFunctionTableIT.java | 16 +
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 42 +-
.../it/query/old/query/IoTDBInTableIT.java | 89 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 120 +++
.../relational/it/schema/IoTDBDatabaseIT.java | 31 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 32 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 189 +++-
.../it/session/IoTDBTableModelSessionIT.java | 45 +-
.../pool/IoTDBInsertTableSessionPoolIT.java | 30 +-
.../session/pool/IoTDBTableModelSessionPoolIT.java | 17 +-
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 401 ++------
.../IoTDBDefaultTsfilePushConsumerIT.java | 6 +-
.../IoTDBRootDatasetPushConsumerIT.java | 2 +-
.../IoTDBRootPullConsumeTsfileIT.java | 2 +-
.../param/IoTDBTestParamPullConsumerIT.java | 6 +-
.../format/IoTDBDBDataSetPullConsumerIT.java | 2 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 2 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 2 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 2 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 6 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 2 +-
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 2 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 2 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 +-
.../format/IoTDBTestPushConsumeDataSetIT.java | 2 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 2 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 2 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 8 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 8 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 12 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 10 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 10 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 12 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 12 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 4 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 2 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 2 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +-
.../IoTDBDBPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBDBPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBRootPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBTSPatternDatasetPushConsumerIT.java | 2 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +-
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 2 +-
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 2 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 2 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 2 +-
.../udf/api/relational/AggregationFunction.java | 6 +-
iotdb-client/client-cpp/src/main/Session.cpp | 2 +-
.../java/org/apache/iotdb/isession/ISession.java | 16 -
.../org/apache/iotdb/isession/ITableSession.java | 89 ++
.../apache/iotdb/isession/pool/ISessionPool.java | 3 -
.../iotdb/isession/pool/ITableSessionPool.java | 48 +
iotdb-client/jdbc/src/main/feature/feature.xml | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 10 +
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 9 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 17 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 8 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 3 +
.../SubscriptionPipeTimeoutException.java | 2 +-
....java => SubscriptionPollTimeoutException.java} | 12 +-
...tion.java => SubscriptionTimeoutException.java} | 14 +-
.../payload/poll/SubscriptionPollRequest.java | 2 +-
.../iotdb/session/AbstractSessionBuilder.java | 71 ++
.../java/org/apache/iotdb/session/Session.java | 133 +--
.../apache/iotdb/session/SessionConnection.java | 8 +-
.../org/apache/iotdb/session/TableSession.java} | 77 +-
.../apache/iotdb/session/TableSessionBuilder.java | 275 ++++++
.../session/pool/AbstractSessionPoolBuilder.java | 13 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 84 +-
.../iotdb/session/pool/TableSessionPool.java | 22 +-
.../session/pool/TableSessionPoolBuilder.java | 293 ++++++
...essionWrapper.java => TableSessionWrapper.java} | 123 +--
.../consumer/SubscriptionConsumer.java | 173 ++--
.../SubscriptionExecutorServiceManager.java | 11 +-
.../consumer/SubscriptionProvider.java | 13 +-
.../SubscriptionSessionDataSetsHandler.java | 19 +-
.../iotdb/session/SessionCacheLeaderTest.java | 2 +-
iotdb-core/ainode/pom.xml | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 -
.../src/assembly/resources/conf/confignode-env.sh | 35 +-
.../assembly/resources/sbin/stop-confignode.bat | 8 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 5 +
.../client/async/CnToDnAsyncRequestType.java | 7 +
.../CnToDnInternalServiceAsyncRequestManager.java | 44 +
.../heartbeat/DataNodeHeartbeatHandler.java | 14 +-
.../consensus/request/ConfigPhysicalPlan.java | 14 +-
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
.../table/DescTablePlan.java} | 28 +-
.../request/write/database/DatabaseSchemaPlan.java | 12 +-
.../pipe/runtime/PipeHandleMetaChangePlan.java | 8 +-
.../write/table/AbstractTableColumnPlan.java | 62 ++
...pTablePlan.java => CommitDeleteColumnPlan.java} | 12 +-
...opTablePlan.java => CommitDeleteTablePlan.java} | 10 +-
...DropTablePlan.java => PreDeleteColumnPlan.java} | 11 +-
.../response/pipe/task/PipeTableResp.java | 5 +-
.../consensus/response/table/DescTableResp.java | 52 +
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 55 +-
.../apache/iotdb/confignode/manager/IManager.java | 8 +
.../iotdb/confignode/manager/ProcedureManager.java | 125 +++
.../manager/load/balancer/RouteBalancer.java | 5 +-
.../manager/load/cache/AbstractLoadCache.java | 2 +-
.../confignode/manager/load/cache/LoadCache.java | 45 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 9 +
.../load/cache/region/RegionGroupCache.java | 4 +
.../manager/partition/PartitionManager.java | 8 +-
.../manager/partition/PartitionMetrics.java | 8 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 4 +-
.../runtime/PipeLeaderChangeHandler.java | 2 +-
.../runtime/heartbeat/PipeHeartbeat.java | 3 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 5 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 29 +-
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 4 +-
.../metric/PipeConfigNodeRemainingTimeMetrics.java | 9 +-
.../PipeConfigNodeRemainingTimeOperator.java | 5 +-
... => PipeTemporaryMetaInCoordinatorMetrics.java} | 29 +-
.../manager/schema/ClusterSchemaManager.java | 52 +-
.../persistence/executor/ConfigPlanExecutor.java | 19 +-
.../persistence/partition/PartitionInfo.java | 97 +-
.../confignode/persistence/pipe/PipeInfo.java | 16 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 89 +-
.../confignode/persistence/schema/ConfigMTree.java | 119 ++-
.../schema/mnode/impl/ConfigTableNode.java | 15 +-
.../schema/mnode/info/ConfigTableInfo.java | 36 +-
.../procedure/env/RegionMaintainHandler.java | 5 +-
.../procedure/env/RemoveDataNodeHandler.java | 71 +-
.../impl/node/RemoveDataNodesProcedure.java | 34 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 79 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 2 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../procedure/impl/region/RegionMigrationPlan.java | 12 +
.../impl/schema/DeactivateTemplateProcedure.java | 6 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 2 +-
.../procedure/impl/schema/SchemaUtils.java | 2 +-
.../table/AbstractAlterOrDropTableProcedure.java | 67 ++
.../impl/schema/table/AddTableColumnProcedure.java | 38 +-
.../impl/schema/table/CreateTableProcedure.java | 37 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 381 +++++++
.../schema/table/DropTableColumnProcedure.java | 191 +++-
.../impl/schema/table/DropTableProcedure.java | 79 +-
.../schema/table/RenameTableColumnProcedure.java | 26 +-
.../schema/table/SetTablePropertiesProcedure.java | 26 +-
...bstractOperateSubscriptionAndPipeProcedure.java | 4 +-
...bleColumnState.java => DeleteDevicesState.java} | 8 +-
.../state/schema/DropTableColumnState.java | 5 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 1 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 28 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 46 +-
.../confignode/manager/ProcedureManagerTest.java | 24 +
.../schema/table/DeleteDevicesProcedureTest.java | 59 ++
.../apache/iotdb/consensus/config/RatisConfig.java | 28 -
.../apache/iotdb/consensus/iot/IoTConsensus.java | 19 +-
.../consensus/iot/IoTConsensusServerImpl.java | 31 +-
.../iot/client/IoTConsensusClientPool.java | 5 +-
.../service/IoTConsensusRPCServiceProcessor.java | 2 +-
.../consensus/iot/snapshot/SnapshotFragment.java | 1 +
.../iot/snapshot/SnapshotFragmentReader.java | 8 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 26 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 59 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 18 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 23 +-
iotdb-core/datanode/pom.xml | 6 +
.../src/assembly/resources/conf/datanode-env.sh | 43 +-
.../assembly/resources/sbin/remove-datanode.bat | 11 +-
.../src/assembly/resources/sbin/remove-datanode.sh | 8 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 8 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 1 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 80 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 88 +-
.../dataregion/DataExecutionVisitor.java | 12 +
.../dataregion/DataRegionStateMachine.java | 2 +-
.../schemaregion/SchemaExecutionVisitor.java | 84 +-
.../exception/metadata/DatabaseModelException.java | 24 +-
.../ColumnNotExistsException.java} | 12 +-
.../PipeDataRegionProcessorConstructor.java | 4 +
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 30 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 4 +-
.../evolvable/batch/PipeTabletEventBatch.java | 5 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 10 +-
.../connector/payload/legacy/DeletionPipeData.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 11 +-
.../pipeconsensus/PipeConsensusSyncConnector.java | 2 +-
.../PipeConsensusTabletBatchEventHandler.java | 10 +-
.../request/PipeConsensusDeleteNodeReq.java | 7 +-
.../async/IoTDBDataRegionAsyncConnector.java | 2 +-
.../PipeTransferTabletBatchEventHandler.java | 6 +-
.../protocol/writeback/WriteBackConnector.java | 120 +--
.../pipe/consensus/deletion/DeletionResource.java | 15 +-
.../deletion/DeletionResourceManager.java | 8 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 4 +
.../common/deletion/PipeDeleteDataNodeEvent.java | 9 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 34 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 10 +-
.../tablet/parser/TabletInsertionEventParser.java | 75 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 85 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 11 +-
.../parser/scan/SinglePageWholeChunkReader.java | 50 +-
.../scan/TsFileInsertionEventScanParser.java | 14 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 4 +-
.../event/realtime/PipeRealtimeEventFactory.java | 4 +-
.../dataregion/DataRegionListeningFilter.java | 28 +
...oricalDataRegionTsFileAndDeletionExtractor.java | 80 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 12 +-
.../listener/PipeInsertionDataNodeListener.java | 10 +-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 45 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 5 +-
.../aggregate/AbstractFormalProcessor.java | 9 +-
.../schemachange/RenameDatabaseProcessor.java | 101 ++
.../protocol/legacy/loader/DeletionLoader.java | 2 +-
.../pipeconsensus/PipeConsensusReceiver.java | 38 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 6 +
.../resource/tsfile/PipeTsFileResourceManager.java | 24 +-
.../tsfile/PipeTsFileResourceSegmentLock.java | 9 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 14 +-
.../hardlink/PipeWALHardlinkResourceManager.java | 20 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 19 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 8 +-
.../protocol/client/DataNodeClientPoolFactory.java | 5 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 289 ++++--
.../db/queryengine/common/MPPQueryContext.java | 6 +
.../common/header/ColumnHeaderConstant.java | 9 +
.../common/header/DatasetHeaderFactory.java | 4 +
.../db/queryengine/execution/driver/Driver.java | 31 +-
.../execution/executor/RegionWriteExecutor.java | 14 +
.../fragment/FragmentInstanceContext.java | 19 +
.../execution/fragment/QueryContext.java | 40 +-
.../execution/fragment/QueryStatistics.java | 65 +-
.../schema/source/DeviceAttributeUpdater.java | 61 +-
.../schema/source/DeviceBlackListConstructor.java | 86 ++
.../schema/source/DevicePredicateHandler.java | 13 +-
.../operator/schema/source/DeviceUpdater.java | 81 ++
.../execution/operator/source/FileLoaderUtils.java | 19 +-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../source/relational/TableInnerJoinOperator.java | 7 +-
.../relational/aggregation/AccumulatorFactory.java | 15 +-
.../relational/aggregation/AvgAccumulator.java | 4 +-
.../relational/aggregation/FirstAccumulator.java | 25 +-
.../relational/aggregation/FirstByAccumulator.java | 23 +-
.../aggregation/FirstByDescAccumulator.java | 55 ++
.../aggregation/FirstDescAccumulator.java | 55 ++
.../relational/aggregation/LastAccumulator.java | 17 +-
.../relational/aggregation/LastByAccumulator.java | 20 +-
.../aggregation/LastByDescAccumulator.java | 62 ++
.../aggregation/LastDescAccumulator.java | 61 ++
.../aggregation/TableMaxMinByBaseAccumulator.java | 14 +-
.../aggregation/TableModeAccumulator.java | 14 +
.../aggregation/TableVarianceAccumulator.java | 15 +
.../aggregation/grouped/GroupedAccumulator.java | 2 +
.../aggregation/grouped/GroupedAggregator.java | 4 +
.../aggregation/grouped/GroupedAvgAccumulator.java | 11 +-
.../grouped/GroupedCountAccumulator.java | 5 +
.../grouped/GroupedExtremeAccumulator.java | 28 +
.../grouped/GroupedFirstAccumulator.java | 40 +-
.../grouped/GroupedFirstByAccumulator.java | 41 +-
.../grouped/GroupedLastAccumulator.java | 40 +-
.../grouped/GroupedLastByAccumulator.java | 38 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 32 +
.../grouped/GroupedMaxMinByBaseAccumulator.java | 74 ++
.../aggregation/grouped/GroupedMinAccumulator.java | 32 +
.../grouped/GroupedModeAccumulator.java | 20 +
.../aggregation/grouped/GroupedSumAccumulator.java | 6 +
.../grouped/GroupedVarianceAccumulator.java | 22 +
.../grouped/HashAggregationOperator.java | 11 +-
.../grouped/StreamingAggregationOperator.java | 266 +++++
.../grouped/StreamingHashAggregationOperator.java | 327 ++++++
.../aggregation/grouped/array/BinaryBigArray.java | 4 +
.../aggregation/grouped/array/BooleanBigArray.java | 4 +
.../aggregation/grouped/array/ByteBigArray.java | 4 +
.../aggregation/grouped/array/DoubleBigArray.java | 4 +
.../aggregation/grouped/array/FloatBigArray.java | 4 +
.../aggregation/grouped/array/IntBigArray.java | 4 +
.../aggregation/grouped/array/LongBigArray.java | 4 +
.../aggregation/grouped/array/MapBigArray.java | 9 +
.../aggregation/grouped/array/ObjectBigArray.java | 16 +
.../aggregation/grouped/array/ShortBigArray.java | 4 +
.../grouped/builder/HashAggregationBuilder.java | 4 +
.../builder/InMemoryHashAggregationBuilder.java | 40 +-
.../relational/ColumnTransformerBuilder.java | 12 +-
.../metric/SeriesScanCostMetricSet.java | 255 ++++-
.../iotdb/db/queryengine/plan/Coordinator.java | 55 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 255 +++++
.../db/queryengine/plan/analyze/Analyzer.java | 9 +-
.../queryengine/plan/analyze/PredicateUtils.java | 9 +-
.../analyze/cache/schema/DataNodeTTLCache.java | 4 +-
.../cache/schema/dualkeycache/IDualKeyCache.java | 3 +
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 52 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 22 +
.../analyze/load/LoadTsFileTableSchemaCache.java | 11 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 19 +-
.../load/LoadTsFileToTreeModelAnalyzer.java | 19 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 11 +-
.../queryengine/plan/execution/QueryExecution.java | 11 +-
.../plan/execution/config/ConfigExecution.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 104 +-
.../config/executor/ClusterConfigTaskExecutor.java | 198 +++-
.../config/executor/IConfigTaskExecutor.java | 8 +-
.../relational/AbstractAlterOrDropTableTask.java | 16 +-
...OrDropTableTask.java => AbstractTableTask.java} | 13 +-
.../config/metadata/relational/CreateDBTask.java | 6 +-
.../metadata/relational/DeleteDeviceTask.java | 79 ++
...ableTask.java => DescribeTableDetailsTask.java} | 39 +-
.../metadata/relational/DescribeTableTask.java | 27 +-
.../config/metadata/relational/ShowDBTask.java | 35 +-
.../execution/config/sys/pipe/AlterPipeTask.java | 43 +
.../execution/config/sys/pipe/CreatePipeTask.java | 43 +
.../config/sys/pipe/PipeFunctionSupport.java | 85 ++
.../TableModelStatementMemorySourceVisitor.java | 11 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 24 +-
.../queryengine/plan/planner/LogicalPlanner.java | 12 +-
.../plan/planner/TableOperatorGenerator.java | 309 ++++--
.../planner/distribution/ExchangeNodeAdder.java | 4 +
.../plan/planner/plan/node/ExplainAnalyzeNode.java | 25 +-
.../plan/planner/plan/node/PlanNodeType.java | 32 +-
.../plan/planner/plan/node/PlanVisitor.java | 34 +
.../plan/node/load/LoadSingleTsFileNode.java | 4 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 2 +
.../plan/node/write/AbstractDeleteDataNode.java | 81 ++
.../planner/plan/node/write/DeleteDataNode.java | 36 +-
.../planner/plan/node/write/DeleteNodeType.java | 68 ++
.../plan/planner/plan/node/write/InsertNode.java | 2 -
.../planner/plan/node/write/InsertTabletNode.java | 12 +-
.../plan/node/write/RelationalDeleteDataNode.java | 281 ++++++
.../node/write/RelationalInsertTabletNode.java | 88 +-
.../plan/relational/analyzer/Analysis.java | 16 +-
.../plan/relational/analyzer/Analyzer.java | 8 +-
.../relational/analyzer/StatementAnalyzer.java | 44 +-
.../analyzer/StatementAnalyzerFactory.java | 12 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 48 +-
.../ConvertPredicateToTimeFilterVisitor.java | 60 +-
.../PredicatePushIntoMetadataChecker.java | 153 ++-
.../schema/CheckSchemaPredicateVisitor.java | 51 +-
.../function/arithmetic/AdditionResolver.java | 14 +
.../function/arithmetic/DivisionResolver.java | 10 +
.../function/arithmetic/ModulusResolver.java | 10 +
.../arithmetic/MultiplicationResolver.java | 10 +
.../function/arithmetic/SubtractionResolver.java | 10 +
.../relational/metadata/TableMetadataImpl.java | 31 +-
.../fetcher/TableDeviceSchemaValidator.java | 11 +
.../fetcher/TableHeaderSchemaValidator.java | 2 +-
.../fetcher/cache/TableAttributeSchema.java | 18 +-
.../fetcher/cache/TableDeviceCacheEntry.java | 17 +-
.../fetcher/cache/TableDeviceLastCache.java | 12 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 76 +-
.../plan/relational/planner/IrTypeAnalyzer.java | 12 +
.../plan/relational/planner/PlanBuilder.java | 4 +-
.../plan/relational/planner/QueryPlanner.java | 24 +-
.../plan/relational/planner/RelationPlan.java | 14 +-
.../plan/relational/planner/RelationPlanner.java | 48 +-
.../relational/planner/TableLogicalPlanner.java | 143 ++-
.../plan/relational/planner/TableModelPlanner.java | 72 +-
.../planner/distribute/AddExchangeNodes.java | 23 +
.../distribute/TableDistributedPlanGenerator.java | 89 +-
.../distribute/TableDistributedPlanner.java | 50 +-
.../distribute/TableModelQueryFragmentPlanner.java | 7 +-
.../TableModelTypeProviderExtractor.java | 5 +
.../relational/planner/ir/ExpressionRewriter.java | 12 +
.../planner/ir/ExpressionTreeRewriter.java | 32 +-
.../ir/GlobalTimePredicateExtractVisitor.java | 37 +-
...AddTableScanColumnsToTypeProviderOptimizer.java | 66 --
.../iterative/rule/PruneTableScanColumns.java | 12 +-
.../planner/node/ExplainAnalyzeNode.java | 115 +++
.../plan/relational/planner/node/JoinNode.java | 5 +
.../relational/planner/node/TableScanNode.java | 25 +-
.../schema/AbstractTableDevicesDeletionNode.java | 91 ++
.../schema/ConstructTableDevicesBlackListNode.java | 104 ++
.../node/schema/CreateOrUpdateTableDeviceNode.java | 2 +-
.../schema/DeleteTableDevicesInBlackListNode.java | 76 ++
.../schema/RollbackTableDevicesBlackListNode.java | 76 ++
.../node/schema/TableAttributeColumnDropNode.java | 124 +++
.../optimizations/LogicalOptimizeFactory.java | 4 +-
.../planner/optimizations/PlanOptimizer.java | 8 -
.../PushAggregationIntoTableScan.java | 22 +-
.../PushLimitOffsetIntoTableScan.java | 6 +-
.../optimizations/PushPredicateIntoTableScan.java | 116 +--
.../planner/optimizations/SortElimination.java | 16 +-
.../TransformAggregationToStreamable.java | 4 +-
.../optimizations/TransformSortToStreamSort.java | 5 +-
.../optimizations/UnaliasSymbolReferences.java | 10 +
.../relational/sql/ast/AbstractTraverseDevice.java | 4 +-
.../plan/relational/sql/ast/AstVisitor.java | 20 +-
.../plan/relational/sql/ast/ColumnDefinition.java | 11 +-
.../plan/relational/sql/ast/CreateTable.java | 14 -
.../plan/relational/sql/ast/CurrentDatabase.java | 13 +-
.../plan/relational/sql/ast/CurrentUser.java | 13 +-
.../plan/relational/sql/ast/Delete.java | 33 +
.../plan/relational/sql/ast/DeleteDevice.java | 231 +++++
.../plan/relational/sql/ast/DescribeTable.java | 20 +-
.../plan/relational/sql/ast/InsertTablet.java | 3 +
.../relational/sql/ast/TableExpressionType.java | 4 +-
.../plan/relational/sql/ast/TimeRange.java | 16 +-
.../plan/relational/sql/parser/AstBuilder.java | 25 +-
.../plan/relational/sql/parser/SqlParser.java | 8 +
.../plan/relational/utils/TypeUtil.java | 8 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 22 +
.../plan/statement/crud/InsertTabletStatement.java | 10 +
.../metadata/DatabaseSchemaStatement.java | 28 +-
.../FragmentInstanceStatisticsDrawer.java | 64 ++
.../dag/column/leaf/NullColumnTransformer.java | 4 +-
.../AbstractCastFunctionColumnTransformer.java | 4 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 35 +-
.../rescon/ISchemaRegionStatistics.java | 6 +-
.../rescon/MemSchemaRegionStatistics.java | 10 +
.../schemaengine/schemaregion/ISchemaRegion.java | 21 +-
.../schemaregion/ISchemaRegionPlan.java | 2 +-
.../schemaregion/SchemaRegionPlanType.java | 4 +
.../schemaregion/SchemaRegionPlanVisitor.java | 25 +
.../attribute/DeviceAttributeStore.java | 15 +-
.../attribute/IDeviceAttributeStore.java | 4 +-
.../update/DeviceAttributeCacheUpdater.java | 50 +-
.../attribute/update/UpdateClearContainer.java | 21 +
.../attribute/update/UpdateContainer.java | 6 +
.../attribute/update/UpdateDetailContainer.java | 113 ++-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 130 ++-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 27 +
.../visitor/SchemaRegionPlanDeserializer.java | 33 +-
.../visitor/SchemaRegionPlanSerializer.java | 32 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 160 ++-
.../impl/mem/mnode/factory/MemMNodeFactory.java | 6 +-
.../impl/mem/mnode/info/DatabaseDeviceInfo.java | 2 +-
.../mtree/impl/mem/mnode/info/TableDeviceInfo.java | 38 +-
.../info/{DeviceInfo.java => TreeDeviceInfo.java} | 27 +-
.../mnode/iterator/AbstractTraverserIterator.java | 2 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 9 +-
.../pbtree/mnode/factory/CacheMNodeFactory.java | 6 +-
.../impl/pbtree/schemafile/WrappedSegment.java | 2 -
.../schemaregion/mtree/traverser/Traverser.java | 2 +-
.../read/resp/info/impl/ShowDevicesResult.java | 4 +-
.../schemaregion/utils/MNodeUtils.java | 4 +-
.../schemaregion/utils/ResourceByPathUtils.java | 14 +-
.../write/req/SchemaRegionWritePlanFactory.java | 14 +-
.../db/schemaengine/table/DataNodeTableCache.java | 45 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 2 +
.../template/ClusterTemplateManager.java | 1 -
.../java/org/apache/iotdb/db/service/DataNode.java | 16 +-
.../iotdb/db/storageengine/StorageEngine.java | 106 +-
.../db/storageengine/buffer/BloomFilterCache.java | 80 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 138 ++-
.../buffer/TimeSeriesMetadataCache.java | 65 +-
.../db/storageengine/dataregion/DataRegion.java | 1038 ++++++++------------
.../CompactionStatisticsCheckFailedException.java | 87 ++
.../performer/impl/FastCompactionPerformer.java | 25 +-
.../RepairUnsortedFileCompactionPerformer.java | 7 +-
.../execute/recover/CompactionRecoverTask.java | 37 +-
.../execute/task/AbstractCompactionTask.java | 6 +-
.../execute/task/InnerSpaceCompactionTask.java | 32 +-
.../task/InsertionCrossSpaceCompactionTask.java | 13 +-
.../task/RepairUnsortedFileCompactionTask.java | 17 +-
.../execute/task/SettleCompactionTask.java | 6 +-
.../subtask/FastCompactionPerformerSubTask.java | 8 +-
.../compaction/execute/utils/CompactionUtils.java | 101 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 52 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 8 +-
.../executor/batch/utils/BatchCompactionPlan.java | 2 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 8 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 4 +-
.../executor/fast/SeriesCompactionExecutor.java | 14 +-
.../fast/reader/CompactionAlignedChunkReader.java | 18 +-
.../fast/reader/CompactionChunkReader.java | 14 +-
.../readchunk/loader/InstantChunkLoader.java | 3 +-
.../readchunk/loader/InstantPageLoader.java | 17 +-
.../execute/utils/log/TsFileIdentifier.java | 7 +-
.../compaction/repair/RepairDataFileScanUtil.java | 335 +++++--
.../repair/RepairTimePartitionScanTask.java | 4 +-
.../estimator/CompactionEstimateUtils.java | 4 +-
.../selector/estimator/CompactionTaskInfo.java | 6 +-
.../selector/impl/SettleSelectorImpl.java | 34 +-
.../compaction/settle/SettleRequestHandler.java | 4 +-
.../dataregion/flush/FlushManager.java | 50 +-
.../dataregion/flush/TsFileFlushPolicy.java | 6 +-
.../dataregion/memtable/AbstractMemTable.java | 109 +-
.../memtable/AlignedWritableMemChunk.java | 20 +-
.../memtable/AlignedWritableMemChunkGroup.java | 41 +-
.../dataregion/memtable/IMemTable.java | 22 +-
.../memtable/IWritableMemChunkGroup.java | 7 +-
.../dataregion/memtable/TsFileProcessor.java | 207 ++--
.../dataregion/memtable/WritableMemChunkGroup.java | 61 +-
.../dataregion/modification/DeletionPredicate.java | 183 ++++
.../dataregion/modification/IDPredicate.java | 405 ++++++++
.../dataregion/modification/ModEntry.java | 199 ++++
.../modification/ModFileManagement.java} | 22 +-
.../dataregion/modification/ModificationFile.java | 406 ++++----
.../modification/PartitionLevelModFileManager.java | 157 +++
.../modification/TableDeletionEntry.java | 151 +++
.../dataregion/modification/TreeDeletionEntry.java | 227 +++++
.../dataregion/modification/{ => v1}/Deletion.java | 2 +-
.../modification/{ => v1}/Modification.java | 2 +-
.../ModificationFileV1.java} | 33 +-
.../{ => v1}/io/LocalTextModificationAccessor.java | 6 +-
.../{ => v1}/io/ModificationReader.java | 4 +-
.../{ => v1}/io/ModificationWriter.java | 4 +-
.../dataregion/read/control/FileReaderManager.java | 32 +-
.../filescan/impl/ClosedFileScanHandleImpl.java | 19 +-
.../filescan/impl/DiskAlignedChunkHandleImpl.java | 11 +-
.../read/filescan/impl/DiskChunkHandleImpl.java | 7 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 6 +-
.../read/reader/chunk/DiskChunkLoader.java | 7 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 10 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 6 +-
.../dataregion/snapshot/SnapshotFileSet.java | 2 +
.../dataregion/snapshot/SnapshotTaker.java | 31 +-
.../dataregion/tsfile/TsFileManager.java | 25 +
.../dataregion/tsfile/TsFileResource.java | 362 ++++++-
.../generator/SimpleFileVersionController.java | 160 ---
.../tsfile/generator/VersionController.java | 44 -
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 14 +-
.../dataregion/utils/SharedTimeDataBuffer.java | 8 +-
.../storageengine/dataregion/wal/WALManager.java | 2 -
.../wal/allocation/NodeAllocationStrategy.java | 2 -
.../dataregion/wal/buffer/WALBuffer.java | 3 +
.../dataregion/wal/buffer/WALEntry.java | 6 +
.../dataregion/wal/buffer/WALEntryType.java | 4 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 1 +
.../dataregion/wal/node/IWALNode.java | 4 +
.../dataregion/wal/node/WALFakeNode.java | 6 +
.../storageengine/dataregion/wal/node/WALNode.java | 13 +
.../wal/recover/file/TsFilePlanRedoer.java | 72 +-
.../file/UnsealedTsFileRecoverPerformer.java | 99 +-
.../dataregion/wal/utils/WALEntryHandler.java | 12 +-
.../db/storageengine/load/LoadTsFileManager.java | 10 +-
.../storageengine/load/splitter/DeletionData.java | 18 +-
.../load/splitter/TsFileSplitter.java | 32 +-
.../agent/SubscriptionReceiverAgent.java | 13 +
.../broker/SubscriptionPrefetchingQueue.java | 22 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 22 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 35 +-
.../db/subscription/event/SubscriptionEvent.java | 6 +-
.../event/batch/SubscriptionPipeEventBatch.java | 8 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 200 ++--
.../batch/SubscriptionPipeTsFileEventBatch.java | 8 +-
.../SubscriptionEventExtendableResponse.java | 10 -
.../event/response/SubscriptionEventResponse.java | 4 +-
.../response/SubscriptionEventSingleResponse.java | 2 +-
.../response/SubscriptionEventTabletResponse.java | 77 +-
.../response/SubscriptionEventTsFileResponse.java | 73 +-
.../receiver/SubscriptionReceiver.java | 2 +
.../receiver/SubscriptionReceiverV1.java | 271 ++---
.../execution/SubscriptionSubtaskExecutor.java | 50 +
...utor.java => SubscriptionSubtaskScheduler.java} | 22 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 36 +-
.../SubscriptionConnectorSubtaskLifeCycle.java | 8 +-
.../task/subtask/SubscriptionReceiverSubtask.java} | 8 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 59 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 3 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 2 +-
.../iotdb/db/tools/utils/TsFileValidationScan.java | 2 -
.../TsFileOverlapValidationAndRepairTool.java | 5 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 159 +--
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 6 +
.../db/utils/datastructure/AlignedTVList.java | 123 ++-
.../utils/datastructure/PatternTreeMapFactory.java | 64 +-
.../iotdb/db/utils/io/BufferSerializable.java} | 11 +-
.../io/StreamSerializable.java} | 12 +-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 78 +-
.../db/pipe/consensus/DeletionRecoverTest.java | 48 +-
.../db/pipe/consensus/DeletionResourceTest.java | 70 +-
.../resource/PipeTsFileResourceManagerTest.java | 16 +-
.../operator/sink/IdentitySinkOperatorTest.java | 35 +-
.../node/write/RelationalDeleteDataNodeTest.java | 105 ++
.../plan/relational/analyzer/AggregationTest.java | 155 ++-
.../plan/relational/analyzer/AnalyzerTest.java | 201 ++--
.../plan/relational/analyzer/JoinTest.java | 54 +-
.../analyzer/LimitOffsetPushDownTest.java | 50 +-
.../plan/relational/analyzer/SortTest.java | 164 +++-
.../plan/relational/analyzer/SubQueryTest.java | 39 +-
.../plan/relational/analyzer/TestMatadata.java | 30 +
.../plan/relational/analyzer/TestUtils.java | 6 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 61 +-
.../plan/relational/planner/PlanTester.java | 3 +-
.../db/storageengine/buffer/ChunkCacheTest.java | 6 +-
.../storageengine/dataregion/DataRegionTest.java | 105 +-
.../TsFileResourceProgressIndexTest.java | 5 +
.../compaction/AbstractCompactionTest.java | 4 +-
.../compaction/CompactionTaskComparatorTest.java | 8 +-
.../compaction/CompactionValidationTest.java | 2 +-
.../compaction/ReadChunkInnerCompactionTest.java | 80 +-
.../compaction/TestUtilsForAlignedSeries.java | 9 +-
...tchedAlignedSeriesCrossSpaceCompactionTest.java | 18 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 24 +-
.../InsertionCrossSpaceCompactionRecoverTest.java | 34 +-
.../dataregion/compaction/cross/MergeTest.java | 2 -
.../RewriteCrossSpaceCompactionRecoverTest.java | 52 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 68 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 68 +-
...atchedAlignedSeriesFastInnerCompactionTest.java | 22 +-
...atchedAlignedSeriesReadChunkCompactionTest.java | 36 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 20 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 20 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 40 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 19 +-
...nkCompactionPerformerWithAlignedSeriesTest.java | 46 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 8 +-
.../NewSizeTieredCompactionSelectorTest.java | 40 +-
.../SizeTieredCompactionRecoverTest.java | 30 +-
.../repair/RepairDataFileScanUtilTest.java | 128 ++-
.../repair/RepairUnsortedFileCompactionTest.java | 17 +-
.../settle/SettleCompactionRecoverTest.java | 86 +-
.../settle/SettleCompactionSelectorTest.java | 78 +-
.../tablemodel/CompactionWithAllNullRowsTest.java | 32 +-
.../TableModelCompactionWithTTLTest.java | 3 +-
.../compaction/utils/CompactionCheckerUtils.java | 26 +-
.../utils/CompactionFileGeneratorUtils.java | 16 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 16 +-
.../dataregion/memtable/TsFileProcessorTest.java | 88 +-
.../modification/ModificationFileTest.java | 79 +-
.../modification/TableDeletionEntryTest.java | 208 ++++
.../modification/TreeDeletionEntryTest.java | 153 +++
.../io/LocalTextModificationAccessorTest.java | 6 +-
.../generator/SimpleFileVersionControllerTest.java | 56 --
.../wal/recover/file/TsFilePlanRedoerTest.java | 4 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 8 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 20 +-
.../org/apache/iotdb/db/utils/AnnotationTest.java | 71 ++
.../reporter/iotdb/IoTDBSessionReporter.java | 2 +-
.../conf/iotdb-system.properties.template | 15 +
.../apache/iotdb/commons/client/ClientManager.java | 11 +-
.../iotdb/commons/client/ClientPoolFactory.java | 35 +-
.../iotdb/commons/client/IClientPoolFactory.java | 4 +-
.../container/PipeConsensusClientMgrContainer.java | 22 +-
.../client/factory/AsyncThriftClientFactory.java | 6 +
.../client/request/AsyncRequestContext.java | 6 +-
.../client/request/AsyncRequestManager.java | 10 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 30 +-
.../iotdb/commons/conf/CommonDescriptor.java | 11 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../commons/consensus/index/ProgressIndex.java | 12 +-
.../consensus/index/impl/HybridProgressIndex.java | 36 +-
.../consensus/index/impl/IoTProgressIndex.java | 12 +
.../consensus/index/impl/MetaProgressIndex.java | 9 +-
.../consensus/index/impl/MinimumProgressIndex.java | 5 +
.../consensus/index/impl/RecoverProgressIndex.java | 13 +
.../consensus/index/impl/SimpleProgressIndex.java | 9 +-
.../consensus/index/impl/StateProgressIndex.java | 17 +-
.../index/impl/TimeWindowStateProgressIndex.java | 24 +
.../exception/IoTDBIORuntimeException.java} | 14 +-
.../commons/file/SystemPropertiesHandler.java | 17 +-
.../iotdb/commons/partition/DataPartition.java | 18 +
.../apache/iotdb/commons/path/PatternTreeMap.java | 25 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 3 +
.../schemachange/RenameDatabaseProcessor.java} | 15 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 59 ++
.../commons/pipe/agent/task/PipeTaskManager.java | 7 +-
.../agent/task/execution/PipeSubtaskExecutor.java | 26 +-
.../commons/pipe/agent/task/meta/PipeMeta.java | 17 +-
.../pipe/agent/task/meta/PipeTemporaryMeta.java | 73 +-
.../agent/task/meta/PipeTemporaryMetaInAgent.java | 107 ++
...ta.java => PipeTemporaryMetaInCoordinator.java} | 5 +-
.../pipe/agent/task/progress/CommitterKey.java | 2 +-
.../task/progress/PipeEventCommitManager.java | 12 +-
.../task/subtask/PipeAbstractConnectorSubtask.java | 6 +-
.../config/constant/PipeExtractorConstant.java | 3 +
.../config/constant/PipeProcessorConstant.java | 2 +
.../connector/client/IoTDBSyncClientManager.java | 25 +-
.../pipe/datastructure/pattern/TablePattern.java | 28 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 6 -
.../commons/pipe/metric/PipeRemainingOperator.java | 12 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 5 +-
.../resource/ref/PipePhantomReferenceManager.java | 4 +-
.../schema/node/common/DeviceMNodeWrapper.java | 16 +-
.../commons/schema/node/info/IDeviceInfo.java | 6 +-
.../commons/schema/node/role/IDeviceMNode.java | 6 +-
.../commons/schema/table/TableNodeStatus.java | 5 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 77 +-
.../schema/table/TsTableInternalRPCUtil.java | 31 +-
.../schema/table/column/AttributeColumnSchema.java | 21 +-
.../schema/table/column/TimeColumnSchema.java | 21 +-
.../schema/table/column/TsTableColumnSchema.java | 11 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +
.../subscription/config/SubscriptionConfig.java | 14 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 45 +-
...oTConsensusRemovePeerCoordinatorKillPoints.java | 2 +-
.../org/apache/iotdb/commons/utils/TestOnly.java | 2 +-
.../iotdb/commons/client/ClientManagerTest.java | 11 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 19 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 11 +-
iotdb-doap.rdf | 8 +
.../src/main/thrift/confignode.thrift | 25 +
.../src/main/thrift/iotconsensus.thrift | 5 +-
.../src/main/thrift/datanode.thrift | 84 +-
.../apache/iotdb/library/dprofile/UDAFMedian.java | 14 +-
pom.xml | 6 +-
765 files changed, 28718 insertions(+), 7923 deletions(-)
create mode 100644 distribution/src/assembly/ainode.xml
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DropTableColumnState.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2TableModel.java
(88%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBEncryptionValueQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBLoadEncryptedTsFileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBLoadPlainTsFileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/PipeNowFunctionIT.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate/AbstractPipeDualAutoIT.java
=> tablemodel/AbstractPipeTableModelTestIT.java} (96%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeAlterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeAutoConflictIT.java
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeAutoDropIT.java (79%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeClusterIT.java
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeConnectorCompressionIT.java (84%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeConnectorParallelIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeDataSinkIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeExtractorIT.java
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeLifeCycleIT.java (53%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeNullValueIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeProtocolIT.java
copy integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
tablemodel}/IoTDBPipeSwitchStatusIT.java (85%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeSyntaxIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeWithLoadIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBTablePatternFormatIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/TableModelUtils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableIT.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DropTableColumnState.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
(88%)
create mode 100644
iotdb-client/isession/src/main/java/org/apache/iotdb/isession/ITableSession.java
create mode 100644
iotdb-client/isession/src/main/java/org/apache/iotdb/isession/pool/ITableSessionPool.java
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionPipeTimeoutException.java
=> SubscriptionPollTimeoutException.java} (74%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionPipeTimeoutException.java
=> SubscriptionTimeoutException.java} (66%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/AbstractSessionBuilder.java
rename
iotdb-client/{isession/src/main/java/org/apache/iotdb/isession/IPooledSession.java
=> session/src/main/java/org/apache/iotdb/session/TableSession.java} (51%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/TableSessionBuilder.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/ISchemaRegionPlan.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/pool/AbstractSessionPoolBuilder.java
(65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/leaf/NullColumnTransformer.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/pool/TableSessionPool.java
(60%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/pool/TableSessionPoolBuilder.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/pool/{SessionWrapper.java
=> TableSessionWrapper.java} (62%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/table/DropTablePlan.java
=> read/table/DescTablePlan.java} (55%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/AbstractTableColumnPlan.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{DropTablePlan.java
=> CommitDeleteColumnPlan.java} (72%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{DropTablePlan.java
=> CommitDeleteTablePlan.java} (76%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{DropTablePlan.java
=> PreDeleteColumnPlan.java} (73%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/DescTableResp.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/{PipeTemporaryMetaMetrics.java
=> PipeTemporaryMetaInCoordinatorMetrics.java} (82%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DeleteDevicesProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DropTableColumnState.java
=> DeleteDevicesState.java} (85%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DeleteDevicesProcedureTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/{DatabaseModelException.java
=> table/ColumnNotExistsException.java} (69%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/schemachange/RenameDatabaseProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceBlackListConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceUpdater.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/StreamingAggregationOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/StreamingHashAggregationOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AbstractAlterOrDropTableTask.java
=> AbstractTableTask.java} (70%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/DeleteDeviceTask.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{DescribeTableTask.java
=> DescribeTableDetailsTask.java} (70%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/PipeFunctionSupport.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/AbstractDeleteDataNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/DeleteNodeType.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalDeleteDataNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/AddTableScanColumnsToTypeProviderOptimizer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/ExplainAnalyzeNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/AbstractTableDevicesDeletionNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/ConstructTableDevicesBlackListNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/DeleteTableDevicesInBlackListNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/RollbackTableDevicesBlackListNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/schema/TableAttributeColumnDropNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DeleteDevice.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/info/{DeviceInfo.java
=> TreeDeviceInfo.java} (86%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/CompactionStatisticsCheckFailedException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/DeletionPredicate.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/IDPredicate.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/ModEntry.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{schemaengine/table/ITableCache.java
=> storageengine/dataregion/modification/ModFileManagement.java} (58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/PartitionLevelModFileManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/TableDeletionEntry.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/TreeDeletionEntry.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/{
=> v1}/Deletion.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/{
=> v1}/Modification.java (99%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/{ModificationFile.java
=> v1/ModificationFileV1.java} (91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/{
=> v1}/io/LocalTextModificationAccessor.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/{
=> v1}/io/ModificationReader.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/{
=> v1}/io/ModificationWriter.java (98%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/generator/SimpleFileVersionController.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/generator/VersionController.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/execution/{SubscriptionSubtaskExecutor.java
=> SubscriptionSubtaskScheduler.java} (61%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DropTableColumnState.java
=>
datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionReceiverSubtask.java}
(83%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DropTableColumnState.java
=>
datanode/src/main/java/org/apache/iotdb/db/utils/io/BufferSerializable.java}
(81%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{schemaengine/schemaregion/ISchemaRegionPlan.java
=> utils/io/StreamSerializable.java} (74%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/write/RelationalDeleteDataNodeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/modification/TableDeletionEntryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/modification/TreeDeletionEntryTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/modification/{
=> v1}/io/LocalTextModificationAccessorTest.java (99%)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/generator/SimpleFileVersionControllerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/AnnotationTest.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/ISchemaRegionPlan.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/IoTDBIORuntimeException.java}
(71%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/ISchemaRegionPlan.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/schemachange/RenameDatabaseProcessor.java}
(63%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/PipeTemporaryMetaInAgent.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/meta/{PipeTemporaryMeta.java
=> PipeTemporaryMetaInCoordinator.java} (94%)
