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
from 98ff8b30a5c code smell
add 5ad07424552 Optimize fetch template schema (#11566)
add 27637120a72 Pipe: skip pipe CN meta sync after successful
synchronization when having no pipe (#11532)
add 2db45ac660a Fix some code smells (#11575)
add e38f7d9c4e8 Fix query data with authority return unexpected result
#11576
add 20cb7295f4c Modify compaction schedule for insertion compaction
(#11582)
add d988ea4f30a fix auth upgrade.
add 0acd405bc0c Remove wrong TimeSliceAllocator (#11569)
add b72b5b1d01c Fix construct of PartialPath in Compaction (#11579)
add b3b6a32d8ee Fix insertTablets API didn't return schema validation
error (#11577)
add cba948251b6 Fix some code smells for integration test (#11583)
add b2b17d5aa02 Fix some code smells of JDBC module (#11588)
add 13ff9c8cf01 [IOTDB-6244] Add built-in variance and standard deviation
aggregator. (#11581)
add a61ee4cf6e0 Fix some code smells (#11587)
add 72b528cf533 [IOTDB-6253] Use template to accelerate front-end query
performance
add a1cdd6851ad Fix Some Code Smells of DataNode Module (#11590)
add 07b6875ed28 Fix Some Code Smells of Client Session Module (#11589)
add e17d9eb1795 [IOTDB-6249] Load: Streaming read timeseries metadata from
tsfile when auto creating or verifying schema (#11540)
add 7640df9a2b9 Pipe: Introduce PipeEventCommitManager to manage event
commit order to avoid losing data during parallel connector scheduling (#11489)
add 3ca454e2fb9 Add isDebugEnable judgement for each LOGGER.DEBUG
add 023f5f89103 Accelerate the process of PlanNode to Operator
add c3c5cbc011e [IOTDB-6254] Fix limit push down bug in aligned sensor
add 278ee6570ea Fix AutoCreateSchema using template without WRITE_SCHEMA
add 7f425fc586d Fix flasky ITs (#11574)
add 89708420e16 Use template to reduce the repeated creation and
serialization in align by device query
add 0f18f38b11d Improve Statistics deserialization
add f94b365350d Fix Some Code Smells of DataNode Module (#11606)
add d0c88113033 fix iotdb-common.sh to check port (#11524)
add cb253412e25 Asynchronously make memtable checkpoints for wal (#11556)
add a216d372d1c Fix Some Code Smells of Examples Module (#11607)
add 022bd455f89 Fix fetch nested device with template will miss some
devices (#11597)
add a5b668ba67c Pipe: introduce global cache for TsFile metadatas and
support TTL of Pipe TsFile (#11240)
add 9619aac1988 [IOTDB-6256] Fix FLUSH deadlock
add a41439e2ab6 Fix Some Code Smells of Node Commons Module (#11604)
add fa3612d96ad Optimize memory usage of fetchSchema when inserting data
(#11591)
add 028a06f9c6b Use `Expression` to represent predicate in FE & Refactor
`tsfile/read/filter` module
add dcb6d8e3caa Fix explain error when align by device + template
add 7a17343a569 To adapt activation (#11613)
add fa7fc93b040 [IOTDB-6251] Make read in SchemaRegion linearizable by
default (#11571)
add fdda945f178 Rename THeartbeat to TDataNodeHeart (#11603)
add ed8595aae03 Pipe: add async connector retry queue / cache hit and
request count / commit queue metrics & initialize pipe metrics on CN (#11601)
add b5214cbca03 [IOTDB-6255] Scatter width metric (#11609)
add c7ab4723eaa Use min(limt, page size) as the init capacity of result
block
add 1a52ca3822d Pipe IT: Add tests for iotdb-legacy-pipe-sink & Add
forced-log & file mode tests for real-time mode & Refactor ITs (#11617)
add f34e950d0d1 Fix concurrent bug in PartitonCache
add cac7a525776 Fix follower data may out of order (#11625)
add 2253eedef80 Fix query return unexpected result with authority
add 27d265e597a Adjust series_partition_slot_num to series_slot_num in the
response message (#11628)
add 2d8b9550a2c [RatisConsensus] Fix ReadRecoverTest CI failure (#11616)
add 3b4fb7b6d96 [IOTDB-6257] Safely Delete IoT WAL with LastFlushedIndex
To Support Kill -9 (#11614)
add 4fa35d57cd0 Pipe: Implement down-sampling-processor plugin for
reducing the amount of data transferred during data sync (#11557)
add 34fc2237819 Pipe: degrade exception to log when executing pipe
procedure operations on DN to enhance the availability (#11623)
add 57b9194a459 Optimizing the Binary comparison method in
CompareBinaryColumnTransformer
add f68fdaea159 Bump org.springframework.boot:spring-boot from 2.7.15 to
2.7.18 (#11634)
add bb20b5f3f8f [RatisConsensus] Cache group id in the write/read critical
path (#11615)
add 259d3fcd618 Fix npe in TopKOperator when topKResult is null
add 7b82a00764d Fix compaction selector ut running time is too long
(#11635)
add afc6c7f916f Only root can alter template
add 431e9b81e80 Fix error judgement for MainFragmentLocatedRegion and
MostlyUsedDataRegion in distributed plan
add 919a24f3d37 fix:grafana plugin build
add 80c5b2ad138 auth.add IT for create role/user with identifier.
add 2a1fad8c871 Bump ch.qos.logback:logback-classic from 1.3.11 to 1.3.12
(#11645)
add 0dcb04086e3 Get correct TsFileSequenceReader from FileReaderManager
add 0cc841b7639 Fix close method of TopOperator and make close method of
Operator an interface
add d0918bd367a Temporarily ignore testPBTreeMemoryStatistics (#11648)
add 2aadeb4a93c [IOTDB-6259] Bump ratis version to 3.0.0 (#11618)
add 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)
add 35c29e16cfc Fix concurrent bug During Heartbeat and Region Creation
(#11656)
add 636bd465714 delete data and files together
add 0144133481c PBTree Improvement: WrappedSegment Layout Revision for
Reduced GC Overhead (#11652)
add 9eb60a9faa8 Bump logback.version from 1.3.12 to 1.3.13 (#11653)
add b2be051adb0 fix the error when last query non-writble view with same
sensors (#11658)
add 8fe672fcfad Finish
add 67e6f67210f code smell
add 49192eaed45 Merge branch 'greedy-copy-set' of
https://github.com/apache/iotdb into greedy-copy-set
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 | 14 +-
.../apache/iotdb/pipe/it/AbstractPipeDualIT.java | 60 ++
.../apache/iotdb/pipe/it/IoTDBPipeClusterIT.java | 254 ++++---
.../pipe/it/IoTDBPipeConnectorParallelIT.java | 77 +-
...ipeDataSyncIT.java => IoTDBPipeDataSinkIT.java} | 157 ++--
.../it/{extractor => }/IoTDBPipeExtractorIT.java | 414 ++++-------
.../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 +-
.../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 +-
...ion.java => RatisReadUnavailableException.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} | 10 +-
.../env/PipeTaskExtractorRuntimeEnvironment.java | 9 +-
.../env/PipeTaskProcessorRuntimeEnvironment.java} | 10 +-
.../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 +
.../{PipeMetrics.java => PipeDataNodeMetrics.java} | 16 +-
.../db/pipe/metric/PipeEventCommitMetrics.java | 141 ++++
.../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 +-
.../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} | 24 +-
.../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 +-
.../ConvertPredicateToTimeFilterTest.java | 148 ++++
.../predicate/PredicateRemoveNotTest.java | 95 +++
.../CaseWhenThenExpressionTest.java | 2 +-
.../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} | 18 +-
.../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 +-
...ReaderTimeseriesMetadataIteratorException.java} | 24 +-
.../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/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 +++-
.../IDisableStatisticsTimeFilter.java} | 18 +-
.../IDisableStatisticsValueFilter.java} | 18 +-
.../FilterType.java => basic/IStatefulFilter.java} | 23 +-
.../FilterType.java => basic/ITimeFilter.java} | 18 +-
.../FilterType.java => basic/IValueFilter.java} | 23 +-
.../OperatorType.java} | 54 +-
.../tsfile/read/filter/basic/UnaryFilter.java | 97 ---
.../tsfile/read/filter/factory/FilterFactory.java | 93 +--
.../tsfile/read/filter/factory/TimeFilter.java | 101 +++
.../tsfile/read/filter/factory/ValueFilter.java | 168 +++++
.../filter/operator/{AndFilter.java => And.java} | 54 +-
.../iotdb/tsfile/read/filter/operator/Between.java | 168 -----
.../iotdb/tsfile/read/filter/operator/Eq.java | 115 ---
.../read/filter/{ => operator}/GroupByFilter.java | 116 ++-
.../filter/{ => operator}/GroupByMonthFilter.java | 171 +++--
.../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 ---
.../filter/operator/{NotFilter.java => Not.java} | 114 ++-
.../iotdb/tsfile/read/filter/operator/NotEq.java | 115 ---
.../filter/operator/{OrFilter.java => Or.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} | 47 +-
.../filter/operator/base/ColumnCompareFilter.java} | 32 +-
.../operator/base/ColumnPatternMatchFilter.java} | 37 +-
.../filter/operator/base/ColumnRangeFilter.java} | 38 +-
.../filter/operator/base/ColumnSetFilter.java} | 31 +-
.../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 -
.../apache/iotdb/library/dprofile/UDAFStddev.java | 66 --
pom.xml | 10 +-
558 files changed, 16622 insertions(+), 8998 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBVarianceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBAlignByDeviceWithTemplateIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedOffsetLimitPushDownIT.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/timer/ITimeSliceAllocator.java
=>
integration-test/src/test/java/org/apache/iotdb/pipe/PipeEnvironmentException.java
(75%)
create 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/{IoTDBPipeDataSyncIT.java
=> IoTDBPipeDataSinkIT.java} (56%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{extractor =>
}/IoTDBPipeExtractorIT.java (60%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProcessorIT.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeMetrics.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeProcedureMetrics.java
create 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/{RatisUnderRecoveryException.java
=> RatisReadUnavailableException.java} (71%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/commit/PipeEventCommitManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/commit/PipeEventCommitter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/{constant/PipeProcessorConstant.java
=> plugin/env/PipeTaskConnectorRuntimeEnvironment.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/{constant/PipeProcessorConstant.java
=> plugin/env/PipeTaskProcessorRuntimeEnvironment.java} (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{PipeMetrics.java
=> PipeDataNodeMetrics.java} (82%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeEventCommitMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/DownSamplingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/PartialPathLastTimeCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryWeighUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/tsfile/PipeTsFileResource.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/VarianceAccumulator.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/timer/RuleBasedTimeSliceAllocator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/PredicateUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyze.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedInfo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/other/GroupByTimeExpression.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ConvertPredicateToTimeFilterVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/PredicateVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ReversePredicateVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TemplatedLogicalPlan.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TemplatedLogicalPlanBuilder.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/Segment.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/planner/plan/node/source/SeriesSourceNode.java
=> storageengine/dataregion/compaction/execute/utils/CompactionPathUtils.java}
(54%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataRegionStateMachineTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/predicate/ConvertPredicateToTimeFilterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/predicate/PredicateRemoveNotTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/{other
=> serde}/CaseWhenThenExpressionTest.java (98%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/PipeTaskOperation.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/DownSamplingProcessor.java}
(63%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/PlaceHolderProcessor.java
copy
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/{read/filter/factory/FilterSerializeId.java
=> exception/TsFileSequenceReaderTimeseriesMetadataIteratorException.java}
(76%)
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileSequenceReaderTimeseriesMetadataIterator.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/TimeFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/ValueFilter.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/BinaryFilter.java
copy
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{factory/FilterType.java
=> basic/IDisableStatisticsTimeFilter.java} (73%)
copy
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{factory/FilterType.java
=> basic/IDisableStatisticsValueFilter.java} (71%)
copy
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{factory/FilterType.java
=> basic/IStatefulFilter.java} (73%)
copy
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{factory/FilterType.java
=> basic/ITimeFilter.java} (65%)
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{factory/FilterType.java
=> basic/IValueFilter.java} (62%)
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{factory/FilterSerializeId.java
=> basic/OperatorType.java} (61%)
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/UnaryFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/TimeFilter.java
create 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/{AndFilter.java
=> And.java} (82%)
mode change 100755 => 100644
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Between.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Eq.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%)
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Gt.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/GtEq.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/In.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Like.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Lt.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/LtEq.java
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/{NotFilter.java
=> Not.java} (68%)
mode change 100755 => 100644
delete 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/{OrFilter.java
=> Or.java} (55%)
mode change 100755 => 100644
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Regexp.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/TimeFilterOperators.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/ValueFilterOperators.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/LastSeriesSourceNode.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/BinaryLogicalFilter.java}
(50%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnCompareFilter.java}
(51%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/iterator/MNodeIterator.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnPatternMatchFilter.java}
(54%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/iterator/MNodeIterator.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnRangeFilter.java}
(52%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnSetFilter.java}
(55%)
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/RegexUtils.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TsFileSequenceReaderTimeseriesMetadataIteratorTest.java
delete mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFStddev.java
