This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch force_ci/split_chunk
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e8e449e58f1 Tvlist feat new (#14616)
add fcb3fac14c5 Added permission check for auto create table / add column
& auto create database / insert in tsFile load
add cac80f031c0 Fixed the bug that measurement is not replaced to null for
logical view's partial insert (#14743)
add 2448945529d Fix createView NPE issue when region migration #14746
add 8b6311bd042 Reduced the log of table cache update
add ace3d5baefb Settle task was selected without mods and ttl (#14731)
add 0f799c6b58f Subscription: intro table model subscription session and
consumer (#14406)
add 34914932924 Correct the Blob data cast error msg
add 9be5eeb18c3 Fix delete data TsFileProcessor NPE (#14748)
add 765cbb213b0 Extract "merge" method for SearchNode (#14736)
add ddd580d17ed Fix format IT
add 42531c3975f Bump jetty version to 9.4.57.v20241219
add 1cfd139cd23 Add optimizers for distinct in AggFunction
add a681582d6c8 Fix wrong deviceId after
PartialPath.concatAsMeasurementPath (#14750)
add 79b08072fd6 Fix region reconstruction IT (#14753)
add cb4c05c0319 Region group status refactor (#14738)
add 7f3b281f7d3 [remove datanode] Add Remove DataNode SQL (#14678)
add 3369e7a202e Let the DataPartitionTable be automatically cleanable
(#14737)
add 04810e27cc8 Fix predicate pushdown when dealing with ProjectNode
(#14754)
add 8c62821f1ad [Daily IT]: Daily IT adds a single region task (#14659)
add e56b34f3535 fix mods file metrics & fix the issue of missing mods with
concurrent deletion and compaction (#14765)
add 7af1b52dbcb Implemented TableDeviceSchemaCache#getLastEntries for query
add 93e83c63fbd Pipe: incorporate batch data into
TsFileInsertionEventScanParser memory control & Subscription: close data
container in tsfile event & bind memory block for tablet response & generate
empty tablet as initial response & offer subsequent tablet response before ack
& expose prefetch and backdoor configs & best-effort disorder control (#14752)
add 5933818eec7 Delete the adjustment operation of TCP port (#14770)
add 52da69813b0 Fixed the NPE of TableDeviceLastEntry
add 1b0af7dfd25 Permission for Relation model
add f2d24ffdc7d Introduce operator of window function.
add 25128fcc1a7 Remove duplicate code in column transformer
add 9c9b2393af3 Fix query error after insert an all null aligned tablet
and flush (#14777)
add 024b05cc4d8 Fixed the bug that the database is not totally separated
in partition cache
add 526f678f746 [RatisConsensus] Prevent misuse of addRemotePeer (#14779)
add 43eb55ad927 Pipe: Introduce periodic verification for username and
password on receiver side (#14764)
add 02ff0d27c57 Pipe / Load: Enable validation skip for load tsFile
(#14774)
add cbd683ece36 Adapte table model in import/export tools (#14677)
add a966f82d953 Fix duplicated time in result set bug
add 69d9dae6e93 Fix problem when import tsfile fail (#14792)
add e7d009cb725 Correct Block Queue Time metric
add 270e0d3a224 Region operations for table model (#14794)
add 063c8421ea0 Fix null measurement name issue in insertTablet (#14795)
add 9d6b811cca0 Add some tsfile-related tools (#14766)
add a49958c1f30 Correct binary column memory calculation (#14796)
add 8ff89289148 Merge branch 'master' of github.com:apache/iotdb into
force_ci/split_chunk
No new revisions were added by this update.
Summary of changes:
.github/workflows/daily-it.yml | 36 +-
.../apache/iotdb/SubscriptionSessionExample.java | 35 +-
.../TableModelSubscriptionSessionExample.java | 173 +++
integration-test/pom.xml | 2 +
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +
.../it/env/cluster/config/MppCommonConfig.java | 12 +
.../it/env/cluster/config/MppDataNodeConfig.java | 7 +
.../env/cluster/config/MppSharedCommonConfig.java | 14 +
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 6 +
.../it/env/remote/config/RemoteCommonConfig.java | 10 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../it/database/IoTDBDatabaseSetAndDeleteIT.java | 4 +-
.../IoTDBPartitionTableAutoCleanTest.java | 135 +++
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 22 +-
.../IoTDBRemoveDataNodeITFramework.java | 93 +-
.../IoTDBRemoveDataNodeNormalIT.java | 25 +-
.../confignode/it/removedatanode/SQLModel.java | 9 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 137 +--
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 71 +-
.../it/auth/IoTDBClusterAuthorityRelationalIT.java | 513 +++++++++
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 350 ++++++
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 71 ++
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 16 +-
.../pipe/it/tablemodel/IoTDBPipeDataSinkIT.java | 97 ++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 285 ++++-
.../scalar/IoTDBFormatFunctionTableIT.java | 18 +-
.../IoTDBNullValueIT.java} | 43 +-
.../IoTDBTableAggregationFunctionDistinctIT.java | 374 +++++++
.../it/query/recent/IoTDBTableAggregationIT.java | 261 ++++-
.../relational/it/schema/IoTDBDatabaseIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 128 +++
.../subscription/it/AbstractSubscriptionIT.java | 2 +-
.../it/cluster/IoTDBSubscriptionRestartIT.java | 34 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 16 +-
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 10 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 44 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 42 +-
.../it/local/IoTDBSubscriptionDataTypeIT.java | 10 +-
.../it/local/IoTDBSubscriptionIdempotentIT.java | 24 +-
.../it/local/IoTDBSubscriptionTopicIT.java | 10 +-
.../it/triple/AbstractSubscriptionTripleIT.java | 2 +-
.../it/triple/IoTDBSubscriptionSharingIT.java | 32 +-
.../AbstractSubscriptionRegressionIT.java | 26 +-
.../IoTDBDefaultPullConsumerDataSetIT.java | 4 +-
.../IoTDBDefaultTsfilePushConsumerIT.java | 6 +-
.../IoTDBRootDatasetPushConsumerIT.java | 6 +-
.../IoTDBRootPullConsumeTsfileIT.java | 6 +-
...merPullConsumerWith1TopicShareProcessMixIT.java | 12 +-
.../param/IoTDBTestParamPullConsumerIT.java | 93 +-
.../param/IoTDBTestParamPushConsumerIT.java | 47 +-
.../param/IoTDBTestParamSubscriptionSessionIT.java | 12 +-
.../regression/param/IoTDBTestParamTopicIT.java | 6 +-
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 6 +-
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 6 +-
.../format/IoTDBDBDataSetPullConsumerIT.java | 6 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 6 +-
.../IoTDBAllTsDatasetPullConsumerIT.java | 4 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 6 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 6 +-
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 4 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 6 +-
.../IoTDBTimeTsDatasetPullConsumerIT.java | 4 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 6 +-
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 4 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 6 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 6 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 6 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 12 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 4 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 4 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 4 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 6 +-
.../IoTDBDBPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 6 +-
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 4 +-
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 4 +-
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 6 +-
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 6 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 6 +-
.../IoTDBTSPatternPullConsumerDataSetIT.java | 4 +-
.../time/IoTDBAllPullConsumerDataSetIT.java | 4 +-
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 4 +-
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 4 +-
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 4 +-
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 4 +-
.../format/IoTDBTestPushConsumeDataSetIT.java | 6 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 6 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 6 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 6 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 6 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 6 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 6 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 6 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 6 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 6 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 6 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 6 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 6 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 6 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 6 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 6 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 10 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 10 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 26 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 6 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 6 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 6 +-
.../IoTDBDBPatternDatasetPushConsumerIT.java | 6 +-
.../IoTDBDBPatternTsfilePushConsumerIT.java | 6 +-
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 6 +-
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 6 +-
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 6 +-
.../IoTDBRootPatternDatasetPushConsumerIT.java | 6 +-
.../IoTDBTSPatternDatasetPushConsumerIT.java | 6 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 6 +-
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 6 +-
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 6 +-
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 6 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 6 +-
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 6 +-
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 6 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 6 +-
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 4 +-
.../regression/topic/IoTDBTestTopicNameIT.java | 4 +-
.../regression/user/IoTDBOtherUserConsumerIT.java | 6 +-
.../org/apache/iotdb/tool/common/Constants.java | 319 ++++++
.../iotdb/tool/common/ImportTsFileOperation.java | 59 +
.../org/apache/iotdb/tool/common/OptionsUtil.java | 915 ++++++++++++++++
.../apache/iotdb/tool/data/AbstractDataTool.java | 1019 +++++-------------
.../apache/iotdb/tool/data/AbstractExportData.java | 70 ++
.../AbstractImportData.java} | 216 ++--
.../apache/iotdb/tool/data/AsyncImportData.java | 160 ---
.../org/apache/iotdb/tool/data/ExportData.java | 775 +++-----------
.../apache/iotdb/tool/data/ExportDataTable.java | 341 ++++++
.../org/apache/iotdb/tool/data/ExportDataTree.java | 420 ++++++++
.../org/apache/iotdb/tool/data/ImportData.java | 795 ++++++--------
.../apache/iotdb/tool/data/ImportDataScanTool.java | 4 -
.../apache/iotdb/tool/data/ImportDataTable.java | 392 +++++++
.../org/apache/iotdb/tool/data/ImportDataTree.java | 476 +++++++++
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 69 +-
.../apache/iotdb/tool/tsfile/ImportTsFileBase.java | 9 +-
.../iotdb/tool/tsfile/ImportTsFileLocally.java | 8 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 8 +
.../iotdb/tool/ImportTsFileOperationTest.java | 49 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 22 +
.../subscription/payload/poll/TabletsPayload.java | 11 +-
.../java/org/apache/iotdb/session/Session.java | 6 +
.../subscription/AbstractSubscriptionSession.java | 219 ++++
.../subscription/ISubscriptionTableSession.java | 177 +++
.../subscription/ISubscriptionTreeSession.java | 177 +++
.../session/subscription/SubscriptionSession.java | 337 ------
.../SubscriptionSessionConnection.java | 26 +-
.../subscription/SubscriptionSessionWrapper.java | 72 ++
.../subscription/SubscriptionTableSession.java | 113 ++
.../SubscriptionTableSessionBuilder.java | 66 ++
.../subscription/SubscriptionTreeSession.java | 180 ++++
.../SubscriptionTreeSessionBuilder.java | 63 ++
.../consumer/ISubscriptionTablePullConsumer.java | 181 ++++
.../consumer/ISubscriptionTablePushConsumer.java | 86 ++
.../consumer/ISubscriptionTreePullConsumer.java | 181 ++++
.../consumer/ISubscriptionTreePushConsumer.java | 86 ++
.../AbstractSubscriptionConsumer.java} | 170 +--
.../base/AbstractSubscriptionConsumerBuilder.java | 150 +++
.../AbstractSubscriptionProvider.java} | 47 +-
.../AbstractSubscriptionProviders.java} | 58 +-
.../AbstractSubscriptionPullConsumer.java} | 155 +--
.../AbstractSubscriptionPullConsumerBuilder.java | 122 +++
.../AbstractSubscriptionPushConsumer.java} | 147 +--
.../AbstractSubscriptionPushConsumerBuilder.java | 139 +++
.../SubscriptionExecutorServiceManager.java | 2 +-
.../consumer/table/SubscriptionTableProvider.java | 49 +
.../table/SubscriptionTablePullConsumer.java | 152 +++
.../SubscriptionTablePullConsumerBuilder.java | 125 +++
.../table/SubscriptionTablePushConsumer.java | 95 ++
.../SubscriptionTablePushConsumerBuilder.java | 138 +++
.../consumer/tree/SubscriptionTreeProvider.java | 49 +
.../tree/SubscriptionTreePullConsumer.java | 317 ++++++
.../tree/SubscriptionTreePullConsumerBuilder.java | 124 +++
.../tree/SubscriptionTreePushConsumer.java | 290 +++++
.../tree/SubscriptionTreePushConsumerBuilder.java | 139 +++
.../session/subscription/model/Subscription.java | 3 +-
.../iotdb/session/subscription/model/Topic.java | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 7 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 9 +
.../consensus/request/ConfigPhysicalPlan.java | 38 +-
.../consensus/request/ConfigPhysicalPlanType.java | 34 +
.../request/read/auth/AuthorReadPlan.java | 143 ---
.../consensus/request/write/auth/AuthorPlan.java | 168 +--
.../request/write/auth/AuthorRelationalPlan.java | 167 +++
.../auth/{AuthorPlan.java => AuthorTreePlan.java} | 176 +--
.../partition/AutoCleanPartitionTablePlan.java | 99 ++
.../statemachine/ConfigRegionStateMachine.java | 1 -
.../iotdb/confignode/manager/ConfigManager.java | 18 +-
.../apache/iotdb/confignode/manager/IManager.java | 6 +-
.../confignode/manager/PermissionManager.java | 23 +-
.../iotdb/confignode/manager/ProcedureManager.java | 42 +-
.../iotdb/confignode/manager/TTLManager.java | 11 +
.../confignode/manager/load/cache/LoadCache.java | 13 +-
.../load/cache/region/RegionGroupCache.java | 39 +-
.../manager/partition/PartitionManager.java | 13 +-
.../manager/partition/RegionGroupStatus.java | 25 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 3 +
.../protocol/IoTDBConfigRegionConnector.java | 6 +-
...eConfigPhysicalPlanTreePatternParseVisitor.java | 34 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 66 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 551 +++++-----
.../iotdb/confignode/persistence/TTLInfo.java | 16 +
.../persistence/executor/ConfigPlanExecutor.java | 43 +-
.../partition/DatabasePartitionTable.java | 10 +
.../persistence/partition/PartitionInfo.java | 19 +
.../schema/CNPhysicalPlanGenerator.java | 148 ++-
.../persistence/schema/ClusterSchemaInfo.java | 12 +-
.../procedure/PartitionTableAutoCleaner.java | 81 ++
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../impl/sync/AuthOperationProcedure.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 98 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 64 +-
.../confignode/manager/load/LoadManagerTest.java | 12 +-
.../manager/load/cache/RegionGroupCacheTest.java | 132 ++-
...figPhysicalPlanTreePatternParseVisitorTest.java | 18 +-
.../confignode/persistence/AuthorInfoTest.java | 917 +++++++---------
.../persistence/CNPhysicalPlanGeneratorTest.java | 23 +-
.../ConfigRegionListeningQueueTest.java | 4 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 4 +-
.../impl/sync/AuthOperationProcedureTest.java | 39 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 11 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 215 +++-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 8 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 475 +++++----
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 37 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 26 +-
.../dataregion/DataRegionStateMachine.java | 144 +--
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 3 +
.../async/IoTDBDataRegionAsyncConnector.java | 3 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
.../scan/TsFileInsertionEventScanParser.java | 19 +
.../protocol/thrift/IoTDBDataNodeReceiver.java | 44 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 48 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 20 +-
.../thrift/impl/DataNodeRegionManager.java | 4 +-
.../execution/exchange/SharedTsBlockQueue.java | 8 +-
.../execution/exchange/sink/SinkChannel.java | 11 +-
.../exchange/source/LocalSourceHandle.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 11 +-
.../fragment/FragmentInstanceContext.java | 9 +
.../execution/operator/AbstractOperator.java | 2 +-
.../operator/process/AbstractSortOperator.java | 2 +-
.../execution/operator/process/SortOperator.java | 2 +-
.../operator/process/TableStreamSortOperator.java | 2 +-
.../process/window/TableWindowOperator.java | 411 +++++++
.../function/WindowFunction.java} | 30 +-
.../aggregate/AggregationWindowFunction.java | 113 ++
.../function/aggregate/WindowAggregator.java} | 102 +-
.../function/rank/CumeDistFunction.java} | 33 +-
.../function/rank/DenseRankFunction.java} | 33 +-
.../function/rank/NTileFunction.java} | 48 +-
.../function/rank/PercentRankFunction.java} | 53 +-
.../function/rank/RankFunction.java} | 38 +-
.../window/function/rank/RankWindowFunction.java | 66 ++
.../function/rank/RowNumberFunction.java} | 24 +-
.../window/function/value/FirstValueFunction.java | 64 ++
.../process/window/function/value/LagFunction.java | 77 ++
.../window/function/value/LastValueFunction.java | 64 ++
.../window/function/value/LeadFunction.java | 79 ++
.../window/function/value/NthValueFunction.java | 81 ++
.../function/value/ValueWindowFunction.java} | 40 +-
.../process/window/partition/Partition.java | 226 ++++
.../window/partition/PartitionExecutor.java | 197 ++++
.../partition/frame/Frame.java} | 8 +-
.../process/window/partition/frame/FrameInfo.java | 145 +++
.../window/partition/frame/GroupsFrame.java | 238 +++++
.../process/window/partition/frame/RangeFrame.java | 617 +++++++++++
.../process/window/partition/frame/RowsFrame.java | 108 ++
.../operator/process/window/utils/ColumnList.java | 141 +++
.../utils/Range.java} | 20 +-
.../process/window/utils/RowComparator.java | 231 ++++
.../execution/operator/source/FileLoaderUtils.java | 4 +-
.../InformationSchemaContentSupplierFactory.java | 9 +-
.../source/relational/MarkDistinctOperator.java | 170 +++
.../relational/aggregation/AvgAccumulator.java | 2 +-
.../relational/aggregation/TableAggregator.java | 4 +
.../grouped/HashAggregationOperator.java | 4 +-
.../grouped/StreamingAggregationOperator.java | 9 +-
.../grouped/StreamingHashAggregationOperator.java | 4 +-
.../aggregation/grouped/hash/MarkDistinctHash.java | 2 +-
.../relational/ColumnTransformerBuilder.java | 234 ++--
.../execution/schedule/DriverScheduler.java | 8 -
.../iotdb/db/queryengine/plan/Coordinator.java | 19 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 4 +-
.../analyze/cache/partition/PartitionCache.java | 5 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 9 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 6 +-
.../execution/config/TableConfigTaskVisitor.java | 77 +-
.../execution/config/TreeConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 109 +-
.../config/executor/IConfigTaskExecutor.java | 20 +-
...rateRegionTask.java => RemoveDataNodeTask.java} | 14 +-
.../config/metadata/region/ExtendRegionTask.java | 20 +-
.../config/metadata/region/MigrateRegionTask.java | 21 +-
.../metadata/region/ReconstructRegionTask.java | 25 +-
.../config/metadata/region/RemoveRegionTask.java | 20 +-
.../RelationalAuthorizerTask.java} | 23 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 19 +-
.../plan/planner/TableOperatorGenerator.java | 41 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 41 +-
.../plan/planner/plan/node/PlanNodeType.java | 4 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../metadata/write/view/AlterLogicalViewNode.java | 2 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 13 +
.../plan/node/pipe/PipeEnrichedInsertNode.java | 5 +
.../ContinuousSameSearchIndexSeparatorNode.java | 6 +
.../planner/plan/node/write/DeleteDataNode.java | 36 +
.../plan/node/write/InsertMultiTabletsNode.java | 5 +
.../plan/planner/plan/node/write/InsertNode.java | 21 +
.../planner/plan/node/write/InsertRowNode.java | 12 +
.../planner/plan/node/write/InsertRowsNode.java | 15 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 5 +
.../planner/plan/node/write/InsertTabletNode.java | 11 +
.../plan/node/write/RelationalDeleteDataNode.java | 23 +-
.../plan/planner/plan/node/write/SearchNode.java | 4 +
.../fetcher/TableHeaderSchemaValidator.java | 14 +-
.../fetcher/cache/TableDeviceLastCache.java | 2 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 19 +
.../distribute/TableDistributedPlanGenerator.java | 17 +-
.../MultipleDistinctAggregationToMarkDistinct.java | 202 ++++
...tColumns.java => PruneMarkDistinctColumns.java} | 26 +-
.../rule/SingleDistinctAggregationToGroupBy.java | 160 +++
.../relational/planner/node/AggregationNode.java | 6 +-
.../relational/planner/node/MarkDistinctNode.java | 162 +++
.../plan/relational/planner/node/Patterns.java | 7 +-
.../optimizations/LogicalOptimizeFactory.java | 15 +-
.../optimizations/PushPredicateIntoTableScan.java | 156 ++-
.../optimizations/UnaliasSymbolReferences.java | 21 +
.../plan/relational/security/AccessControl.java | 10 +
.../relational/security/AccessControlImpl.java | 217 ++++
.../relational/security/AllowAllAccessControl.java | 7 +
.../relational/security/ITableAuthChecker.java | 17 +
.../relational/security/ITableAuthCheckerImpl.java | 169 +++
.../relational/security/TableModelPrivilege.java | 54 +-
.../plan/relational/sql/ast/AstVisitor.java | 24 +
.../sql/ast/{Row.java => ExtendRegion.java} | 52 +-
.../plan/relational/sql/ast/LoadTsFile.java | 7 +
.../sql/ast/{Values.java => MigrateRegion.java} | 67 +-
.../sql/ast/{Row.java => ReconstructRegion.java} | 53 +-
.../sql/ast/RelationalAuthorStatement.java | 247 +++++
.../{ShowDataNodes.java => RemoveDataNode.java} | 24 +-
.../sql/ast/{Row.java => RemoveRegion.java} | 52 +-
.../plan/relational/sql/parser/AstBuilder.java | 305 +++++-
.../plan/relational/sql/util/SqlFormatter.java | 223 ++++
.../type/{TypeManager.java => AuthorRType.java} | 48 +-
.../statement/AuthorityInformationStatement.java | 2 +-
.../plan/statement/StatementVisitor.java | 5 +
.../plan/statement/crud/DeleteDataStatement.java | 3 +-
.../plan/statement/crud/InsertBaseStatement.java | 2 +-
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../plan/statement/crud/InsertStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 4 +-
.../plan/statement/crud/QueryStatement.java | 2 +-
.../InternalBatchActivateTemplateStatement.java | 3 +-
.../InternalCreateMultiTimeSeriesStatement.java | 2 +-
.../InternalCreateTimeSeriesStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 3 +-
.../statement/metadata/CountDevicesStatement.java | 6 +-
.../metadata/CountTimeSeriesStatement.java | 6 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 2 +-
.../metadata/CreateContinuousQueryStatement.java | 2 +-
.../metadata/CreateFunctionStatement.java | 2 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/CreateTimeSeriesStatement.java | 3 +-
.../statement/metadata/CreateTriggerStatement.java | 2 +-
.../metadata/DatabaseSchemaStatement.java | 2 +-
.../metadata/DeleteDatabaseStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 3 +-
.../metadata/DropContinuousQueryStatement.java | 2 +-
.../statement/metadata/DropFunctionStatement.java | 2 +-
.../statement/metadata/DropTriggerStatement.java | 2 +-
...Statement.java => RemoveDataNodeStatement.java} | 38 +-
.../plan/statement/metadata/SetTTLStatement.java | 3 +-
.../statement/metadata/ShowClusterStatement.java | 2 +-
.../metadata/ShowContinuousQueriesStatement.java | 2 +-
.../statement/metadata/ShowDevicesStatement.java | 6 +-
.../statement/metadata/ShowFunctionsStatement.java | 2 +-
.../metadata/ShowTimeSeriesStatement.java | 6 +-
.../statement/metadata/ShowTriggersStatement.java | 2 +-
.../metadata/model/CreateModelStatement.java | 2 +-
.../metadata/model/DropModelStatement.java | 2 +-
.../metadata/model/ShowModelsStatement.java | 2 +-
.../metadata/pipe/AlterPipeStatement.java | 2 +-
.../metadata/pipe/CreatePipePluginStatement.java | 2 +-
.../metadata/pipe/CreatePipeStatement.java | 2 +-
.../metadata/pipe/DropPipePluginStatement.java | 2 +-
.../statement/metadata/pipe/DropPipeStatement.java | 2 +-
.../metadata/pipe/ShowPipePluginsStatement.java | 2 +-
.../metadata/pipe/ShowPipesStatement.java | 2 +-
.../metadata/pipe/StartPipeStatement.java | 2 +-
.../statement/metadata/pipe/StopPipeStatement.java | 2 +-
.../metadata/region/ExtendRegionStatement.java | 14 +
.../metadata/region/MigrateRegionStatement.java | 14 +
.../region/ReconstructRegionStatement.java | 14 +
.../metadata/region/RemoveRegionStatement.java | 14 +
.../subscription/CreateTopicStatement.java | 2 +-
.../metadata/subscription/DropTopicStatement.java | 2 +-
.../subscription/ShowSubscriptionsStatement.java | 2 +-
.../metadata/subscription/ShowTopicsStatement.java | 2 +-
.../template/ActivateTemplateStatement.java | 3 +-
.../template/BatchActivateTemplateStatement.java | 3 +-
.../template/DeactivateTemplateStatement.java | 3 +-
.../metadata/view/AlterLogicalViewStatement.java | 6 +-
.../metadata/view/CreateLogicalViewStatement.java | 6 +-
.../metadata/view/DeleteLogicalViewStatement.java | 3 +-
.../metadata/view/RenameLogicalViewStatement.java | 2 +-
.../plan/statement/sys/AuthorStatement.java | 56 +-
.../plan/statement/sys/KillQueryStatement.java | 2 +-
.../plan/statement/sys/ShowQueriesStatement.java | 2 +-
.../AbstractCastFunctionColumnTransformer.java | 43 +-
.../scalar/CastFunctionColumnTransformer.java | 4 +-
.../scalar/TryCastFunctionColumnTransformer.java | 4 +-
.../schemaregion/utils/ResourceByPathUtils.java | 31 +-
.../db/schemaengine/table/DataNodeTableCache.java | 108 +-
.../db/storageengine/dataregion/DataRegion.java | 37 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../compaction/execute/utils/CompactionUtils.java | 5 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 14 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 26 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 40 +-
.../utils/AlignedSeriesBatchCompactionUtils.java | 28 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 23 +-
.../executor/fast/SeriesCompactionExecutor.java | 10 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 31 +-
.../utils/writer/FastCrossCompactionWriter.java | 10 +-
.../utils/writer/FastInnerCompactionWriter.java | 10 +-
.../compaction/schedule/TTLScheduleTask.java | 4 +-
.../selector/impl/SettleSelectorImpl.java | 3 +
.../dataregion/flush/MemTableFlushTask.java | 2 +-
.../memtable/AlignedReadOnlyMemChunk.java | 14 +-
.../memtable/AlignedWritableMemChunk.java | 13 +-
.../dataregion/memtable/TsFileProcessor.java | 7 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 2 +-
.../dataregion/modification/ModificationFile.java | 69 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 5 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 4 +-
.../dataregion/tsfile/TsFileResource.java | 23 +-
.../db/storageengine/load/LoadTsFileManager.java | 5 +-
.../load/active/ActiveLoadTsFileLoader.java | 3 +-
.../load/config/LoadTsFileConfigurator.java | 20 +
.../broker/SubscriptionPrefetchingQueue.java | 47 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 96 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 2 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 2 +-
.../event/SubscriptionCommitContextSupplier.java | 28 -
.../db/subscription/event/SubscriptionEvent.java | 80 +-
.../event/batch/SubscriptionPipeEventBatch.java | 30 -
.../batch/SubscriptionPipeTabletEventBatch.java | 66 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 15 -
.../cache/CachedSubscriptionPollResponse.java | 5 +
.../event/pipe/SubscriptionPipeEmptyEvent.java | 4 +-
.../pipe/SubscriptionPipeTabletBatchEvents.java | 46 +-
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 8 +-
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 8 +-
.../SubscriptionEventExtendableResponse.java | 1 +
.../event/response/SubscriptionEventResponse.java | 10 +-
.../response/SubscriptionEventSingleResponse.java | 1 +
.../response/SubscriptionEventTabletResponse.java | 201 +++-
.../response/SubscriptionEventTsFileResponse.java | 32 +-
.../utils/TsFileRewriteOverPrecisedI64Scan.java | 223 ++++
.../utils/TsFileRewriteSmallRangeI64Scan.java | 230 ++++
.../iotdb/db/tools/utils/TsFileSequenceScan.java | 34 +-
.../iotdb/db/tools/utils/TsFileStatisticScan.java | 266 +++++
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 6 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 9 +-
.../iotdb/db/utils/constant/SqlConstant.java | 2 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 318 +++---
.../auth/authorizer/LocalFileAuthorizerTest.java | 226 ++--
.../db/auth/entity/DataBasePrivilegeTest.java | 75 ++
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 42 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 57 +-
.../iotdb/db/auth/entity/TablePrivilegeTest.java | 67 ++
.../org/apache/iotdb/db/auth/entity/UserTest.java | 14 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 87 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 162 +--
.../db/auth/user/LocalFileUserAccessorTest.java | 119 +--
.../db/auth/user/LocalFileUserManagerTest.java | 117 +-
.../dataregion/DataRegionStateMachineTest.java | 4 +-
.../db/queryengine/execution/exchange/Utils.java | 3 +
.../execution/operator/OperatorMemoryTest.java | 2 +
.../process/window/TableWindowOperatorTest.java | 320 ++++++
.../window/TableWindowOperatorTestUtils.java | 131 +++
.../process/window/function/FunctionTestUtils.java | 113 ++
.../aggregate/AggregationWindowFunctionTest.java | 195 ++++
.../window/function/rank/CumeDistFunctionTest.java | 72 ++
.../function/rank/DenseRankFunctionTest.java | 71 ++
.../window/function/rank/NTileFunctionTest.java | 128 +++
.../function/rank/PercentRankFunctionTest.java | 72 ++
.../window/function/rank/RankFunctionTest.java | 71 ++
.../function/rank/RowNumberFunctionTest.java | 70 ++
.../function/value/FirstValueFunctionTest.java | 120 +++
.../window/function/value/LagFunctionTest.java | 159 +++
.../function/value/LastValueFunctionTest.java | 120 +++
.../window/function/value/LeadFunctionTest.java | 159 +++
.../function/value/NthValueFunctionTest.java | 150 +++
.../window/partition/frame/FrameTestUtils.java | 139 +++
.../window/partition/frame/GroupsFrameTest.java | 359 +++++++
.../window/partition/frame/RangeFrameTest.java | 1127 ++++++++++++++++++++
.../window/partition/frame/RowsFrameTest.java | 359 +++++++
.../plan/parser/StatementGeneratorTest.java | 13 +-
.../plan/relational/analyzer/DistinctTest.java | 118 ++
.../plan/relational/planner/SubqueryTest.java | 147 ++-
...onStepMatcher.java => MarkDistinctMatcher.java} | 50 +-
.../planner/assertions/PlanMatchPattern.java | 22 +
.../relational/sql/parser/AuthorStatementTest.java | 351 ++++++
.../security/encrypt/MessageDigestEncryptTest.java | 8 +-
...InconsistentCompressionTypeAndEncodingTest.java | 6 +-
.../FastInnerCompactionPerformerTest.java | 6 +-
.../repair/RepairUnsortedFileCompactionTest.java | 8 +-
.../compaction/utils/BatchCompactionUtilsTest.java | 39 +-
.../conf/iotdb-system.properties.template | 6 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 271 ++---
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 142 +--
.../commons/auth/authorizer/OpenIdAuthorizer.java | 9 +-
.../commons/auth/entity/DatabasePrivilege.java | 250 +++++
.../IEntityAccessor.java} | 42 +-
.../iotdb/commons/auth/entity/ModelType.java | 9 +-
.../iotdb/commons/auth/entity/PathPrivilege.java | 151 +--
.../commons/auth/entity/PriPrivilegeType.java | 153 ---
.../commons/auth/entity/PrivilegeModelType.java | 10 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 90 +-
.../iotdb/commons/auth/entity/PrivilegeUnion.java | 151 +++
.../org/apache/iotdb/commons/auth/entity/Role.java | 558 ++++++++--
.../iotdb/commons/auth/entity/TablePrivilege.java | 166 +++
.../org/apache/iotdb/commons/auth/entity/User.java | 81 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 267 ++---
.../iotdb/commons/auth/role/IEntityManager.java | 77 ++
.../iotdb/commons/auth/role/IRoleAccessor.java | 70 --
.../iotdb/commons/auth/role/IRoleManager.java | 109 --
.../commons/auth/role/LocalFileRoleAccessor.java | 288 ++---
.../commons/auth/role/LocalFileRoleManager.java | 6 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 260 +----
.../iotdb/commons/auth/user/IUserManager.java | 162 ---
.../commons/auth/user/LocalFileUserAccessor.java | 414 ++-----
.../commons/auth/user/LocalFileUserManager.java | 8 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 99 +-
.../iotdb/commons/conf/CommonDescriptor.java | 48 +-
.../commons/partition/DataPartitionTable.java | 12 +
.../commons/partition/SeriesPartitionTable.java | 16 +
.../org/apache/iotdb/commons/path/PartialPath.java | 8 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 10 +
.../config/constant/PipeConnectorConstant.java | 5 +
.../pipe/connector/client/IoTDBClientManager.java | 6 +-
.../connector/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../pipe/connector/protocol/IoTDBConnector.java | 8 +
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 7 +
.../schema/column/ColumnHeaderConstant.java | 5 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 4 +
.../schema/table/column/TsTableColumnSchema.java | 19 +
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 27 +
.../subscription/config/SubscriptionConfig.java | 47 +-
.../commons/subscription/meta/topic/TopicMeta.java | 4 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 299 +++---
.../org/apache/iotdb/commons/utils/IOUtils.java | 140 +--
.../apache/iotdb/commons/utils/SerializeUtils.java | 21 +
.../iotdb/commons/utils/TimePartitionUtils.java | 13 +
.../apache/iotdb/commons/utils/AuthUtilsTest.java | 72 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 149 ++-
.../src/main/thrift/confignode.thrift | 63 +-
pom.xml | 4 +-
579 files changed, 29160 insertions(+), 9764 deletions(-)
create mode 100644
example/session/src/main/java/org/apache/iotdb/TableModelSubscriptionSessionExample.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionTableAutoCleanTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/IQueryDataSource.java
=>
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java
(86%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBClusterAuthorityRelationalIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBRelationalAuthIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBPredicatePushDownTable3IT.java
=> recent/IoTDBNullValueIT.java} (55%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBTableAggregationFunctionDistinctIT.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/Constants.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/ImportTsFileOperation.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/OptionsUtil.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AbstractExportData.java
copy
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{tsfile/ImportTsFileBase.java
=> data/AbstractImportData.java} (55%)
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AsyncImportData.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ExportDataTable.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ExportDataTree.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportDataTable.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportDataTree.java
create mode 100644
iotdb-client/cli/src/test/java/org/apache/iotdb/tool/ImportTsFileOperationTest.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/AbstractSubscriptionSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ISubscriptionTableSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ISubscriptionTreeSession.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionWrapper.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTableSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTableSessionBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTreeSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTreeSessionBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTablePullConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTablePushConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTreePullConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTreePushConsumer.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionConsumer.java
=> base/AbstractSubscriptionConsumer.java} (90%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionProvider.java
=> base/AbstractSubscriptionProvider.java} (93%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionProviders.java
=> base/AbstractSubscriptionProviders.java} (83%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionPullConsumer.java
=> base/AbstractSubscriptionPullConsumer.java} (67%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionPullConsumerBuilder.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionPushConsumer.java
=> base/AbstractSubscriptionPushConsumer.java} (66%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionPushConsumerBuilder.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{
=> base}/SubscriptionExecutorServiceManager.java (99%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTableProvider.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePullConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePullConsumerBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumerBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreeProvider.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumerBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/auth/AuthorReadPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/AuthorRelationalPlan.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/auth/{AuthorPlan.java
=> AuthorTreePlan.java} (54%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/partition/AutoCleanPartitionTablePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/WindowFunction.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/aggregate/AggregationWindowFunction.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/{source/relational/aggregation/TableAggregator.java
=> process/window/function/aggregate/WindowAggregator.java} (54%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/rank/CumeDistFunction.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/rank/DenseRankFunction.java} (63%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityLinearFill.java
=> window/function/rank/NTileFunction.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityLinearFill.java
=> window/function/rank/PercentRankFunction.java} (54%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/rank/RankFunction.java} (60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/RankWindowFunction.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityFill.java
=> window/function/rank/RowNumberFunction.java} (66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/FirstValueFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LagFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LastValueFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LeadFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/NthValueFunction.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{fill/identity/IdentityLinearFill.java
=> window/function/value/ValueWindowFunction.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/Partition.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/PartitionExecutor.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{ProcessOperator.java
=> window/partition/frame/Frame.java} (78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/FrameInfo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/GroupsFrame.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/RangeFrame.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/RowsFrame.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/utils/ColumnList.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{ProcessOperator.java
=> window/utils/Range.java} (76%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/utils/RowComparator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/MarkDistinctOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{region/MigrateRegionTask.java
=> RemoveDataNodeTask.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{template/DropSchemaTemplateTask.java
=> relational/RelationalAuthorizerTask.java} (67%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/MultipleDistinctAggregationToMarkDistinct.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneSortColumns.java
=> PruneMarkDistinctColumns.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/SingleDistinctAggregationToGroupBy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/MarkDistinctNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/ITableAuthCheckerImpl.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Row.java
=> ExtendRegion.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Values.java
=> MigrateRegion.java} (56%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Row.java
=> ReconstructRegion.java} (61%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/RelationalAuthorStatement.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowDataNodes.java
=> RemoveDataNode.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Row.java
=> RemoveRegion.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/type/{TypeManager.java
=> AuthorRType.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{DropFunctionStatement.java
=> RemoveDataNodeStatement.java} (81%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionCommitContextSupplier.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileRewriteOverPrecisedI64Scan.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileRewriteSmallRangeI64Scan.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileStatisticScan.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/DataBasePrivilegeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/TablePrivilegeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/TableWindowOperatorTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/FunctionTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/aggregate/AggregationWindowFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/CumeDistFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/DenseRankFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/NTileFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/PercentRankFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/RankFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/rank/RowNumberFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/FirstValueFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LagFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LastValueFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/LeadFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/function/value/NthValueFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/FrameTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/GroupsFrameTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/RangeFrameTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/window/partition/frame/RowsFrameTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/{AggregationStepMatcher.java
=> MarkDistinctMatcher.java} (54%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/AuthorStatementTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/DatabasePrivilege.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/{user/IUserAccessor.java
=> entity/IEntityAccessor.java} (60%)
copy iotdb-client/cli/src/main/java/org/apache/iotdb/cli/type/ExitType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/ModelType.java
(89%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/PriPrivilegeType.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2SubscriptionRegressionConsumer.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/PrivilegeModelType.java
(86%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/PrivilegeUnion.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/TablePrivilege.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/IEntityManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/IRoleAccessor.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/role/IRoleManager.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/user/IUserManager.java
