This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/fixSonar
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 46bfb87ec6d fix IT
add 76d66786814 Rename ViewType values to VIEW/BASE (#10191) (#10206)
add dc5ca0b4ff9 Support show isAligned as null when showing devices with
no timeseries but view (#10197)
add 0bf7d75ea46 Set compaction selector log from info to debug (#10207)
add be8fa171e92 [IOTDB-6010] Fix NPE and IndexOutOfRange Exception in CPU
metrics (#10217) (#10224)
add c1467f50f0b Add leader change log (#10230)
add e8cbc76edd5 [IOTDB-6013] Pipe: pipe-related threads (pools) should not
be initialized unless necessary (#10229)
add 49fd2eb1feb Flush previous time partition memtable by wal (#10221)
(#10235)
add b7472ea1355 Rename PB_Tree to PBTree (#10223)
add f35b5b7fd9e Add memory usage and series num to log when series
overflow (#10227)
add 8f637838819 feat(site):remove master & rel/1.2 (#10244)
add 2f223b054d0 Forbid GROUP BY TAG query on views (#10239)
add 8d02f29b85c Degrade IoTConsensus IndexControllel log level (#10241)
add 56faa8ef61b [IOTDB-6015] Pipe: Not checking whether the tsfile data
loaded locally is in the same time partition during the loading process (#10249)
add 201c1db8b46 [IOTDB-6016]Release file num cost after cross compaction
task (#10245)
add 1abfe6966ff [IOTDB-5999] system.properties patch
add ef6071fa841 Fix SonarLint bugs and some code smells in MPP data
exchange module
add e8deab6e177 Fix some code smells in memory and schedule and
transformation package
add 3a469071e3f [IOTDB-6011] Move default database from IoTDBMetricsUtils
to IoTDBConfig (#10219)
add ec4749ab34b Fix code smell in server
add a1e297feb23 Fix error msg of altering not existing view (#10253)
add 781d1b1ef26 Fix sonar bugs and code smells in example (#10215)
add 18487d7be38 Fix some SonarLint code smells of
trigger/query_context/aggregation/modification package
add 6ed2a43af44 [metrics] Refactor compaction read write throughput
metrics (#10248)
add 14eb3bf3fe6 Fix sonar bugs and code smells in mpp/plan/planner and
tsfile/file
add 127cdbe2449 Fix error msg when select into view and normal timeseries
failed (#10260)
add 64a7643ca44 Fix sonar bugs and code smells in iotdb/db/metadata/rescon
(#10265)
add 4e8cb333130 Pipe: fix bugs & smells reported by SonarCloud
(org.apache.iotdb.db.pipe) (#10268)
add 06d353158c7 [IOTDB-6021] Pipe: NPE when sync TEXT timeseries with null
fields between IoTDB instances using file mode with pattern filter (#10269)
add 810ebc2f7a9 Fix sonar bugs and code smells in confignode module about
cq
add e8d6e4ce986 Fix sonar bugs and code smells in server and tsfile module
add 82e85d9983b [IOTDB-5999] System properties patch
add 94ca2b54bef [IOTDB-6018] Heterogeneous Database document (#10258)
add a2a0e1ec9eb Fix slow creation of view when using batch creation sql
(#10278)
add fe967b122e8 [IOTDB-5937] Fix wrong measurement check when using view
to import csv (#10276)
add f915a5554c2 The ConfigNode should restore cluster_name and
config_node_id at the first step of restart. (#10279)
add 11755a10f5f [IOTDB-6023] Pipe: LoadTsFilePieceNode error when loading
tsfile with empty value chunks (#10281)
add 8f6244a5431 Pipe: rename collector to extractor (#10286)
add 1c7664f5486 Merge remote-tracking branch 'origin/master' into
lmh/fixSonar
add 5ee0d5d09f3 spotless apply
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 12 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 6 +-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 4 +
.../confignode/conf/SystemPropertiesUtils.java | 16 +
.../consensus/request/write/cq/ActiveCQPlan.java | 13 +-
.../consensus/request/write/cq/AddCQPlan.java | 13 +-
.../consensus/request/write/cq/DropCQPlan.java | 13 +-
.../consensus/request/write/cq/ShowCQPlan.java | 5 +-
.../request/write/cq/UpdateCQLastExecTimePlan.java | 13 +-
.../response/pipe/task/PipeTableResp.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 11 +-
.../iotdb/confignode/manager/cq/CQManager.java | 9 +-
.../confignode/manager/cq/CQScheduleTask.java | 13 +-
.../manager/load/service/StatisticsService.java | 3 +-
.../manager/pipe/runtime/PipeHeartbeatParser.java | 47 +-
.../pipe/runtime/PipeLeaderChangeHandler.java | 18 +-
.../pipe/runtime/PipeRuntimeCoordinator.java | 22 +-
.../manager/schema/ClusterSchemaManager.java | 6 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 37 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +-
.../persistence/pipe/PipePluginInfo.java | 20 +-
.../procedure/impl/cq/CreateCQProcedure.java | 126 ++---
.../impl/pipe/task/CreatePipeProcedureV2.java | 14 +-
.../impl/schema/AlterLogicalViewProcedure.java | 47 +-
.../procedure/state/cq/CreateCQState.java | 1 +
.../iotdb/confignode/service/ConfigNode.java | 4 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 4 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 6 +-
.../runtime/PipeHandleMetaChangeProcedureTest.java | 2 +-
.../impl/pipe/task/CreatePipeProcedureV2Test.java | 6 +-
.../iot/logdispatcher/IndexController.java | 2 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 6 +-
docs/UserGuide/Operate-Metadata/Database.md | 90 ++++
docs/UserGuide/Reference/Common-Config-Manual.md | 2 +-
docs/UserGuide/Reference/Status-Codes.md | 4 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 8 +-
docs/zh/UserGuide/Operate-Metadata/Database.md | 90 ++++
.../zh/UserGuide/Reference/Common-Config-Manual.md | 2 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 4 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 2 +-
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 24 +-
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 6 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 24 +-
.../iotdb/flink/FlinkTsFileStreamSource.java | 12 +-
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 11 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 29 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 21 +-
.../org/apache/iotdb/PrepareStatementDemo.java | 13 +-
.../iotdb/SyntaxConventionRelatedExample.java | 36 +-
.../main/java/org/apache/iotdb/kafka/Consumer.java | 6 +-
.../org/apache/iotdb/kafka/ConsumerThread.java | 16 +-
.../main/java/org/apache/iotdb/kafka/Producer.java | 8 +-
.../server/CustomizedJsonPayloadFormatter.java | 6 +-
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 4 +-
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 6 +-
.../java/org/apache/iotdb/rabbitmq/Constant.java | 18 +-
.../iotdb/rabbitmq/RabbitMQChannelUtils.java | 2 +
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 6 +-
.../main/java/org/apache/iotdb/HttpExample.java | 29 +-
.../main/java/org/apache/iotdb/HttpsExample.java | 32 +-
.../src/main/java/org/apache/iotdb/SSLClient.java | 22 +-
.../java/org/apache/iotdb/rocketmq/Constant.java | 2 +
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 3 +-
.../apache/iotdb/rocketmq/RocketMQProducer.java | 14 +-
.../main/java/org/apache/iotdb/rocketmq/Utils.java | 2 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 13 +-
.../org/apache/iotdb/DataMigrationExample.java | 18 +-
.../iotdb/HybridTimeseriesSessionExample.java | 9 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 34 +-
.../main/java/org/apache/iotdb/SessionExample.java | 32 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 1 +
.../iotdb/SyntaxConventionRelatedExample.java | 10 +-
.../main/java/org/apache/iotdb/TabletExample.java | 139 ++---
.../iotdb/trigger/ClusterAlertingExample.java | 15 +-
.../org/apache/iotdb/trigger/LoggerTrigger.java | 85 ++--
.../iotdb/trigger/StatisticsUpdaterTrigger.java | 6 +-
.../iotdb/tsfile/TsFileForceAppendWrite.java | 13 +-
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 10 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 17 +-
.../tsfile/TsFileWriteAlignedWithTSRecord.java | 9 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 9 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 6 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 5 +-
.../SlidingTimeWindowAccessStrategyExample.java | 45 +-
.../java/org/apache/iotdb/udf/UDTFExample.java | 17 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 32 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 56 +--
.../it/schema/view/IoTDBCreateAndShowViewIT.java | 72 +--
.../view/IoTDBShowDevicesContainedViewIT.java | 226 +++++++++
.../org/apache/iotdb/util/AbstractSchemaIT.java | 4 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 12 +-
.../org/apache/iotdb/pipe/api/PipeConnector.java | 2 +-
.../api/{PipeCollector.java => PipeExtractor.java} | 52 +-
.../org/apache/iotdb/pipe/api/PipeProcessor.java | 4 +-
...java => PipeExtractorRuntimeConfiguration.java} | 2 +-
iotdb-client/client-cpp/src/main/Session.h | 4 +-
iotdb-client/client-py/tests/test_dataframe.py | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +-
.../src/main/thrift/confignode.thrift | 4 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 8 +-
.../metrics/metricsets/cpu/CpuUsageMetrics.java | 6 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 7 +-
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 3 +-
.../resources/conf/iotdb-common.properties | 22 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 -
.../apache/iotdb/commons/conf/CommonConfig.java | 45 +-
.../iotdb/commons/conf/CommonDescriptor.java | 29 +-
.../runtime/UnSupportedDataTypeException.java | 11 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 11 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 28 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 18 +-
.../IoTDBExtractor.java} | 16 +-
.../commons/pipe/task/meta/PipeStaticMeta.java | 34 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 12 +-
...FilterVisitor.java => SchemaFilterFactory.java} | 45 +-
.../commons/schema/filter/SchemaFilterType.java | 9 +-
.../commons/schema/filter/SchemaFilterVisitor.java | 28 +-
.../impl/{DataTypeFilter.java => AndFilter.java} | 41 +-
.../commons/schema/filter/impl/DataTypeFilter.java | 6 +-
.../schema/filter/impl/PathContainsFilter.java | 8 +-
.../commons/schema/filter/impl/TagFilter.java | 6 +-
.../{DataTypeFilter.java => ViewTypeFilter.java} | 32 +-
.../node/common/AbstractDatabaseDeviceMNode.java | 11 +-
.../schema/node/common/AbstractDeviceMNode.java | 11 +-
.../node/common/AbstractMeasurementMNode.java | 2 +-
.../commons/schema/node/info/IDeviceInfo.java | 4 +-
.../commons/schema/node/role/IDeviceMNode.java | 4 +-
.../apache/iotdb/commons/schema/view/ViewType.java | 49 +-
.../iotdb/commons/pipe/PipeMetaDeSerTest.java | 2 +-
.../iotdb/db/client/DataNodeInternalClient.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 5 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 11 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 35 +-
.../org/apache/iotdb/db/constant/TestConstant.java | 53 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 1 +
.../db/engine/cache/CacheHitRatioMonitor.java | 5 +-
.../engine/cache/CacheHitRatioMonitorMXBean.java | 1 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 10 +-
.../impl/ReadChunkCompactionPerformer.java | 21 +-
.../execute/task/CrossSpaceCompactionTask.java | 3 +
.../compaction/execute/utils/CompactionUtils.java | 3 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 19 +-
.../fast/AlignedSeriesCompactionExecutor.java | 21 +
.../readchunk/AlignedSeriesCompactionExecutor.java | 99 ++--
.../readchunk/SingleSeriesCompactionExecutor.java | 56 +--
.../utils/writer/AbstractCompactionWriter.java | 73 ++-
.../writer/AbstractCrossCompactionWriter.java | 24 +-
.../writer/AbstractInnerCompactionWriter.java | 13 +-
.../utils/writer/FastCrossCompactionWriter.java | 4 +-
.../writer/ReadPointCrossCompactionWriter.java | 2 +-
.../writer/ReadPointInnerCompactionWriter.java | 2 +-
.../compaction/io/CompactionTsFileReader.java | 178 +++++++
.../compaction/io/CompactionTsFileWriter.java | 130 +++++
.../compaction/schedule/CompactionTaskManager.java | 10 -
.../schedule/constant/CompactionIoDataType.java | 18 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 3 +-
.../iotdb/db/engine/load/TsFileSplitter.java | 8 +-
.../iotdb/db/engine/modification/Deletion.java | 2 +-
.../db/engine/modification/ModificationFile.java | 9 +-
.../io/LocalTextModificationAccessor.java | 4 +
.../modification/utils/TracedBufferedReader.java | 33 +-
.../querycontext/AlignedReadOnlyMemChunk.java | 4 +-
.../db/engine/querycontext/QueryDataSource.java | 8 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 5 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 5 +
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../db/engine/trigger/builtin/ForwardTrigger.java | 9 +-
.../sink/forward/http/HTTPForwardHandler.java | 10 +-
.../forward/mqtt/MQTTForwardConfiguration.java | 1 +
.../sink/forward/mqtt/MQTTForwardHandler.java | 10 +-
.../trigger/sink/mqtt/MQTTConfiguration.java | 3 +-
.../db/engine/trigger/utils/BatchHandlerQueue.java | 11 +-
.../engine/trigger/utils/HTTPConnectionPool.java | 4 +-
.../metadata/SeriesOverflowException.java | 8 +-
.../SchemaFileLogCorruptedException.java | 2 +-
.../metadata/schemafile/SchemaFileNotExists.java | 2 +-
.../schemafile/SchemaPageOverflowException.java | 3 +-
.../query/QueryTimeoutRuntimeException.java | 1 +
.../ClassLoaderManagerInitializationException.java | 6 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 8 +-
.../idtable/AppendOnlyDiskSchemaManager.java | 2 +-
.../metadata/metric/SchemaEngineCachedMetric.java | 2 +-
.../metadata/metric/SchemaRegionCachedMetric.java | 4 +-
.../db/metadata/mnode/mem/info/DeviceInfo.java | 6 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 2 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 32 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +-
.../mtree/store/disk/schemafile/ISchemaFile.java | 4 +-
.../store/disk/schemafile/MockSchemaFile.java | 4 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 28 +-
.../store/disk/schemafile/SchemaFileConfig.java | 4 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 2 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 2 +-
.../traverser/collector/MeasurementCollector.java | 2 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 9 +-
.../schemaregion/result/ShowDevicesResult.java | 6 +-
.../db/metadata/query/info/IDeviceSchemaInfo.java | 2 +-
.../rescon/CachedSchemaEngineStatistics.java | 5 +-
.../rescon/CachedSchemaRegionStatistics.java | 15 +-
.../rescon/DataNodeSchemaQuotaManager.java | 2 +
.../metadata/rescon/ISchemaEngineStatistics.java | 1 +
.../metadata/rescon/ISchemaRegionStatistics.java | 5 +
.../metadata/rescon/MemSchemaEngineStatistics.java | 5 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 23 +-
.../db/metadata/rescon/SchemaResourceManager.java | 4 +-
.../db/metadata/schemaregion/SchemaEngine.java | 2 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 12 +-
.../schemaregion/SchemaRegionPBTreeImpl.java | 31 +-
.../db/metadata/utils/ResourceByPathUtils.java | 10 +-
.../db/metadata/visitor/DeviceFilterVisitor.java | 6 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 2 +-
.../metadata/visitor/TimeseriesFilterVisitor.java | 15 +-
.../iotdb/db/mpp/aggregation/Accumulator.java | 1 +
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 4 +-
.../slidingwindow/SlidingWindowAggregator.java | 4 +-
.../SlidingWindowAggregatorFactory.java | 4 +-
.../timerangeiterator/AggrWindowIterator.java | 4 +-
.../timerangeiterator/ITimeRangeIterator.java | 7 +-
.../timerangeiterator/PreAggrWindowIterator.java | 6 +-
.../PreAggrWindowWithNaturalMonthIterator.java | 1 +
.../TimeRangeIteratorFactory.java | 1 +
.../db/mpp/common/header/ColumnHeaderConstant.java | 4 +-
.../db/mpp/exception/CpuNotEnoughException.java | 1 +
.../db/mpp/exception/MemoryNotEnoughException.java | 1 +
.../iotdb/db/mpp/execution/FutureStateChange.java | 1 +
.../iotdb/db/mpp/execution/QueryIdGenerator.java | 7 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 1 +
.../iotdb/db/mpp/execution/StateMachine.java | 51 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 15 +-
.../db/mpp/execution/driver/DataDriverContext.java | 2 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 23 +-
.../db/mpp/execution/driver/DriverContext.java | 1 +
.../iotdb/db/mpp/execution/driver/IDriver.java | 16 +-
.../db/mpp/execution/driver/SchemaDriver.java | 1 +
.../mpp/execution/driver/SchemaDriverContext.java | 2 +-
.../exchange/IMPPDataExchangeManager.java | 3 +-
.../execution/exchange/MPPDataExchangeManager.java | 17 +-
.../exchange/MPPDataExchangeServiceMBean.java | 1 +
.../MPPDataExchangeServiceThriftHandler.java | 13 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 8 +-
.../exchange/sink/DownStreamChannelIndex.java | 2 +-
.../exchange/sink/DownStreamChannelLocation.java | 2 +
.../db/mpp/execution/exchange/sink/ISink.java | 6 +-
.../mpp/execution/exchange/sink/ISinkHandle.java | 2 +-
.../execution/exchange/sink/LocalSinkChannel.java | 7 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 13 +-
.../mpp/execution/exchange/sink/SinkChannel.java | 3 +
.../execution/exchange/source/ISourceHandle.java | 8 +-
.../exchange/source/PipelineSourceHandle.java | 1 +
.../execution/exchange/source/SourceHandle.java | 10 +-
.../mpp/execution/executor/RegionReadExecutor.java | 13 +-
.../execution/executor/RegionWriteExecutor.java | 155 +++---
.../db/mpp/execution/fragment/FragmentInfo.java | 17 +
.../fragment/FragmentInstanceContext.java | 44 +-
.../fragment/FragmentInstanceExecution.java | 64 +--
.../fragment/FragmentInstanceFailureInfo.java | 36 +-
.../fragment/FragmentInstanceFailureListener.java | 1 +
.../execution/fragment/FragmentInstanceInfo.java | 1 +
.../fragment/FragmentInstanceManager.java | 4 +
.../execution/fragment/FragmentInstanceState.java | 1 +
.../fragment/FragmentInstanceStateMachine.java | 6 +-
.../db/mpp/execution/fragment/FragmentState.java | 1 +
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 14 +-
.../db/mpp/execution/operator/AggregationUtil.java | 71 ++-
.../iotdb/db/mpp/execution/operator/Operator.java | 27 +-
.../db/mpp/execution/operator/OperatorContext.java | 2 +-
.../process/AbstractConsumeAllOperator.java | 1 +
.../operator/process/AbstractIntoOperator.java | 10 +-
.../operator/process/AggregationOperator.java | 1 +
.../operator/process/DeviceMergeOperator.java | 316 ------------
.../operator/process/DeviceViewIntoOperator.java | 7 +-
.../operator/process/DeviceViewOperator.java | 1 +
.../execution/operator/process/FillOperator.java | 3 +-
.../operator/process/FilterAndProjectOperator.java | 45 +-
.../execution/operator/process/IntoOperator.java | 1 +
.../execution/operator/process/LimitOperator.java | 1 +
.../operator/process/LinearFillOperator.java | 16 +-
.../operator/process/MergeSortOperator.java | 11 +-
.../execution/operator/process/OffsetOperator.java | 1 +
.../operator/process/ProcessOperator.java | 2 +-
.../process/RawDataAggregationOperator.java | 10 +-
.../process/SingleInputAggregationOperator.java | 1 +
.../process/SlidingWindowAggregationOperator.java | 14 +-
.../execution/operator/process/SortOperator.java | 47 +-
.../operator/process/TagAggregationOperator.java | 68 +--
.../operator/process/TransformOperator.java | 45 +-
.../mpp/execution/operator/process/fill/IFill.java | 1 +
.../operator/process/fill/ILinearFill.java | 7 +-
.../process/fill/identity/IdentityFill.java | 1 +
.../process/fill/identity/IdentityLinearFill.java | 5 +-
.../operator/process/fill/linear/LinearFill.java | 57 ++-
.../process/join/HorizontallyConcatOperator.java | 11 +-
.../process/join/RowBasedTimeJoinOperator.java | 66 ++-
.../operator/process/join/TimeJoinOperator.java | 292 -----------
.../process/join/merge/AscTimeComparator.java | 3 +-
.../operator/process/join/merge/ColumnMerger.java | 9 +-
.../process/join/merge/DescTimeComparator.java | 3 +-
.../process/join/merge/MergeSortComparator.java | 10 +-
.../process/join/merge/MultiColumnMerger.java | 12 +-
.../join/merge/NonOverlappedMultiColumnMerger.java | 5 +-
.../process/join/merge/SingleColumnMerger.java | 26 +-
.../process/join/merge/SortKeyComparator.java | 9 +-
.../process/join/merge/TimeComparator.java | 7 +-
.../last/AlignedUpdateLastCacheOperator.java | 2 +-
.../process/last/LastQueryCollectOperator.java | 1 +
.../process/last/LastQueryMergeOperator.java | 123 +++--
.../operator/process/last/LastQueryOperator.java | 1 +
.../process/last/LastQuerySortOperator.java | 52 +-
.../operator/process/last/LastQueryUtil.java | 5 +
.../process/last/UpdateLastCacheOperator.java | 3 +-
.../schema/source/LogicalViewSchemaSource.java | 77 +--
.../schema/source/TimeSeriesSchemaSource.java | 7 +-
.../mpp/execution/operator/sink/SinkOperator.java | 1 +
.../AbstractSeriesAggregationScanOperator.java | 14 +-
.../AlignedSeriesAggregationScanOperator.java | 1 +
.../operator/source/AlignedSeriesScanOperator.java | 53 +-
.../operator/source/AlignedSeriesScanUtil.java | 99 ++--
.../operator/source/DataSourceOperator.java | 1 +
.../operator/source/ExchangeOperator.java | 1 +
.../operator/source/LastCacheScanOperator.java | 1 +
.../source/SeriesAggregationScanOperator.java | 2 +
.../operator/source/SeriesScanOperator.java | 34 +-
.../execution/operator/source/SeriesScanUtil.java | 58 ++-
.../operator/source/ShowQueriesOperator.java | 15 +-
.../execution/operator/source/SourceOperator.java | 1 +
.../operator/window/ConditionWindowManager.java | 84 ++--
.../mpp/execution/operator/window/CountWindow.java | 1 +
.../operator/window/CountWindowManager.java | 24 +-
.../operator/window/CountWindowParameter.java | 1 +
.../db/mpp/execution/operator/window/IWindow.java | 8 +-
.../execution/operator/window/IWindowManager.java | 18 +-
.../operator/window/SessionWindowManager.java | 3 +-
.../operator/window/TimeWindowManager.java | 13 +-
.../operator/window/WindowManagerFactory.java | 4 +
.../execution/operator/window/WindowParameter.java | 2 +-
.../execution/schedule/AbstractDriverThread.java | 12 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 8 +-
.../schedule/DriverTaskAbortedException.java | 2 +-
.../mpp/execution/schedule/DriverTaskThread.java | 3 -
.../schedule/DriverTaskTimeoutSentinelThread.java | 3 +-
.../mpp/execution/schedule/ExecutionContext.java | 3 +-
.../mpp/execution/schedule/IDriverScheduler.java | 5 +-
.../db/mpp/execution/schedule/ITaskScheduler.java | 3 +-
.../db/mpp/execution/schedule/ThreadProducer.java | 1 +
.../iotdb/db/mpp/execution/schedule/queue/ID.java | 3 +-
.../schedule/queue/IDIndexedAccessible.java | 3 +-
.../schedule/queue/IndexedBlockingQueue.java | 50 +-
.../queue/IndexedBlockingReserveQueue.java | 2 +-
.../execution/schedule/queue/L1PriorityQueue.java | 1 +
.../execution/schedule/queue/L2PriorityQueue.java | 1 +
.../queue/multilevelqueue/DriverTaskHandle.java | 4 +-
.../multilevelqueue/MultilevelPriorityQueue.java | 10 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 14 +-
.../mpp/execution/schedule/task/DriverTaskId.java | 2 +-
.../execution/schedule/task/DriverTaskStatus.java | 3 +-
.../timer/RuleBasedTimeSliceAllocator.java | 2 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 69 ++-
.../config/executor/ClusterConfigTaskExecutor.java | 10 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 2 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 34 +-
.../db/mpp/plan/parser/StatementGenerator.java | 6 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 333 ++++++------
.../db/mpp/plan/planner/SubPlanTypeExtractor.java | 2 +
.../plan/planner/distribution/SourceRewriter.java | 8 +-
.../plan/node/load/LoadSingleTsFileNode.java | 18 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 6 +
.../metedata/write/view/AlterLogicalViewNode.java | 5 +
.../metedata/write/view/CreateLogicalViewNode.java | 39 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 1 +
.../planner/plan/node/write/InsertRowNode.java | 127 +++--
.../planner/plan/node/write/InsertTabletNode.java | 9 +-
.../crud/InsertMultiTabletsStatement.java | 32 --
.../crud/InsertRowsOfOneDeviceStatement.java | 1 -
.../plan/statement/crud/InsertRowsStatement.java | 32 --
.../statement/sys/pipe/CreatePipeStatement.java | 10 +-
.../iotdb/db/mpp/statistics/StatisticsManager.java | 10 +-
.../db/mpp/transformation/api/LayerRowReader.java | 4 +-
.../dag/column/CaseWhenThenColumnTransformer.java | 6 +-
.../mpp/transformation/dag/column/ColumnCache.java | 4 +-
.../dag/column/ColumnTransformer.java | 8 +-
.../binary/CompareBinaryColumnTransformer.java | 12 +-
.../dag/column/leaf/NullColumnTransformer.java | 4 +-
.../dag/column/unary/InColumnTransformer.java | 13 +-
.../scalar/CastFunctionColumnTransformer.java | 20 +-
.../transformation/dag/input/IUDFInputDataSet.java | 4 +-
.../MultiInputColumnIntermediateLayer.java | 4 +-
...InputColumnMultiReferenceIntermediateLayer.java | 6 +-
...nputColumnSingleReferenceIntermediateLayer.java | 4 +-
.../mpp/transformation/dag/memory/SafetyLine.java | 4 +
.../dag/transformer/Transformer.java | 5 +-
.../dag/transformer/multi/UDFQueryTransformer.java | 3 +-
.../transformer/ternary/TernaryTransformer.java | 4 +-
.../transformer/unary/TransparentTransformer.java | 1 +
.../mpp/transformation/dag/udf/UDTFExecutor.java | 12 +-
.../mpp/transformation/dag/util/InputRowUtils.java | 5 +
.../transformation/dag/util/LayerCacheUtils.java | 18 +-
.../transformation/dag/util/TransformUtils.java | 112 ++---
.../db/mpp/transformation/datastructure/Cache.java | 21 +
.../datastructure/SerializableList.java | 60 +--
.../row/ElasticSerializableRowRecordList.java | 14 +-
.../row/SerializableRowRecordList.java | 3 +
.../tv/ElasticSerializableTVList.java | 9 +-
.../db/pipe/agent/plugin/PipePluginAgent.java | 25 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 6 +-
.../SimpleConsensusProgressIndexAssigner.java | 5 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 135 ++---
.../pipe/collector/IoTDBDataRegionCollector.java | 218 --------
.../PipeHistoricalDataRegionCollector.java | 27 -
...torConstant.java => PipeExtractorConstant.java} | 26 +-
.../configuraion/PipeTaskRuntimeConfiguration.java | 4 +-
...va => PipeTaskExtractorRuntimeEnvironment.java} | 4 +-
.../pipe/connector/legacy/IoTDBSyncConnector.java | 56 +--
.../pipe/connector/legacy/IoTDBSyncReceiver.java | 37 +-
.../legacy/pipedata/DeletionPipeData.java | 8 +-
.../pipe/connector/legacy/pipedata/PipeData.java | 5 +-
.../connector/legacy/pipedata/TsFilePipeData.java | 3 +-
.../pipe/connector/v1/IoTDBThriftConnectorV1.java | 29 +-
.../pipe/connector/v1/IoTDBThriftReceiverV1.java | 25 +-
.../db/pipe/connector/v1/PipeRequestType.java | 5 +-
.../pipe/connector/v2/IoTDBThriftConnectorV2.java | 47 +-
.../PipeTransferTabletInsertionEventHandler.java | 4 +-
.../PipeTransferTsFileInsertionEventHandler.java | 2 +-
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 6 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 3 -
.../common/tablet/PipeRawTabletInsertionEvent.java | 14 +-
.../tablet/TabletInsertionDataContainer.java | 27 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +-
.../tsfile/TsFileInsertionDataContainer.java | 7 +-
.../tsfile/TsFileInsertionDataTabletIterator.java | 9 +-
...imeCollectEvent.java => PipeRealtimeEvent.java} | 38 +-
...tFactory.java => PipeRealtimeEventFactory.java} | 10 +-
.../executor/PipeSubtaskExecutorManager.java | 6 +-
.../pipe/extractor/IoTDBDataRegionExtractor.java | 217 ++++++++
.../PipeHistoricalDataRegionExtractor.java} | 9 +-
.../PipeHistoricalDataRegionTsFileExtractor.java} | 114 ++---
.../realtime/PipeRealtimeDataRegionExtractor.java} | 32 +-
.../PipeRealtimeDataRegionFakeExtractor.java} | 31 +-
.../PipeRealtimeDataRegionHybridExtractor.java} | 89 ++--
.../PipeRealtimeDataRegionLogExtractor.java} | 38 +-
.../PipeRealtimeDataRegionTsFileExtractor.java} | 39 +-
.../realtime/assigner/DisruptorQueue.java | 4 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 42 +-
.../realtime/epoch/TsFileEpoch.java | 26 +-
.../realtime/epoch/TsFileEpochManager.java | 23 +-
.../realtime/epoch/TsFileEpochStateMigrator.java | 2 +-
.../listener/PipeInsertionDataNodeListener.java | 59 ++-
.../matcher/CachedSchemaPatternMatcher.java | 106 ++--
.../realtime/matcher/PipeDataRegionMatcher.java | 28 +-
.../db/pipe/processor/PipeDoNothingProcessor.java | 6 +-
.../resource/file/PipeFileResourceManager.java | 22 +-
.../db/pipe/resource/wal/PipeWALResource.java | 10 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 79 +--
.../org/apache/iotdb/db/pipe/task/PipeTask.java | 14 +-
.../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 18 +-
.../db/pipe/task/connection/EventSupplier.java | 5 +-
.../pipe/task/connection/PipeEventCollector.java | 4 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 4 +-
...ectorStage.java => PipeTaskExtractorStage.java} | 51 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 8 +-
.../iotdb/db/pipe/task/stage/PipeTaskStage.java | 25 +-
.../db/pipe/task/subtask/PipeConnectorSubtask.java | 47 +-
.../task/subtask/PipeConnectorSubtaskManager.java | 13 +-
.../db/pipe/task/subtask/PipeProcessorSubtask.java | 1 -
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 46 +-
.../protocol/influxdb/util/QueryResultUtils.java | 2 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 23 +-
.../iotdb/db/query/context/QueryContext.java | 58 +--
.../iotdb/db/query/control/FileReaderManager.java | 23 +-
.../iotdb/db/query/control/QueryFileManager.java | 16 +-
.../db/query/control/QueryResourceManager.java | 1 +
.../iotdb/db/query/control/SessionManager.java | 38 +-
.../db/query/control/SessionManagerMBean.java | 3 +
.../query/control/clientsession/ClientSession.java | 24 +-
.../control/clientsession/IClientSession.java | 4 +-
.../clientsession/InternalClientSession.java | 7 +-
.../control/clientsession/MqttClientSession.java | 5 +-
.../query/reader/chunk/DiskAlignedChunkLoader.java | 5 +-
.../db/query/reader/chunk/DiskChunkLoader.java | 2 +-
.../query/reader/chunk/MemAlignedChunkLoader.java | 3 +-
.../query/reader/chunk/MemAlignedChunkReader.java | 3 +-
.../query/reader/chunk/MemAlignedPageReader.java | 108 ++--
.../db/query/reader/chunk/MemChunkLoader.java | 2 +-
.../db/query/reader/chunk/MemChunkReader.java | 10 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 310 +++++++-----
.../metadata/DiskAlignedChunkMetadataLoader.java | 7 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 7 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 1 +
.../chunk/metadata/MemChunkMetadataLoader.java | 1 +
.../universal/AlignedDescPriorityMergeReader.java | 1 +
.../universal/AlignedPriorityMergeReader.java | 15 +-
.../reader/universal/DescPriorityMergeReader.java | 4 +-
.../iotdb/db/query/reader/universal/Element.java | 1 +
.../reader/universal/PriorityMergeReader.java | 28 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 1 -
.../db/service/metrics/CompactionMetrics.java | 192 ++++---
.../iotdb/db/service/metrics/FileMetrics.java | 1 +
.../metrics/IoTDBInternalLocalReporter.java | 6 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 48 +-
.../org/apache/iotdb/db/tools/DiskSpiller.java | 10 +-
.../apache/iotdb/db/tools/FileSpillerReader.java | 8 +-
.../apache/iotdb/db/tools/SortBufferManager.java | 20 +-
.../java/org/apache/iotdb/db/tools/SortReader.java | 13 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 4 +-
.../db/tools/schema/PBTreeFileSketchTool.java | 6 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 2 +-
.../db/trigger/executor/TriggerFireVisitor.java | 6 +-
.../trigger/service/TriggerClassLoaderManager.java | 8 +-
.../trigger/service/TriggerManagementService.java | 36 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 24 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 153 +++---
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 546 +++++++++++++-------
.../SlidingTimeWindowEvaluationHandler.java | 4 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 1 +
.../utils/windowing/window/EvictableBatchList.java | 6 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 12 +-
.../FastCrossCompactionPerformerTest.java | 37 ++
.../db/engine/compaction/MemoryControlTest.java | 11 +
.../cross/CrossSpaceCompactionSelectorTest.java | 2 +
.../mtree/schemafile/AliasIndexPageTest.java | 2 +-
.../mtree/schemafile/InternalPageTest.java | 2 +-
.../mtree/schemafile/SchemaFileLogTest.java | 8 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 2 +-
.../mtree/schemafile/WrappedSegmentTest.java | 2 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 6 +-
.../schemaRegion/SchemaRegionBasicTest.java | 29 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 49 --
.../operator/SingleDeviceViewOperatorTest.java | 2 +-
.../execution/operator/TimeJoinOperatorTest.java | 414 ---------------
.../CachedSchemaPatternMatcherTest.java | 73 ++-
.../PipeRealtimeExtractTest.java} | 102 ++--
.../iotdb/db/tools/PBTreeFileSketchTest.java | 4 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../src/test/resources/iotdb-datanode.properties | 4 +-
site/src/main/.vuepress/components/IoTDB.vue | 4 +-
site/src/main/.vuepress/components/IoTDBZH.vue | 4 +-
.../docsearch/client/components/Docsearch.ts | 7 +-
site/src/main/.vuepress/config.ts | 8 +
site/src/main/.vuepress/navbar/en.ts | 4 +-
site/src/main/.vuepress/navbar/zh.ts | 4 +-
site/src/main/.vuepress/sidebar/en.ts | 552 ++++++++++----------
site/src/main/.vuepress/sidebar/zh.ts | 558 ++++++++++-----------
site/src/main/.vuepress/utils/index.ts | 3 +
site/src/main/package.json | 1 +
.../apache/iotdb/tsfile/common/cache/Cache.java | 1 +
.../apache/iotdb/tsfile/common/cache/LRUCache.java | 3 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 50 +-
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 34 +-
.../tsfile/common/constant/JsonFormatConstant.java | 1 +
.../tsfile/common/constant/QueryConstant.java | 1 +
.../tsfile/common/constant/TsFileConstant.java | 1 +
.../exception/NotCompatibleTsFileException.java | 1 +
.../tsfile/exception/NotImplementedException.java | 1 +
.../iotdb/tsfile/exception/NullFieldException.java | 1 +
.../iotdb/tsfile/exception/PathParseException.java | 1 +
.../tsfile/exception/TsFileRuntimeException.java | 1 +
.../TsFileStatisticsMistakesException.java | 1 +
.../CompressionTypeNotSupportedException.java | 1 +
.../compress/GZIPCompressOverflowException.java | 1 +
.../filter/QueryFilterOptimizationException.java | 1 +
.../exception/filter/StatisticsClassException.java | 1 +
.../filter/UnSupportFilterDataTypeException.java | 1 +
.../exception/write/NoMeasurementException.java | 1 +
.../tsfile/exception/write/PageException.java | 1 +
.../write/UnSupportedDataTypeException.java | 1 +
.../write/UnknownColumnTypeException.java | 1 +
.../exception/write/WriteProcessException.java | 1 +
.../org/apache/iotdb/tsfile/file/MetaMarker.java | 8 +-
.../iotdb/tsfile/file/header/ChunkGroupHeader.java | 20 +-
.../iotdb/tsfile/file/header/ChunkHeader.java | 23 +-
.../iotdb/tsfile/file/header/PageHeader.java | 4 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 12 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 6 +-
.../tsfile/file/metadata/ChunkGroupMetadata.java | 3 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 12 +-
.../tsfile/file/metadata/ITimeSeriesMetadata.java | 10 +-
.../file/metadata/MetadataIndexConstructor.java | 4 +-
.../tsfile/file/metadata/MetadataIndexNode.java | 2 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 21 +-
.../iotdb/tsfile/file/metadata/TsFileMetadata.java | 4 +-
.../file/metadata/enums/CompressionType.java | 22 +-
.../file/metadata/enums/MetadataIndexNodeType.java | 11 +-
.../tsfile/file/metadata/enums/TSDataType.java | 37 +-
.../tsfile/file/metadata/enums/TSEncoding.java | 1 +
.../file/metadata/statistics/BinaryStatistics.java | 22 +-
.../metadata/statistics/BooleanStatistics.java | 18 +-
.../file/metadata/statistics/DoubleStatistics.java | 18 +-
.../file/metadata/statistics/FloatStatistics.java | 17 +-
.../metadata/statistics/IntegerStatistics.java | 18 +-
.../file/metadata/statistics/LongStatistics.java | 92 ++--
.../file/metadata/statistics/Statistics.java | 60 ++-
.../file/metadata/statistics/TimeStatistics.java | 13 +-
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 3 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 18 +-
.../read/controller/IChunkMetadataLoader.java | 4 +-
.../iotdb/tsfile/read/reader/IPageReader.java | 3 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 5 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 3 +-
.../java/org/apache/iotdb/tsfile/utils/Loader.java | 11 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 19 +-
.../v2/file/metadata/TimeseriesMetadataV2.java | 4 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 2 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 30 +-
.../tsfile/file/metadata/utils/TestHelper.java | 2 +-
.../tsfile/write/TsFileIntegrityCheckingTool.java | 2 +-
.../writer/TsFileIOWriterMemoryControlTest.java | 6 +-
614 files changed, 7496 insertions(+), 6485 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/view/IoTDBShowDevicesContainedViewIT.java
rename
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/{PipeCollector.java
=> PipeExtractor.java} (66%)
rename
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/configuration/{PipeCollectorRuntimeConfiguration.java
=> PipeExtractorRuntimeConfiguration.java} (93%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/NotCompatibleTsFileException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/UnSupportedDataTypeException.java
(74%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/{collector/IoTDBCollector.java
=> extractor/IoTDBExtractor.java} (81%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/{SchemaFilterVisitor.java
=> SchemaFilterFactory.java} (52%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/{DataTypeFilter.java
=> AndFilter.java} (58%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/{DataTypeFilter.java
=> ViewTypeFilter.java} (63%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ShowCQPlan.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/view/ViewType.java
(50%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/io/CompactionTsFileReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/io/CompactionTsFileWriter.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/PathParseException.java
=>
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/constant/CompactionIoDataType.java
(75%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/TsFileStatisticsMistakesException.java
=>
server/src/main/java/org/apache/iotdb/db/exception/runtime/ClassLoaderManagerInitializationException.java
(80%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/DeviceMergeOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/TimeJoinOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/collector/IoTDBDataRegionCollector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/collector/historical/PipeHistoricalDataRegionCollector.java
rename
server/src/main/java/org/apache/iotdb/db/pipe/config/constant/{PipeCollectorConstant.java
=> PipeExtractorConstant.java} (55%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/{PipeTaskCollectorRuntimeEnvironment.java
=> PipeTaskExtractorRuntimeEnvironment.java} (92%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/event/realtime/{PipeRealtimeCollectEvent.java
=> PipeRealtimeEvent.java} (78%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/event/realtime/{PipeRealtimeCollectEventFactory.java
=> PipeRealtimeEventFactory.java} (85%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/extractor/IoTDBDataRegionExtractor.java
rename
server/src/main/java/org/apache/iotdb/db/{mpp/statistics/TimeseriesStats.java
=> pipe/extractor/historical/PipeHistoricalDataRegionExtractor.java} (79%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{collector/historical/PipeHistoricalDataRegionTsFileCollector.java
=> extractor/historical/PipeHistoricalDataRegionTsFileExtractor.java} (65%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{collector/realtime/PipeRealtimeDataRegionCollector.java
=> extractor/realtime/PipeRealtimeDataRegionExtractor.java} (69%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{collector/realtime/PipeRealtimeDataRegionFakeCollector.java
=> extractor/realtime/PipeRealtimeDataRegionFakeExtractor.java} (65%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{collector/realtime/PipeRealtimeDataRegionHybridCollector.java
=> extractor/realtime/PipeRealtimeDataRegionHybridExtractor.java} (67%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{collector/realtime/PipeRealtimeDataRegionLogCollector.java
=> extractor/realtime/PipeRealtimeDataRegionLogExtractor.java} (70%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{collector/realtime/PipeRealtimeDataRegionTsFileCollector.java
=> extractor/realtime/PipeRealtimeDataRegionTsFileExtractor.java} (70%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/realtime/assigner/DisruptorQueue.java (96%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/realtime/assigner/PipeDataRegionAssigner.java (60%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/realtime/epoch/TsFileEpoch.java (67%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/realtime/epoch/TsFileEpochManager.java (79%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/realtime/epoch/TsFileEpochStateMigrator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/realtime/listener/PipeInsertionDataNodeListener.java (68%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/realtime/matcher/CachedSchemaPatternMatcher.java (63%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/realtime/matcher/PipeDataRegionMatcher.java (56%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/task/stage/{PipeTaskCollectorStage.java
=> PipeTaskExtractorStage.java} (67%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/TimeJoinOperatorTest.java
rename server/src/test/java/org/apache/iotdb/db/pipe/{collector =>
extractor}/CachedSchemaPatternMatcherTest.java (68%)
rename
server/src/test/java/org/apache/iotdb/db/pipe/{collector/PipeRealtimeCollectTest.java
=> extractor/PipeRealtimeExtractTest.java} (77%)
