This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch pipe-sep
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d715262421f auto
add fa626bfa0a7 support serializing plain device time index (#17285)
add 964f51738f2 Update pyproject.toml (#17296)
add 6d9e6d0622a Subscription: support consumer timeout and idle disconnect
(#17293)
add 80399a6f120 Subscription: refactor payload APIs to use ResultSet and
tsfile readers (#17225)
add d8dfe1b9170 [AINode] Modify model loading (#17299)
add a7c82cd8493 Fix incorrect measurement schema during compaction (#17297)
add 67ddff930b8 [AINode] Fix call inference error (#17308)
add e593fcba00b Implement table & tree disk usage statistics (#17169)
add 12f655ff763 Pipe: Optimized the OPC UA logic to avoid potential bugs
(#17309)
add 599ad8b8a82 Upgrade GitHub Actions plugins to supported Node runtimes
(#17311)
add 75364c2396b [AINode] Fix backend auto-selection (#17314)
add 2e88860c583 Subscription: split client and example modules (#17306)
add dc0758fcbdb Deleted the useless device flush map & Pipe: Made the
assigner cache to full cache & Use precise match in assigner device & Print
periodical log when assigner has exceeded half of the capacity (#17312)
add 278b05b1dc3 Pipe: Use async launch to avoid blocking datanode start
(#17315)
add 0356975bad1 Support aggregation push-down optimize for table view of
non aligned series (#17294)
add cbde990898c support the counting filtered rows when filter is pushed
down to scan node (#17304)
add fd3797797a0 Remove extra user caching for REST services and migrate to
the unified user check cache. (#17321)
add 063794bf577 Implement and fix Windows disk metrics parsing (#17290)
add f7b70883ec1 Remove OpenIdAuthorizer and OpenID authentication
dependencies (#17320)
add c9066c72e87 Add optional responseData to TSStatus and RpcUtils helpers
(#17328)
add e8af596c640 [AINode] Upgrade torch version (#17323)
add 8c20a1d4f91 fix: pick deletion event for historical resend (#17329)
add 402abdd0071 Automatically repair lost data partitions (#17279)
add 9be854c0e70 Fix Process resource leak in system metrics collection
(#17212)
add 6f546910e62 Fix: add @deprecated Javadoc and handle deprecated method
properly (#17331)
add 5a83067d05a [AINode] Support hubmixin models and modify pipeline
(#17334)
add 9f790e1c8f3 Pipe: Fixed the initial value bug for opc value + quality
(#17345)
add 936af64f79e support EXPLAIN and EXPLAIN ANALYZE for EXECUTE prepared
statement (#17318)
add 5f9cb661d1b Fixed the REST partial insert & Pipe: Added partial insert
IT (#17340)
add e48272a8ae6 Pipe: Fixed the log of disruptor queue & deleted the
useless binary buffer (#17341)
add 355a872cfae Pipe: Fixed the bug that separated historical pipe may not
include mod on deletion & The pipe without data.insert may be wrongly separated
by pipe and transfer data (#17346)
add c8455c142b7 Add extra client_ip and timeout columns for show queries
(#17350)
add 55611f1b7bb Fixed the default string charset in CI (#17354)
add 6c8e1d5dd47 Pipe: Fixed the on committed hook square bug & Trimmed the
raw tablet hook & Fixed the premature report for source event & Skipped the
parsing of time-covered tsFile (#17360)
add fd3726f384a Avoid to roll back the state imminently and resolve the
NoSuchElementException (#17363)
add 720cf156aa3 s
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 8 +-
.github/workflows/cluster-it-1c1d1a.yml | 4 +-
.github/workflows/cluster-it-1c3d.yml | 6 +-
.github/workflows/compile-check.yml | 4 +-
.github/workflows/daily-it.yml | 92 +-
.github/workflows/daily-ut.yml | 6 +-
.github/workflows/dependency-check.yml | 6 +-
.github/workflows/greeting-ainode.yml | 6 +-
.github/workflows/multi-language-client.yml | 18 +-
.github/workflows/pipe-it.yml | 88 +-
.github/workflows/sonar-codecov.yml | 12 +-
.github/workflows/table-cluster-it-1c1d.yml | 8 +-
.github/workflows/table-cluster-it-1c3d.yml | 6 +-
.github/workflows/todos-check.yml | 2 +-
.github/workflows/unit-test.yml | 6 +-
.github/workflows/vulnerability-check.yml | 6 +-
LICENSE-binary | 10 -
dependencies.json | 8 -
.../server/CustomizedJsonPayloadFormatter.java | 6 +-
example/pom.xml | 1 +
example/{mqtt => subscription}/pom.xml | 9 +-
.../apache/iotdb/SubscriptionSessionExample.java | 45 +-
.../TableModelSubscriptionSessionExample.java | 22 +-
external-service-impl/rest/pom.xml | 12 -
.../rest/protocol/filter/AuthorizationFilter.java | 10 +-
.../iotdb/rest/protocol/filter/UserCache.java | 57 --
integration-test/pom.xml | 5 +
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 50 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 1 +
.../ainode/it/AINodeInstanceManagementIT.java | 74 +-
.../iotdb/ainode/it/AINodeModelManageIT.java | 59 +-
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 32 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 109 ++-
.../apache/iotdb/db/it/IoTDBShowDiskUsageIT.java | 163 ++++
.../iotdb/db/it/query/IoTDBFilteredRowsIT.java | 364 ++++++++
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 1 -
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 54 +-
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 66 +-
.../relational/it/IoTDBShowDiskUsageTableIT.java | 176 ++++
.../it/insertquery/IoTDBInsertQueryIT.java | 5 +-
.../it/query/recent/IoTDBMaintainAuthIT.java | 12 +-
.../it/query/recent/IoTDBTableFilteredRowsIT.java | 272 ++++++
.../query/view/recent/IoTDBTableViewQueryIT.java | 52 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 25 +-
.../iotdb/session/it/IoTDBConnectionsIT.java | 1 +
.../iotdb/session/it/pool/SessionPoolIT.java | 6 +-
.../it/SubscriptionTreeReaderTestUtils.java | 164 ++++
.../it/cluster/IoTDBSubscriptionRestartIT.java | 47 +-
.../dual/tablemodel/IoTDBSubscriptionTopicIT.java | 18 +-
.../IoTDBSubscriptionConsumerGroupIT.java | 43 +-
.../IoTDBSubscriptionTimePrecisionIT.java | 3 +-
.../dual/treemodel/IoTDBSubscriptionTopicIT.java | 40 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 68 +-
.../it/local/IoTDBSubscriptionDataTypeIT.java | 48 +-
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 66 +-
.../treemodel/IoTDBSubscriptionSharingIT.java | 146 ++--
.../AbstractSubscriptionTreeRegressionIT.java | 40 +-
.../IoTDBDefaultTsfilePushConsumerIT.java | 14 +-
.../IoTDBRootDatasetPushConsumerIT.java | 9 +-
...merPullConsumerWith1TopicShareProcessMixIT.java | 9 +-
.../param/IoTDBTestParamPullConsumerIT.java | 23 +-
.../param/IoTDBTestParamPushConsumerIT.java | 19 +-
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 3 +-
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 3 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 39 +-
.../format/IoTDBTestPushConsumeDataSetIT.java | 9 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 12 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 12 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 9 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 9 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 16 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 14 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 9 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 10 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 9 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 9 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 14 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 10 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 9 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 9 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 14 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 15 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 15 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 125 ++-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 9 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 36 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 19 +-
.../IoTDBDBPatternDatasetPushConsumerIT.java | 9 +-
.../IoTDBDBPatternTsfilePushConsumerIT.java | 14 +-
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 14 +-
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 9 +-
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 14 +-
.../IoTDBRootPatternDatasetPushConsumerIT.java | 9 +-
.../IoTDBTSPatternDatasetPushConsumerIT.java | 9 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 14 +-
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 9 +-
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 10 +-
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 9 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 10 +-
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 9 +-
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 9 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 10 +-
iotdb-client/cli/pom.xml | 5 +
.../subscription/SubscriptionTableTsFile.java | 2 +-
.../subscription/SubscriptionTreeTsFile.java | 2 +-
iotdb-client/pom.xml | 1 +
iotdb-client/service-rpc/pom.xml | 5 -
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 33 +
.../iotdb/session/AbstractSessionBuilder.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 1 +
.../payload/SubscriptionSessionDataSet.java | 255 ------
.../SubscriptionSessionDataSetsHandler.java | 91 --
.../src/test/resources/iotdb-common.properties | 9 -
iotdb-client/{isession => subscription}/pom.xml | 39 +-
.../rpc/subscription/annotation/TableModel.java | 0
.../rpc/subscription/config/ConsumerConfig.java | 12 +
.../rpc/subscription/config/ConsumerConstant.java | 3 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 10 +-
.../rpc/subscription/config/TopicConstant.java | 11 +-
.../exception/SubscriptionConnectionException.java | 0
.../exception/SubscriptionException.java | 0
.../SubscriptionIdentifierSemanticException.java | 0
.../SubscriptionIncompatibleHandlerException.java | 0
.../SubscriptionParameterNotValidException.java | 0
.../SubscriptionPayloadExceedException.java | 0
.../SubscriptionPipeTimeoutException.java | 0
.../SubscriptionPollTimeoutException.java | 0
.../SubscriptionRuntimeCriticalException.java | 0
.../exception/SubscriptionRuntimeException.java | 0
.../SubscriptionRuntimeNonCriticalException.java | 0
.../exception/SubscriptionTimeoutException.java | 0
.../subscription/payload/poll/ErrorPayload.java | 0
.../subscription/payload/poll/FileInitPayload.java | 0
.../payload/poll/FilePiecePayload.java | 0
.../subscription/payload/poll/FileSealPayload.java | 0
.../subscription/payload/poll/PollFilePayload.java | 0
.../rpc/subscription/payload/poll/PollPayload.java | 0
.../payload/poll/PollTabletsPayload.java | 0
.../payload/poll/SubscriptionCommitContext.java | 0
.../payload/poll/SubscriptionPollPayload.java | 0
.../payload/poll/SubscriptionPollRequest.java | 0
.../payload/poll/SubscriptionPollRequestType.java | 0
.../payload/poll/SubscriptionPollResponse.java | 0
.../payload/poll/SubscriptionPollResponseType.java | 0
.../subscription/payload/poll/TabletsPayload.java | 0
.../payload/poll/TerminationPayload.java | 0
.../payload/request/PipeSubscribeCloseReq.java | 0
.../payload/request/PipeSubscribeCommitReq.java | 0
.../payload/request/PipeSubscribeHandshakeReq.java | 0
.../payload/request/PipeSubscribeHeartbeatReq.java | 0
.../payload/request/PipeSubscribePollReq.java | 0
.../payload/request/PipeSubscribeRequestType.java | 0
.../request/PipeSubscribeRequestVersion.java | 0
.../payload/request/PipeSubscribeSubscribeReq.java | 0
.../request/PipeSubscribeUnsubscribeReq.java | 0
.../payload/response/PipeSubscribeCloseResp.java | 0
.../payload/response/PipeSubscribeCommitResp.java | 0
.../response/PipeSubscribeHandshakeResp.java | 0
.../response/PipeSubscribeHeartbeatResp.java | 0
.../payload/response/PipeSubscribePollResp.java | 0
.../response/PipeSubscribeResponseType.java | 0
.../response/PipeSubscribeResponseVersion.java | 0
.../response/PipeSubscribeSubscribeResp.java | 0
.../response/PipeSubscribeUnsubscribeResp.java | 0
.../subscription/AbstractSubscriptionSession.java | 0
.../subscription/ISubscriptionTableSession.java | 0
.../subscription/ISubscriptionTreeSession.java | 0
.../SubscriptionSessionConnection.java | 0
.../subscription/SubscriptionSessionWrapper.java | 2 +-
.../subscription/SubscriptionTableSession.java | 0
.../SubscriptionTableSessionBuilder.java | 5 +
.../subscription/SubscriptionTreeSession.java | 0
.../SubscriptionTreeSessionBuilder.java | 5 +
.../session/subscription/consumer/AckStrategy.java | 0
.../subscription/consumer/AsyncCommitCallback.java | 0
.../subscription/consumer/ConsumeListener.java | 0
.../subscription/consumer/ConsumeResult.java | 0
.../consumer/ISubscriptionTablePullConsumer.java | 0
.../consumer/ISubscriptionTablePushConsumer.java | 0
.../consumer/ISubscriptionTreePullConsumer.java | 0
.../consumer/ISubscriptionTreePushConsumer.java | 0
.../base/AbstractSubscriptionConsumer.java | 21 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 7 +
.../base/AbstractSubscriptionProvider.java | 22 +-
.../base/AbstractSubscriptionProviders.java | 0
.../base/AbstractSubscriptionPullConsumer.java | 0
.../AbstractSubscriptionPullConsumerBuilder.java | 7 +
.../base/AbstractSubscriptionPushConsumer.java | 0
.../AbstractSubscriptionPushConsumerBuilder.java | 7 +
.../base/SubscriptionExecutorServiceManager.java | 0
.../consumer/table/SubscriptionTableProvider.java | 20 +-
.../table/SubscriptionTablePullConsumer.java | 13 +-
.../SubscriptionTablePullConsumerBuilder.java | 7 +
.../table/SubscriptionTablePushConsumer.java | 13 +-
.../SubscriptionTablePushConsumerBuilder.java | 7 +
.../consumer/tree/SubscriptionTreeProvider.java | 20 +-
.../tree/SubscriptionTreePullConsumer.java | 20 +-
.../tree/SubscriptionTreePullConsumerBuilder.java | 7 +
.../tree/SubscriptionTreePushConsumer.java | 20 +-
.../tree/SubscriptionTreePushConsumerBuilder.java | 7 +
.../session/subscription/model/Subscription.java | 0
.../iotdb/session/subscription/model/Topic.java | 0
.../payload/SubscriptionFileHandler.java | 0
.../subscription/payload/SubscriptionMessage.java | 31 +-
.../payload/SubscriptionMessageHandler.java | 0
.../payload/SubscriptionMessageType.java | 4 +-
.../payload/SubscriptionRecordHandler.java | 392 +++++++++
.../payload/SubscriptionTsFileHandler.java | 28 +-
.../session/subscription/util/CollectionUtils.java | 0
.../session/subscription/util/IdentifierUtils.java | 0
.../iotdb/session/subscription/util/PollTimer.java | 0
.../subscription/util/RandomStringGenerator.java | 0
.../session/subscription/util/SetPartitioner.java | 0
.../ainode/core/device/backend/cuda_backend.py | 20 +
iotdb-core/ainode/iotdb/ainode/core/exception.py | 6 -
.../core/inference/pipeline/basic_pipeline.py | 209 ++++-
.../iotdb/ainode/core/inference/pool_controller.py | 110 ++-
.../pool_scheduler/basic_pool_scheduler.py | 4 +-
.../iotdb/ainode/core/manager/device_manager.py | 14 +-
.../iotdb/ainode/core/manager/inference_manager.py | 65 +-
.../iotdb/ainode/core/manager/model_manager.py | 1 -
.../core/model/chronos2/pipeline_chronos2.py | 6 +-
.../iotdb/ainode/core/model/model_constants.py | 31 +-
.../ainode/iotdb/ainode/core/model/model_info.py | 12 +-
.../ainode/iotdb/ainode/core/model/model_loader.py | 120 +--
.../iotdb/ainode/core/model/model_storage.py | 106 ++-
.../ainode/core/model/moirai2/pipeline_moirai2.py | 6 +-
.../ainode/core/model/sktime/pipeline_sktime.py | 7 +-
.../ainode/core/model/sundial/pipeline_sundial.py | 6 +-
.../ainode/core/model/timer_xl/pipeline_timer.py | 6 +-
iotdb-core/ainode/iotdb/ainode/core/model/utils.py | 118 ++-
iotdb-core/ainode/iotdb/ainode/core/script.py | 27 +-
.../ainode/iotdb/ainode/core/util/decorator.py | 8 +-
iotdb-core/ainode/iotdb/ainode/core/util/serde.py | 15 +-
iotdb-core/ainode/pyproject.toml | 4 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 13 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
iotdb-core/confignode/pom.xml | 5 +
.../client/sync/CnToDnSyncRequestType.java | 5 +
.../client/sync/SyncDataNodeClientPool.java | 10 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 11 +
.../confignode/conf/ConfigNodeDescriptor.java | 6 +
.../iotdb/confignode/manager/ProcedureManager.java | 11 +
.../persistence/auth/AuthorPlanExecutor.java | 10 +-
.../impl/partition/ConfigNodeProcedureEnv.java | 23 +-
.../DataPartitionTableIntegrityCheckProcedure.java | 972 +++++++++++++++++++++
...artitionTableIntegrityCheckProcedureState.java} | 18 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 5 +-
.../iotdb/confignode/service/ConfigNode.java | 58 +-
iotdb-core/datanode/pom.xml | 32 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 32 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 31 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 11 -
.../db/partition/DataPartitionTableGenerator.java | 277 ++++++
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 3 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 7 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 12 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 65 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 16 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 33 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 11 +
.../scan/AlignedSinglePageWholeChunkReader.java | 6 +-
.../parser/scan/SinglePageWholeChunkReader.java | 2 +-
.../scan/TsFileInsertionEventScanParser.java | 2 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 241 +++--
.../iotconsensusv2/IoTConsensusV2Receiver.java | 10 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 11 +-
.../request/PipeTransferTabletBatchReq.java | 55 +-
.../request/PipeTransferTabletBatchReqV2.java | 75 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 19 +-
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 23 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 20 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 16 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 123 +--
.../thrift/async/IoTDBDataRegionAsyncSink.java | 6 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 17 +-
.../sink/protocol/writeback/WriteBackSink.java | 14 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 12 +
.../realtime/assigner/DisruptorQueue.java | 27 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +-
.../matcher/CachedSchemaPatternMatcher.java | 41 +-
.../iotdb/db/protocol/thrift/OperationType.java | 5 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 317 ++++++-
.../db/queryengine/common/MPPQueryContext.java | 9 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../execution/fragment/DataNodeQueryContext.java | 30 +
.../fragment/FakedFragmentInstanceContext.java | 2 +-
.../fragment/FragmentInstanceContext.java | 46 +-
.../fragment/FragmentInstanceExecution.java | 13 +-
.../fragment/FragmentInstanceManager.java | 6 +-
.../execution/fragment/QueryContext.java | 13 +-
.../execution/fragment/QueryStatistics.java | 45 +-
.../execution/operator/OperatorContext.java | 18 +-
.../operator/sink/IdentitySinkOperator.java | 3 +
.../operator/source/ExchangeOperator.java | 13 +-
.../execution/operator/source/FileLoaderUtils.java | 11 +
.../execution/operator/source/SeriesScanUtil.java | 76 +-
.../operator/source/ShowDiskUsageOperator.java | 198 +++++
.../operator/source/ShowQueriesOperator.java | 4 +
.../relational/AbstractAggTableScanOperator.java | 23 +-
.../relational/AbstractTableScanOperator.java | 1 -
.../relational/DeviceIteratorScanOperator.java | 15 +-
.../InformationSchemaContentSupplierFactory.java | 370 +++++++-
.../InformationSchemaTableScanOperator.java | 13 +-
.../relational/LastQueryAggTableScanOperator.java | 3 +-
...onAlignedDeviceViewAggregationScanOperator.java | 259 ++++++
.../iotdb/db/queryengine/plan/Coordinator.java | 54 +-
.../db/queryengine/plan/analyze/Analysis.java | 2 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 83 +-
.../plan/execution/IQueryExecution.java | 3 +
.../queryengine/plan/execution/QueryExecution.java | 5 +
.../plan/execution/config/ConfigExecution.java | 5 +
.../config/executor/ClusterConfigTaskExecutor.java | 52 +-
.../plan/optimization/LimitOffsetPushDown.java | 39 +-
.../plan/optimization/PredicatePushDown.java | 58 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 36 +
.../plan/planner/LogicalPlanBuilder.java | 68 ++
.../plan/planner/LogicalPlanVisitor.java | 18 +
.../plan/planner/OperatorTreeGenerator.java | 61 ++
.../plan/planner/TableOperatorGenerator.java | 123 ++-
.../planner/distribution/DistributionPlanner.java | 20 +-
.../planner/distribution/ExchangeNodeAdder.java | 6 +
.../planner/distribution/NodeGroupContext.java | 5 +
.../SimpleFragmentParallelPlanner.java | 5 +-
.../distribution/WriteFragmentParallelPlanner.java | 1 +
.../memory/PipelineMemoryEstimatorFactory.java | 1 +
.../plan/AbstractFragmentParallelPlanner.java | 2 +-
.../plan/planner/plan/FragmentInstance.java | 29 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 24 +
.../plan/planner/plan/node/PlanNodeType.java | 27 +-
.../plan/planner/plan/node/PlanVisitor.java | 22 +
.../plan/node/process}/CollectNode.java | 66 +-
.../plan/node/source/ShowDiskUsageNode.java | 214 +++++
.../planner/plan/node/source/ShowQueriesNode.java | 12 +-
.../planner/plan/parameter/SeriesScanOptions.java | 13 +-
.../function/tvf/ForecastTableFunction.java | 50 +-
.../function/tvf/TableFunctionUtils.java | 74 ++
.../plan/relational/planner/CteMaterializer.java | 3 +-
.../plan/relational/planner/RelationPlanner.java | 24 +-
.../distribute/TableDistributedPlanGenerator.java | 471 +++++++---
.../distribute/TableModelQueryFragmentPlanner.java | 3 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 3 +-
.../rule/PushDownOffsetIntoTableScan.java | 8 +-
.../node/AggregationTreeDeviceViewScanNode.java | 15 +-
... AlignedAggregationTreeDeviceViewScanNode.java} | 64 +-
.../node/InformationSchemaTableScanNode.java | 11 +-
...nAlignedAggregationTreeDeviceViewScanNode.java} | 64 +-
...leDiskUsageInformationSchemaTableScanNode.java} | 92 +-
.../DataNodeLocationSupplierFactory.java | 34 +
.../PushAggregationIntoTableScan.java | 4 -
.../PushLimitOffsetIntoTableScan.java | 44 +-
.../optimizations/PushPredicateIntoTableScan.java | 206 +++--
.../security/TreeAccessCheckVisitor.java | 10 +
.../plan/relational/sql/parser/AstBuilder.java | 21 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 19 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 6 +-
.../queryengine/plan/statement/StatementType.java | 2 +
.../plan/statement/StatementVisitor.java | 5 +
.../plan/statement/component/OrderByComponent.java | 6 +-
.../plan/statement/component/OrderByKey.java | 5 +
...sStatement.java => ShowDiskUsageStatement.java} | 63 +-
.../FragmentInstanceStatisticsDrawer.java | 501 ++++++-----
.../iotdb/db/service/metrics/WritingMetrics.java | 22 +
.../metrics/file/SystemRelatedFileMetrics.java | 24 +-
.../iotdb/db/storageengine/StorageEngine.java | 2 +
.../db/storageengine/dataregion/DataRegion.java | 31 +-
.../dataregion/HashLastFlushTimeMap.java | 44 -
.../dataregion/ILastFlushTimeMap.java | 6 -
.../performer/impl/FastCompactionPerformer.java | 16 +-
.../impl/ReadChunkCompactionPerformer.java | 69 +-
.../impl/ReadPointCompactionPerformer.java | 1 +
.../execute/task/CompactionTaskSummary.java | 15 +
.../execute/task/CrossSpaceCompactionTask.java | 19 +
.../execute/task/InnerSpaceCompactionTask.java | 26 +-
.../task/InsertionCrossSpaceCompactionTask.java | 4 +
.../execute/utils/CompactionSeriesContext.java | 13 +
.../compaction/execute/utils/CompactionUtils.java | 40 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 252 +++++-
...edReadChunkAlignedSeriesCompactionExecutor.java | 10 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 11 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 126 ++-
.../utils/writer/AbstractCompactionWriter.java | 7 +
.../writer/AbstractCrossCompactionWriter.java | 3 +
.../writer/AbstractInnerCompactionWriter.java | 4 +
.../memtable/AlignedReadOnlyMemChunk.java | 3 +-
.../memtable/AlignedWritableMemChunk.java | 3 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 3 +-
.../dataregion/memtable/TsFileProcessor.java | 6 +
.../dataregion/memtable/WritableMemChunk.java | 2 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 10 +-
.../read/reader/chunk/DiskChunkLoader.java | 6 +-
.../read/reader/chunk/MemAlignedPageReader.java | 20 +-
.../read/reader/chunk/MemPageReader.java | 22 +-
.../chunk/metadata/ChunkMetadataLoaderUtils.java | 55 ++
.../metadata/DiskAlignedChunkMetadataLoader.java | 5 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 4 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 4 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 4 +-
.../storageengine/dataregion/tsfile/TsFileID.java | 4 +
.../dataregion/tsfile/TsFileManager.java | 12 +
.../dataregion/tsfile/TsFileResource.java | 10 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 9 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 41 +
.../dataregion/tsfile/timeindex/ITimeIndex.java | 8 +
.../tsfile/timeindex/PlainDeviceTimeIndex.java | 6 -
.../dataregion/utils/DiskUsageStatisticUtil.java | 272 ++++++
.../utils/StorageEngineTimePartitionIterator.java | 112 +++
.../utils/TableDiskUsageStatisticUtil.java | 255 ++++++
.../utils/TreeDiskUsageStatisticUtil.java | 170 ++++
.../AbstractTableSizeIndexWriter.java | 85 ++
.../DataRegionTableSizeQueryContext.java | 181 ++++
.../DefaultTableDiskUsageIndexProvider.java} | 18 +-
.../tableDiskUsageIndex/TableDiskUsageIndex.java | 533 +++++++++++
.../TableDiskUsageIndexProvider.java | 6 +-
.../TableDiskUsageIndexReader.java | 211 +++++
.../TimePartitionTableSizeQueryContext.java | 109 +++
.../object/EmptyObjectTableSizeIndexReader.java} | 17 +-
.../object/IObjectTableSizeIndexReader.java | 48 +
.../tsfile/TsFileTableDiskUsageIndexWriter.java | 311 +++++++
.../tsfile/TsFileTableSizeIndexFileWriter.java | 200 +++++
.../tsfile/TsFileTableSizeIndexReader.java | 401 +++++++++
.../db/storageengine/load/LoadTsFileManager.java | 7 +-
.../agent/SubscriptionReceiverAgent.java | 26 +-
.../receiver/SubscriptionReceiver.java | 2 +
.../receiver/SubscriptionReceiverV1.java | 144 ++-
.../db/utils/datastructure/AlignedTVList.java | 141 ++-
.../db/utils/datastructure/MemPointIterator.java | 18 +-
.../datastructure/MemPointIteratorFactory.java | 220 +++--
.../MergeSortMultiAlignedTVListIterator.java | 7 +-
.../MergeSortMultiTVListIterator.java | 7 +-
.../datastructure/MultiAlignedTVListIterator.java | 20 +-
.../utils/datastructure/MultiTVListIterator.java | 32 +-
.../OrderedMultiAlignedTVListIterator.java | 7 +-
.../datastructure/OrderedMultiTVListIterator.java | 7 +-
.../iotdb/db/utils/datastructure/TVList.java | 134 ++-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 114 ---
.../db/pipe/pattern/IoTDBTreePatternTest.java | 5 +
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 25 +-
.../operator/DeviceIteratorScanOperatorTest.java | 8 +-
.../execution/operator/ExchangeOperatorTest.java | 161 ++++
.../operator/MergeTreeSortOperatorTest.java | 5 +
.../execution/operator/OperatorMemoryTest.java | 8 +-
.../process/join/InnerTimeJoinOperatorTest.java | 15 +-
.../join/LeftOuterTimeJoinOperatorTest.java | 9 +-
.../sink/SinkOperatorDownStreamNodeIdTest.java | 173 ++++
.../plan/analyze/FakeSchemaFetcherImpl.java | 4 +-
.../plan/parser/StatementGeneratorTest.java | 32 +
.../plan/planner/FragmentInstanceSerdeTest.java | 2 +
.../planner/node/source/SourceNodeSerdeTest.java | 75 ++
.../analyzer/AsofInnerJoinOperatorTest.java | 3 +-
.../plan/relational/analyzer/TreeViewTest.java | 82 +-
.../relational/planner/CteMaterializerTest.java | 3 +-
.../plan/relational/planner/CteSubqueryTest.java | 3 +-
.../planner/assertions/PlanMatchPattern.java | 34 +
.../planner/informationschema/ShowQueriesTest.java | 13 +-
.../DataNodeInternalRPCServiceImplTest.java | 3 +-
.../compaction/AbstractCompactionTest.java | 28 +
.../compaction/CompactionDataTypeAlterTest.java | 377 --------
...ctionDataTypeNotMatchAlterableDataTypeTest.java | 221 -----
.../AbstractCompactionAlterDataTypeTest.java | 177 ++++
.../CompactionDataTypeAlterTableTest.java | 241 +++++
.../alterDataType/CompactionDataTypeAlterTest.java | 230 +++++
...ctionDataTypeNotMatchAlterableDataTypeTest.java | 163 ++++
.../CompactionDataTypeNotMatchTest.java | 152 ++--
.../repair/RepairUnsortedFileCompactionTest.java | 26 +
.../TableModelCompactionWithTTLTest.java | 25 +-
.../utils/CompactionFakeSchemaFetcherImpl.java} | 22 +-
.../memtable/MemChunkDeserializeTest.java | 4 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 25 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 4 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 36 +-
.../dataregion/utils/TableDiskUsageTest.java | 300 +++++++
.../utils/TsFileTableSizeCacheWriterTest.java | 472 ++++++++++
.../wal/recover/file/TsFilePlanRedoerTest.java | 27 +-
.../receiver/SubscriptionReceiverV1Test.java | 114 +++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +
.../src/test/resources/iotdb-common.properties | 9 -
.../src/test/resources/iotdb-system.properties | 9 -
.../metricsets/disk/WindowsDiskMetricsManager.java | 504 ++++++++++-
.../metricsets/net/LinuxNetMetricManager.java | 13 +-
.../metricsets/net/WindowsNetMetricManager.java | 199 ++++-
.../metrics/metricsets/system/SystemMetrics.java | 11 +-
iotdb-core/node-commons/pom.xml | 21 +-
.../conf/iotdb-system.properties.template | 44 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 270 ------
.../iotdb/commons/concurrent/ThreadName.java | 3 +
.../apache/iotdb/commons/conf/CommonConfig.java | 11 -
.../iotdb/commons/conf/CommonDescriptor.java | 3 -
....java => DataPartitionTableGeneratorState.java} | 29 +-
.../iotdb/commons/model/ModelInformation.java | 66 +-
.../org/apache/iotdb/commons/model/ModelType.java | 26 -
.../commons/partition/DataPartitionTable.java | 42 +
.../DatabaseScopedDataPartitionTable.java | 102 +++
.../commons/partition/SeriesPartitionTable.java | 16 +-
.../runtime/AbstractPipePeriodicalJobExecutor.java | 4 +
.../task/progress/interval/PipeCommitInterval.java | 3 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 1 +
.../pipe/config/constant/PipeSinkConstant.java | 8 +
.../datastructure/pattern/IoTDBTreePattern.java | 12 +-
.../datastructure/pattern/PrefixTreePattern.java | 5 +
.../pipe/datastructure/pattern/TreePattern.java | 15 +-
.../pattern/UnionIoTDBTreePattern.java | 5 +
.../datastructure/pattern/UnionTreePattern.java | 5 +
.../pattern/WithExclusionIoTDBTreePattern.java | 5 +
.../pattern/WithExclusionTreePattern.java | 6 +
.../schema/column/ColumnHeaderConstant.java | 24 +-
.../commons/schema/table/InformationSchema.java | 54 ++
.../apache/iotdb/commons/schema/table/TsTable.java | 3 +-
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 35 +
.../iotdb/commons/utils/TimePartitionUtils.java | 4 +
.../db/relational/grammar/sql/RelationalSql.g4 | 5 +-
.../thrift-commons/src/main/thrift/common.thrift | 1 +
.../src/main/thrift/datanode.thrift | 59 ++
pom.xml | 41 +-
518 files changed, 17081 insertions(+), 4859 deletions(-)
copy example/{mqtt => subscription}/pom.xml (84%)
rename example/{session =>
subscription}/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java
(89%)
rename example/{session =>
subscription}/src/main/java/org/apache/iotdb/TableModelSubscriptionSessionExample.java
(90%)
delete mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/filter/UserCache.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBShowDiskUsageIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBFilteredRowsIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/IoTDBShowDiskUsageTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBTableFilteredRowsIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/SubscriptionTreeReaderTestUtils.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionSessionDataSet.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionSessionDataSetsHandler.java
copy iotdb-client/{isession => subscription}/pom.xml (75%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/annotation/TableModel.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/ConsumerConfig.java
(88%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/ConsumerConstant.java
(96%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicConfig.java
(95%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicConstant.java
(85%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionConnectionException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionIdentifierSemanticException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionIncompatibleHandlerException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionParameterNotValidException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPayloadExceedException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPipeTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionPollTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeCriticalException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionRuntimeNonCriticalException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionTimeoutException.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/ErrorPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FileInitPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FilePiecePayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/FileSealPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollFilePayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/PollTabletsPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionCommitContext.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollRequest.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollRequestType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponse.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponseType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TabletsPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TerminationPayload.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeCloseReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeCommitReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeHandshakeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeHeartbeatReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribePollReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeRequestVersion.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSubscribeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeUnsubscribeReq.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeCloseResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeCommitResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeHandshakeResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeHeartbeatResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribePollResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeResponseType.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeResponseVersion.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeSubscribeResp.java
(100%)
rename iotdb-client/{service-rpc =>
subscription}/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeUnsubscribeResp.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/AbstractSubscriptionSession.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/ISubscriptionTableSession.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/ISubscriptionTreeSession.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionConnection.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionWrapper.java
(97%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTableSession.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTableSessionBuilder.java
(92%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTreeSession.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTreeSessionBuilder.java
(91%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/AckStrategy.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/AsyncCommitCallback.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ConsumeListener.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ConsumeResult.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTablePullConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTablePushConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTreePullConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTreePushConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.java
(98%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java
(94%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionProvider.java
(95%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionProviders.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionPullConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionPullConsumerBuilder.java
(94%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionPushConsumer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionPushConsumerBuilder.java
(95%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionExecutorServiceManager.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTableProvider.java
(78%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePullConsumer.java
(94%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePullConsumerBuilder.java
(94%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumer.java
(91%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumerBuilder.java
(95%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreeProvider.java
(78%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumer.java
(94%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumerBuilder.java
(94%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumer.java
(94%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.java
(95%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/model/Subscription.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/model/Topic.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionFileHandler.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessage.java
(73%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessageHandler.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionMessageType.java
(95%)
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionRecordHandler.java
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/payload/SubscriptionTsFileHandler.java
(56%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/CollectionUtils.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/IdentifierUtils.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/PollTimer.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/RandomStringGenerator.java
(100%)
rename iotdb-client/{session =>
subscription}/src/main/java/org/apache/iotdb/session/subscription/util/SetPartitioner.java
(100%)
copy example/rest-client-c-example/base64.h =>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/partition/ConfigNodeProcedureEnv.java
(64%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/partition/DataPartitionTableIntegrityCheckProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{AddConfigNodeState.java
=> DataPartitionTableIntegrityCheckProcedureState.java} (58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/partition/DataPartitionTableGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/ShowDiskUsageOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TreeNonAlignedDeviceViewAggregationScanOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{relational/planner/node
=> planner/plan/node/process}/CollectNode.java (56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/ShowDiskUsageNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/TableFunctionUtils.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{TreeNonAlignedDeviceViewScanNode.java
=> AlignedAggregationTreeDeviceViewScanNode.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{TreeNonAlignedDeviceViewScanNode.java
=> NonAlignedAggregationTreeDeviceViewScanNode.java} (66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{InformationSchemaTableScanNode.java
=> TableDiskUsageInformationSchemaTableScanNode.java} (61%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{ShowQueriesStatement.java
=> ShowDiskUsageStatement.java} (63%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/ChunkMetadataLoaderUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/DiskUsageStatisticUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/StorageEngineTimePartitionIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/TableDiskUsageStatisticUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/TreeDiskUsageStatisticUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/AbstractTableSizeIndexWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/DataRegionTableSizeQueryContext.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/sql/ast/PipeStatement.java
=>
storageengine/dataregion/utils/tableDiskUsageIndex/DefaultTableDiskUsageIndexProvider.java}
(70%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/TableDiskUsageIndex.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2SubscriptionTreeRegressionMisc.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/TableDiskUsageIndexProvider.java
(83%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/TableDiskUsageIndexReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/TimePartitionTableSizeQueryContext.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/view/viewExpression/leaf/LeafViewOperand.java
=>
datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/object/EmptyObjectTableSizeIndexReader.java}
(66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/object/IObjectTableSizeIndexReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/tsfile/TsFileTableDiskUsageIndexWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/tsfile/TsFileTableSizeIndexFileWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/tableDiskUsageIndex/tsfile/TsFileTableSizeIndexReader.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/ExchangeOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/sink/SinkOperatorDownStreamNodeIdTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionDataTypeAlterTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionDataTypeNotMatchAlterableDataTypeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/alterDataType/AbstractCompactionAlterDataTypeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/alterDataType/CompactionDataTypeAlterTableTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/alterDataType/CompactionDataTypeAlterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/alterDataType/CompactionDataTypeNotMatchAlterableDataTypeTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{
=> alterDataType}/CompactionDataTypeNotMatchTest.java (58%)
copy
iotdb-core/datanode/src/{main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/schedule/constant/CompactionType.java
=>
test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionFakeSchemaFetcherImpl.java}
(62%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/utils/TableDiskUsageTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/utils/TsFileTableSizeCacheWriterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1Test.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/authorizer/OpenIdAuthorizer.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/enums/{DataNodeRemoveState.java
=> DataPartitionTableGeneratorState.java} (68%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelType.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/partition/DatabaseScopedDataPartitionTable.java
