This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch refactor/new_auth
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e7b949b7e65 Fix Test
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 a76d8badae9 Fix bugs & code smells identified by Sonar
add 30018f2d530 [IOTDB-5809]The search configuration file path
specification is inconsistent (#10236)
add 34dfb499ad8 Remove the useless testcontainer module and dependency
(#10302)
add 379f2c713c2 Fix sonar check in schema module (#10297)
add 453f19930ac Fix sonar bugs and code smells in iotdb/db/metadata/metric
(#10264)
add ea911e4284f Fix sonar bugs and code smells in
mpp/execution/operator/schema (#10303)
add 1e35786c7e7 UDF: fix bugs & smells reported by SonarCloud
(org.apache.iotdb.library) (#10289)
add 268c6b88f92 [IOTDB-6017] Pipe: separate pipe heartbeat from cluster
heartbeat (#10285)
add 3bdb5d2cf52 fix code smells in settle package (#10293)
new 9dc992eba43 Merge branch 'master' into refactor/new_auth
new 9278be98fcd Fix IT
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/e2e.yml | 63 --
.github/workflows/main-unix.yml | 2 +-
.github/workflows/sonar-coveralls.yml | 6 +-
.github/workflows/sync.yml | 57 --
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 12 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +-
.../confignode/client/DataNodeRequestType.java | 1 +
.../client/async/AsyncDataNodeClientPool.java | 8 +
.../client/async/handlers/AsyncClientHandler.java | 10 +
.../handlers/rpc/PipeHeartbeatRPCHandler.java | 70 ++
.../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 +-
.../statemachine/ConfigRegionStateMachine.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 11 +-
.../iotdb/confignode/manager/cq/CQManager.java | 9 +-
.../confignode/manager/cq/CQScheduleTask.java | 13 +-
.../manager/load/service/HeartbeatService.java | 8 +-
.../manager/load/service/StatisticsService.java | 3 +-
.../manager/pipe/runtime/PipeHeartbeatParser.java | 47 +-
.../pipe/runtime/PipeHeartbeatScheduler.java | 111 +++
.../pipe/runtime/PipeLeaderChangeHandler.java | 33 +-
.../pipe/runtime/PipeRuntimeCoordinator.java | 44 +-
.../manager/schema/ClusterSchemaManager.java | 6 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 37 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +-
.../persistence/pipe/PipePluginInfo.java | 20 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../procedure/impl/cq/CreateCQProcedure.java | 126 +--
.../runtime/PipeHandleLeaderChangeProcedure.java | 18 +-
.../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 +-
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 13 +-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 4 +-
.../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 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +-
.../src/main/thrift/confignode.thrift | 4 +-
.../thrift/src/main/thrift/datanode.thrift | 13 +
.../org/apache/iotdb/library/anomaly/UDTFIQR.java | 21 +-
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 30 +-
.../org/apache/iotdb/library/anomaly/UDTFLOF.java | 18 +-
.../apache/iotdb/library/anomaly/UDTFOutlier.java | 14 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 7 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 7 +-
.../iotdb/library/anomaly/util/MissDetector.java | 8 +-
.../library/anomaly/util/StreamMissDetector.java | 24 +-
.../iotdb/library/anomaly/util/WindowDetect.java | 6 +-
.../org/apache/iotdb/library/dlearn/UDTFAR.java | 19 +-
.../org/apache/iotdb/library/dmatch/UDAFCov.java | 20 +-
.../apache/iotdb/library/dmatch/UDAFPearson.java | 36 +-
.../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 7 +-
.../library/dmatch/util/CrossCorrelation.java | 13 +-
.../iotdb/library/dprofile/UDAFIntegral.java | 5 +-
.../iotdb/library/dprofile/UDAFIntegralAvg.java | 2 +-
.../org/apache/iotdb/library/dprofile/UDAFMad.java | 2 +-
.../apache/iotdb/library/dprofile/UDAFMedian.java | 2 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 14 +-
.../apache/iotdb/library/dprofile/UDAFPeriod.java | 28 +-
.../iotdb/library/dprofile/UDAFQuantile.java | 19 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 36 +-
.../org/apache/iotdb/library/dprofile/UDTFACF.java | 5 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 12 +
.../iotdb/library/dprofile/UDTFHistogram.java | 1 +
.../apache/iotdb/library/dprofile/UDTFMinMax.java | 20 +-
.../apache/iotdb/library/dprofile/UDTFMvAvg.java | 6 +-
.../apache/iotdb/library/dprofile/UDTFPACF.java | 1 +
.../org/apache/iotdb/library/dprofile/UDTFQLB.java | 1 +
.../iotdb/library/dprofile/UDTFResample.java | 12 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 19 +-
.../apache/iotdb/library/dprofile/UDTFSegment.java | 34 +-
.../apache/iotdb/library/dprofile/UDTFSpline.java | 2 +-
.../apache/iotdb/library/dprofile/UDTFZScore.java | 20 +-
.../library/dprofile/util/CrossCorrelation.java | 14 +-
.../dprofile/util/ExactOrderStatistics.java | 139 +--
.../iotdb/library/dprofile/util/GKArray.java | 22 +-
.../library/dprofile/util/HeapLongKLLSketch.java | 237 +++--
.../dprofile/util/KLLSketchForQuantile.java | 155 ++--
.../iotdb/library/dprofile/util/MADSketch.java | 157 ++--
.../apache/iotdb/library/dprofile/util/Mad.java | 9 +-
.../iotdb/library/dprofile/util/MaxSelector.java | 3 +-
.../iotdb/library/dprofile/util/Resampler.java | 17 +-
.../iotdb/library/dprofile/util/Segment.java | 141 +--
.../iotdb/library/dprofile/util/YuleWalker.java | 11 +-
.../iotdb/library/dquality/UDTFCompleteness.java | 2 +-
.../iotdb/library/dquality/UDTFConsistency.java | 2 +-
.../iotdb/library/dquality/UDTFTimeliness.java | 2 +-
.../iotdb/library/dquality/UDTFValidity.java | 2 +-
.../library/dquality/util/TimeSeriesQuality.java | 21 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 5 +-
.../iotdb/library/drepair/UDTFValueFill.java | 6 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 3 +-
.../apache/iotdb/library/drepair/util/ARFill.java | 34 +-
.../iotdb/library/drepair/util/LikelihoodFill.java | 15 +-
.../iotdb/library/drepair/util/LinearFill.java | 1 +
.../iotdb/library/drepair/util/LsGreedy.java | 12 +-
.../apache/iotdb/library/drepair/util/MAFill.java | 21 +-
.../iotdb/library/drepair/util/MeanFill.java | 1 +
.../iotdb/library/drepair/util/PreviousFill.java | 1 +
.../apache/iotdb/library/drepair/util/Screen.java | 4 +-
.../iotdb/library/drepair/util/ScreenFill.java | 30 +-
.../library/drepair/util/TimestampInterval.java | 13 +-
.../library/drepair/util/TimestampRepair.java | 56 +-
.../iotdb/library/drepair/util/ValueFill.java | 21 +-
.../iotdb/library/drepair/util/ValueRepair.java | 11 +-
.../apache/iotdb/library/frequency/UDTFDWT.java | 1 +
.../apache/iotdb/library/frequency/UDTFDeconv.java | 18 +-
.../apache/iotdb/library/frequency/UDTFFFT.java | 7 +-
.../iotdb/library/frequency/UDTFHighPass.java | 8 +-
.../apache/iotdb/library/frequency/UDTFIDWT.java | 1 +
.../apache/iotdb/library/frequency/UDTFIFFT.java | 11 +-
.../iotdb/library/frequency/UDTFLowPass.java | 8 +-
.../iotdb/library/frequency/util/DWTUtil.java | 12 +-
.../iotdb/library/frequency/util/FFTUtil.java | 12 +-
.../library/series/UDTFConsecutiveWindows.java | 4 +-
.../iotdb/library/series/util/ConsecutiveUtil.java | 18 +-
.../iotdb/library/util/BooleanCircularQueue.java | 31 +-
.../apache/iotdb/library/util/CircularQueue.java | 29 +-
.../iotdb/library/util/DoubleCircularQueue.java | 31 +-
.../iotdb/library/util/LinearRegression.java | 15 +-
.../iotdb/library/util/LongCircularQueue.java | 35 +-
.../iotdb/library/util/NoNumberException.java | 1 +
.../java/org/apache/iotdb/library/util/Util.java | 63 +-
.../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 | 30 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 68 +-
.../iotdb/commons/conf/CommonDescriptor.java | 40 +-
.../runtime/SchemaExecutionException.java | 17 +-
.../runtime/UnSupportedDataTypeException.java | 11 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 41 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 18 +-
.../IoTDBExtractor.java} | 16 +-
.../commons/pipe/task/meta/PipeStaticMeta.java | 34 +-
.../iotdb/commons/pipe/PipeMetaDeSerTest.java | 2 +-
pom.xml | 31 -
.../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 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 2 -
.../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} | 17 +-
.../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 +-
.../apache/iotdb/db/engine/settle/SettleLog.java | 6 +-
.../db/engine/settle/SettleRequestHandler.java | 11 +-
.../apache/iotdb/db/engine/settle/SettleTask.java | 6 +-
.../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/AlignedTimeseriesException.java | 4 -
.../metadata/DataTypeMismatchException.java | 14 +-
.../metadata/DuplicateInsertException.java | 1 +
.../metadata/IllegalParameterOfPathException.java | 1 +
.../metadata/MNodeTypeMismatchException.java | 1 +
.../metadata/MeasurementAlreadyExistException.java | 2 +-
.../SchemaDirCreationFailureException.java | 1 +
.../metadata/SchemaQuotaExceededException.java | 6 +-
.../metadata/SeriesNumberOverflowException.java | 29 -
.../metadata/SeriesOverflowException.java | 10 +-
.../metadata/cache/MNodeNotCachedException.java | 1 +
.../schemafile/ColossalRecordException.java | 1 +
.../SchemaFileLogCorruptedException.java | 2 +-
.../metadata/schemafile/SchemaFileNotExists.java | 2 +-
.../schemafile/SchemaPageOverflowException.java | 3 +-
.../template/TemplateImcompatibeException.java | 3 +-
.../metadata/view/BrokenViewException.java | 5 +-
.../view/InsertNonWritableViewException.java | 1 +
.../metadata/view/UnsupportedViewException.java | 1 +
.../view/ViewContainsAggregationException.java | 1 +
.../metadata/view/ViewNotExistException.java | 1 +
.../query/QueryTimeoutRuntimeException.java | 1 +
.../ClassLoaderManagerInitializationException.java | 6 +-
.../sql/MeasurementNotExistException.java | 2 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 8 +-
.../idtable/AppendOnlyDiskSchemaManager.java | 10 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 47 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 80 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 25 +-
.../db/metadata/idtable/IDiskSchemaManager.java | 22 +-
.../db/metadata/idtable/entry/DiskSchemaEntry.java | 2 +-
.../iotdb/db/metadata/idtable/entry/IDeviceID.java | 8 +-
.../db/metadata/idtable/entry/PlainDeviceID.java | 2 +-
.../db/metadata/idtable/entry/SHA256DeviceID.java | 16 +-
.../db/metadata/idtable/entry/SchemaEntry.java | 16 +-
.../db/metadata/idtable/entry/TimeseriesID.java | 5 +-
.../db/metadata/logfile/BufferedSerializer.java | 2 +-
.../iotdb/db/metadata/logfile/IDeserializer.java | 2 +-
.../iotdb/db/metadata/logfile/ISerializer.java | 2 +-
.../iotdb/db/metadata/logfile/MLogDescription.java | 1 +
.../db/metadata/logfile/MLogDescriptionReader.java | 11 +-
.../db/metadata/logfile/MLogDescriptionWriter.java | 20 +-
.../db/metadata/logfile/MetadataOperationType.java | 1 +
.../iotdb/db/metadata/logfile/SchemaLogReader.java | 28 +-
.../iotdb/db/metadata/logfile/SchemaLogWriter.java | 2 +-
.../db/metadata/metric/ISchemaEngineMetric.java | 1 +
.../db/metadata/metric/ISchemaRegionMetric.java | 1 +
.../metadata/metric/SchemaEngineCachedMetric.java | 3 +-
.../db/metadata/metric/SchemaEngineMemMetric.java | 7 +-
.../db/metadata/metric/SchemaMetricManager.java | 25 +-
.../metadata/metric/SchemaRegionCachedMetric.java | 5 +-
.../db/metadata/metric/SchemaRegionMemMetric.java | 1 +
.../mtree/store/disk/schemafile/ISchemaFile.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 +-
.../db/metadata/path/PatternTreeMapFactory.java | 6 +
.../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 | 14 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 12 +-
.../schemaregion/SchemaRegionPBTreeImpl.java | 31 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 15 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 75 +-
.../metadata/template/ClusterTemplateManager.java | 37 +-
.../db/metadata/template/ITemplateManager.java | 19 +-
.../iotdb/db/metadata/template/Template.java | 15 +-
.../metadata/template/TemplateInternalRPCUtil.java | 4 +-
.../template/alter/TemplateAlterOperationUtil.java | 6 +-
.../template/alter/TemplateExtendInfo.java | 27 +-
.../db/metadata/utils/ResourceByPathUtils.java | 10 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 2 +-
.../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 +
.../org/apache/iotdb/db/mpp/common/QueryId.java | 10 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 8 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../mpp/common/schematree/ClusterSchemaTree.java | 37 +-
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 14 +-
.../common/schematree/IMeasurementSchemaInfo.java | 6 +-
.../db/mpp/common/schematree/ISchemaTree.java | 6 +-
.../schematree/node/SchemaMeasurementNode.java | 7 +-
.../db/mpp/common/schematree/node/SchemaNode.java | 4 +-
.../schematree/visitor/SchemaTreeVisitor.java | 2 +-
.../visitor/SchemaTreeVisitorFactory.java | 6 +
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 1 +
.../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/CountGroupByLevelMergeOperator.java | 6 +-
.../schema/CountGroupByLevelScanOperator.java | 3 +-
.../operator/schema/CountMergeOperator.java | 21 +-
.../schema/NodeManageMemoryMergeOperator.java | 2 +-
.../operator/schema/SchemaCountOperator.java | 3 +-
.../operator/schema/SchemaFetchScanOperator.java | 10 +-
.../operator/schema/SchemaQueryMergeOperator.java | 7 +-
.../operator/schema/SchemaQueryScanOperator.java | 4 +-
.../operator/schema/SchemaTsBlockUtil.java | 4 +
.../operator/schema/source/DeviceSchemaSource.java | 3 +-
.../operator/schema/source/ISchemaSource.java | 6 +-
.../schema/source/LogicalViewSchemaSource.java | 3 +-
.../operator/schema/source/NodeSchemaSource.java | 3 +-
.../schema/source/PathsUsingTemplateSource.java | 3 +-
.../schema/source/SchemaSourceFactory.java | 2 +-
.../schema/source/TimeSeriesSchemaSource.java | 5 +-
.../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 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 1 +
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 173 ----
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 24 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 250 +++---
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 2 +-
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 6 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 57 +-
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 15 +-
.../db/mpp/plan/analyze/IPartitionFetcher.java | 1 +
.../iotdb/db/mpp/plan/analyze/QueryType.java | 1 +
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 15 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 1 +
.../analyze/cache/StorageGroupCacheResult.java | 1 +
.../analyze/schema/AutoCreateSchemaExecutor.java | 22 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 4 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 5 +-
.../plan/analyze/schema/TemplateSchemaFetcher.java | 4 -
.../db/mpp/plan/execution/ExecutionResult.java | 4 +-
.../db/mpp/plan/execution/QueryExecution.java | 14 +-
.../mpp/plan/execution/config/ConfigExecution.java | 12 +-
.../plan/execution/config/ConfigTaskVisitor.java | 3 +-
.../config/executor/ClusterConfigTaskExecutor.java | 18 +-
.../config/metadata/DatabaseSchemaTask.java | 4 +-
.../execution/config/metadata/GetRegionIdTask.java | 2 +-
.../config/metadata/GetSeriesSlotListTask.java | 2 +-
.../config/metadata/ShowClusterDetailsTask.java | 1 +
.../execution/config/metadata/ShowClusterTask.java | 2 +-
.../config/metadata/ShowConfigNodesTask.java | 9 +-
.../config/metadata/ShowFunctionsTask.java | 2 +-
.../config/metadata/model/ShowModelsTask.java | 4 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 2 +-
.../config/sys/quota/ShowSpaceQuotaTask.java | 2 +-
.../config/sys/quota/ShowThrottleQuotaTask.java | 6 +-
.../plan/execution/memory/MemorySourceHandle.java | 12 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 3 +-
.../db/mpp/plan/expression/ExpressionFactory.java | 4 +
.../db/mpp/plan/expression/ExpressionType.java | 8 +-
.../UnknownExpressionTypeException.java} | 17 +-
.../plan/expression/binary/AdditionExpression.java | 6 +
.../plan/expression/binary/BinaryExpression.java | 1 +
.../plan/expression/binary/DivisionExpression.java | 6 +
.../plan/expression/binary/EqualToExpression.java | 6 +
.../expression/binary/GreaterEqualExpression.java | 6 +
.../expression/binary/GreaterThanExpression.java | 6 +
.../expression/binary/LessEqualExpression.java | 6 +
.../plan/expression/binary/LessThanExpression.java | 6 +
.../plan/expression/binary/LogicAndExpression.java | 6 +
.../plan/expression/binary/LogicOrExpression.java | 6 +
.../plan/expression/binary/ModuloExpression.java | 6 +
.../binary/MultiplicationExpression.java | 6 +
.../plan/expression/binary/NonEqualExpression.java | 6 +
.../expression/binary/SubtractionExpression.java | 6 +
.../plan/expression/multi/FunctionExpression.java | 8 +-
.../BuiltInScalarFunctionHelperFactory.java | 5 +
.../multi/builtin/helper/CastFunctionHelper.java | 22 +-
.../mpp/plan/expression/unary/LikeExpression.java | 11 +-
.../BindTypeForTimeSeriesOperandVisitor.java | 3 +-
.../visitor/ColumnTransformerVisitor.java | 9 +-
.../visitor/CompleteMeasurementSchemaVisitor.java | 17 +-
.../plan/expression/visitor/ExpressionVisitor.java | 66 ++
.../visitor/IntermediateLayerVisitor.java | 24 +-
.../visitor/TransformToViewExpressionVisitor.java | 106 +--
.../cartesian/BindSchemaForExpressionVisitor.java | 19 +-
.../db/mpp/plan/optimization/PlanOptimizer.java | 1 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 77 +-
.../db/mpp/plan/parser/StatementGenerator.java | 68 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 339 ++++----
.../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 +-
.../parameter/DeviceViewIntoPathDescriptor.java | 5 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 5 +-
.../iotdb/db/mpp/plan/statement/AuthorType.java | 1 +
.../iotdb/db/mpp/plan/statement/Statement.java | 2 +-
.../plan/statement/component/FillComponent.java | 4 +-
.../mpp/plan/statement/component/FillPolicy.java | 1 +
.../plan/statement/component/FilterNullPolicy.java | 25 -
.../plan/statement/component/FromComponent.java | 4 +-
.../plan/statement/component/GroupByComponent.java | 8 +-
.../statement/component/GroupByCountComponent.java | 1 +
.../statement/component/GroupByTimeComponent.java | 4 +-
.../plan/statement/component/IntoComponent.java | 12 +-
.../plan/statement/component/OrderByComponent.java | 3 +
.../mpp/plan/statement/component/OrderByKey.java | 4 +
.../plan/statement/crud/DeleteDataStatement.java | 4 +-
.../plan/statement/crud/InsertBaseStatement.java | 12 +-
.../crud/InsertMultiTabletsStatement.java | 31 -
.../plan/statement/crud/InsertRowStatement.java | 11 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 1 -
.../plan/statement/crud/InsertRowsStatement.java | 31 -
.../plan/statement/crud/InsertTabletStatement.java | 18 +-
.../plan/statement/crud/LoadTsFileStatement.java | 2 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 9 +-
.../InternalBatchActivateTemplateStatement.java | 2 +-
.../InternalCreateMultiTimeSeriesStatement.java | 2 +-
.../InternalCreateTimeSeriesStatement.java | 2 +-
.../db/mpp/plan/statement/literal/LongLiteral.java | 6 +-
.../db/mpp/plan/statement/literal/NullLiteral.java | 5 +-
.../metadata/CreateContinuousQueryStatement.java | 3 +-
.../metadata/CreateFunctionStatement.java | 2 +-
.../metadata/CreatePipePluginStatement.java | 2 +-
.../statement/metadata/CreateTriggerStatement.java | 2 +-
.../metadata/DatabaseSchemaStatement.java | 12 +-
.../metadata/DropContinuousQueryStatement.java | 2 +-
.../statement/metadata/DropFunctionStatement.java | 2 +-
.../metadata/DropPipePluginStatement.java | 2 +-
.../statement/metadata/DropTriggerStatement.java | 2 +-
.../statement/metadata/MigrateRegionStatement.java | 20 +-
.../statement/metadata/ShowClusterStatement.java | 1 +
.../statement/metadata/ShowVariablesStatement.java | 1 +
.../metadata/model/CreateModelStatement.java | 6 +-
.../metadata/model/DropModelStatement.java | 2 +-
.../metadata/model/ShowModelsStatement.java | 6 +-
.../metadata/model/ShowTrailsStatement.java | 2 +-
.../template/ActivateTemplateStatement.java | 2 +-
.../template/AlterSchemaTemplateStatement.java | 5 +-
.../template/BatchActivateTemplateStatement.java | 4 +-
.../template/CreateSchemaTemplateStatement.java | 8 +-
.../template/DeactivateTemplateStatement.java | 4 +-
.../template/DropSchemaTemplateStatement.java | 2 +-
.../template/UnsetSchemaTemplateStatement.java | 2 +-
.../metadata/view/CreateLogicalViewStatement.java | 13 +-
.../metadata/view/RenameLogicalViewStatement.java | 2 +-
.../db/mpp/plan/statement/sys/AuthorStatement.java | 1 +
.../mpp/plan/statement/sys/ExplainStatement.java | 2 +-
.../mpp/plan/statement/sys/KillQueryStatement.java | 2 +-
.../statement/sys/LoadConfigurationStatement.java | 1 +
.../statement/sys/SetSystemStatusStatement.java | 1 +
.../plan/statement/sys/ShowQueriesStatement.java | 4 +-
.../plan/statement/sys/ShowVersionStatement.java | 4 +-
.../statement/sys/pipe/CreatePipeStatement.java | 10 +-
.../sys/quota/ShowSpaceQuotaStatement.java | 2 +-
.../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 | 157 ++--
.../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 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 9 +
.../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 | 28 +-
.../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 +-
.../apache/iotdb/db/engine/StorageEngineTest.java | 2 +-
.../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 | 4 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../execution/exchange/LocalSinkChannelTest.java | 2 +-
.../execution/exchange/LocalSourceHandleTest.java | 2 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 2 +-
.../mpp/execution/operator/FillOperatorTest.java | 2 +-
.../execution/operator/LinearFillOperatorTest.java | 2 +-
.../execution/operator/MergeSortOperatorTest.java | 2 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 55 +-
.../operator/SingleDeviceViewOperatorTest.java | 2 +-
.../execution/operator/TimeJoinOperatorTest.java | 414 ---------
.../schema/CountGroupByLevelMergeOperatorTest.java | 1 -
.../node/process/AggregationNodeSerdeTest.java | 2 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 2 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 2 +-
.../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 +-
.../src/test/resources/testcontainers.properties | 17 -
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 +
test/e2e/base/docker-compose.yaml | 51 --
test/e2e/cases/README.md | 53 --
test/e2e/cases/cli/README.md | 24 -
test/e2e/cases/cli/cleanup.sh | 27 -
test/e2e/cases/cli/docker-compose.yaml | 41 -
test/e2e/cases/cli/res/init.sql | 26 -
test/e2e/cases/cli/run.sh | 48 --
testcontainer/Readme.md | 62 --
testcontainer/pom.xml | 246 ------
.../test/java/org/apache/iotdb/db/sql/Cases.java | 949 ---------------------
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 105 ---
.../iotdb/db/sql/ClusterSessionSimpleIT.java | 85 --
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 88 --
.../iotdb/db/sql/node1/OneNodeClusterIT.java | 54 --
.../db/sql/nodes3/AbstractThreeNodeClusterIT.java | 61 --
.../iotdb/db/sql/nodes3/ThreeNodeCluster1IT.java | 23 -
.../iotdb/db/sql/nodes3/ThreeNodeCluster2IT.java | 32 -
.../db/sql/nodes5/AbstractFiveNodeClusterIT.java | 85 --
.../iotdb/db/sql/nodes5/FiveNodeCluster1IT.java | 23 -
.../iotdb/db/sql/nodes5/FiveNodeCluster2IT.java | 32 -
.../iotdb/db/sql/nodes5/FiveNodeCluster4IT.java | 32 -
.../test/java/org/apache/iotdb/db/sync/SyncIT.java | 426 ---------
.../apache/iotdb/db/sync/SyncWeakNetworkIT.java | 40 -
.../NoProjectNameDockerComposeContainer.java | 38 -
.../src/test/resources/iotdb-datanode.properties | 24 -
.../src/test/resources/logback-container.xml | 39 -
testcontainer/src/test/resources/logback.xml | 52 --
.../src/test/resources/sync/docker-compose.yaml | 52 --
testcontainer/src/tool/README.md | 33 -
testcontainer/src/tool/parser.py | 79 --
.../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 +-
.../apache/iotdb/tsfile/read/TimeValuePair.java | 1 +
.../iotdb/tsfile/read/TsFileCheckStatus.java | 4 +
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 5 +-
.../org/apache/iotdb/tsfile/read/TsFileReader.java | 1 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 85 +-
.../iotdb/tsfile/read/UnClosedTsFileReader.java | 1 +
.../apache/iotdb/tsfile/read/common/BatchData.java | 21 +-
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 3 +-
.../tsfile/read/common/DescReadBatchData.java | 4 +-
.../tsfile/read/common/DescReadWriteBatchData.java | 7 +-
.../tsfile/read/common/ExceptionBatchData.java | 37 -
.../org/apache/iotdb/tsfile/read/common/Field.java | 3 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 1 +
.../apache/iotdb/tsfile/read/common/RowRecord.java | 1 +
.../iotdb/tsfile/read/common/SignalBatchData.java | 1 +
.../apache/iotdb/tsfile/read/common/TimeRange.java | 7 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 33 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 1 +
.../read/common/block/TsBlockBuilderStatus.java | 1 +
.../tsfile/read/common/block/TsBlockMetadata.java | 41 -
.../tsfile/read/common/block/TsBlockUtil.java | 4 +-
.../read/common/block/column/BinaryColumn.java | 1 +
.../common/block/column/BinaryColumnBuilder.java | 1 +
.../read/common/block/column/BooleanColumn.java | 1 +
.../common/block/column/BooleanColumnBuilder.java | 1 +
.../tsfile/read/common/block/column/Column.java | 1 +
.../read/common/block/column/ColumnBuilder.java | 1 +
.../common/block/column/ColumnBuilderStatus.java | 1 +
.../common/block/column/ColumnEncoderFactory.java | 4 +
.../read/common/block/column/ColumnUtil.java | 1 +
.../read/common/block/column/DoubleColumn.java | 1 +
.../common/block/column/DoubleColumnBuilder.java | 1 +
.../read/common/block/column/FloatColumn.java | 1 +
.../common/block/column/FloatColumnBuilder.java | 1 +
.../tsfile/read/common/block/column/IntColumn.java | 1 +
.../read/common/block/column/IntColumnBuilder.java | 1 +
.../read/common/block/column/LongColumn.java | 1 +
.../common/block/column/LongColumnBuilder.java | 1 +
.../read/common/block/column/NullColumn.java | 5 +-
.../block/column/RunLengthEncodedColumn.java | 1 +
.../read/common/block/column/TimeColumn.java | 1 +
.../common/block/column/TimeColumnBuilder.java | 1 +
.../read/common/parser/PathNodesGenerator.java | 12 +-
.../tsfile/read/common/parser/PathParseError.java | 1 +
.../tsfile/read/common/parser/PathVisitor.java | 1 +
.../iotdb/tsfile/read/common/type/TypeFactory.java | 5 +
.../read/controller/CachedChunkLoaderImpl.java | 1 +
.../iotdb/tsfile/read/controller/IChunkLoader.java | 1 +
.../read/controller/IChunkMetadataLoader.java | 5 +-
.../tsfile/read/controller/IMetadataQuerier.java | 1 +
.../read/controller/MetadataQuerierByFileImpl.java | 11 +-
.../tsfile/read/expression/ExpressionType.java | 1 +
.../tsfile/read/expression/IBinaryExpression.java | 1 +
.../iotdb/tsfile/read/expression/IExpression.java | 1 +
.../tsfile/read/expression/IUnaryExpression.java | 1 +
.../tsfile/read/expression/QueryExpression.java | 1 +
.../read/expression/impl/BinaryExpression.java | 9 +-
.../read/expression/impl/GlobalTimeExpression.java | 1 +
.../expression/impl/SingleSeriesExpression.java | 1 +
.../read/expression/util/ExpressionOptimizer.java | 3 +-
.../read/expression/util/ExpressionPrinter.java | 60 --
.../iotdb/tsfile/read/filter/GroupByFilter.java | 1 +
.../tsfile/read/filter/GroupByMonthFilter.java | 1 +
.../read/filter/PredicateRemoveNotRewriter.java | 4 +
.../iotdb/tsfile/read/filter/TimeFilter.java | 4 +-
.../iotdb/tsfile/read/filter/ValueFilter.java | 161 +---
.../tsfile/read/filter/basic/BinaryFilter.java | 8 +-
.../iotdb/tsfile/read/filter/basic/Filter.java | 1 +
.../tsfile/read/filter/basic/UnaryFilter.java | 6 +-
.../tsfile/read/filter/factory/FilterFactory.java | 5 +
.../tsfile/read/filter/factory/FilterType.java | 1 +
.../tsfile/read/filter/operator/AndFilter.java | 9 +-
.../iotdb/tsfile/read/filter/operator/Eq.java | 1 +
.../iotdb/tsfile/read/filter/operator/Gt.java | 1 +
.../iotdb/tsfile/read/filter/operator/GtEq.java | 1 +
.../iotdb/tsfile/read/filter/operator/In.java | 1 +
.../iotdb/tsfile/read/filter/operator/Like.java | 24 +-
.../iotdb/tsfile/read/filter/operator/Lt.java | 1 +
.../iotdb/tsfile/read/filter/operator/LtEq.java | 1 +
.../iotdb/tsfile/read/filter/operator/NotEq.java | 1 +
.../tsfile/read/filter/operator/NotFilter.java | 1 +
.../tsfile/read/filter/operator/OrFilter.java | 9 +-
.../iotdb/tsfile/read/filter/operator/Regexp.java | 1 +
.../query/dataset/DataSetWithTimeGenerator.java | 3 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 17 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 18 +-
.../query/executor/ExecutorWithTimeGenerator.java | 5 +-
.../tsfile/read/query/executor/QueryExecutor.java | 1 +
.../tsfile/read/query/executor/TsFileExecutor.java | 1 +
.../read/query/timegenerator/TimeGenerator.java | 1 +
.../query/timegenerator/TsFileTimeGenerator.java | 1 +
.../read/query/timegenerator/node/AndNode.java | 1 +
.../read/query/timegenerator/node/LeafNode.java | 1 +
.../tsfile/read/query/timegenerator/node/Node.java | 1 +
.../read/query/timegenerator/node/NodeType.java | 1 +
.../read/query/timegenerator/node/OrNode.java | 1 +
.../tsfile/read/reader/IAlignedPageReader.java | 1 +
.../iotdb/tsfile/read/reader/IBatchReader.java | 1 +
.../iotdb/tsfile/read/reader/IChunkReader.java | 1 +
.../iotdb/tsfile/read/reader/IPageReader.java | 4 +-
.../iotdb/tsfile/read/reader/IPointReader.java | 1 +
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 1 +
.../iotdb/tsfile/read/reader/TsFileInput.java | 1 +
.../read/reader/chunk/AlignedChunkReader.java | 10 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 4 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 7 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 8 +-
.../tsfile/read/reader/page/TimePageReader.java | 1 +
.../tsfile/read/reader/page/ValuePageReader.java | 1 +
.../reader/series/AbstractFileSeriesReader.java | 2 +-
.../read/reader/series/FileSeriesReader.java | 1 +
.../reader/series/FileSeriesReaderByTimestamp.java | 1 +
.../read/reader/series/PaginationController.java | 3 +-
.../java/org/apache/iotdb/tsfile/utils/Loader.java | 11 +-
.../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 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 7 +-
.../tsfile/write/TsFileIntegrityCheckingTool.java | 2 +-
.../writer/TsFileIOWriterMemoryControlTest.java | 6 +-
1031 files changed, 9637 insertions(+), 11874 deletions(-)
delete mode 100644 .github/workflows/e2e.yml
delete mode 100644 .github/workflows/sync.yml
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/PipeHeartbeatRPCHandler.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/PipeHeartbeatScheduler.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/filter/QueryFilterOptimizationException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/SchemaExecutionException.java
(72%)
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%)
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
server/src/main/java/org/apache/iotdb/db/{exception/sql/MeasurementNotExistException.java
=> engine/compaction/schedule/constant/CompactionIoDataType.java} (75%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/metadata/SeriesNumberOverflowException.java
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/mpp/plan/TestRPCClient.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/schemaregion/SchemaEngineMode.java
=> mpp/plan/expression/UnknownExpressionTypeException.java} (75%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/FilterNullPolicy.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%)
delete mode 100644 server/src/test/resources/testcontainers.properties
delete mode 100644 test/e2e/base/docker-compose.yaml
delete mode 100644 test/e2e/cases/README.md
delete mode 100644 test/e2e/cases/cli/README.md
delete mode 100755 test/e2e/cases/cli/cleanup.sh
delete mode 100644 test/e2e/cases/cli/docker-compose.yaml
delete mode 100644 test/e2e/cases/cli/res/init.sql
delete mode 100755 test/e2e/cases/cli/run.sh
delete mode 100644 testcontainer/Readme.md
delete mode 100644 testcontainer/pom.xml
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/Cases.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/ClusterIT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/ClusterSessionSimpleIT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/SingleNodeIT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/node1/OneNodeClusterIT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes3/AbstractThreeNodeClusterIT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes3/ThreeNodeCluster1IT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes3/ThreeNodeCluster2IT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/AbstractFiveNodeClusterIT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster1IT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster2IT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster4IT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sync/SyncIT.java
delete mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sync/SyncWeakNetworkIT.java
delete mode 100644
testcontainer/src/test/java/org/testcontainers/containers/NoProjectNameDockerComposeContainer.java
delete mode 100644 testcontainer/src/test/resources/iotdb-datanode.properties
delete mode 100644 testcontainer/src/test/resources/logback-container.xml
delete mode 100644 testcontainer/src/test/resources/logback.xml
delete mode 100644 testcontainer/src/test/resources/sync/docker-compose.yaml
delete mode 100644 testcontainer/src/tool/README.md
delete mode 100644 testcontainer/src/tool/parser.py
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/ExceptionBatchData.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlockMetadata.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/expression/util/ExpressionPrinter.java
