This is an automated email from the ASF dual-hosted git repository.
weihao pushed a change to branch optimizeLast
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a74313956c8 optimize
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 6f0798d520f merge
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 +-
example/pom.xml | 1 +
example/{mqtt => subscription}/pom.xml | 9 +-
.../apache/iotdb/SubscriptionSessionExample.java | 45 +-
.../TableModelSubscriptionSessionExample.java | 22 +-
integration-test/pom.xml | 5 +
.../ainode/it/AINodeInstanceManagementIT.java | 8 +-
.../apache/iotdb/db/it/IoTDBShowDiskUsageIT.java | 163 +++++++
.../relational/it/IoTDBShowDiskUsageTableIT.java | 176 +++++++
.../relational/it/schema/IoTDBDatabaseIT.java | 17 +-
.../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 -
.../iotdb/session/AbstractSessionBuilder.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 1 +
.../payload/SubscriptionSessionDataSet.java | 255 ----------
.../SubscriptionSessionDataSetsHandler.java | 91 ----
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
.../iotdb/ainode/core/inference/pool_controller.py | 110 +++--
.../pool_scheduler/basic_pool_scheduler.py | 4 +-
.../iotdb/ainode/core/manager/device_manager.py | 14 +-
.../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 +
iotdb-core/datanode/pom.xml | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 20 +
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 3 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 12 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 65 +--
.../metric/sink/PipeDataRegionSinkMetrics.java | 241 +++++-----
.../iotconsensusv2/IoTConsensusV2Receiver.java | 10 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 25 +-
.../realtime/assigner/DisruptorQueue.java | 27 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +-
.../matcher/CachedSchemaPatternMatcher.java | 41 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../execution/fragment/DataNodeQueryContext.java | 30 ++
.../execution/operator/OperatorContext.java | 7 +-
.../operator/source/ShowDiskUsageOperator.java | 198 ++++++++
.../InformationSchemaContentSupplierFactory.java | 367 +++++++++++++-
.../InformationSchemaTableScanOperator.java | 13 +-
.../db/queryengine/plan/analyze/Analysis.java | 2 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 82 +++-
.../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 | 13 +
.../plan/planner/OperatorTreeGenerator.java | 43 ++
.../plan/planner/TableOperatorGenerator.java | 6 +-
.../planner/distribution/ExchangeNodeAdder.java | 6 +
.../SimpleFragmentParallelPlanner.java | 2 +
.../memory/PipelineMemoryEstimatorFactory.java | 1 +
.../plan/AbstractFragmentParallelPlanner.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 24 +
.../plan/planner/plan/node/PlanNodeType.java | 20 +-
.../plan/planner/plan/node/PlanVisitor.java | 10 +
.../plan/node/process}/CollectNode.java | 66 +--
.../plan/node/source/ShowDiskUsageNode.java | 214 +++++++++
.../plan/relational/planner/RelationPlanner.java | 24 +-
.../distribute/TableDistributedPlanGenerator.java | 77 ++-
.../rule/PushDownOffsetIntoTableScan.java | 8 +-
.../node/InformationSchemaTableScanNode.java | 11 +-
...leDiskUsageInformationSchemaTableScanNode.java} | 92 ++--
.../DataNodeLocationSupplierFactory.java | 34 ++
.../PushLimitOffsetIntoTableScan.java | 44 +-
.../optimizations/PushPredicateIntoTableScan.java | 206 ++++----
.../security/TreeAccessCheckVisitor.java | 10 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 19 +-
.../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 +--
.../iotdb/db/service/metrics/WritingMetrics.java | 22 +
.../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 +
.../dataregion/memtable/TsFileProcessor.java | 6 +
.../storageengine/dataregion/tsfile/TsFileID.java | 4 +
.../dataregion/tsfile/TsFileManager.java | 12 +
.../dataregion/tsfile/TsFileResource.java | 2 +-
.../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/pipe/pattern/IoTDBTreePatternTest.java | 5 +
.../process/join/InnerTimeJoinOperatorTest.java | 15 +-
.../join/LeftOuterTimeJoinOperatorTest.java | 9 +-
.../plan/analyze/FakeSchemaFetcherImpl.java | 4 +-
.../plan/parser/StatementGeneratorTest.java | 32 ++
.../planner/node/source/SourceNodeSerdeTest.java | 75 +++
.../analyzer/AsofInnerJoinOperatorTest.java | 3 +-
.../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 +++---
.../TableModelCompactionWithTTLTest.java | 25 +-
.../utils/CompactionFakeSchemaFetcherImpl.java} | 22 +-
.../dataregion/utils/TableDiskUsageTest.java | 300 ++++++++++++
.../utils/TsFileTableSizeCacheWriterTest.java | 472 ++++++++++++++++++
.../receiver/SubscriptionReceiverV1Test.java | 114 +++++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +
iotdb-core/node-commons/pom.xml | 5 +
.../conf/iotdb-system.properties.template | 5 +
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../iotdb/commons/model/ModelInformation.java | 66 +--
.../org/apache/iotdb/commons/model/ModelType.java | 26 -
.../runtime/AbstractPipePeriodicalJobExecutor.java | 4 +
.../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 | 12 +
.../commons/schema/table/InformationSchema.java | 47 ++
.../apache/iotdb/commons/schema/table/TsTable.java | 3 +-
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../db/relational/grammar/sql/RelationalSql.g4 | 1 -
335 files changed, 9734 insertions(+), 2737 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%)
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/relational/it/IoTDBShowDiskUsageTableIT.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%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/ShowDiskUsageOperator.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
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/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/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/model/ModelType.java
