This is an automated email from the ASF dual-hosted git repository. yongzao pushed a change to branch greedy-copy-set in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 49192eaed45 Merge branch 'greedy-copy-set' of https://github.com/apache/iotdb into greedy-copy-set discard 67e6f67210f code smell discard 8fe672fcfad Finish omit b2be051adb0 fix the error when last query non-writble view with same sensors (#11658) omit 9eb60a9faa8 Bump logback.version from 1.3.12 to 1.3.13 (#11653) omit 0144133481c PBTree Improvement: WrappedSegment Layout Revision for Reduced GC Overhead (#11652) omit 636bd465714 delete data and files together omit 35c29e16cfc Fix concurrent bug During Heartbeat and Region Creation (#11656) omit 477e8e5480c [IOTDB-6248] Fix the connection will close when WebSocketConnectorServer doesn't response in Flink-CDC-Connector & Fix multiple cdc tasks cannot run properly at the same time (#11598) omit 2aadeb4a93c [IOTDB-6259] Bump ratis version to 3.0.0 (#11618) omit d0918bd367a Temporarily ignore testPBTreeMemoryStatistics (#11648) omit 0cc841b7639 Fix close method of TopOperator and make close method of Operator an interface omit 0dcb04086e3 Get correct TsFileSequenceReader from FileReaderManager omit 2a1fad8c871 Bump ch.qos.logback:logback-classic from 1.3.11 to 1.3.12 (#11645) omit 80c5b2ad138 auth.add IT for create role/user with identifier. omit 919a24f3d37 fix:grafana plugin build omit 431e9b81e80 Fix error judgement for MainFragmentLocatedRegion and MostlyUsedDataRegion in distributed plan omit afc6c7f916f Only root can alter template omit 7b82a00764d Fix compaction selector ut running time is too long (#11635) omit 259d3fcd618 Fix npe in TopKOperator when topKResult is null omit bb20b5f3f8f [RatisConsensus] Cache group id in the write/read critical path (#11615) omit f68fdaea159 Bump org.springframework.boot:spring-boot from 2.7.15 to 2.7.18 (#11634) omit 57b9194a459 Optimizing the Binary comparison method in CompareBinaryColumnTransformer omit 34fc2237819 Pipe: degrade exception to log when executing pipe procedure operations on DN to enhance the availability (#11623) omit 4fa35d57cd0 Pipe: Implement down-sampling-processor plugin for reducing the amount of data transferred during data sync (#11557) omit 3b4fb7b6d96 [IOTDB-6257] Safely Delete IoT WAL with LastFlushedIndex To Support Kill -9 (#11614) omit 2d8b9550a2c [RatisConsensus] Fix ReadRecoverTest CI failure (#11616) omit 27d265e597a Adjust series_partition_slot_num to series_slot_num in the response message (#11628) omit 2253eedef80 Fix query return unexpected result with authority omit cac7a525776 Fix follower data may out of order (#11625) omit f34e950d0d1 Fix concurrent bug in PartitonCache omit 1a52ca3822d Pipe IT: Add tests for iotdb-legacy-pipe-sink & Add forced-log & file mode tests for real-time mode & Refactor ITs (#11617) omit c7ab4723eaa Use min(limt, page size) as the init capacity of result block omit b5214cbca03 [IOTDB-6255] Scatter width metric (#11609) omit ed8595aae03 Pipe: add async connector retry queue / cache hit and request count / commit queue metrics & initialize pipe metrics on CN (#11601) omit fdda945f178 Rename THeartbeat to TDataNodeHeart (#11603) omit fa7fc93b040 [IOTDB-6251] Make read in SchemaRegion linearizable by default (#11571) omit 7a17343a569 To adapt activation (#11613) omit dcb6d8e3caa Fix explain error when align by device + template omit 028a06f9c6b Use `Expression` to represent predicate in FE & Refactor `tsfile/read/filter` module omit fa3612d96ad Optimize memory usage of fetchSchema when inserting data (#11591) omit a41439e2ab6 Fix Some Code Smells of Node Commons Module (#11604) omit 9619aac1988 [IOTDB-6256] Fix FLUSH deadlock omit a5b668ba67c Pipe: introduce global cache for TsFile metadatas and support TTL of Pipe TsFile (#11240) omit 022bd455f89 Fix fetch nested device with template will miss some devices (#11597) omit a216d372d1c Fix Some Code Smells of Examples Module (#11607) omit cb253412e25 Asynchronously make memtable checkpoints for wal (#11556) omit d0c88113033 fix iotdb-common.sh to check port (#11524) omit f94b365350d Fix Some Code Smells of DataNode Module (#11606) omit 0f18f38b11d Improve Statistics deserialization omit 89708420e16 Use template to reduce the repeated creation and serialization in align by device query omit 7f425fc586d Fix flasky ITs (#11574) omit 278ee6570ea Fix AutoCreateSchema using template without WRITE_SCHEMA omit c3c5cbc011e [IOTDB-6254] Fix limit push down bug in aligned sensor omit 023f5f89103 Accelerate the process of PlanNode to Operator omit 3ca454e2fb9 Add isDebugEnable judgement for each LOGGER.DEBUG omit 7640df9a2b9 Pipe: Introduce PipeEventCommitManager to manage event commit order to avoid losing data during parallel connector scheduling (#11489) omit e17d9eb1795 [IOTDB-6249] Load: Streaming read timeseries metadata from tsfile when auto creating or verifying schema (#11540) omit 07b6875ed28 Fix Some Code Smells of Client Session Module (#11589) omit a1cdd6851ad Fix Some Code Smells of DataNode Module (#11590) omit 72b528cf533 [IOTDB-6253] Use template to accelerate front-end query performance omit a61ee4cf6e0 Fix some code smells (#11587) omit 13ff9c8cf01 [IOTDB-6244] Add built-in variance and standard deviation aggregator. (#11581) omit b2b17d5aa02 Fix some code smells of JDBC module (#11588) omit cba948251b6 Fix some code smells for integration test (#11583) omit b3b6a32d8ee Fix insertTablets API didn't return schema validation error (#11577) omit b72b5b1d01c Fix construct of PartialPath in Compaction (#11579) omit 0acd405bc0c Remove wrong TimeSliceAllocator (#11569) omit d988ea4f30a fix auth upgrade. omit 20cb7295f4c Modify compaction schedule for insertion compaction (#11582) omit e38f7d9c4e8 Fix query data with authority return unexpected result #11576 omit 2db45ac660a Fix some code smells (#11575) omit 27637120a72 Pipe: skip pipe CN meta sync after successful synchronization when having no pipe (#11532) omit 5ad07424552 Optimize fetch template schema (#11566) This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/greedy-copy-set (98ff8b30a5c) \ O -- O -- O (49192eaed45) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .github/workflows/grafana-plugin.yml | 2 +- .../apache/iotdb/flink/FlinkTsFileBatchSink.java | 4 +- .../apache/iotdb/flink/FlinkTsFileBatchSource.java | 4 +- .../apache/iotdb/flink/FlinkTsFileStreamSink.java | 4 +- .../iotdb/flink/FlinkTsFileStreamSource.java | 4 +- .../java/org/apache/iotdb/flink/TsFileUtils.java | 4 +- .../iotdb/hadoop/tsfile/TSFMRReadExample.java | 8 +- .../iotdb/hadoop/tsfile/TSMRWriteExample.java | 8 +- .../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 6 +- .../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 4 +- .../main/java/org/apache/iotdb/JDBCExample.java | 4 +- .../org/apache/iotdb/PrepareStatementDemo.java | 6 +- .../main/java/org/apache/iotdb/kafka/Consumer.java | 8 +- .../org/apache/iotdb/kafka/ConsumerThread.java | 4 +- .../main/java/org/apache/iotdb/kafka/Producer.java | 4 +- .../java/org/apache/iotdb/CountPointProcessor.java | 3 +- .../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 4 + .../org/apache/iotdb/pulsar/PulsarConsumer.java | 4 +- .../apache/iotdb/pulsar/PulsarConsumerThread.java | 4 +- .../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 6 +- .../apache/iotdb/rabbitmq/RabbitMQProducer.java | 4 +- .../main/java/org/apache/iotdb/HttpExample.java | 20 +- .../main/java/org/apache/iotdb/HttpsExample.java | 20 +- .../src/main/java/org/apache/iotdb/SSLClient.java | 4 +- .../apache/iotdb/rocketmq/RocketMQConsumer.java | 6 +- .../apache/iotdb/rocketmq/RocketMQProducer.java | 5 +- example/schema/pom.xml | 2 +- .../org/apache/iotdb/schema/PathCheckExample.java | 26 +- .../org/apache/iotdb/DataMigrationExample.java | 14 +- .../iotdb/HybridTimeseriesSessionExample.java | 7 +- .../org/apache/iotdb/SessionConcurrentExample.java | 12 +- .../java/org/apache/iotdb/SessionPoolExample.java | 6 +- .../iotdb/SyntaxConventionRelatedExample.java | 7 +- .../iotdb/tsfile/TsFileForceAppendWrite.java | 8 +- .../java/org/apache/iotdb/tsfile/TsFileRead.java | 10 +- .../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 4 +- .../iotdb/tsfile/TsFileWriteWithTSRecord.java | 4 +- .../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 4 +- .../iotdb/it/env/cluster/ClusterConstant.java | 2 +- .../org/apache/iotdb/it/utils/TsFileGenerator.java | 14 +- .../constant/BuiltinAggregationFunctionEnum.java | 6 - .../apache/iotdb/itbase/constant/TestConstant.java | 24 - .../iotdb/itbase/runtime/ClusterTestStatement.java | 10 +- .../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 4 +- .../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 34 - .../db/it/aggregation/IoTDBAggregationIT.java | 10 +- .../aggregation/IoTDBAggregationSmallDataIT.java | 4 +- .../iotdb/db/it/aggregation/IoTDBVarianceIT.java | 733 ------------------- .../IoTDBAlignByDeviceWithTemplateIT.java | 607 ---------------- .../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 7 - .../aligned/IoTDBAlignedOffsetLimitPushDownIT.java | 151 ---- .../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 100 +-- .../org/apache/iotdb/db/it/utils/TestUtils.java | 53 -- .../iotdb/libudf/it/dprofile/DProfileIT.java | 27 + .../iotdb/pipe/PipeEnvironmentException.java | 31 - .../apache/iotdb/pipe/it/AbstractPipeDualIT.java | 60 -- .../apache/iotdb/pipe/it/IoTDBPipeClusterIT.java | 254 +++---- .../pipe/it/IoTDBPipeConnectorParallelIT.java | 77 +- ...ipeDataSinkIT.java => IoTDBPipeDataSyncIT.java} | 157 ++-- .../apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java | 62 +- .../apache/iotdb/pipe/it/IoTDBPipeProcessorIT.java | 104 --- .../apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java | 61 +- .../iotdb/pipe/it/IoTDBPipeSingleEnvDemoIT.java | 16 +- .../iotdb/pipe/it/IoTDBPipeSwitchStatusIT.java | 29 +- .../apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java | 29 +- .../it/{ => extractor}/IoTDBPipeExtractorIT.java | 414 +++++++---- .../iotdb/session/it/IoTDBSessionSimpleIT.java | 64 +- .../java/org/apache/iotdb/pipe/api/access/Row.java | 10 +- .../java/org/apache/iotdb/tool/ExportTsFile.java | 8 +- .../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 2 +- .../org/apache/iotdb/jdbc/IoTDBDataSource.java | 6 +- .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 86 ++- .../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 2 +- .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 6 +- .../java/org/apache/iotdb/jdbc/StringUtils.java | 8 +- .../org/apache/iotdb/session/pool/SessionPool.java | 347 ++++----- .../flink/sql/client/IoTDBWebSocketClient.java | 20 +- .../sql/factory/IoTDBDynamicTableFactory.java | 6 - .../flink/sql/function/IoTDBCDCSourceFunction.java | 84 ++- iotdb-connector/grafana-plugin/backend-compile.bat | 2 +- iotdb-connector/grafana-plugin/backend-compile.sh | 31 +- iotdb-connector/grafana-plugin/go.mod | 35 +- .../iotdb/spark/tsfile/NarrowConverter.scala | 2 +- .../apache/iotdb/spark/tsfile/WideConverter.scala | 2 +- .../async/AsyncDataNodeHeartbeatClientPool.java | 4 +- .../heartbeat/DataNodeHeartbeatHandler.java | 6 +- .../iotdb/confignode/manager/ConfigManager.java | 2 +- .../iotdb/confignode/manager/ProcedureManager.java | 21 - .../load/cache/node/NodeHeartbeatSample.java | 7 +- .../manager/load/cache/node/NodeStatistics.java | 4 +- .../manager/load/service/HeartbeatService.java | 8 +- .../iotdb/confignode/manager/node/NodeManager.java | 9 - .../manager/partition/PartitionManager.java | 21 - .../manager/partition/PartitionMetrics.java | 36 - .../manager/pipe/metric/PipeConfigNodeMetrics.java | 47 -- .../manager/pipe/metric/PipeProcedureMetrics.java | 97 --- .../manager/pipe/metric/PipeTaskInfoMetrics.java | 99 --- .../manager/pipe/runtime/PipeMetaSyncer.java | 52 +- .../manager/pipe/task/PipeTaskCoordinator.java | 27 - .../iotdb/confignode/persistence/AuthorInfo.java | 174 ++--- .../confignode/persistence/node/NodeInfo.java | 29 +- .../partition/DatabasePartitionTable.java | 29 - .../persistence/partition/PartitionInfo.java | 24 - .../confignode/persistence/pipe/PipeTaskInfo.java | 65 -- .../impl/pipe/AbstractOperatePipeProcedureV2.java | 11 - .../procedure/impl/pipe/PipeTaskOperation.java | 24 +- .../impl/pipe/task/CreatePipeProcedureV2.java | 19 +- .../impl/pipe/task/DropPipeProcedureV2.java | 8 +- .../impl/pipe/task/StartPipeProcedureV2.java | 20 +- .../impl/pipe/task/StopPipeProcedureV2.java | 19 +- .../iotdb/confignode/service/ConfigNode.java | 3 - .../router/priority/GreedyPriorityTest.java | 4 +- .../priority/LeaderPriorityBalancerTest.java | 4 +- .../manager/load/cache/NodeCacheTest.java | 8 +- .../confignode/persistence/AuthorInfoTest.java | 134 ++-- iotdb-core/consensus/pom.xml | 10 +- .../apache/iotdb/consensus/config/RatisConfig.java | 2 +- ...ption.java => RatisUnderRecoveryException.java} | 11 +- .../consensus/iot/IoTConsensusServerImpl.java | 23 +- .../consensus/iot/IoTConsensusServerMetrics.java | 2 +- .../consensus/iot/client/DispatchLogHandler.java | 15 +- .../iot/logdispatcher/IndexController.java | 2 + .../consensus/iot/logdispatcher/LogDispatcher.java | 14 +- .../service/IoTConsensusRPCServiceProcessor.java | 29 +- .../ratis/ApplicationStateMachineProxy.java | 17 +- .../iotdb/consensus/ratis/RatisConsensus.java | 34 +- .../consensus/ratis/metrics/CounterProxy.java | 6 +- .../iotdb/consensus/ratis/metrics/GaugeProxy.java | 24 +- .../ratis/metrics/IoTDBMetricRegistry.java | 121 +++- .../ratis/metrics/MetricRegistryManager.java | 2 +- .../ratis/metrics/RatisMetricsManager.java | 20 +- .../iotdb/consensus/ratis/metrics/TimerProxy.java | 32 +- .../apache/iotdb/consensus/ratis/utils/Utils.java | 27 +- .../apache/iotdb/consensus/iot/ReplicateTest.java | 30 +- .../iotdb/consensus/ratis/RecoverReadTest.java | 12 +- .../apache/iotdb/consensus/ratis/TestUtils.java | 4 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 80 +-- .../db/consensus/SchemaRegionConsensusImpl.java | 1 - .../dataregion/DataExecutionVisitor.java | 21 +- .../dataregion/DataRegionStateMachine.java | 13 +- .../IoTConsensusDataRegionStateMachine.java | 7 +- .../db/pipe/agent/plugin/PipePluginAgent.java | 6 +- .../agent/plugin/PipeProcessorConstructor.java | 3 - .../agent/runtime/PipePeriodicalJobExecutor.java | 65 +- .../db/pipe/agent/runtime/PipeRuntimeAgent.java | 22 - .../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 6 +- .../db/pipe/commit/PipeEventCommitManager.java | 110 --- .../iotdb/db/pipe/commit/PipeEventCommitter.java | 98 --- .../config/constant/PipeProcessorConstant.java | 12 - .../env/PipeTaskConnectorRuntimeEnvironment.java | 27 - .../env/PipeTaskExtractorRuntimeEnvironment.java | 9 +- .../env/PipeTaskProcessorRuntimeEnvironment.java | 27 - .../plugin/env/PipeTaskRuntimeEnvironment.java | 8 +- ...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 49 ++ ...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 45 +- .../builder/PipeTransferBatchReqBuilder.java | 45 -- .../request/PipeTransferTabletBatchReq.java | 2 +- .../request/PipeTransferTabletRawReq.java | 2 +- .../protocol/opcua/OpcUaKeyStoreLoader.java | 5 +- .../protocol/opcua/OpcUaServerBuilder.java | 4 +- .../thrift/async/IoTDBThriftAsyncConnector.java | 119 +-- .../PipeTransferTabletBatchEventHandler.java | 13 +- .../PipeTransferTabletInsertNodeEventHandler.java | 3 +- .../PipeTransferTabletInsertionEventHandler.java | 39 +- .../handler/PipeTransferTabletRawEventHandler.java | 3 +- .../PipeTransferTsFileInsertionEventHandler.java | 20 +- .../protocol/websocket/WebSocketConnector.java | 140 ++-- .../websocket/WebSocketConnectorServer.java | 488 ++++--------- .../apache/iotdb/db/pipe/event/EnrichedEvent.java | 39 +- .../event/common/heartbeat/PipeHeartbeatEvent.java | 10 +- .../iotdb/db/pipe/event/common/row/PipeRow.java | 5 - .../db/pipe/event/common/row/PipeRowCollector.java | 8 +- .../tablet/PipeInsertNodeTabletInsertionEvent.java | 18 +- .../common/tablet/PipeRawTabletInsertionEvent.java | 16 +- .../tablet/TabletInsertionDataContainer.java | 10 +- .../common/tsfile/PipeTsFileInsertionEvent.java | 17 +- .../tsfile/TsFileInsertionDataContainer.java | 66 +- .../db/pipe/event/realtime/PipeRealtimeEvent.java | 8 +- .../execution/executor/PipeSubtaskExecutor.java | 1 - .../pipe/extractor/IoTDBDataRegionExtractor.java | 4 +- .../PipeHistoricalDataRegionTsFileExtractor.java | 62 +- .../realtime/PipeRealtimeDataRegionExtractor.java | 5 +- .../realtime/assigner/PipeDataRegionAssigner.java | 2 +- .../listener/PipeInsertionDataNodeListener.java | 10 +- .../iotdb/db/pipe/metric/PipeConnectorMetrics.java | 22 - .../db/pipe/metric/PipeEventCommitMetrics.java | 141 ---- .../{PipeDataNodeMetrics.java => PipeMetrics.java} | 16 +- .../pipe/metric/PipeWALInsertNodeCacheMetrics.java | 24 - .../downsampling/DownSamplingProcessor.java | 213 ------ .../downsampling/PartialPathLastTimeCache.java | 111 --- .../legacy/IoTDBLegacyPipeReceiverAgent.java | 11 +- .../receiver/legacy/loader/DeletionLoader.java | 5 +- .../pipe/receiver/legacy/loader/TsFileLoader.java | 5 +- .../receiver/thrift/IoTDBThriftReceiverV1.java | 2 +- .../db/pipe/resource/memory/PipeMemoryBlock.java | 16 +- .../db/pipe/resource/memory/PipeMemoryManager.java | 37 - .../pipe/resource/memory/PipeMemoryWeighUtil.java | 58 -- .../pipe/resource/tsfile/PipeTsFileResource.java | 217 ------ .../resource/tsfile/PipeTsFileResourceManager.java | 210 ++---- .../db/pipe/resource/wal/PipeWALResource.java | 4 +- .../pipe/resource/wal/PipeWALResourceManager.java | 67 +- .../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 3 +- .../pipe/task/connection/PipeEventCollector.java | 10 +- .../db/pipe/task/stage/PipeTaskConnectorStage.java | 17 +- .../db/pipe/task/stage/PipeTaskProcessorStage.java | 8 +- .../iotdb/db/pipe/task/stage/PipeTaskStage.java | 6 +- .../subtask/connector/PipeConnectorSubtask.java | 17 - .../connector/PipeConnectorSubtaskLifeCycle.java | 51 +- .../connector/PipeConnectorSubtaskManager.java | 32 +- .../protocol/thrift/impl/ClientRPCServiceImpl.java | 8 +- .../impl/DataNodeInternalRPCServiceImpl.java | 8 +- .../db/queryengine/common/MPPQueryContext.java | 15 - .../common/schematree/ClusterSchemaTree.java | 35 +- .../queryengine/common/schematree/ISchemaTree.java | 8 - .../visitor/SchemaTreeVisitorFactory.java | 5 - .../execution/aggregation/Accumulator.java | 9 - .../execution/aggregation/AccumulatorFactory.java | 10 - .../execution/aggregation/AvgAccumulator.java | 13 - .../execution/aggregation/CountAccumulator.java | 9 - .../execution/aggregation/SumAccumulator.java | 9 - .../execution/aggregation/VarianceAccumulator.java | 273 ------- .../slidingwindow/SlidingWindowAggregator.java | 34 + .../SlidingWindowAggregatorFactory.java | 6 - .../SmoothQueueSlidingWindowAggregator.java | 4 +- .../db/queryengine/execution/driver/Driver.java | 4 + .../execution/driver/DriverContext.java | 8 + .../execution/exchange/MPPDataExchangeManager.java | 174 ++--- .../execution/exchange/sink/LocalSinkChannel.java | 39 +- .../execution/exchange/sink/ShuffleSinkHandle.java | 27 +- .../execution/exchange/sink/SinkChannel.java | 73 +- .../exchange/source/LocalSourceHandle.java | 49 +- .../execution/exchange/source/SourceHandle.java | 80 +-- .../fragment/FragmentInstanceContext.java | 31 +- .../fragment/FragmentInstanceExecution.java | 3 +- .../fragment/FragmentInstanceManager.java | 2 +- .../queryengine/execution/memory/MemoryPool.java | 6 +- .../execution/operator/AbstractOperator.java | 8 +- .../queryengine/execution/operator/Operator.java | 12 +- .../execution/operator/OperatorContext.java | 12 +- .../execution/operator/process/TopKOperator.java | 35 +- .../operator/process/last/LastQueryUtil.java | 8 +- .../operator/schema/SchemaFetchScanOperator.java | 13 +- .../source/AbstractDataSourceOperator.java | 15 - .../AbstractSeriesAggregationScanOperator.java | 19 +- .../operator/source/AlignedSeriesScanOperator.java | 34 +- .../operator/source/AlignedSeriesScanUtil.java | 17 +- .../operator/source/LastCacheScanOperator.java | 5 - .../operator/source/SeriesScanOperator.java | 26 +- .../execution/operator/source/SeriesScanUtil.java | 8 +- .../operator/source/ShowQueriesOperator.java | 5 - .../schedule/DriverTaskTimeoutSentinelThread.java | 2 +- .../ITimeSliceAllocator.java} | 13 +- .../timer/RuleBasedTimeSliceAllocator.java | 69 ++ .../iotdb/db/queryengine/plan/Coordinator.java | 1 + .../db/queryengine/plan/analyze/Analysis.java | 102 +-- .../queryengine/plan/analyze/AnalyzeVisitor.java | 174 ++--- .../plan/analyze/ExpressionAnalyzer.java | 217 ++++++ .../plan/analyze/ExpressionTypeAnalyzer.java | 11 - .../queryengine/plan/analyze/ExpressionUtils.java | 105 ++- .../plan/analyze/LoadTsfileAnalyzer.java | 233 +++--- .../queryengine/plan/analyze/PredicateUtils.java | 347 --------- .../queryengine/plan/analyze/TemplatedAnalyze.java | 408 ----------- .../db/queryengine/plan/analyze/TemplatedInfo.java | 275 ------- .../db/queryengine/plan/analyze/TypeProvider.java | 40 +- .../analyze/cache/partition/PartitionCache.java | 12 +- .../analyze/schema/AutoCreateSchemaExecutor.java | 25 +- .../analyze/schema/ClusterSchemaFetchExecutor.java | 17 +- .../plan/analyze/schema/ClusterSchemaFetcher.java | 13 +- .../plan/analyze/schema/ISchemaFetcher.java | 6 +- .../queryengine/plan/execution/QueryExecution.java | 1 - .../config/executor/ClusterConfigTaskExecutor.java | 3 +- .../memory/StatementMemorySourceVisitor.java | 3 +- .../db/queryengine/plan/expression/Expression.java | 5 - .../plan/expression/ExpressionFactory.java | 53 -- .../plan/expression/ExpressionType.java | 3 +- .../expression/other/GroupByTimeExpression.java | 159 ---- .../plan/expression/unary/InExpression.java | 15 +- .../plan/expression/unary/IsNullExpression.java | 5 + .../plan/expression/unary/LikeExpression.java | 84 ++- .../plan/expression/unary/LogicNotExpression.java | 5 + .../plan/expression/unary/NegationExpression.java | 5 + .../plan/expression/unary/RegularExpression.java | 31 +- .../plan/expression/unary/UnaryExpression.java | 2 + .../plan/expression/visitor/ExpressionVisitor.java | 5 - .../visitor/TransformToViewExpressionVisitor.java | 10 +- .../ConvertPredicateToTimeFilterVisitor.java | 241 ------- .../visitor/predicate/PredicateVisitor.java | 102 --- .../visitor/predicate/ReversePredicateVisitor.java | 148 ---- .../plan/optimization/LimitOffsetPushDown.java | 8 +- .../db/queryengine/plan/parser/ASTVisitor.java | 12 +- .../plan/planner/LocalExecutionPlanContext.java | 26 +- .../plan/planner/LogicalPlanBuilder.java | 93 ++- .../plan/planner/LogicalPlanVisitor.java | 15 +- .../plan/planner/OperatorTreeGenerator.java | 259 ++++--- .../plan/planner/SubPlanTypeExtractor.java | 13 +- .../plan/planner/TemplatedLogicalPlan.java | 206 ------ .../plan/planner/TemplatedLogicalPlanBuilder.java | 142 ---- .../distribution/DistributionPlanContext.java | 5 - .../planner/distribution/ExchangeNodeAdder.java | 44 +- .../SimpleFragmentParallelPlanner.java | 6 +- .../plan/planner/distribution/SourceRewriter.java | 46 +- .../distribution/WriteFragmentParallelPlanner.java | 6 +- .../plan/planner/plan/FragmentInstance.java | 41 +- .../plan/planner/plan/PlanFragment.java | 36 +- .../plan/planner/plan/node/PlanGraphPrinter.java | 9 +- .../plan/planner/plan/node/PlanNode.java | 18 +- .../plan/planner/plan/node/PlanNodeType.java | 17 - .../plan/node/load/LoadSingleTsFileNode.java | 4 +- .../plan/node/load/LoadTsFilePieceNode.java | 8 +- .../node/metedata/read/SchemaFetchScanNode.java | 17 +- .../plan/node/process/SingleDeviceViewNode.java | 28 - .../plan/node/process/last/LastQueryNode.java | 45 +- .../plan/node/source/AlignedLastQueryScanNode.java | 8 +- .../source/AlignedSeriesAggregationScanNode.java | 51 +- .../plan/node/source/AlignedSeriesScanNode.java | 183 +++-- .../plan/node/source/LastQueryScanNode.java | 8 +- .../plan/node/source/LastSeriesSourceNode.java | 7 - .../node/source/SeriesAggregationScanNode.java | 51 +- .../node/source/SeriesAggregationSourceNode.java | 31 +- .../planner/plan/node/source/SeriesScanNode.java | 146 ++-- .../planner/plan/node/source/SeriesSourceNode.java | 4 +- .../planner/plan/node/write/DeleteDataNode.java | 2 +- .../plan/parameter/AggregationDescriptor.java | 18 - .../planner/plan/parameter/SeriesScanOptions.java | 63 +- .../scheduler/load/LoadTsFileDispatcherImpl.java | 18 +- .../crud/InsertMultiTabletsStatement.java | 9 - .../InternalBatchActivateTemplateStatement.java | 33 +- .../statement/internal/SchemaFetchStatement.java | 11 +- .../metadata/CreateContinuousQueryStatement.java | 4 +- .../template/AlterSchemaTemplateStatement.java | 4 +- .../binary/CompareBinaryColumnTransformer.java | 33 +- .../column/ternary/BetweenColumnTransformer.java | 21 +- .../binary/CompareEqualToTransformer.java | 5 +- .../binary/CompareGreaterEqualTransformer.java | 5 +- .../binary/CompareGreaterThanTransformer.java | 5 +- .../binary/CompareLessEqualTransformer.java | 5 +- .../binary/CompareLessThanTransformer.java | 5 +- .../binary/CompareNonEqualTransformer.java | 5 +- .../transformer/ternary/BetweenTransformer.java | 15 +- .../transformation/dag/util/TransformUtils.java | 41 +- .../apache/iotdb/db/schemaengine/SchemaEngine.java | 39 +- .../schemaengine/schemaregion/ISchemaRegion.java | 5 +- .../schemaregion/impl/SchemaRegionMemoryImpl.java | 9 +- .../schemaregion/impl/SchemaRegionPBTreeImpl.java | 9 +- .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 36 +- .../mnode/iterator/AbstractTraverserIterator.java | 11 +- .../impl/mem/mnode/iterator/MNodeIterator.java | 5 - .../mtree/impl/pbtree/CachedMTreeStore.java | 21 +- .../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 36 +- .../mtree/impl/pbtree/schemafile/InternalPage.java | 18 +- .../mtree/impl/pbtree/schemafile/SchemaPage.java | 2 +- .../mtree/impl/pbtree/schemafile/Segment.java | 478 ++++++++++++ .../impl/pbtree/schemafile/WrappedSegment.java | 708 ++++-------------- .../schemaregion/mtree/traverser/Traverser.java | 25 +- .../reader/impl/TimeseriesReaderWithViewFetch.java | 3 +- .../view/visitor/TransformToExpressionVisitor.java | 10 +- .../db/service/metrics/DataNodeMetricsHelper.java | 4 +- .../iotdb/db/storageengine/StorageEngine.java | 76 +- .../iotdb/db/storageengine/buffer/ChunkCache.java | 10 +- .../db/storageengine/dataregion/DataRegion.java | 251 +------ .../impl/ReadChunkCompactionPerformer.java | 5 +- .../execute/recover/CompactionRecoverTask.java | 27 +- .../execute/utils/CompactionPathUtils.java | 40 -- .../execute/utils/MultiTsFileDeviceIterator.java | 7 +- .../fast/AlignedSeriesCompactionExecutor.java | 21 +- .../fast/NonAlignedSeriesCompactionExecutor.java | 12 +- .../compaction/schedule/CompactionWorker.java | 13 +- .../read/reader/chunk/DiskAlignedChunkLoader.java | 6 +- .../read/reader/chunk/DiskChunkLoader.java | 6 +- .../read/reader/chunk/MemAlignedPageReader.java | 4 +- .../read/reader/chunk/MemPageReader.java | 4 +- .../dataregion/wal/buffer/WALBuffer.java | 52 +- .../dataregion/wal/buffer/WALEntry.java | 3 - .../dataregion/wal/buffer/WALEntryType.java | 2 - .../dataregion/wal/buffer/WALInfoEntry.java | 2 - .../dataregion/wal/buffer/WALSignalEntry.java | 13 +- .../dataregion/wal/checkpoint/Checkpoint.java | 10 +- .../wal/checkpoint/CheckpointManager.java | 25 +- .../dataregion/wal/checkpoint/MemTableInfo.java | 10 +- .../storageengine/dataregion/wal/node/WALNode.java | 20 +- .../dataregion/wal/utils/WALInsertNodeCache.java | 18 +- .../rescon/disk/strategy/DirectoryStrategy.java | 4 +- .../MinFolderOccupiedSpaceFirstStrategy.java | 2 +- .../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 8 +- .../iotdb/db/tools/TsFileSplitByPartitionTool.java | 14 +- .../org/apache/iotdb/db/tools/TsFileSplitTool.java | 4 +- .../trigger/service/TriggerInformationUpdater.java | 2 +- .../java/org/apache/iotdb/db/utils/MemUtils.java | 4 +- .../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 8 +- .../org/apache/iotdb/db/utils/SchemaUtils.java | 24 - .../apache/iotdb/db/utils/TimeValuePairUtils.java | 62 ++ .../apache/iotdb/db/utils/TypeInferenceUtils.java | 20 +- .../iotdb/db/utils/constant/SqlConstant.java | 6 - .../db/auth/role/LocalFileRoleAccessorTest.java | 55 +- .../db/auth/role/LocalFileRoleManagerTest.java | 124 +--- .../db/auth/user/LocalFileUserAccessorTest.java | 74 +- .../db/auth/user/LocalFileUserManagerTest.java | 48 ++ .../dataregion/DataRegionStateMachineTest.java | 78 -- .../schemaRegion/SchemaRegionBasicTest.java | 46 +- .../schemaRegion/SchemaRegionTemplateTest.java | 37 +- .../schemaRegion/SchemaStatisticsTest.java | 2 - .../event/TsFileInsertionDataContainerTest.java | 2 +- .../resource/PipeTsFileResourceManagerTest.java | 18 +- .../execution/aggregation/AccumulatorTest.java | 332 --------- .../AlignedSeriesAggregationScanOperatorTest.java | 10 +- .../operator/AlignedSeriesScanOperatorTest.java | 15 +- .../execution/operator/FillOperatorTest.java | 15 - .../operator/LastQueryMergeOperatorTest.java | 20 - .../execution/operator/LinearFillOperatorTest.java | 35 - .../execution/operator/OperatorMemoryTest.java | 11 +- .../operator/RawDataAggregationOperatorTest.java | 5 +- .../SeriesAggregationScanOperatorTest.java | 10 +- .../execution/operator/TopKOperatorTest.java | 297 ++------ .../operator/UpdateLastCacheOperatorTest.java | 2 +- .../schema/SchemaFetchScanOperatorTest.java | 4 +- .../CaseWhenThenExpressionTest.java | 2 +- .../ConvertPredicateToTimeFilterTest.java | 148 ---- .../predicate/PredicateRemoveNotTest.java | 95 --- .../db/queryengine/plan/analyze/AnalyzeTest.java | 26 +- .../plan/analyze/ExpressionAnalyzerTest.java | 2 +- .../plan/analyze/FakeSchemaFetcherImpl.java | 12 +- .../plan/analyze/QueryTimePartitionTest.java | 120 ++-- .../plan/optimization/TestPlanBuilder.java | 8 +- .../plan/plan/FragmentInstanceSerdeTest.java | 4 +- .../plan/plan/QueryLogicalPlanUtil.java | 43 +- .../AlignByDeviceOrderByLimitOffsetTest.java | 4 +- .../distribution/DistributionPlannerCycleTest.java | 9 +- .../plan/plan/distribution/LastQueryTest.java | 2 +- .../queryengine/plan/plan/distribution/Util.java | 8 +- .../queryengine/plan/plan/distribution/Util2.java | 22 +- .../plan/plan/node/PlanGraphPrinterTest.java | 2 +- .../metadata/read/SchemaFetchMergeNodeTest.java | 1 - .../metadata/read/SchemaFetchScanNodeTest.java | 2 - .../node/process/AggregationNodeSerdeTest.java | 8 +- .../node/process/GroupByLevelNodeSerdeTest.java | 11 +- .../plan/node/process/GroupByTagNodeSerdeTest.java | 9 +- .../plan/plan/node/process/LimitNodeSerdeTest.java | 2 + .../plan/node/process/OffsetNodeSerdeTest.java | 2 + .../plan/plan/node/process/SortNodeSerdeTest.java | 2 + .../plan/node/process/TimeJoinNodeSerdeTest.java | 4 + .../source/SeriesAggregationScanNodeSerdeTest.java | 9 +- .../plan/node/source/SeriesScanNodeSerdeTest.java | 2 + .../db/storageengine/buffer/ChunkCacheTest.java | 6 +- .../storageengine/dataregion/DataRegionTest.java | 86 --- .../compaction/CompactionTaskManagerTest.java | 10 +- .../inner/InnerSpaceCompactionSelectorTest.java | 41 +- .../AlignedSeriesScanLimitOffsetPushDownTest.java | 4 +- .../series/SeriesScanLimitOffsetPushDownTest.java | 4 +- .../wal/checkpoint/CheckpointManagerTest.java | 7 +- .../dataregion/wal/node/WALEntryHandlerTest.java | 2 - .../dataregion/wal/node/WALNodeTest.java | 4 - .../wal/recover/WALRecoverManagerTest.java | 40 +- .../wal/utils/WALInsertNodeCacheTest.java | 9 +- .../metricsets/disk/LinuxDiskMetricsManager.java | 12 +- .../metricsets/net/LinuxNetMetricManager.java | 12 +- .../src/assembly/resources/sbin/iotdb-common.sh | 15 +- .../commons/auth/authorizer/BasicAuthorizer.java | 10 +- .../commons/auth/entity/PriPrivilegeType.java | 52 +- .../iotdb/commons/auth/role/BasicRoleManager.java | 92 ++- .../iotdb/commons/auth/user/BasicUserManager.java | 86 ++- .../apache/iotdb/commons/client/ClientManager.java | 7 +- .../iotdb/commons/concurrent/ThreadName.java | 6 +- .../apache/iotdb/commons/conf/CommonConfig.java | 2 +- .../apache/iotdb/commons/path/PathPatternTree.java | 8 - .../iotdb/commons/path/fa/dfa/PatternDFA.java | 18 +- .../iotdb/commons/path/fa/dfa/graph/DFAGraph.java | 75 +- .../pipe/plugin/builtin/BuiltinPipePlugin.java | 47 +- .../builtin/processor/DownSamplingProcessor.java | 28 - .../builtin/processor/PlaceHolderProcessor.java | 68 -- .../commons/pipe/task/meta/PipeMetaKeeper.java | 32 - .../commons/schema/node/utils/IMNodeIterator.java | 2 - .../commons/schema/tree/AbstractTreeVisitor.java | 35 - .../viewExpression/unary/LikeViewExpression.java | 20 +- .../unary/RegularViewExpression.java | 24 +- .../iotdb/commons/service/metric/enums/Metric.java | 7 - .../udf/builtin/BuiltinAggregationFunction.java | 20 +- .../org/apache/iotdb/commons/utils/AuthUtils.java | 48 +- .../org/apache/iotdb/commons/utils/FileUtils.java | 16 +- .../org/apache/iotdb/commons/utils/IOUtils.java | 28 +- .../apache/iotdb/commons/utils/SerializeUtils.java | 8 + .../apache/iotdb/commons/path/PatternDFATest.java | 10 +- ...eReaderTimeseriesMetadataIteratorException.java | 27 - .../file/metadata/enums/MetadataIndexNodeType.java | 2 +- .../file/metadata/statistics/BinaryStatistics.java | 6 +- .../iotdb/tsfile/read/TsFileSequenceReader.java | 4 - ...leSequenceReaderTimeseriesMetadataIterator.java | 220 ------ .../apache/iotdb/tsfile/read/common/TimeRange.java | 2 +- .../read/expression/impl/GlobalTimeExpression.java | 12 +- .../expression/impl/SingleSeriesExpression.java | 11 +- .../read/filter/{operator => }/GroupByFilter.java | 116 +-- .../filter/{operator => }/GroupByMonthFilter.java | 171 ++--- .../read/filter/PredicateRemoveNotRewriter.java | 30 +- .../iotdb/tsfile/read/filter/TimeFilter.java | 321 +++++++++ .../iotdb/tsfile/read/filter/ValueFilter.java | 164 +++++ .../tsfile/read/filter/basic/BinaryFilter.java | 95 +++ .../iotdb/tsfile/read/filter/basic/Filter.java | 158 +--- .../filter/basic/IDisableStatisticsTimeFilter.java | 31 - .../basic/IDisableStatisticsValueFilter.java | 33 - .../tsfile/read/filter/basic/IStatefulFilter.java | 32 - .../tsfile/read/filter/basic/ITimeFilter.java | 33 - .../tsfile/read/filter/basic/IValueFilter.java | 40 -- .../tsfile/read/filter/basic/OperatorType.java | 61 -- .../tsfile/read/filter/basic/UnaryFilter.java | 97 +++ .../tsfile/read/filter/factory/FilterFactory.java | 93 ++- .../factory/FilterSerializeId.java} | 20 +- .../tsfile/read/filter/factory/FilterType.java} | 12 +- .../tsfile/read/filter/factory/TimeFilter.java | 101 --- .../tsfile/read/filter/factory/ValueFilter.java | 168 ----- .../filter/operator/{And.java => AndFilter.java} | 54 +- .../iotdb/tsfile/read/filter/operator/Between.java | 168 +++++ .../iotdb/tsfile/read/filter/operator/Eq.java | 115 +++ .../iotdb/tsfile/read/filter/operator/Gt.java | 113 +++ .../iotdb/tsfile/read/filter/operator/GtEq.java | 113 +++ .../iotdb/tsfile/read/filter/operator/In.java | 153 ++++ .../iotdb/tsfile/read/filter/operator/Like.java | 201 ++++++ .../iotdb/tsfile/read/filter/operator/Lt.java | 113 +++ .../iotdb/tsfile/read/filter/operator/LtEq.java | 113 +++ .../iotdb/tsfile/read/filter/operator/NotEq.java | 115 +++ .../filter/operator/{Not.java => NotFilter.java} | 114 +-- .../filter/operator/{Or.java => OrFilter.java} | 144 ++-- .../iotdb/tsfile/read/filter/operator/Regexp.java | 199 +++++ .../read/filter/operator/TimeFilterOperators.java | 615 ---------------- .../read/filter/operator/ValueFilterOperators.java | 799 --------------------- .../filter/operator/base/BinaryLogicalFilter.java | 70 -- .../filter/operator/base/ColumnCompareFilter.java | 51 -- .../operator/base/ColumnPatternMatchFilter.java | 50 -- .../filter/operator/base/ColumnRangeFilter.java | 51 -- .../read/filter/operator/base/ColumnSetFilter.java | 50 -- .../tsfile/read/reader/page/AlignedPageReader.java | 103 +-- .../iotdb/tsfile/read/reader/page/PageReader.java | 18 +- .../tsfile/read/reader/page/ValuePageReader.java | 128 +--- .../org/apache/iotdb/tsfile/utils/BytesUtils.java | 10 - .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 55 +- .../org/apache/iotdb/tsfile/utils/RegexUtils.java | 92 --- .../apache/iotdb/tsfile/read/ExpressionTest.java | 2 +- .../iotdb/tsfile/read/ReadInPartitionTest.java | 4 +- .../org/apache/iotdb/tsfile/read/ReadTest.java | 4 +- .../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 4 +- .../apache/iotdb/tsfile/read/TsFileReaderTest.java | 4 +- ...quenceReaderTimeseriesMetadataIteratorTest.java | 62 -- .../tsfile/read/filter/FilterSerializeTest.java | 36 +- .../tsfile/read/filter/GroupByFilterTest.java | 4 +- .../tsfile/read/filter/GroupByMonthFilterTest.java | 67 +- .../read/filter/IExpressionOptimizerTest.java | 2 - .../read/filter/MinTimeMaxTimeFilterTest.java | 9 +- .../iotdb/tsfile/read/filter/OperatorTest.java | 2 - .../filter/PredicateRemoveNotRewriterTest.java | 109 ++- .../tsfile/read/filter/StatisticsFilterTest.java | 4 +- .../read/query/executor/QueryExecutorTest.java | 4 +- .../read/query/timegenerator/ReadWriteTest.java | 4 +- .../timegenerator/TimeGeneratorReadEmptyTest.java | 4 +- .../timegenerator/TimeGeneratorReadWriteTest.java | 4 +- .../query/timegenerator/TimeGeneratorTest.java | 4 +- .../iotdb/tsfile/read/reader/ReaderTest.java | 4 +- .../thrift-commons/src/main/thrift/common.thrift | 8 +- .../src/main/thrift/confignode.thrift | 5 - .../src/main/thrift/datanode.thrift | 8 +- library-udf/src/assembly/tools/register-UDF.bat | 1 + library-udf/src/assembly/tools/register-UDF.sh | 1 + .../dprofile/{UDAFSkew.java => UDAFStddev.java} | 10 +- pom.xml | 10 +- 561 files changed, 8757 insertions(+), 17095 deletions(-) delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBVarianceIT.java delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBAlignByDeviceWithTemplateIT.java delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedOffsetLimitPushDownIT.java delete mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/PipeEnvironmentException.java delete mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/AbstractPipeDualIT.java rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{IoTDBPipeDataSinkIT.java => IoTDBPipeDataSyncIT.java} (56%) delete mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProcessorIT.java rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => extractor}/IoTDBPipeExtractorIT.java (60%) delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeMetrics.java delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeProcedureMetrics.java delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeTaskInfoMetrics.java rename iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/{RatisReadUnavailableException.java => RatisUnderRecoveryException.java} (71%) delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/commit/PipeEventCommitManager.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/commit/PipeEventCommitter.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskConnectorRuntimeEnvironment.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskProcessorRuntimeEnvironment.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeEventCommitMetrics.java rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{PipeDataNodeMetrics.java => PipeMetrics.java} (82%) delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/DownSamplingProcessor.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/PartialPathLastTimeCache.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeighUtil.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/tsfile/PipeTsFileResource.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/VarianceAccumulator.java copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/{operator/process/ProcessOperator.java => timer/ITimeSliceAllocator.java} (76%) create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/timer/RuleBasedTimeSliceAllocator.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/PredicateUtils.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyze.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedInfo.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/other/GroupByTimeExpression.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ConvertPredicateToTimeFilterVisitor.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/PredicateVisitor.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ReversePredicateVisitor.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TemplatedLogicalPlan.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TemplatedLogicalPlanBuilder.java create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/Segment.java delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/CompactionPathUtils.java delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataRegionStateMachineTest.java rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/{serde => other}/CaseWhenThenExpressionTest.java (98%) delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/predicate/ConvertPredicateToTimeFilterTest.java delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/predicate/PredicateRemoveNotTest.java delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/DownSamplingProcessor.java delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/PlaceHolderProcessor.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/exception/TsFileSequenceReaderTimeseriesMetadataIteratorException.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReaderTimeseriesMetadataIterator.java rename iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{operator => }/GroupByFilter.java (62%) rename iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{operator => }/GroupByMonthFilter.java (66%) create mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/TimeFilter.java create mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/ValueFilter.java create mode 100755 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/BinaryFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/IDisableStatisticsTimeFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/IDisableStatisticsValueFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/IStatefulFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/ITimeFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/IValueFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/OperatorType.java create mode 100755 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/UnaryFilter.java copy iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/{query/timegenerator/node/NodeType.java => filter/factory/FilterSerializeId.java} (79%) copy iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/schedule/constant/ProcessChunkType.java => tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java} (78%) delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/TimeFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/ValueFilter.java rename iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/{And.java => AndFilter.java} (82%) mode change 100644 => 100755 create mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Between.java create mode 100755 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Eq.java create mode 100755 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Gt.java create mode 100755 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/GtEq.java create mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/In.java create mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Like.java create mode 100755 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Lt.java create mode 100755 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/LtEq.java create mode 100755 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/NotEq.java rename iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/{Not.java => NotFilter.java} (68%) mode change 100644 => 100755 rename iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/{Or.java => OrFilter.java} (55%) mode change 100644 => 100755 create mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Regexp.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/TimeFilterOperators.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/ValueFilterOperators.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/BinaryLogicalFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnCompareFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnPatternMatchFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnRangeFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnSetFilter.java delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/RegexUtils.java delete mode 100644 iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TsFileSequenceReaderTimeseriesMetadataIteratorTest.java copy library-udf/src/main/java/org/apache/iotdb/library/dprofile/{UDAFSkew.java => UDAFStddev.java} (86%)
