This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch rc/1.3.0
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e7592c09d91 fix the issue that compaction scheduler is not started
when DataRegion created (#11446)
new 8d9b7cdf516 Refactor Series/Device Quota Limitation (#11422)
new bf478904cf8 [IOTDB-6227] Remove unused retry policy in IStateMachine
(#11451)
new 3215a87b4ef Fix concurrent read lock bug in StampedWriterPreferredLock
(#11453)
new 953610cbcb2 [IOTDB-6220] Pipe: Changed the sink loopback detection
logic to support hostName and IPv6 specification. (#11455)
new 72a076e2074 [IOTDB-6234] Pipe: Added client example for
opc-ua-connector (#11460)
new 95fe078d06d Pipe: add stream & batch options for source.realtime.mode
& remove some pipe plugins from show pipe plugins' dataset & make pipe-api
compatible with the v1.2.x releases (#11461)
new f3cc2cf3534 To adapt activation (#11463)
new 4d8d9c681be Disable spotless for JDK 21 (#11469)
new e09f7bba909 [IOTDB-6224] Fix group by month in non-ms precision and
mixed unit
new c5fd430ae99 [IOTDB-6236] Pipe: CountPointProcessor example (#11470)
new caa3f1c0542 Implement iterative volatile node process during pbtree
flush (#11432)
new a81185c317d [IOTDB-6235] Pipe: Implement write-back-sink to transfer
data back to the sender (#11466)
new b228f041b5b Fix the path of TsFileResource in unit test
new dad01cbfb0e Pipe: add connector's pending tsfile event count to help
isTsFileEventCountInQueueExceededLimit judgement when hybrid mode is enabled
(#11476)
new 4797ada28d4 Make all built-in scalar UDF into batch processing
new 7d4ab1ac5a4 Pipe: preliminary SSL support for pipe connector (sink)
sync client (#11465)
new 26803fd3cf7 fix empty resource recovered from wal (#11452)
new cc59cff7fbb Pipe: Enable github machines instead of self-hosted
machines to run pipe IT (#11435)
new ba82b156656 [IOTDB-6240] Pipe: Fix bug with PipeMemoryManager
allocating memory for the DisruptorQueue (#11485)
new dd4cf0deed3 Pipe: refined key set of tags for pipe metrics & fixed hit
rate in PipeWALInsertNodeCacheMetrics always `1.0`(#11484)
new ea2adefddcb Pipe: convert the value of source, processor, sink key to
lowercase & convert `SHOW_PIPE_PLUGINS_BLACKLIST` keys to uppercase (#11487)
new d0fd90cf9ba Fix empty tsfile genarated when all datatypes in one
insert mismatching (#11456)
new 27f12e5490a Add Metric Prometheus Reporter IT (#11443)
new 22136712706 PBTree: Logging Disabled with Ratis and Pre-Allocation
Disabled for devices using template (#11467)
new e608944ffc1 Feat/configurable home directory (#11492)
new 0ad2ae8853d fix: Increase the timeout even more to finally make the
build succeed.
new 482f2f373bf Fix NPE in SchemaStatisticsTest (#11490)
new 0dd03d2ec29 [IOTDB-6239] Show regions display error create time
(#11481)
new e3d814e70af Fix datanode stuck when meets disk error (#11486)
new d56522ed329 Simplify library-udf packaging result
new b6f70ec5a2b [IOTDB-6241] Load: Check System READ_ONLY mode in
Analysis, Dispatch and Writing Stage (#11488)
new 6c04bc8b889 Pipe: Added check in PipeSubtask submit logic to ensure
one PipeConnectorSubtask instance is running in only one thread (#11474)
new 7ccbc007c6f [IOTDB-6206] Metric Core: Shrink ringBuffer length to
optimize histogram and timer's record performance (#11500)
new 7bb108d6101 Fix aggregation error when inserting negative timestamp
new 25361fab2a9 Pipe: Make each connector subtask inject cron event at fix
rate to avoid random time of batch transmission (#11501)
new d6ba29af82d [IOTDB-6238] Fix delete timeSeries / deactivate template
procedure rollback logic (#11479)
new 43092365eee Pipe: introduce pipe_max_allowed_pinned_memtable_count
param for realtime hybrid mode (#11505)
new e6f98243b39 add time cost for datanode start (#11498)
new 4d8de4d17ce Pipe IT: adjust -DintegrationTest.forkCount &
-DDataNodeMaxHeapSize in pipe-it-2cluster.yml to provide more stable env
(#11504)
new 9e919d1af0f Check empty target file after sequence
InnerSpaceCompactionTask (#11454)
new d791ca19130 Add compaction logs and metrics (#11448)
new ba565428be5 Pipe: skip pipe CN heartbeat and sync when
`PipeTaskCoordinatorLock` is held by another thread (#11509)
new d6c4d1a188f [IOTDB-6209] Pipe: Solving the topological order of the
progress index in the historical data collection phase (#11478)
new 41766f795f5 [IOTDB-6227] Add retry for RatisConsensus read (#11458)
new 61434dd6372 [IOTDB-6245] Load: Adjust forceCloseWriterManager
execution delay in LoadTsFileManager to 15mins to avoid OOM & clear all data
structures after use to help GC (#11506)
new e462cab84fd fix(conf): add e.g. for ssl (#11512)
new 92ae15adaa2 Check and update searchIndex when restarting dataNode if
necessary (#11510)
new b8ca4144f98 Pipe: collect total memory size with pipe module instead
of memory usage (#11513)
new 92cecef8bb2 [IOTDB-6246] Pipe: Validator validates the range of values
for optional parameters improperly (#11520)
new e66021a7729 remove duplicate description of metric (#11519)
new 748972ba17a Pipe: Added concurrency check to avoid
WALEntryHandler#getInsertNode returning null to fix potential NPE (#11523)
new d9b78e9db14 Add logs in compaction recovery (#11433)
new f28605ef056 [IOTDB-6247] Remove redundant error log when restarting
simple consensus ConfigNode (#11529)
new 939b2ed5a48 [IOTDB-6239] Revert updation of CreateRegionGroupsPlan
(#11528)
new 601fb0ae892 Add OFF level (#11530)
new 7403da89fc8 Revert "[IOTDB-6235] Pipe: Implement write-back-sink to
transfer data back to the sender (#11466)"
new be9d3edaa9b Revert "Pipe: preliminary SSL support for pipe connector
(sink) sync client (#11465)"
new 42caed717e8 fix insertion compaction replace keyword bug (#11514)
new 19129313578 Validate flushed tsfile without holding closeQueryLock
(#11508)
new cba8cb5b4c7 Pipe: Enable dynamic adjusting of allocated pipe memory
(#11518)
new d56e2bd2685 Pipe IT: Enable Pipe IT to tolerate failures caused by
resource shortage (#11527)
new 10a0ad47344 Support high available while meeting timeout exception
new 3f6ac9a2336 Pipe IT: Fix WALFlushListener.testConcurrentGetValue() &
Fix smells reported by sonar (#11525)
new 377dacc34a4 Bump
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc
(#11517)
new 433a98ffa5f Implement more fine-grained time slice control for the
AggregationScanOperator (#11521)
new cf51769584a Pipe IT: Enable IoTDBPipeExtractorIT &
IoTDBPipeSwitchStatusIT to tolerate failures caused by resource shortage
(#11539)
new 3b0d1e4063d fix compaction logs and metrics (#11533)
new 5202200d467 DataNode & ConfigNode exit directly while meeting
OutOfMemoryError
new fafa015e50d add nonnull to ProgressIndex's topological sort (#11542)
new 1643532b5a8 return WRITE_PROCESS_ERROR when catching
BatchProcessException in writing process (#11543)
new 317aa80c780 add file validate when rename file, avoid rename error
because file is not exist (#11536)
new 11b642e0cfa Fix insertRecordsOfOneDevice causes data out of order
(#11535)
new 76b8ccf2068 Pipe: Make the pipe to detect illegal parameters when
there is no data (#11541)
new b521e9799b3 Fix aligned series modification not matched in
MultiTsFileDeviceIterator (#11544)
new d5e6d7b2aa3 Increase retry timeout for ratis retry mechanism (#11548)
new 180d49c0d32 Revert "DataNode & ConfigNode exit directly while meeting
OutOfMemoryError"
new c8ed6cc2ccd Fix aligned device modification not matched in
MultiTsFileDeviceIterator (#11555)
new a2c3acec995 Change the package name back in common-api
new 712495c8c8c Enhance IoTConsensus retry judgement to all writenodes in
a batch (#11564)
new bc198d0bddb Pipe: Fixed event forever pinned and retry never invoked
when TException encountered in IoTDBThriftAsyncConnector (#11560)
new 77145b10458 fix auth upgrade.
new cd01ffeb464 Fix insertTablets API didn't return schema validation
error (#11577)
new ef2a28a2367 Add isDebugEnable judgement for each LOGGER.DEBUG
new 79a3e5366a8 [IOTDB-6254] Fix limit push down bug in aligned sensor
new ea07eb99043 Fix AutoCreateSchema using template without WRITE_SCHEMA
new f46d7b121a6 To adapt activation (#11613)
new 7afffb09849 Rename THeartbeat to TDataNodeHeart (#11603)
new d1e64b446d1 Fix follower data may out of order (#11625)
new dc3490d5577 Fix npe in TopKOperator when topKResult is null
new 1ad9c0ac897 Only root can alter template
new d41f64baf3e Fix error judgement for MainFragmentLocatedRegion and
MostlyUsedDataRegion in distributed plan
new 6817624b775 Fix concurrent bug During Heartbeat and Region Creation
(#11656)
new 5fb58cb01ac Asynchronously make memtable checkpoints for wal (#11556)
new 5c52d552edb [IOTDB-6256] Fix FLUSH deadlock
new 84151f370ab Fix file counted twice in TsFileMetrics (#11662)
new ad55c2d330e Rest service code optimization and fixed insertRecords
error prompt returning null issue (#11678)
new 8bd5a2b4845 Enhance the note of parameter seed_config_node (#11685)
new 3d2533d34e3 Enhance the exapmle of parameter dn_seed_config_node
(#11686)
new 69c3c2ceef3 Enhance parameter dn_seed_config_node commets order
(#11687)
new f17901167ac Featrue add insertRecords and insertTablets to the rest v2
service for data type verification (#11708)
new 7cd3f35acdb PBTree Improvement: WrappedSegment Layout Revision for
Reduced GC Overhead (#11652)
new e5004e6a14d Add a param to switch whether to enable data separation or
not (#11692)
The 102 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/pipe-it-2cluster.yml | 9 +-
Jenkinsfile | 2 +-
distribution/src/assembly/library-udf.xml | 23 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSource.java | 2 +-
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 2 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 2 +-
.../java/org/apache/iotdb/flink/TsFileUtils.java | 2 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 2 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 2 +-
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 2 +-
.../main/java/org/apache/iotdb/kafka/Consumer.java | 2 +-
.../org/apache/iotdb/kafka/ConsumerThread.java | 2 +-
example/pipe-count-point-processor/pom.xml | 66 ++
.../java/org/apache/iotdb/CountPointProcessor.java | 82 +++
example/pipe-opc-ua-sink/pom.xml | 42 ++
.../java/org/apache/iotdb/opcua/ClientExample.java | 50 ++
.../apache/iotdb/opcua/ClientExampleRunner.java | 144 +++++
.../java/org/apache/iotdb/opcua/ClientTest.java | 129 ++++
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 128 ++++
example/pom.xml | 2 +
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 2 +-
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 2 +-
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 2 +-
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 2 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 2 +-
.../org/apache/iotdb/DataMigrationExample.java | 2 +-
.../iotdb/HybridTimeseriesSessionExample.java | 2 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 2 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 2 +-
.../iotdb/SyntaxConventionRelatedExample.java | 2 +-
.../main/java/org/apache/iotdb/TabletExample.java | 2 +-
.../org/apache/iotdb/trigger/LoggerTrigger.java | 2 +-
.../iotdb/trigger/StatisticsUpdaterTrigger.java | 2 +-
.../iotdb/tsfile/TsFileForceAppendWrite.java | 2 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../tsfile/TsFileWriteAlignedWithTSRecord.java | 2 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 2 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 2 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 2 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 2 +-
.../iotdb/db/query/udf/example/TwoSumBlock.java | 4 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 5 +-
.../it/env/cluster/config/MppCommonConfig.java | 40 +-
.../it/env/cluster/config/MppConfigNodeConfig.java | 7 +
.../it/env/cluster/config/MppDataNodeConfig.java | 7 +
.../env/cluster/config/MppSharedCommonConfig.java | 44 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 71 ++-
.../it/env/cluster/node/AbstractNodeWrapper.java | 7 +
.../it/env/cluster/node/ConfigNodeWrapper.java | 7 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 5 +-
.../it/env/remote/config/RemoteCommonConfig.java | 24 +-
.../env/remote/config/RemoteConfigNodeConfig.java | 9 +-
.../it/env/remote/config/RemoteDataNodeConfig.java | 9 +-
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 17 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 40 ++
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 2 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 12 +-
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 6 +-
.../apache/iotdb/itbase/env/DataNodeConfig.java | 6 +-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 2 +-
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 21 +
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 23 +
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 2 +-
.../aligned/IoTDBAlignedOffsetLimitPushDownIT.java | 151 +++++
.../db/it/aligned/IoTDBAlignedSeriesQuery5IT.java | 56 ++
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 37 +-
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 108 +++-
.../IoTDBGroupByNaturalMonthNsPrecisionIT.java | 107 ++++
.../IoTDBGroupByNaturalMonthUsPrecisionIT.java | 92 +++
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 68 ++
.../{ => quota}/IoTDBClusterDeviceQuotaIT.java | 7 +-
.../IoTDBClusterMixQuotaIT.java} | 77 +--
.../IoTDBClusterQuotaIT.java} | 39 +-
.../IoTDBClusterTimeSeriesQuotaIT.java} | 10 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 2 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 104 ++-
.../test/java/org/apache/iotdb/flink/it/Utils.java | 2 +-
.../apache/iotdb/pipe/it/IoTDBPipeClusterIT.java | 130 ++--
.../pipe/it/IoTDBPipeConnectorParallelIT.java | 11 +-
.../apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java | 14 +-
.../apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java | 192 ++++--
.../apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java | 48 +-
.../iotdb/pipe/it/IoTDBPipeSwitchStatusIT.java | 10 +-
.../apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java | 43 +-
.../pipe/it/extractor/IoTDBPipeExtractorIT.java | 231 +++++--
.../session/it/IoTDBSessionAlignedInsertIT.java | 2 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 2 +-
.../it/IoTDBSessionDisableMemControlIT.java | 2 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 2 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 2 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 2 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 66 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 2 +-
.../org/apache/iotdb/session/it/SessionIT.java | 2 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 2 +-
.../{ => write}/UnSupportedDataTypeException.java | 2 +-
.../{ => file/metadata}/enums/TSDataType.java | 4 +-
.../common/block}/TsBlockBuilderStatus.java | 4 +-
.../common/block/column}/Column.java | 5 +-
.../common/block/column}/ColumnBuilder.java | 4 +-
.../common/block/column}/ColumnBuilderStatus.java | 4 +-
.../common/block/column}/ColumnEncoding.java | 2 +-
.../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 4 +-
.../parameter/PipeParameterValidator.java | 6 +-
.../api/customizer/parameter/PipeParameters.java | 41 +-
.../main/java/org/apache/iotdb/udf/api/UDTF.java | 6 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 2 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 2 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 14 +-
.../java/org/apache/iotdb/isession/ISession.java | 2 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 4 +-
.../apache/iotdb/isession/pool/ISessionPool.java | 2 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 2 +
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 2 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 4 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 2 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 4 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 4 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 2 +-
.../iotdb/session/template/MeasurementNode.java | 2 +-
.../apache/iotdb/session/util/SessionUtils.java | 4 +-
.../iotdb/session/SessionCacheLeaderTest.java | 2 +-
.../java/org/apache/iotdb/session/SessionTest.java | 2 +-
.../java/org/apache/iotdb/session/TabletTest.java | 2 +-
.../session/pool/SessionPoolExceptionTest.java | 2 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 2 +-
.../iotdb/session/util/SessionUtilsTest.java | 2 +-
.../iotdb/flink/DefaultIoTSerializationSchema.java | 2 +-
.../main/java/org/apache/iotdb/flink/Event.java | 2 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 2 +-
.../iotdb/flink/options/IoTDBSinkOptions.java | 2 +-
.../org/apache/iotdb/flink/sql/common/Utils.java | 2 +-
.../sql/function/IoTDBBoundedScanFunction.java | 2 +-
.../flink/sql/function/IoTDBCDCSourceFunction.java | 2 +-
.../flink/sql/function/IoTDBLookupFunction.java | 2 +-
.../flink/sql/function/IoTDBSinkFunction.java | 2 +-
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 2 +-
.../tsfile/RowTsFileOutputFormatTestBase.java | 2 +-
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 2 +-
iotdb-connector/grafana-plugin/go.mod | 22 +-
.../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 4 +-
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 2 +-
.../org/apache/iotdb/hive/TsFileTestHelper.java | 2 +-
.../org/apache/iotdb/spark/db/DataFrameTools.scala | 4 +-
.../tsfile/qp/optimizer/PhysicalOptimizer.java | 2 +-
.../org/apache/iotdb/spark/tsfile/Converter.scala | 3 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 3 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 3 +-
.../apache/iotdb/spark/tsfile/ConverterTest.scala | 2 +-
.../resources/conf/iotdb-confignode.properties | 9 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 7 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 4 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 14 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 37 +-
.../confignode/conf/ConfigNodeDescriptor.java | 17 +-
.../write/region/CreateRegionGroupsPlan.java | 35 +-
.../statemachine/ConfigRegionStateMachine.java | 3 +-
.../iotdb/confignode/manager/ConfigManager.java | 28 +-
.../manager/consensus/ConsensusManager.java | 18 +-
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../confignode/manager/load/cache/LoadCache.java | 8 +-
.../load/cache/node/NodeHeartbeatSample.java | 15 +-
.../manager/load/cache/node/NodeStatistics.java | 4 +-
.../manager/load/service/HeartbeatService.java | 41 +-
.../iotdb/confignode/manager/node/NodeManager.java | 4 +-
.../pipe/runtime/PipeHeartbeatScheduler.java | 6 +
.../manager/pipe/runtime/PipeMetaSyncer.java | 8 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 7 +-
.../manager/pipe/task/PipeTaskCoordinatorLock.java | 4 +
.../manager/schema/ClusterSchemaManager.java | 31 +-
.../schema/ClusterSchemaQuotaStatistics.java | 73 ++-
.../iotdb/confignode/persistence/AuthorInfo.java | 174 ++---
.../confignode/persistence/node/NodeInfo.java | 11 +-
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/PartitionInfo.java | 4 +-
.../persistence/pipe/PipePluginInfo.java | 2 +-
.../persistence/schema/TemplateTable.java | 2 +-
.../impl/schema/DeactivateTemplateProcedure.java | 40 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 44 +-
.../impl/schema/UnsetTemplateProcedure.java | 9 +-
.../statemachine/CreateRegionGroupsProcedure.java | 10 +-
.../iotdb/confignode/service/ConfigNode.java | 10 +-
.../confignode/service/ConfigNodeCommandLine.java | 8 +-
.../confignode/service/ConfigNodeShutdownHook.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 8 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 3 +-
.../router/priority/GreedyPriorityTest.java | 4 +-
.../priority/LeaderPriorityBalancerTest.java | 4 +-
.../manager/load/cache/NodeCacheTest.java | 8 +-
.../confignode/persistence/AuthorInfoTest.java | 134 ++--
.../persistence/schema/ClusterSchemaInfoTest.java | 2 +-
.../persistence/schema/TemplateTableTest.java | 2 +-
.../impl/CreateRegionGroupsProcedureTest.java | 1 +
.../schema/DeactivateTemplateProcedureTest.java | 2 +-
.../impl/schema/UnsetTemplateProcedureTest.java | 2 +-
.../confignode1conf/iotdb-confignode.properties | 1 -
.../confignode2conf/iotdb-confignode.properties | 1 -
.../confignode3conf/iotdb-confignode.properties | 1 -
.../org/apache/iotdb/consensus/IStateMachine.java | 32 -
.../consensus/iot/IoTConsensusServerImpl.java | 21 +
.../consensus/iot/client/DispatchLogHandler.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 60 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 91 ++-
.../iotdb/consensus/ratis/utils/Retriable.java | 107 ++++
.../iotdb/consensus/ratis/utils/RetryPolicy.java | 79 +++
.../apache/iotdb/consensus/ratis/utils/Utils.java | 10 +
.../iotdb/consensus/ratis/RecoverReadTest.java | 3 +-
.../resources/conf/iotdb-datanode.properties | 29 +-
.../src/main/codegen/templates/ModeAccumulator.ftl | 6 +-
.../codegen/templates/abstractVariationWindow.ftl | 2 +-
.../src/main/codegen/templates/constantFill.ftl | 2 +-
.../src/main/codegen/templates/linearFill.ftl | 2 +-
.../src/main/codegen/templates/previousFill.ftl | 2 +-
.../src/main/codegen/templates/variationWindow.ftl | 2 +-
.../codegen/templates/variationWindowManager.ftl | 2 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 6 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 49 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 33 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 5 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 1 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 119 ++--
.../db/consensus/DataRegionConsensusImpl.java | 2 +
.../db/consensus/SchemaRegionConsensusImpl.java | 2 +
.../consensus/statemachine/BaseStateMachine.java | 3 +-
.../dataregion/DataExecutionVisitor.java | 4 +-
.../dataregion/DataRegionStateMachine.java | 31 +-
.../schemaregion/SchemaExecutionVisitor.java | 2 +-
.../schemaregion/SchemaRegionStateMachine.java | 18 -
.../iotdb/db/exception/LoadReadOnlyException.java} | 26 +-
.../metadata/DataTypeMismatchException.java | 2 +-
.../metadata/SchemaQuotaExceededException.java | 8 +-
.../agent/plugin/PipeConnectorConstructor.java | 112 ++++
.../agent/plugin/PipeExtractorConstructor.java | 58 ++
.../db/pipe/agent/plugin/PipePluginAgent.java | 111 ++--
.../pipe/agent/plugin/PipePluginConstructor.java | 85 +++
.../agent/plugin/PipeProcessorConstructor.java | 52 ++
.../pipe/agent/runtime/PipeCronEventInjector.java | 70 --
.../agent/runtime/PipePeriodicalJobExecutor.java | 100 +++
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 7 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 6 +-
.../config/constant/PipeExtractorConstant.java | 2 +
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 2 +-
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 2 +-
.../builder/PipeTransferBatchReqBuilder.java | 30 +-
.../request/PipeTransferTabletRawReq.java | 4 +-
.../db/pipe/connector/protocol/IoTDBConnector.java | 11 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 33 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 34 +-
.../connector/protocol/opcua/OpcUaConnector.java | 2 +-
.../thrift/async/IoTDBThriftAsyncConnector.java | 120 ++--
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../PipeTransferTsFileInsertionEventHandler.java | 5 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 23 +-
.../protocol/websocket/WebSocketConnector.java | 11 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 7 +-
.../event/common/row/PipeDataTypeTransformer.java | 2 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 2 +-
.../tablet/TabletInsertionDataContainer.java | 4 +-
.../tsfile/TsFileInsertionDataContainer.java | 2 +-
.../tsfile/TsFileInsertionDataTabletIterator.java | 2 +-
.../pipe/extractor/IoTDBDataRegionExtractor.java | 33 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 26 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 58 +-
.../PipeRealtimeDataRegionLogExtractor.java | 2 +-
.../realtime/assigner/DisruptorQueue.java | 4 +-
.../iotdb/db/pipe/metric/PipeConnectorMetrics.java | 86 ++-
.../iotdb/db/pipe/metric/PipeExtractorMetrics.java | 114 +++-
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 86 ++-
.../iotdb/db/pipe/metric/PipeResourceMetrics.java | 23 +-
.../db/pipe/resource/memory/PipeMemoryBlock.java | 137 +++-
.../db/pipe/resource/memory/PipeMemoryManager.java | 123 +++-
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 15 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 16 +-
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 14 +-
.../subtask/connector/PipeConnectorSubtask.java | 121 +++-
.../connector/PipeConnectorSubtaskManager.java | 75 +--
.../subtask/processor/PipeProcessorSubtask.java | 21 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 5 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 14 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 2 +-
.../org/apache/iotdb/db/protocol/mqtt/Message.java | 2 +-
.../db/protocol/rest/utils/InsertRowDataUtils.java | 2 +-
.../rest/v1/handler/QueryDataSetHandler.java | 4 +-
.../rest/v1/handler/RequestValidationHandler.java | 12 -
.../v1/handler/StatementConstructionHandler.java | 61 +-
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 47 --
.../rest/v2/handler/QueryDataSetHandler.java | 4 +-
.../rest/v2/handler/RequestValidationHandler.java | 43 ++
.../v2/handler/StatementConstructionHandler.java | 2 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 36 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 8 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 27 +-
.../db/queryengine/common/header/ColumnHeader.java | 2 +-
.../common/header/ColumnHeaderConstant.java | 2 +-
.../queryengine/common/header/DatasetHeader.java | 2 +-
.../execution/aggregation/Accumulator.java | 6 +-
.../execution/aggregation/AccumulatorFactory.java | 2 +-
.../execution/aggregation/Aggregator.java | 6 +-
.../execution/aggregation/AvgAccumulator.java | 8 +-
.../execution/aggregation/CountAccumulator.java | 6 +-
.../execution/aggregation/CountIfAccumulator.java | 6 +-
.../aggregation/CountTimeAccumulator.java | 6 +-
.../execution/aggregation/ExtremeAccumulator.java | 8 +-
.../aggregation/FirstValueAccumulator.java | 8 +-
.../aggregation/FirstValueDescAccumulator.java | 4 +-
.../aggregation/LastValueAccumulator.java | 8 +-
.../aggregation/LastValueDescAccumulator.java | 4 +-
.../execution/aggregation/MaxTimeAccumulator.java | 6 +-
.../aggregation/MaxTimeDescAccumulator.java | 2 +-
.../execution/aggregation/MaxValueAccumulator.java | 8 +-
.../execution/aggregation/MinTimeAccumulator.java | 6 +-
.../aggregation/MinTimeDescAccumulator.java | 2 +-
.../execution/aggregation/MinValueAccumulator.java | 8 +-
.../execution/aggregation/SumAccumulator.java | 8 +-
.../aggregation/TimeDurationAccumulator.java | 6 +-
.../MonotonicQueueSlidingWindowAggregator.java | 2 +-
.../slidingwindow/SlidingWindowAggregator.java | 8 +-
.../SlidingWindowAggregatorFactory.java | 4 +-
.../timerangeiterator/AggrWindowIterator.java | 91 +--
.../PreAggrWindowWithNaturalMonthIterator.java | 17 +-
.../SingleTimeWindowIterator.java | 3 +-
.../TimeRangeIteratorFactory.java | 41 +-
.../execution/exchange/MPPDataExchangeManager.java | 174 +++--
.../exchange/source/LocalSourceHandle.java | 34 +-
.../execution/exchange/source/SourceHandle.java | 60 +-
.../execution/load/AlignedChunkData.java | 4 +-
.../execution/load/NonAlignedChunkData.java | 2 +-
.../queryengine/execution/load/TsFileSplitter.java | 2 +-
.../execution/operator/AbstractOperator.java | 8 +-
.../execution/operator/AggregationUtil.java | 8 +-
.../operator/process/AbstractIntoOperator.java | 6 +-
.../operator/process/AggregationOperator.java | 2 +-
.../operator/process/DeviceViewIntoOperator.java | 4 +-
.../operator/process/DeviceViewOperator.java | 6 +-
.../execution/operator/process/FillOperator.java | 2 +-
.../operator/process/FilterAndProjectOperator.java | 6 +-
.../execution/operator/process/IntoOperator.java | 4 +-
.../operator/process/LinearFillOperator.java | 2 +-
.../operator/process/MergeSortOperator.java | 4 +-
.../process/RawDataAggregationOperator.java | 2 +-
.../operator/process/SingleDeviceViewOperator.java | 4 +-
.../process/SlidingWindowAggregationOperator.java | 2 +-
.../execution/operator/process/SortOperator.java | 4 +-
.../operator/process/TagAggregationOperator.java | 4 +-
.../execution/operator/process/TopKOperator.java | 29 +-
.../operator/process/TransformOperator.java | 6 +-
.../execution/operator/process/fill/IFill.java | 2 +-
.../operator/process/fill/ILinearFill.java | 2 +-
.../process/fill/identity/IdentityFill.java | 2 +-
.../process/fill/identity/IdentityLinearFill.java | 2 +-
.../operator/process/fill/linear/LinearFill.java | 2 +-
.../process/join/HorizontallyConcatOperator.java | 6 +-
.../process/join/RowBasedTimeJoinOperator.java | 2 +-
.../operator/process/join/merge/ColumnMerger.java | 2 +-
.../process/join/merge/MergeSortComparator.java | 2 +-
.../process/join/merge/MultiColumnMerger.java | 4 +-
.../join/merge/NonOverlappedMultiColumnMerger.java | 2 +-
.../process/join/merge/SingleColumnMerger.java | 4 +-
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
.../operator/process/last/LastQueryUtil.java | 2 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../last/UpdateViewPathLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelMergeOperator.java | 2 +-
.../schema/CountGroupByLevelScanOperator.java | 2 +-
.../operator/schema/CountMergeOperator.java | 2 +-
.../schema/NodeManageMemoryMergeOperator.java | 2 +-
.../operator/schema/NodePathsConvertOperator.java | 2 +-
.../operator/schema/NodePathsCountOperator.java | 2 +-
.../operator/schema/SchemaCountOperator.java | 2 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 2 +-
.../operator/schema/SchemaQueryScanOperator.java | 2 +-
.../operator/schema/SchemaTsBlockUtil.java | 2 +-
.../AbstractSeriesAggregationScanOperator.java | 144 +++--
.../operator/source/AlignedSeriesScanOperator.java | 4 +-
.../operator/source/AlignedSeriesScanUtil.java | 2 +-
.../operator/source/SeriesScanOperator.java | 4 +-
.../execution/operator/source/SeriesScanUtil.java | 4 +-
.../operator/source/ShowQueriesOperator.java | 4 +-
.../operator/window/AbstractVariationWindow.java | 2 +-
.../execution/operator/window/ConditionWindow.java | 2 +-
.../operator/window/ConditionWindowManager.java | 4 +-
.../execution/operator/window/CountWindow.java | 2 +-
.../operator/window/CountWindowManager.java | 4 +-
.../execution/operator/window/IWindow.java | 2 +-
.../execution/operator/window/IWindowManager.java | 4 +-
.../execution/operator/window/SessionWindow.java | 2 +-
.../operator/window/SessionWindowManager.java | 2 +-
.../execution/operator/window/TimeWindow.java | 2 +-
.../operator/window/TimeWindowManager.java | 2 +-
.../operator/window/VariationWindowManager.java | 2 +-
.../operator/window/VariationWindowParameter.java | 2 +-
.../operator/window/WindowManagerFactory.java | 2 +-
.../db/queryengine/plan/analyze/Analysis.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 40 +-
.../plan/analyze/ExpressionAnalyzer.java | 2 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 2 +-
.../queryengine/plan/analyze/ExpressionUtils.java | 2 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 25 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 2 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 2 +-
.../analyze/cache/schema/SchemaCacheEntry.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 27 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 2 +-
.../plan/analyze/schema/ISchemaAutoCreation.java | 2 +-
.../plan/analyze/schema/ISchemaFetcher.java | 2 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 2 +-
.../plan/analyze/schema/SchemaValidator.java | 2 +-
.../plan/analyze/schema/TemplateSchemaFetcher.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 29 +
.../config/metadata/CountDatabaseTask.java | 2 +-
.../config/metadata/CountTimeSlotListTask.java | 2 +-
.../execution/config/metadata/GetRegionIdTask.java | 2 +-
.../config/metadata/GetSeriesSlotListTask.java | 2 +-
.../config/metadata/GetTimeSlotListTask.java | 2 +-
.../config/metadata/ShowClusterDetailsTask.java | 2 +-
.../execution/config/metadata/ShowClusterTask.java | 3 +-
.../config/metadata/ShowConfigNodesTask.java | 2 +-
.../config/metadata/ShowContinuousQueriesTask.java | 4 +-
.../config/metadata/ShowDataNodesTask.java | 2 +-
.../config/metadata/ShowFunctionsTask.java | 2 +-
.../config/metadata/ShowPipePluginsTask.java | 8 +-
.../execution/config/metadata/ShowRegionTask.java | 2 +-
.../execution/config/metadata/ShowTTLTask.java | 2 +-
.../config/metadata/ShowTriggersTask.java | 2 +-
.../config/metadata/ShowVariablesTask.java | 2 +-
.../template/ShowNodesInSchemaTemplateTask.java | 2 +-
.../metadata/template/ShowPathSetTemplateTask.java | 2 +-
.../metadata/template/ShowSchemaTemplateTask.java | 2 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 2 +-
.../config/sys/quota/ShowSpaceQuotaTask.java | 2 +-
.../config/sys/quota/ShowThrottleQuotaTask.java | 2 +-
.../memory/StatementMemorySourceVisitor.java | 2 +-
.../db/queryengine/plan/expression/Expression.java | 2 +-
.../plan/expression/ExpressionFactory.java | 2 +-
.../plan/expression/binary/BinaryExpression.java | 2 +-
.../plan/expression/leaf/ConstantOperand.java | 2 +-
.../plan/expression/leaf/LeafOperand.java | 2 +-
.../plan/expression/leaf/TimeSeriesOperand.java | 2 +-
.../plan/expression/multi/FunctionExpression.java | 2 +-
.../multi/builtin/BuiltInScalarFunctionHelper.java | 2 +-
.../multi/builtin/helper/CastFunctionHelper.java | 2 +-
.../multi/builtin/helper/DiffFunctionHelper.java | 2 +-
.../builtin/helper/ReplaceFunctionHelper.java | 2 +-
.../multi/builtin/helper/RoundFunctionHelper.java | 2 +-
.../builtin/helper/SubStringFunctionHelper.java | 2 +-
.../expression/other/CaseWhenThenExpression.java | 2 +-
.../plan/expression/ternary/TernaryExpression.java | 2 +-
.../plan/expression/unary/UnaryExpression.java | 2 +-
.../visitor/ColumnTransformerVisitor.java | 2 +-
.../visitor/IntermediateLayerVisitor.java | 2 +-
.../plan/optimization/LimitOffsetPushDown.java | 15 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 74 +--
.../plan/parser/StatementGenerator.java | 9 +-
.../plan/planner/LocalExecutionPlanContext.java | 2 +-
.../plan/planner/LogicalPlanBuilder.java | 2 +-
.../plan/planner/OperatorTreeGenerator.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 41 +-
.../write/CreateAlignedTimeSeriesNode.java | 2 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 2 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 2 +-
.../plan/node/metedata/write/MeasurementGroup.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 13 +-
.../planner/plan/node/write/InsertRowNode.java | 4 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 48 +-
.../planner/plan/node/write/InsertTabletNode.java | 4 +-
.../plan/node/write/PipeEnrichedInsertNode.java | 2 +-
.../parameter/DeviceViewIntoPathDescriptor.java | 2 +-
.../plan/parameter/GroupByTimeParameter.java | 85 +--
.../planner/plan/parameter/IntoPathDescriptor.java | 2 +-
.../planner/plan/parameter/SeriesScanOptions.java | 7 +-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 7 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 19 +-
.../statement/component/GroupByTimeComponent.java | 52 +-
.../plan/statement/crud/InsertBaseStatement.java | 2 +-
.../crud/InsertMultiTabletsStatement.java | 11 +-
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 2 +-
.../plan/statement/crud/InsertRowsStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 4 +-
.../crud/PipeEnrichedInsertBaseStatement.java | 2 +-
.../InternalBatchActivateTemplateStatement.java | 33 +-
.../InternalCreateTimeSeriesStatement.java | 2 +-
.../plan/statement/literal/BooleanLiteral.java | 2 +-
.../plan/statement/literal/DoubleLiteral.java | 2 +-
.../plan/statement/literal/Literal.java | 2 +-
.../plan/statement/literal/LongLiteral.java | 2 +-
.../plan/statement/literal/NullLiteral.java | 2 +-
.../plan/statement/literal/StringLiteral.java | 2 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 2 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/CreateTimeSeriesStatement.java | 2 +-
.../statement/metadata/ShowDatabaseStatement.java | 2 +-
.../template/AlterSchemaTemplateStatement.java | 6 +-
.../template/CreateSchemaTemplateStatement.java | 2 +-
.../transformation/api/LayerPointReader.java | 2 +-
.../transformation/api/LayerRowReader.java | 2 +-
.../transformation/api/LayerRowWindowReader.java | 2 +-
...ializableRowRecordListBackedMultiColumnRow.java | 2 +-
...izableRowRecordListBackedMultiColumnWindow.java | 2 +-
.../dag/builder/EvaluationDAGBuilder.java | 2 +-
.../dag/column/CaseWhenThenColumnTransformer.java | 4 +-
.../transformation/dag/column/ColumnCache.java | 2 +-
.../dag/column/ColumnTransformer.java | 2 +-
.../binary/ArithmeticBinaryColumnTransformer.java | 4 +-
.../dag/column/binary/BinaryColumnTransformer.java | 4 +-
.../binary/CompareBinaryColumnTransformer.java | 4 +-
.../column/binary/LogicAndColumnTransformer.java | 4 +-
.../column/binary/LogicOrColumnTransformer.java | 4 +-
.../dag/column/leaf/ConstantColumnTransformer.java | 2 +-
.../column/multi/MappableUDFColumnTransformer.java | 4 +-
.../column/ternary/BetweenColumnTransformer.java | 4 +-
.../ternary/CompareTernaryColumnTransformer.java | 4 +-
.../unary/ArithmeticNegationColumnTransformer.java | 4 +-
.../dag/column/unary/InColumnTransformer.java | 4 +-
.../dag/column/unary/IsNullColumnTransformer.java | 4 +-
.../column/unary/LogicNotColumnTransformer.java | 4 +-
.../dag/column/unary/RegularColumnTransformer.java | 4 +-
.../dag/column/unary/UnaryColumnTransformer.java | 4 +-
.../scalar/CastFunctionColumnTransformer.java | 4 +-
.../scalar/DiffFunctionColumnTransformer.java | 4 +-
.../scalar/ReplaceFunctionColumnTransformer.java | 4 +-
.../scalar/RoundFunctionColumnTransformer.java | 4 +-
.../scalar/SubStringFunctionColumnTransformer.java | 4 +-
.../dag/input/ConstantInputReader.java | 2 +-
.../transformation/dag/input/IUDFInputDataSet.java | 2 +-
.../dag/input/QueryDataSetInputLayer.java | 2 +-
.../dag/input/TsBlockInputDataSet.java | 2 +-
.../MultiInputColumnIntermediateLayer.java | 4 +-
...InputColumnMultiReferenceIntermediateLayer.java | 2 +-
...nputColumnSingleReferenceIntermediateLayer.java | 2 +-
.../binary/ArithmeticBinaryTransformer.java | 4 +-
.../dag/transformer/binary/BinaryTransformer.java | 2 +-
.../binary/CompareBinaryTransformer.java | 4 +-
.../binary/CompareNonEqualTransformer.java | 2 +-
.../transformer/binary/LogicBinaryTransformer.java | 4 +-
.../multi/MappableUDFQueryRowTransformer.java | 2 +-
.../dag/transformer/multi/UDFQueryTransformer.java | 2 +-
.../multi/UniversalUDFQueryTransformer.java | 2 +-
.../ternary/CompareTernaryTransformer.java | 4 +-
.../transformer/ternary/TernaryTransformer.java | 2 +-
.../unary/ArithmeticNegationTransformer.java | 2 +-
.../dag/transformer/unary/InTransformer.java | 2 +-
.../dag/transformer/unary/IsNullTransformer.java | 2 +-
.../dag/transformer/unary/LogicNotTransformer.java | 4 +-
.../dag/transformer/unary/RegularTransformer.java | 4 +-
.../transformer/unary/TransparentTransformer.java | 2 +-
.../dag/transformer/unary/UnaryTransformer.java | 2 +-
.../unary/scalar/CastFunctionTransformer.java | 2 +-
.../unary/scalar/DiffFunctionTransformer.java | 2 +-
.../unary/scalar/ReplaceFunctionTransformer.java | 2 +-
.../unary/scalar/RoundFunctionTransformer.java | 2 +-
.../unary/scalar/SubStringFunctionTransformer.java | 2 +-
.../transformation/dag/udf/UDTFExecutor.java | 6 +-
.../dag/udf/UDTFInformationInferrer.java | 2 +-
.../transformation/dag/util/LayerCacheUtils.java | 2 +-
.../transformation/dag/util/TransformUtils.java | 6 +-
.../row/ElasticSerializableRowRecordList.java | 2 +-
.../row/SerializableRowRecordList.java | 4 +-
.../tv/ElasticSerializableBinaryTVList.java | 2 +-
.../tv/ElasticSerializableTVList.java | 4 +-
.../datastructure/tv/SerializableBinaryTVList.java | 2 +-
.../tv/SerializableBooleanTVList.java | 2 +-
.../datastructure/tv/SerializableDoubleTVList.java | 2 +-
.../datastructure/tv/SerializableFloatTVList.java | 2 +-
.../datastructure/tv/SerializableIntTVList.java | 2 +-
.../datastructure/tv/SerializableLongTVList.java | 2 +-
.../datastructure/tv/SerializableTVList.java | 4 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 81 +--
.../rescon/DataNodeSchemaQuotaManager.java | 85 ++-
.../rescon/ISchemaEngineStatistics.java | 2 +
.../rescon/MemSchemaEngineStatistics.java | 14 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 13 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 13 +-
.../visitor/SchemaRegionPlanDeserializer.java | 2 +-
.../visitor/SchemaRegionPlanSerializer.java | 2 +-
.../visitor/SchemaRegionPlanTxtSerializer.java | 2 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 2 +-
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 2 +-
.../mtree/impl/mem/mnode/info/MeasurementInfo.java | 2 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 78 ++-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 2 +-
.../impl/pbtree/StampedWriterPreferredLock.java | 10 +-
.../mtree/impl/pbtree/cache/CacheManager.java | 286 +++++++--
.../mtree/impl/pbtree/cache/ICacheManager.java | 10 +-
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 104 +++
.../mnode/container/CachedMNodeContainer.java | 5 +
.../mnode/container/ICachedMNodeContainer.java | 2 +
.../mtree/impl/pbtree/schemafile/InternalPage.java | 18 +-
.../mtree/impl/pbtree/schemafile/RecordUtils.java | 2 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 35 +-
.../mtree/impl/pbtree/schemafile/SchemaPage.java | 2 +-
.../mtree/impl/pbtree/schemafile/Segment.java | 478 --------------
.../impl/pbtree/schemafile/WrappedSegment.java | 710 +++++++++++++++++----
.../schemafile/pagemgr/BTreePageManager.java | 6 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 71 ++-
.../read/resp/info/impl/ShowTimeSeriesResult.java | 2 +-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 2 +-
.../schemaregion/utils/ResourceByPathUtils.java | 2 +-
.../write/req/ICreateAlignedTimeSeriesPlan.java | 2 +-
.../write/req/ICreateTimeSeriesPlan.java | 2 +-
.../write/req/SchemaRegionWritePlanFactory.java | 2 +-
.../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 2 +-
.../write/req/impl/CreateTimeSeriesPlanImpl.java | 2 +-
.../template/ClusterTemplateManager.java | 6 +-
.../iotdb/db/schemaengine/template/Template.java | 2 +-
.../template/alter/TemplateExtendInfo.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 67 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 3 +
.../db/service/metrics/CompactionMetrics.java | 311 +++++++++
.../metrics/IoTDBInternalLocalReporter.java | 2 +-
.../db/service/metrics/file/TsFileMetrics.java | 8 +-
.../iotdb/db/storageengine/StorageEngine.java | 7 +
.../db/storageengine/dataregion/DataRegion.java | 346 ++++++----
.../dataregion/HashLastFlushTimeMap.java | 117 +---
.../dataregion/ILastFlushTimeMap.java | 31 +-
.../impl/ReadChunkCompactionPerformer.java | 6 +-
.../execute/recover/CompactionRecoverManager.java | 18 +-
.../execute/task/AbstractCompactionTask.java | 63 +-
.../execute/task/CrossSpaceCompactionTask.java | 7 +-
.../execute/task/InnerSpaceCompactionTask.java | 35 +-
.../task/InsertionCrossSpaceCompactionTask.java | 24 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 22 +-
.../utils/writer/AbstractCompactionWriter.java | 2 +-
.../writer/AbstractCrossCompactionWriter.java | 2 +-
.../writer/AbstractInnerCompactionWriter.java | 2 +-
.../utils/writer/FastCrossCompactionWriter.java | 2 +-
.../utils/writer/FastInnerCompactionWriter.java | 2 +-
.../writer/ReadPointCrossCompactionWriter.java | 2 +-
.../writer/ReadPointInnerCompactionWriter.java | 2 +-
.../compaction/io/CompactionTsFileWriter.java | 13 +-
.../schedule/CompactionScheduleSummary.java | 72 +++
.../compaction/schedule/CompactionScheduler.java | 36 +-
.../compaction/schedule/CompactionWorker.java | 13 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 11 +-
.../dataregion/flush/MemTableFlushTask.java | 4 +-
.../dataregion/memtable/AbstractMemTable.java | 2 +-
.../memtable/AlignedReadOnlyMemChunk.java | 2 +-
.../memtable/AlignedWritableMemChunk.java | 4 +-
.../dataregion/memtable/IWritableMemChunk.java | 2 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 2 +-
.../dataregion/memtable/TsFileProcessor.java | 2 +-
.../dataregion/memtable/WritableMemChunk.java | 4 +-
.../io/LocalTextModificationAccessor.java | 3 +
.../read/reader/chunk/MemAlignedPageReader.java | 6 +-
.../read/reader/chunk/MemPageReader.java | 6 +-
.../reader/common/CachedPriorityMergeReader.java | 2 +-
.../dataregion/tsfile/TsFileResource.java | 5 +-
.../dataregion/utils/TsFileResourceUtils.java | 2 +-
.../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 | 27 +-
.../dataregion/wal/utils/WALEntryHandler.java | 2 +-
.../dataregion/wal/utils/WALEntryPosition.java | 8 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 63 +-
.../dataregion/wal/utils/WALWriteUtils.java | 2 +-
.../wal/utils/listener/AbstractResultListener.java | 2 +
.../wal/utils/listener/WALFlushListener.java | 2 +-
.../db/storageengine/rescon/disk/TierManager.java | 3 +
.../rescon/memory/PrimitiveArrayManager.java | 4 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 52 +-
.../rescon/quotas/DefaultOperationQuota.java | 2 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 4 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 4 +-
.../db/tools/validate/TsFileValidationTool.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 2 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 113 +++-
.../iotdb/db/utils/EncodingInferenceUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 6 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 4 +-
.../iotdb/db/utils/TimestampPrecisionUtils.java | 19 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../db/utils/datastructure/BackAlignedTVList.java | 2 +-
.../db/utils/datastructure/BackBinaryTVList.java | 2 +-
.../db/utils/datastructure/BackBooleanTVList.java | 2 +-
.../db/utils/datastructure/BackDoubleTVList.java | 2 +-
.../db/utils/datastructure/BackFloatTVList.java | 2 +-
.../db/utils/datastructure/BackIntTVList.java | 2 +-
.../db/utils/datastructure/BackLongTVList.java | 2 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 2 +-
.../db/utils/datastructure/BooleanTVList.java | 2 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 2 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 2 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 2 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 2 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 2 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../db/utils/datastructure/TimAlignedTVList.java | 2 +-
.../db/utils/datastructure/TimBinaryTVList.java | 2 +-
.../db/utils/datastructure/TimBooleanTVList.java | 2 +-
.../db/utils/datastructure/TimDoubleTVList.java | 2 +-
.../db/utils/datastructure/TimFloatTVList.java | 2 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 2 +-
.../db/utils/datastructure/TimLongTVList.java | 2 +-
.../apache/iotdb/db/utils/sort/DiskSpiller.java | 4 +-
.../iotdb/db/utils/windowing/api/Window.java | 2 +-
.../windowing/configuration/Configuration.java | 2 +-
.../SlidingSizeWindowConfiguration.java | 2 +-
.../SlidingTimeWindowConfiguration.java | 2 +-
.../utils/windowing/window/EvictableBatchList.java | 2 +-
.../db/utils/windowing/window/WindowImpl.java | 4 +-
.../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} | 60 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 2 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 2 +-
.../cache/dualkeycache/DualKeyCacheTest.java | 2 +-
.../mtree/lock/StampedWriterPreferredLockTest.java | 43 ++
.../metadata/mtree/schemafile/RecordUtilTests.java | 2 +-
.../mtree/schemafile/SchemaFileLogTest.java | 13 +
.../metadata/mtree/schemafile/SchemaFileTest.java | 2 +-
.../metadata/mtree/schemafile/SchemaPageTest.java | 2 +-
.../mtree/schemafile/WrappedSegmentTest.java | 2 +-
.../db/metadata/path/MeasurementPathTest.java | 2 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 2 +-
.../schemaRegion/SchemaRegionBasicTest.java | 2 +-
.../schemaRegion/SchemaRegionManagementTest.java | 2 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 44 +-
.../schemaRegion/SchemaRegionTestUtil.java | 2 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../metadata/view/ViewExpressionToStringTest.java | 2 +-
.../db/pipe/agent/plugin/PipePluginAgentTest.java | 6 +-
.../iotdb/db/pipe/connector/PipeReceiverTest.java | 2 +-
.../db/pipe/connector/PipeThriftRequestTest.java | 2 +-
.../db/pipe/event/PipeDataTypeTransformerTest.java | 2 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 2 +-
.../PipeConnectorSubtaskExecutorTest.java | 3 +
.../PipeProcessorSubtaskExecutorTest.java | 3 +
.../resource/PipeTsFileResourceManagerTest.java | 2 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 2 +-
.../common/schematree/ClusterSchemaTreeTest.java | 2 +-
.../queryengine/common/schematree/NodeRefTest.java | 2 +-
.../queryengine/execution/ConfigExecutionTest.java | 2 +-
.../db/queryengine/execution/DataDriverTest.java | 2 +-
.../execution/aggregation/AccumulatorTest.java | 6 +-
.../aggregation/TimeRangeIteratorTest.java | 183 +++++-
.../executor/RegionWriteExecutorTest.java | 2 +-
.../operator/AggregationOperatorTest.java | 9 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 24 +-
.../operator/AlignedSeriesScanOperatorTest.java | 2 +-
.../execution/operator/AlignedSeriesTestUtil.java | 2 +-
.../execution/operator/DeviceViewOperatorTest.java | 2 +-
.../execution/operator/FillOperatorTest.java | 2 +-
.../operator/HorizontallyConcatOperatorTest.java | 6 +-
.../execution/operator/LastQueryOperatorTest.java | 2 +-
.../operator/LastQuerySortOperatorTest.java | 2 +-
.../execution/operator/LimitOperatorTest.java | 2 +-
.../execution/operator/LinearFillOperatorTest.java | 2 +-
.../execution/operator/MergeSortOperatorTest.java | 4 +-
.../execution/operator/MultiColumnMergerTest.java | 6 +-
.../NonOverlappedMultiColumnMergerTest.java | 6 +-
.../execution/operator/OffsetOperatorTest.java | 2 +-
.../execution/operator/OperatorMemoryTest.java | 24 +-
.../operator/RawDataAggregationOperatorTest.java | 18 +-
.../SeriesAggregationScanOperatorTest.java | 24 +-
.../execution/operator/SeriesScanOperatorTest.java | 2 +-
.../execution/operator/SingleColumnMergerTest.java | 6 +-
.../operator/SingleDeviceViewOperatorTest.java | 2 +-
.../SlidingWindowAggregationOperatorTest.java | 5 +-
.../execution/operator/SortOperatorTest.java | 2 +-
.../execution/operator/TopKOperatorTest.java | 301 +++++++--
.../operator/UpdateLastCacheOperatorTest.java | 2 +-
.../schema/SchemaFetchScanOperatorTest.java | 2 +-
.../schema/SchemaQueryScanOperatorTest.java | 2 +-
.../operator/sink/IdentitySinkOperatorTest.java | 2 +-
.../plan/analyze/AggregationDescriptorTest.java | 2 +-
.../db/queryengine/plan/analyze/AnalyzeTest.java | 2 +-
.../plan/analyze/FakeSchemaFetcherImpl.java | 2 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 2 +-
.../plan/parser/StatementGeneratorTest.java | 2 +-
.../db/queryengine/plan/plan/ExpressionTest.java | 2 +-
.../queryengine/plan/plan/LogicalPlannerTest.java | 2 +-
.../queryengine/plan/plan/PipelineBuilderTest.java | 2 +-
.../plan/plan/QueryLogicalPlanUtil.java | 2 +-
.../distribution/AggregationDistributionTest.java | 2 +-
.../distribution/DistributionPlannerBasicTest.java | 2 +-
.../queryengine/plan/plan/distribution/Util.java | 2 +-
.../queryengine/plan/plan/distribution/Util2.java | 2 +-
.../metadata/write/MetadataWriteNodeSerDeTest.java | 2 +-
.../node/process/AggregationNodeSerdeTest.java | 5 +-
.../plan/node/process/FilterNodeSerdeTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 5 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 5 +-
.../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 | 2 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 5 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 2 +-
.../write/InsertMultiTabletsNodeSerdeTest.java | 2 +-
.../plan/node/write/InsertRowNodeSerdeTest.java | 2 +-
.../plan/node/write/InsertRowsNodeSerdeTest.java | 2 +-
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 2 +-
.../plan/node/write/InsertTabletNodeSerdeTest.java | 2 +-
.../plan/node/write/WritePlanNodeSplitTest.java | 82 ++-
...meticAndCompareBinaryColumnTransformerTest.java | 6 +-
.../binary/LogicBinaryColumnTransformerTest.java | 6 +-
.../column/unary/UnaryColumnTransformerTest.java | 6 +-
.../ElasticSerializableRowRecordListTest.java | 2 +-
.../ElasticSerializableTVListTest.java | 2 +-
.../SerializableBinaryTVListTest.java | 2 +-
.../SerializableBooleanTVListTest.java | 2 +-
.../SerializableDoubleTVListTest.java | 2 +-
.../datastructure/SerializableFloatTVListTest.java | 2 +-
.../datastructure/SerializableIntTVListTest.java | 2 +-
.../datastructure/SerializableLongTVListTest.java | 2 +-
.../SerializableRowRecordListTest.java | 2 +-
.../DataNodeInternalRPCServiceImplTest.java | 2 +-
.../storageengine/buffer/BloomFilterCacheTest.java | 2 +-
.../db/storageengine/buffer/ChunkCacheTest.java | 2 +-
.../storageengine/dataregion/DataRegionTest.java | 170 ++++-
.../dataregion/LastFlushTimeMapTest.java | 36 +-
.../iotdb/db/storageengine/dataregion/TTLTest.java | 2 +-
.../TsFileResourceProgressIndexTest.java | 162 ++++-
.../compaction/AbstractCompactionTest.java | 70 +-
.../compaction/CompactionValidationTest.java | 2 +-
.../CrossSpaceCompactionWithUnusualCasesTest.java | 2 +-
.../compaction/FastAlignedCrossCompactionTest.java | 2 +-
.../FastCrossCompactionPerformerTest.java | 2 +-
.../FastInnerCompactionPerformerTest.java | 4 +-
.../FastNonAlignedCrossCompactionTest.java | 2 +-
.../compaction/ReadChunkInnerCompactionTest.java | 299 ++++++++-
.../ReadPointAlignedCrossCompactionTest.java | 2 +-
.../ReadPointCompactionPerformerTest.java | 2 +-
.../ReadPointNonAlignedCrossCompactionTest.java | 2 +-
.../compaction/TestUtilsForAlignedSeries.java | 2 +-
.../TsFileValidationCorrectnessTests.java | 2 +-
...eCompactionWithFastPerformerValidationTest.java | 2 +-
...actionWithReadPointPerformerValidationTest.java | 2 +-
.../InsertionCrossSpaceCompactionRecoverTest.java | 2 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 2 +-
.../cross/InsertionCrossSpaceCompactionTest.java | 22 +-
.../dataregion/compaction/cross/MergeTest.java | 2 +-
.../compaction/cross/MergeUpgradeTest.java | 2 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 2 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 6 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 2 +-
.../inner/FastCompactionPerformerAlignedTest.java | 2 +-
.../FastCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 2 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../inner/InnerCompactionSchedulerTest.java | 10 +-
.../compaction/inner/InnerCompactionTest.java | 2 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 2 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 2 +-
.../recover/SizeTieredCompactionRecoverTest.java | 2 +-
.../settle/SettleRequestHandlerTest.java | 2 +-
.../compaction/utils/CompactionCheckerUtils.java | 2 +-
.../utils/CompactionFileGeneratorUtils.java | 2 +-
.../compaction/utils/CompactionTestFileWriter.java | 2 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 2 +-
.../compaction/utils/TsFileGeneratorUtils.java | 2 +-
.../dataregion/memtable/MemTableFlushTaskTest.java | 2 +-
.../dataregion/memtable/MemTableTestUtils.java | 2 +-
.../dataregion/memtable/MemtableBenchmark.java | 2 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 4 +-
.../dataregion/memtable/TsFileProcessorTest.java | 2 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 2 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 2 +-
.../read/reader/common/FakedSeriesReader.java | 2 +-
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 2 +-
.../read/reader/series/SeriesReaderTestUtil.java | 2 +-
.../series/SeriesScanLimitOffsetPushDownTest.java | 2 +-
.../dataregion/wal/WALManagerTest.java | 2 +-
.../wal/allocation/ElasticStrategyTest.java | 2 +-
.../wal/allocation/FirstCreateStrategyTest.java | 2 +-
.../wal/allocation/RoundRobinStrategyTest.java | 2 +-
.../dataregion/wal/buffer/WALBufferCommonTest.java | 2 +-
.../wal/checkpoint/CheckpointManagerTest.java | 7 +-
.../dataregion/wal/io/WALFileTest.java | 2 +-
.../wal/node/ConsensusReqReaderTest.java | 2 +-
.../dataregion/wal/node/WALEntryHandlerTest.java | 13 +-
.../dataregion/wal/node/WALNodeTest.java | 6 +-
.../wal/recover/WALRecoverManagerTest.java | 42 +-
.../wal/recover/WALRecoverWriterTest.java | 2 +-
.../file/SealedTsFileRecoverPerformerTest.java | 2 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 2 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 2 +-
.../wal/utils/WALInsertNodeCacheTest.java | 11 +-
.../rescon/memory/ResourceManagerTest.java | 2 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 2 +-
.../iotdb/db/tools/PBTreeFileSketchTest.java | 2 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 2 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 2 +-
.../db/trigger/executor/TriggerExecuteTest.java | 2 +-
.../DateTimeUtilsTest.java} | 33 +-
.../iotdb/db/utils/EncodingInferenceUtilsTest.java | 2 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 2 +-
.../iotdb/db/utils/QueryDataSetUtilsTest.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 2 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 2 +-
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 2 +-
.../db/utils/datastructure/AlignedTVListTest.java | 2 +-
.../db/utils/datastructure/MergeSortHeapTest.java | 2 +-
.../datastructure/PrimitiveArrayManagerTest.java | 2 +-
.../apache/iotdb/db/utils/sort/SortUtilTest.java | 4 +-
.../SlidingSizeWindowEvaluationHandlerTest.java | 2 +-
.../SlidingTimeWindowEvaluationHandlerTest.java | 2 +-
.../datanode1conf/iotdb-datanode.properties | 1 -
.../datanode2conf/iotdb-datanode.properties | 1 -
.../datanode3conf/iotdb-datanode.properties | 1 -
iotdb-core/metrics/ReadMe.md | 18 +-
.../iotdb/metrics/core/IoTDBMetricManager.java | 3 +-
.../iotdb/metrics/AbstractMetricManager.java | 10 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 2 +-
.../disk/DoNothingDiskMetricsManager.java | 5 +-
.../metricsets/disk/IDiskMetricsManager.java | 24 +-
.../metricsets/net/DoNothingNetMetricManager.java | 5 +-
.../metrics/metricsets/net/INetMetricManager.java | 33 +-
.../metrics/metricsets/system/SystemMetrics.java | 40 +-
.../metrics/reporter/iotdb/IoTDBReporter.java | 2 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 2 +-
.../apache/iotdb/metrics/utils/MetricLevel.java | 2 +-
.../iotdb/metrics/config/MetricConfigTest.java | 2 -
.../resources/conf/iotdb-common.properties | 26 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 4 +
.../commons/auth/entity/PriPrivilegeType.java | 52 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 92 ++-
.../iotdb/commons/auth/user/BasicUserManager.java | 86 +--
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 56 ++
.../iotdb/commons/conf/CommonDescriptor.java | 25 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 5 +
.../commons/consensus/index/ProgressIndex.java | 144 ++++-
.../consensus/index/impl/HybridProgressIndex.java | 36 +-
.../consensus/index/impl/IoTProgressIndex.java | 19 +-
.../consensus/index/impl/MinimumProgressIndex.java | 12 +-
.../consensus/index/impl/RecoverProgressIndex.java | 22 +-
.../consensus/index/impl/SimpleProgressIndex.java | 11 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 2 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 2 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 2 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 16 +
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 24 +
.../commons/schema/filter/SchemaFilterFactory.java | 2 +-
.../commons/schema/filter/impl/DataTypeFilter.java | 2 +-
.../node/common/AbstractMeasurementMNode.java | 2 +-
.../commons/schema/node/info/IMeasurementInfo.java | 2 +-
.../schema/node/role/IMeasurementMNode.java | 2 +-
.../commons/schema/view/LogicalViewSchema.java | 2 +-
.../viewExpression/leaf/ConstantViewOperand.java | 2 +-
.../iotdb/commons/service/RegisterManager.java | 6 +
.../iotdb/commons/service/metric/enums/Metric.java | 8 +-
.../iotdb/commons/service/metric/enums/Tag.java | 4 +-
.../commons/udf/builtin/String/UDTFConcat.java | 63 +-
.../commons/udf/builtin/String/UDTFEndsWith.java | 20 +
.../commons/udf/builtin/String/UDTFLower.java | 21 +
.../commons/udf/builtin/String/UDTFStartsWith.java | 36 +-
.../commons/udf/builtin/String/UDTFStrCompare.java | 40 +-
.../commons/udf/builtin/String/UDTFStrLength.java | 36 +-
.../commons/udf/builtin/String/UDTFStrLocate.java | 37 +-
.../iotdb/commons/udf/builtin/String/UDTFTrim.java | 36 +-
.../commons/udf/builtin/String/UDTFUpper.java | 21 +
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 85 +++
.../iotdb/commons/udf/builtin/UDTFConst.java | 129 +++-
.../iotdb/commons/udf/builtin/UDTFConstE.java | 34 +-
.../iotdb/commons/udf/builtin/UDTFConstPi.java | 34 +-
.../iotdb/commons/udf/builtin/UDTFContains.java | 36 +-
.../udf/builtin/UDTFContinuouslySatisfy.java | 2 +-
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 2 +-
.../udf/builtin/UDTFEqualSizeBucketSample.java | 2 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 123 +++-
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 2 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 2 +-
.../iotdb/commons/udf/builtin/UDTFMatches.java | 35 +-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 87 ++-
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 87 ++-
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 2 +-
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 2 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 2 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 48 +-
.../iotdb/commons/utils/CommonDateTimeUtils.java | 15 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 28 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 65 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 2 +-
.../iotdb/commons/pipe/PipeMetaDeSerTest.java | 4 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../iotdb/tsfile/encoding/decoder/Decoder.java | 2 +-
.../tsfile/encoding/decoder/FloatDecoder.java | 2 +-
.../tsfile/encoding/encoder/FloatEncoder.java | 2 +-
.../tsfile/encoding/encoder/PlainEncoder.java | 2 +-
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 4 +-
.../iotdb/tsfile/file/header/ChunkHeader.java | 2 +-
.../iotdb/tsfile/file/header/PageHeader.java | 2 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 2 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 2 +-
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 2 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 2 +-
.../file/metadata/statistics/BinaryStatistics.java | 2 +-
.../metadata/statistics/BooleanStatistics.java | 2 +-
.../file/metadata/statistics/DoubleStatistics.java | 2 +-
.../file/metadata/statistics/FloatStatistics.java | 2 +-
.../metadata/statistics/IntegerStatistics.java | 2 +-
.../file/metadata/statistics/LongStatistics.java | 2 +-
.../file/metadata/statistics/Statistics.java | 2 +-
.../file/metadata/statistics/TimeStatistics.java | 2 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 2 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 4 +-
.../iotdb/tsfile/read/common/BatchDataFactory.java | 2 +-
.../tsfile/read/common/DescReadBatchData.java | 2 +-
.../tsfile/read/common/DescReadWriteBatchData.java | 4 +-
.../org/apache/iotdb/tsfile/read/common/Field.java | 4 +-
.../apache/iotdb/tsfile/read/common/RowRecord.java | 2 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 4 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 7 +-
.../block/column/BinaryArrayColumnEncoder.java | 3 +-
.../read/common/block/column/BinaryColumn.java | 4 +-
.../common/block/column/BinaryColumnBuilder.java | 7 +-
.../read/common/block/column/BooleanColumn.java | 4 +-
.../common/block/column/BooleanColumnBuilder.java | 7 +-
.../block/column/ByteArrayColumnEncoder.java | 3 +-
.../read/common/block/column/ColumnEncoder.java | 3 +-
.../common/block/column/ColumnEncoderFactory.java | 2 -
.../read/common/block/column/DoubleColumn.java | 4 +-
.../common/block/column/DoubleColumnBuilder.java | 7 +-
.../read/common/block/column/FloatColumn.java | 4 +-
.../common/block/column/FloatColumnBuilder.java | 7 +-
.../block/column/Int32ArrayColumnEncoder.java | 3 +-
.../block/column/Int64ArrayColumnEncoder.java | 3 +-
.../tsfile/read/common/block/column/IntColumn.java | 4 +-
.../read/common/block/column/IntColumnBuilder.java | 7 +-
.../read/common/block/column/LongColumn.java | 4 +-
.../common/block/column/LongColumnBuilder.java | 7 +-
.../read/common/block/column/NullColumn.java | 4 +-
.../block/column/RunLengthColumnEncoder.java | 4 +-
.../block/column/RunLengthEncodedColumn.java | 4 +-
.../read/common/block/column/TimeColumn.java | 4 +-
.../common/block/column/TimeColumnBuilder.java | 7 +-
.../read/common/block/column/TsBlockSerde.java | 4 +-
.../iotdb/tsfile/read/common/type/BinaryType.java | 4 +-
.../iotdb/tsfile/read/common/type/BooleanType.java | 4 +-
.../iotdb/tsfile/read/common/type/DoubleType.java | 4 +-
.../iotdb/tsfile/read/common/type/FloatType.java | 4 +-
.../iotdb/tsfile/read/common/type/IntType.java | 4 +-
.../iotdb/tsfile/read/common/type/LongType.java | 4 +-
.../apache/iotdb/tsfile/read/common/type/Type.java | 4 +-
.../iotdb/tsfile/read/common/type/TypeFactory.java | 2 +-
.../tsfile/read/controller/IMetadataQuerier.java | 2 +-
.../read/controller/MetadataQuerierByFileImpl.java | 2 +-
.../tsfile/read/expression/QueryExpression.java | 2 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 5 +
.../tsfile/read/filter/GroupByMonthFilter.java | 183 +++---
.../iotdb/tsfile/read/filter/operator/Between.java | 2 +-
.../iotdb/tsfile/read/filter/operator/Eq.java | 2 +-
.../iotdb/tsfile/read/filter/operator/Gt.java | 2 +-
.../iotdb/tsfile/read/filter/operator/GtEq.java | 2 +-
.../iotdb/tsfile/read/filter/operator/Lt.java | 2 +-
.../iotdb/tsfile/read/filter/operator/LtEq.java | 2 +-
.../iotdb/tsfile/read/filter/operator/NotEq.java | 2 +-
.../query/dataset/DataSetWithTimeGenerator.java | 2 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 4 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 2 +-
.../query/executor/ExecutorWithTimeGenerator.java | 2 +-
.../tsfile/read/query/executor/TsFileExecutor.java | 2 +-
.../read/query/timegenerator/TimeGenerator.java | 2 +-
.../iotdb/tsfile/read/reader/IPageReader.java | 2 +-
.../read/reader/chunk/AlignedChunkReader.java | 2 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 2 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 89 ++-
.../iotdb/tsfile/read/reader/page/PageReader.java | 6 +-
.../tsfile/read/reader/page/ValuePageReader.java | 134 ++--
.../reader/series/FileSeriesReaderByTimestamp.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 2 +-
.../apache/iotdb/tsfile/utils/TimeDuration.java | 194 ++++++
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 2 +-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 4 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 9 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 7 +-
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 3 +
.../chunk/NonAlignedChunkGroupWriterImpl.java | 4 +-
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 2 +-
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 2 +-
.../apache/iotdb/tsfile/write/page/PageWriter.java | 2 +-
.../iotdb/tsfile/write/page/ValuePageWriter.java | 2 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 4 +-
.../write/record/datapoint/BooleanDataPoint.java | 2 +-
.../tsfile/write/record/datapoint/DataPoint.java | 4 +-
.../write/record/datapoint/DoubleDataPoint.java | 2 +-
.../write/record/datapoint/FloatDataPoint.java | 2 +-
.../write/record/datapoint/IntDataPoint.java | 2 +-
.../write/record/datapoint/LongDataPoint.java | 2 +-
.../write/record/datapoint/StringDataPoint.java | 2 +-
.../tsfile/write/schema/IMeasurementSchema.java | 2 +-
.../tsfile/write/schema/MeasurementSchema.java | 2 +-
.../tsfile/write/schema/TimeseriesSchema.java | 2 +-
.../write/schema/VectorMeasurementSchema.java | 2 +-
.../write/writer/RestorableTsFileIOWriter.java | 2 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +-
.../write/writer/TsFileIOWriterEndFileTest.java | 2 +-
.../write/writer/tsmiterator/DiskTSMIterator.java | 2 +-
.../write/writer/tsmiterator/TSMIterator.java | 2 +-
.../common/block/BinaryArrayColumnEncoderTest.java | 4 +-
.../common/block/ByteArrayColumnEncoderTest.java | 4 +-
.../tsfile/common/block/ColumnEncoderTest.java | 2 +-
.../common/block/Int32ArrayColumnEncoderTest.java | 4 +-
.../common/block/Int64ArrayColumnEncoderTest.java | 4 +-
.../tsfile/common/block/NullColumnUnitTest.java | 4 +-
.../common/block/RunLengthColumnEncoderTest.java | 4 +-
.../tsfile/common/block/TsBlockSerdeTest.java | 6 +-
.../iotdb/tsfile/common/block/TsBlockTest.java | 2 +-
.../tsfile/encoding/decoder/FloatDecoderTest.java | 2 +-
.../tsfile/exception/TsFileExceptionTest.java | 1 +
.../iotdb/tsfile/file/header/PageHeaderTest.java | 2 +-
.../tsfile/file/metadata/utils/TestHelper.java | 2 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 2 +-
.../tsfile/read/TsFileSequenceReaderTest.java | 2 +-
.../iotdb/tsfile/read/common/BatchDataTest.java | 2 +-
.../iotdb/tsfile/read/common/ColumnTest.java | 2 +-
.../tsfile/read/filter/FilterSerializeTest.java | 18 +-
.../tsfile/read/filter/GroupByMonthFilterTest.java | 60 +-
.../tsfile/read/filter/StatisticsFilterTest.java | 2 +-
.../read/query/timegenerator/ReadWriteTest.java | 2 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 2 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 2 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 2 +-
.../iotdb/tsfile/read/reader/FakedBatchReader.java | 2 +-
.../tsfile/read/reader/FakedMultiBatchReader.java | 2 +-
.../iotdb/tsfile/read/reader/PageReaderTest.java | 2 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 2 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 2 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 2 +-
.../iotdb/tsfile/utils/TimeDurationTest.java | 67 ++
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 2 +-
.../iotdb/tsfile/utils/TsPrimitiveTypeTest.java | 2 +-
.../tsfile/write/DefaultSchemaTemplateTest.java | 2 +-
.../tsfile/write/MetadataIndexConstructorTest.java | 2 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 2 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 2 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 2 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 2 +-
.../tsfile/write/TsFileIntegrityCheckingTool.java | 2 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 2 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 2 +-
.../iotdb/tsfile/write/TsFileWriterTest.java | 2 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 2 +-
.../iotdb/tsfile/write/record/TabletTest.java | 2 +-
.../write/schema/converter/SchemaBuilderTest.java | 2 +-
.../write/writer/AlignedChunkWriterImplTest.java | 2 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 2 +-
.../writer/MeasurementSchemaSerializeTest.java | 2 +-
.../iotdb/tsfile/write/writer/PageWriterTest.java | 2 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 2 +-
.../tsfile/write/writer/TimeChunkWriterTest.java | 2 +-
.../tsfile/write/writer/TimePageWriterTest.java | 2 +-
.../writer/TsFileIOWriterMemoryControlTest.java | 2 +-
.../tsfile/write/writer/ValueChunkWriterTest.java | 2 +-
.../tsfile/write/writer/ValuePageWriterTest.java | 2 +-
.../write/writer/VectorMeasurementSchemaStub.java | 2 +-
.../openapi/src/main/openapi3/iotdb_rest_v1.yaml | 52 --
.../thrift-commons/src/main/thrift/common.thrift | 11 +
.../src/main/thrift/confignode.thrift | 32 +-
.../src/main/thrift/datanode.thrift | 25 +-
library-udf/pom.xml | 5 +
.../apache/iotdb/library/anomaly/UDTFRange.java | 9 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 8 +-
.../iotdb/library/string/UDTFRegexMatch.java | 44 +-
.../iotdb/library/string/UDTFRegexReplace.java | 46 +-
.../iotdb/library/string/UDTFRegexSplit.java | 64 +-
.../iotdb/library/string/UDTFStrReplace.java | 45 +-
pom.xml | 10 +
1182 files changed, 12817 insertions(+), 5559 deletions(-)
create mode 100644 example/pipe-count-point-processor/pom.xml
create mode 100644
example/pipe-count-point-processor/src/main/java/org/apache/iotdb/CountPointProcessor.java
create mode 100644 example/pipe-opc-ua-sink/pom.xml
create mode 100644
example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientExample.java
create mode 100644
example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientExampleRunner.java
create mode 100644
example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
create mode 100644
example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/IoTDBKeyStoreLoaderClient.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedOffsetLimitPushDownIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery5IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByNaturalMonthNsPrecisionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByNaturalMonthUsPrecisionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/metric/IoTDBMetricIT.java
copy integration-test/src/test/java/org/apache/iotdb/db/it/schema/{ =>
quota}/IoTDBClusterDeviceQuotaIT.java (85%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/schema/{IoTDBClusterMeasurementQuotaIT.java
=> quota/IoTDBClusterMixQuotaIT.java} (57%)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/schema/{IoTDBClusterMeasurementQuotaIT.java
=> quota/IoTDBClusterQuotaIT.java} (76%)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/schema/{IoTDBClusterDeviceQuotaIT.java
=> quota/IoTDBClusterTimeSeriesQuotaIT.java} (80%)
rename iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/exception/{
=> write}/UnSupportedDataTypeException.java (95%)
rename iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/{ =>
file/metadata}/enums/TSDataType.java (97%)
rename iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/{access =>
read/common/block}/TsBlockBuilderStatus.java (93%)
rename iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/{access =>
read/common/block/column}/Column.java (97%)
rename iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/{access =>
read/common/block/column}/ColumnBuilder.java (96%)
rename iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/{access =>
read/common/block/column}/ColumnBuilderStatus.java (95%)
rename iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/{enums =>
read/common/block/column}/ColumnEncoding.java (96%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/Retriable.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/RetryPolicy.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/service/metric/enums/Tag.java
=>
datanode/src/main/java/org/apache/iotdb/db/exception/LoadReadOnlyException.java}
(66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeExtractorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipePluginConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeProcessorConstructor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipeCronEventInjector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipePeriodicalJobExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/flush/PBTreeFlushExecutor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/schemafile/Segment.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/schedule/CompactionScheduleSummary.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/{queryengine/plan/plan/node/write/InsertRowsNodeSerdeTest.java
=> consensus/statemachine/dataregion/DataRegionStateMachineTest.java} (54%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/{qp/utils/DatetimeQueryDataSetUtilsTest.java
=> utils/DateTimeUtilsTest.java} (89%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/DataNodeConfig.java
=>
iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DoNothingDiskMetricsManager.java
(84%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/DataNodeConfig.java
=>
iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/DoNothingNetMetricManager.java
(84%)
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/TimeDuration.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/TimeDurationTest.java
