This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch pbtree_concurrent
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from db119a762a3 ci
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 b232fcf163d fix inner compaction select task base on mod file (#11654)
add 4a9fb924391 Fix file counted twice in TsFileMetrics (#11662)
add 3427b320b62 Fix compaction UTs and add concurrency control when
schedule compaction (#11638)
add f48454ab50a Update iotdb-doap.rdf
add 2edc91d287f Add format check for Prometheus Reporter Check (#11666)
add ec118416f36 Added getRegionId api for partitionManager (#11663)
add 24f0a606cbc Ignore MismatchedType caused by delete
add 788b0bc9523 Refactor Device Node Implementation in SchemaRegion
(#11661)
add dcaedd336e3 Extend `Filter` interface to support aligned timeseries
add 235a3f3c14e Pipe Schema: Added ConcurrentIterableLinkedQueue to record
the ConsensusRequest and SnapShot event (#11650)
add 5e89a90ece5 TopKNode will use IdentityNode but not ShuffleSinkNode
add 9b19cf72ac4 [IOTDB-6174] Support ColumnInjectOperator for '__endTime'
output
add 6c92fbc8c77 Optimize the efficiency of map-related code in
IRegionGroupAllocator (#11673)
add 78ce7e74bce [IOTDB-6259][RatisConsensus] Fix missing prefix in gauge
metrics (#11677)
add c185c6c9c92 [IOTDB-6263] Enhance IoTDBPartitionCreationIT (#11676)
add 0fa7f403130 Fix reconnect bug for JDBC
add 3b4788614c2 Pipe: avoid useless pipe meta sync (stopped status) to DN
to achieve high availability (#11641)
add 90ce01eb7e8 [RatisConsensus] Retry Read Requests on
StatusRuntimeException (#11679)
add 11adc7c920a [IOTDB-6252] Greedy CopySet allocation algorithm (#11572)
add ee5e23dbb94 Rest service code optimization and fixed insertRecords
error prompt returning null issue (#11678)
add 9ded0bdf7dd Bump ch.qos.logback:logback-core from 1.3.13 to 1.3.14
(#11683)
add 60d66ae873f Enhance the note of parameter seed_config_node (#11685)
add a93cf09d1bd Enhance the exapmle of parameter dn_seed_config_node
(#11686)
add c450e768980 Enhance parameter dn_seed_config_node commets order
(#11687)
add 4922dad4d17 Add last time check for inner space compaction task
(#11553)
add 9af1e765c5d Cache the internal compaction estimation result if
compaction task is failed to run (#11586)
add acde4457a3d [IOTDB-6264] Load: Optimized Validation Messages with
'write_data' Permissions When Loading TsFiles Without schema Creation (#11684)
add 09b7e86fd63 add config for inner compaction selector (#11693)
add b1d3dc63c9e [IOTDB-6265] Construct SessionPool using empty nodeUrls
should throw exception
add 5caeeb3e3b7 Pipe: automatically start pipe upon creation & allow to
start RUNNING pipe & allow to stop STOPPED pipe (#11690)
add a061c0d4514 Pipe: Make error message reported by pipe parameter check
clearer (#11695)
add b57f320153b Make slimit and soffset available in align by device with
template
new de26dd70d9e Merge branch 'master' into pbtree_concurrent
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/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 | 22 +-
.../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 | 25 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 1 +
.../iotdb/itbase/runtime/ClusterTestStatement.java | 10 +-
.../it/partition/IoTDBPartitionCreationIT.java | 4 +-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 6 +-
.../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 | 689 +++++++++++++++
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 7 +
.../aligned/IoTDBAlignedOffsetLimitPushDownIT.java | 151 ++++
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 100 ++-
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 196 +++++
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 71 ++
.../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 | 51 +-
.../apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java | 31 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 64 +-
.../java/org/apache/iotdb/pipe/api/access/Row.java | 10 +-
.../parameter/PipeParameterValidator.java | 6 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 2 +-
.../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 | 19 +-
.../java/org/apache/iotdb/jdbc/StringUtils.java | 8 +-
.../java/org/apache/iotdb/session/Session.java | 8 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 355 ++++----
.../java/org/apache/iotdb/session/SessionTest.java | 12 +
.../session/pool/SessionPoolExceptionTest.java | 12 +
.../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 | 56 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 56 +-
.../resources/conf/iotdb-confignode.properties | 2 +
.../async/AsyncDataNodeHeartbeatClientPool.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 6 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../manager/load/balancer/RegionBalancer.java | 21 +-
.../region/CopySetRegionGroupAllocator.java | 160 ----
.../region/GreedyCopySetRegionGroupAllocator.java | 191 +++++
.../region/GreedyRegionGroupAllocator.java | 31 +-
.../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 | 36 +-
.../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/PipeHeartbeatParser.java | 4 +-
.../manager/pipe/runtime/PipeMetaSyncer.java | 15 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 53 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 174 ++--
.../confignode/persistence/node/NodeInfo.java | 29 +-
.../partition/DatabasePartitionTable.java | 37 +
.../persistence/partition/PartitionInfo.java | 32 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 46 +-
.../confignode/persistence/schema/ConfigMTree.java | 2 +-
.../persistence/schema/mnode/IConfigMNode.java | 28 +
.../schema/mnode/basic/ConfigBasicMNode.java | 50 +-
.../mnode/impl/ConfigBasicInternalMNode.java | 37 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 3 +
.../procedure/impl/pipe/PipeTaskOperation.java | 24 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 21 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 8 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 39 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 38 +-
.../iotdb/confignode/service/ConfigNode.java | 3 +
.../GreedyCopySetRegionGroupAllocatorTest.java | 203 +++++
.../router/priority/GreedyPriorityTest.java | 4 +-
.../priority/LeaderPriorityBalancerTest.java | 4 +-
.../manager/load/cache/NodeCacheTest.java | 8 +-
.../confignode/persistence/AuthorInfoTest.java | 134 ++-
.../confignode/persistence/PartitionInfoTest.java | 70 +-
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 | 57 +-
.../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 +-
.../resources/conf/iotdb-datanode.properties | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 42 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 104 ++-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 1 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 119 +--
.../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 | 12 +-
.../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 | 70 +-
.../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 +-
.../rest/v1/handler/RequestValidationHandler.java | 12 -
.../v1/handler/StatementConstructionHandler.java | 59 --
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 47 -
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 36 +-
.../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 +-
.../execution/operator/AggregationUtil.java | 16 +-
.../queryengine/execution/operator/Operator.java | 12 +-
.../execution/operator/OperatorContext.java | 12 +-
.../operator/process/AggregationOperator.java | 19 +-
.../operator/process/ColumnInjectOperator.java | 115 +++
.../process/SlidingWindowAggregationOperator.java | 18 +-
.../execution/operator/process/TopKOperator.java | 35 +-
.../operator/process/last/LastQueryUtil.java | 8 +-
.../operator/schema/SchemaFetchScanOperator.java | 13 +-
.../source/AbstractDataSourceOperator.java | 15 +
.../AbstractSeriesAggregationScanOperator.java | 38 +-
.../AlignedSeriesAggregationScanOperator.java | 25 +
.../operator/source/AlignedSeriesScanOperator.java | 34 +-
.../operator/source/AlignedSeriesScanUtil.java | 116 ++-
.../operator/source/LastCacheScanOperator.java | 5 +
.../source/SeriesAggregationScanOperator.java | 25 +
.../operator/source/SeriesScanOperator.java | 26 +-
.../execution/operator/source/SeriesScanUtil.java | 40 +-
.../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 | 268 +++---
.../queryengine/plan/analyze/PredicateUtils.java | 347 ++++++++
.../queryengine/plan/analyze/TemplatedAnalyze.java | 426 +++++++++
.../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 | 19 +-
.../plan/optimization/PlanNodePushDown.java | 76 ++
.../base/ColumnInjectionPushDown.java} | 14 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 12 +-
.../plan/planner/LocalExecutionPlanContext.java | 26 +-
.../plan/planner/LogicalPlanBuilder.java | 109 ++-
.../plan/planner/LogicalPlanVisitor.java | 27 +-
.../plan/planner/OperatorTreeGenerator.java | 319 +++----
.../plan/planner/SubPlanTypeExtractor.java | 13 +-
.../plan/planner/TemplatedLogicalPlan.java | 206 +++++
.../plan/planner/TemplatedLogicalPlanBuilder.java | 142 +++
.../distribution/DistributionPlanContext.java | 5 +
.../planner/distribution/DistributionPlanner.java | 36 +-
.../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 | 22 +-
.../plan/planner/plan/node/PlanNode.java | 18 +-
.../plan/planner/plan/node/PlanNodeType.java | 23 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadSingleTsFileNode.java | 4 +-
.../plan/node/load/LoadTsFilePieceNode.java | 8 +-
.../node/metedata/read/SchemaFetchScanNode.java | 17 +-
.../planner/plan/node/process/AggregationNode.java | 8 +-
.../plan/node/process/ColumnInjectNode.java | 123 +++
.../plan/node/process/SingleDeviceViewNode.java | 28 +
.../node/process/SlidingWindowAggregationNode.java | 56 +-
.../plan/node/process/last/LastQueryNode.java | 45 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 8 +-
.../source/AlignedSeriesAggregationScanNode.java | 85 +-
.../plan/node/source/AlignedSeriesScanNode.java | 183 ++--
.../plan/node/source/LastQueryScanNode.java | 8 +-
.../plan/node/source/LastSeriesSourceNode.java | 7 +
.../node/source/SeriesAggregationScanNode.java | 85 +-
.../node/source/SeriesAggregationSourceNode.java | 60 +-
.../planner/plan/node/source/SeriesScanNode.java | 146 ++--
.../planner/plan/node/source/SeriesSourceNode.java | 4 +-
.../planner/plan/node/write/DeleteDataNode.java | 4 +-
.../plan/parameter/AggregationDescriptor.java | 18 +
.../planner/plan/parameter/SeriesScanOptions.java | 66 +-
.../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 | 42 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 23 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 26 +-
.../impl/mem/mnode/factory/MemMNodeFactory.java | 11 +-
.../impl/mem/mnode/impl/BasicInternalMNode.java | 83 +-
.../impl/mem/mnode/impl/DatabaseDeviceMNode.java | 37 -
.../mtree/impl/mem/mnode/impl/DatabaseMNode.java | 17 +-
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 2 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 75 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 59 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 42 +-
.../impl/pbtree/mnode/basic/CachedBasicMNode.java | 25 +-
.../pbtree/mnode/factory/CacheMNodeFactory.java | 11 +-
.../mnode/impl/CachedBasicInternalMNode.java | 91 +-
.../mnode/impl/CachedDatabaseDeviceMNode.java | 49 --
.../pbtree/mnode/impl/CachedDatabaseMNode.java | 18 +-
.../impl/pbtree/mnode/impl/CachedDeviceMNode.java | 48 --
.../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 | 2 +-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 3 +-
.../schemaregion/utils/MNodeUtils.java | 54 +-
.../view/visitor/TransformToExpressionVisitor.java | 10 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 4 +-
.../db/service/metrics/file/TsFileMetrics.java | 8 +-
.../iotdb/db/storageengine/StorageEngine.java | 76 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 10 +-
.../db/storageengine/dataregion/DataRegion.java | 257 +++++-
.../CompactionLastTimeCheckFailedException.java} | 18 +-
.../impl/ReadChunkCompactionPerformer.java | 5 +-
.../execute/recover/CompactionRecoverTask.java | 27 +-
.../execute/task/AbstractCompactionTask.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 8 +-
.../execute/utils/CompactionPathUtils.java} | 24 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 7 +-
.../fast/AlignedSeriesCompactionExecutor.java | 21 +-
.../fast/NonAlignedSeriesCompactionExecutor.java | 12 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 12 +
.../readchunk/SingleSeriesCompactionExecutor.java | 13 +
.../utils/writer/AbstractCompactionWriter.java | 11 +
.../writer/AbstractCrossCompactionWriter.java | 11 +-
.../writer/AbstractInnerCompactionWriter.java | 2 +
.../utils/writer/FastInnerCompactionWriter.java | 4 +
.../compaction/schedule/CompactionScheduler.java | 13 +
.../compaction/schedule/CompactionWorker.java | 22 +-
.../estimator/AbstractCompactionEstimator.java | 27 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../impl/SizeTieredCompactionSelector.java | 11 +-
.../compaction/settle/SettleRequestHandler.java | 24 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 6 +-
.../read/reader/chunk/DiskChunkLoader.java | 6 +-
.../read/reader/chunk/MemAlignedPageReader.java | 82 +-
.../read/reader/chunk/MemPageReader.java | 36 +-
.../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 +-
.../db/utils/columngenerator/ColumnGenerator.java} | 11 +-
.../columngenerator/ColumnGeneratorType.java} | 15 +-
.../SlidingTimeColumnGenerator.java | 52 ++
.../parameter/ColumnGeneratorParameter.java | 82 ++
.../SlidingTimeColumnGeneratorParameter.java | 80 ++
.../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 ++
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 31 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 2 +-
.../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 +++++++
.../operator/AggregationOperatorTest.java | 1 +
.../AlignedSeriesAggregationScanOperatorTest.java | 14 +-
.../operator/AlignedSeriesScanOperatorTest.java | 15 +-
.../execution/operator/FillOperatorTest.java | 15 +
.../operator/LastQueryMergeOperatorTest.java | 20 +
.../execution/operator/LinearFillOperatorTest.java | 35 +
.../execution/operator/OperatorMemoryTest.java | 13 +-
.../operator/RawDataAggregationOperatorTest.java | 5 +-
.../SeriesAggregationScanOperatorTest.java | 14 +-
.../SlidingWindowAggregationOperatorTest.java | 1 +
.../execution/operator/TopKOperatorTest.java | 297 +++++--
.../operator/UpdateLastCacheOperatorTest.java | 6 +-
.../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 | 168 ++--
.../plan/optimization/LimitOffsetPushDownTest.java | 10 +-
.../plan/optimization/TestPlanBuilder.java | 8 +-
.../plan/plan/FragmentInstanceSerdeTest.java | 4 +-
.../plan/plan/QueryLogicalPlanUtil.java | 49 +-
.../distribution/AggregationDistributionTest.java | 3 +-
.../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/CompactionOverlapCheckTest.java | 269 ++++++
.../compaction/CompactionSchedulerTest.java | 25 +-
.../compaction/CompactionTaskManagerTest.java | 10 +-
.../ReadPointCompactionPerformerTest.java | 2 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 63 +-
.../utils/CompactionUpdateFileCountTest.java | 2 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 9 +-
.../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 +-
iotdb-core/node-commons/pom.xml | 5 +
.../resources/conf/iotdb-common.properties | 10 +-
.../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 +-
.../ConcurrentIterableLinkedQueue.java | 345 ++++++++
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 47 +-
.../builtin/processor/DownSamplingProcessor.java} | 17 +-
.../builtin/processor/PlaceHolderProcessor.java | 68 ++
.../commons/pipe/task/meta/PipeMetaKeeper.java | 32 +
.../apache/iotdb/commons/schema/node/IMNode.java | 12 +-
.../node/common/AbstractAboveDatabaseMNode.java | 18 +-
.../node/common/AbstractDatabaseDeviceMNode.java | 299 -------
.../schema/node/common/AbstractDatabaseMNode.java | 26 +-
.../node/common/AbstractMeasurementMNode.java | 19 +-
...actDeviceMNode.java => DeviceMNodeWrapper.java} | 130 ++-
.../commons/schema/node/role/IDeviceMNode.java | 2 +-
.../commons/schema/node/role/IInternalMNode.java} | 37 +-
.../commons/schema/node/visitor/MNodeVisitor.java | 7 -
.../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 +-
.../ConcurrentIterableLinkedQueueTest.java | 439 ++++++++++
.../pipe/{ => task/meta}/PipeMetaDeSerTest.java | 7 +-
...ReaderTimeseriesMetadataIteratorException.java} | 24 +-
.../iotdb/tsfile/file/header/ChunkGroupHeader.java | 2 +-
.../iotdb/tsfile/file/header/PageHeader.java | 23 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 42 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 57 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 22 +
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 6 +-
.../metadata/IMetadata.java} | 15 +-
.../tsfile/file/metadata/ITimeSeriesMetadata.java | 9 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 31 +
.../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 | 10 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 32 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 7 +-
.../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 --
.../read/filter/basic/BinaryLogicalFilter.java} | 47 +-
.../DisableStatisticsTimeFilter.java} | 18 +-
.../basic/DisableStatisticsValueFilter.java} | 37 +-
.../iotdb/tsfile/read/filter/basic/Filter.java | 187 +++-
.../tsfile/read/filter/basic/OperatorType.java | 75 ++
.../iotdb/tsfile/read/filter/basic/TimeFilter.java | 58 ++
.../tsfile/read/filter/basic/UnaryFilter.java | 97 ---
.../tsfile/read/filter/basic/ValueFilter.java | 120 +++
.../tsfile/read/filter/factory/FilterFactory.java | 93 +-
.../tsfile/read/filter/factory/TimeFilterApi.java | 101 +++
.../tsfile/read/filter/factory/ValueFilterApi.java | 186 ++++
.../filter/operator/{AndFilter.java => And.java} | 65 +-
.../iotdb/tsfile/read/filter/operator/Between.java | 168 ----
.../iotdb/tsfile/read/filter/operator/Eq.java | 115 ---
.../read/filter/{ => operator}/GroupByFilter.java | 118 +--
.../filter/{ => operator}/GroupByMonthFilter.java | 172 ++--
.../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} | 126 ++-
.../iotdb/tsfile/read/filter/operator/NotEq.java | 115 ---
.../iotdb/tsfile/read/filter/operator/Or.java | 174 ++++
.../tsfile/read/filter/operator/OrFilter.java | 153 ----
.../iotdb/tsfile/read/filter/operator/Regexp.java | 199 -----
.../read/filter/operator/TimeFilterOperators.java | 601 +++++++++++++
.../read/filter/operator/ValueFilterOperators.java | 954 +++++++++++++++++++++
.../iotdb/tsfile/read/reader/IPageReader.java | 7 +-
.../read/reader/chunk/AlignedChunkReader.java | 34 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 14 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 202 +++--
.../iotdb/tsfile/read/reader/page/PageReader.java | 58 +-
.../tsfile/read/reader/page/ValuePageReader.java | 131 ++-
.../reader/series/AbstractFileSeriesReader.java | 16 +-
.../read/reader/series/EmptyFileSeriesReader.java | 4 +-
.../read/reader/series/FileSeriesReader.java | 4 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 10 +
.../FilterType.java => utils/Preconditions.java} | 24 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 55 +-
.../org/apache/iotdb/tsfile/utils/RegexUtils.java | 92 ++
.../iotdb/tsfile/common/block/TsBlockTest.java | 77 ++
.../apache/iotdb/tsfile/read/ExpressionTest.java | 36 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 8 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 60 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 64 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 66 +-
...quenceReaderTimeseriesMetadataIteratorTest.java | 62 ++
.../tsfile/read/filter/FilterSerializeTest.java | 92 +-
.../iotdb/tsfile/read/filter/FilterTestUtil.java | 105 +++
.../tsfile/read/filter/GroupByFilterTest.java | 33 +-
.../tsfile/read/filter/GroupByMonthFilterTest.java | 88 +-
.../read/filter/IExpressionOptimizerTest.java | 81 +-
.../read/filter/MinTimeMaxTimeFilterTest.java | 75 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 93 +-
.../filter/PredicateRemoveNotRewriterTest.java | 109 +--
.../tsfile/read/filter/StatisticsFilterTest.java | 300 ++++---
.../read/query/executor/QueryExecutorTest.java | 11 +-
.../read/query/timegenerator/ReadWriteTest.java | 10 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 10 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 10 +-
.../query/timegenerator/TimeGeneratorTest.java | 10 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 8 +-
iotdb-doap.rdf | 33 +
.../openapi/src/main/openapi3/iotdb_rest_v1.yaml | 52 --
.../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 +-
674 files changed, 21888 insertions(+), 11396 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
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/CopySetRegionGroupAllocator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyCopySetRegionGroupAllocator.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
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyCopySetRegionGroupAllocatorTest.java
copy
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
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/ColumnInjectOperator.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/optimization/PlanNodePushDown.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/PipeTaskOperation.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/base/ColumnInjectionPushDown.java}
(74%)
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
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/ColumnInjectNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/impl/DatabaseDeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/impl/CachedDatabaseDeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/impl/CachedDeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/Segment.java
rename
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/exception/RatisUnderRecoveryException.java
=>
datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/CompactionLastTimeCheckFailedException.java}
(63%)
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%)
copy
iotdb-core/{tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/IAlignedPageReader.java
=>
datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/ColumnGenerator.java}
(77%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/config/constant/PipeProcessorConstant.java
=> utils/columngenerator/ColumnGeneratorType.java} (77%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/SlidingTimeColumnGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/parameter/ColumnGeneratorParameter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/parameter/SlidingTimeColumnGeneratorParameter.java
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%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionOverlapCheckTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/ConcurrentIterableLinkedQueue.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/config/constant/PipeProcessorConstant.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
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractDatabaseDeviceMNode.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/{AbstractDeviceMNode.java
=> DeviceMNodeWrapper.java} (65%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/impl/DeviceMNode.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/role/IInternalMNode.java}
(51%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/ConcurrentIterableLinkedQueueTest.java
rename iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/{
=> task/meta}/PipeMetaDeSerTest.java (94%)
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/{read/filter/factory/FilterSerializeId.java
=> exception/TsFileSequenceReaderTimeseriesMetadataIteratorException.java}
(76%)
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/{read/reader/IAlignedPageReader.java
=> file/metadata/IMetadata.java} (69%)
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/{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/basic/BinaryLogicalFilter.java}
(50%)
copy
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{factory/FilterType.java
=> basic/DisableStatisticsTimeFilter.java} (73%)
copy
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/{file/metadata/ITimeSeriesMetadata.java
=> read/filter/basic/DisableStatisticsValueFilter.java} (60%)
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/OperatorType.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/TimeFilter.java
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/basic/ValueFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/TimeFilterApi.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/ValueFilterApi.java
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/{AndFilter.java
=> And.java} (73%)
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 (61%)
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} (56%)
mode change 100755 => 100644
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/NotEq.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/Or.java
delete mode 100755
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/OrFilter.java
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
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/{read/filter/factory/FilterType.java
=> utils/Preconditions.java} (65%)
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
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/FilterTestUtil.java
delete mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFStddev.java
