This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch air-gap-udp-transport
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d9aa261f72a Merge origin/master into air-gap-udp-transport
add 87a6d198a90 Allow removing regions from read-only DataNodes (#18670)
add 7310b2bc0eb Fix oversized Load TsFile piece dispatch (#18627)
add 6709dfa9494 Fix concurrent subscription consumer handshakes (#18654)
add 0862ecb1d1c Fix Surefire fork port isolation (#18676)
add 957204481d9 Fragment large TsBlocks in MPP DataExchange responses
(#18645)
add d2fcb5383ab Fix delayed query cleanup during file metadata scans
(#18679)
add 61f2014ded8 Fix client manager metrics and JMX lifecycle races (#18681)
add 94329e01692 [Pipe] Move OPC UA sink to pipe library (#18464)
add 5aae6697fba [Pipe] Avoid no-op consensus writes for covered progress
(#18574)
add 76005c94103 Avoid holding ProcedureManager lock while waiting for
table tasks (#18673)
add 9be80ead1dc Fix PathPatternNode wildcard cache lifecycle (#18672)
add 3b47945b3ce Show pre-deleted table schemas and improve write errors
(#18626)
add 34349e3ad8b Fix snapshot omission of closing TsFiles (#18682)
add 142d3b14fce Pipe: Cache table-model pattern matches by table (#18648)
add 8d94de90db3 Fix stale OPC UA builtin plugin references (#18687)
add a670bce7ec6 Refactor TSDataType switches to use TypeService (#18606)
add 4405647b0f2 Fix schema partition lookup during ConfigNode removal
(#18686)
add 02b8c6c0437 Bump ratis to 3.3.1 (#18605)
add f00b24c66eb Fix table-model pipe batch leader redirects (#18690)
add be8606615e5 Fix SinkChannel failure propagation test race (#18675)
add 56b09f28dec Fix schema cache pollution from LAST queries on virtual
regions (#18694)
add 6377522ce2c Fix pipe leader cache updates for multi-device redirects
(#18689)
add af6f8f52e5a [Test] Avoid metadata lease fencing in DataNode unit tests
(#18284)
add a3330994747 Fix scan termination for finished fragment instances
(#18701)
add e7ec99f5d17 Datanode: validate that a query id belongs to the calling
session (#18643)
add c2ea4a40704 Add ImportWAL tool with WAL replay controls (#18516)
add 02ae00db9bc Wait for region leader election before region migration
(#18699)
add fbd5fd22a6c Fix flaky SHOW RECEIVERS lifecycle test (#18700)
add c32431faa5d Use TypeService for ImportWAL snapshot replay (#18711)
add 0594afc33a8 fix the table function that has scalar argument of null
value (#18714)
add ee17d1a8d25 [Subscription] Recover realtime admission after queue
backpressure (#18715)
add ab15c0a19b0 Recover WAL metadata from readable entries and quarantine
unrecoverable files (#18693)
add 6fa33f21ba0 Fix duplicate subscription auto commits (#18710)
add c8bf0bcfbf3 Validate region operation requests before submitting
procedures (#18696)
add 473672dfc32 Fix fenced owner heartbeat lease refresh (#18717)
add a22746a57af Fix thread pool lifecycle leaks (#18703)
add 5750e9d4014 [Subscription] Fix consumer close deadlock (#18704)
add d6b602e4463 [Subscription] Bound heartbeat provider failures (#18712)
add 7984abcabb6 [Pipe] Fix AirGap receiver retry request body reuse
(#18721)
add 90959ab504c Fix UPDATE attribute column validation (#18705)
add 81caad0395f [Query] Allow concurrent local fragment execution for
last-query collection (#18727)
add 881ed81484b Fix deletion matching during compaction (#18732)
add a51258bbb97 [Performance] Reduce aligned flush duplicate timestamp
overhead
add f24b24dcf7c Add proactive RegionGroup allocation and policy hot reload
(#18692)
add d587d8d295c Remove JDBC OSGi support (#18719)
add 79631e3ec62 Register IoTDBDriver as a JDBC 4 service provider (#18744)
add ba287a9cb41 Fix SHOW DEVICES limit offset test ordering (#18745)
add a6cfe257b1d Avoid size estimation for fixed-length compaction points
(#18707)
add dacf7c681f8 Expand some codes for use in the future (#18752)
add f58a52fe90c Fix WAL replay stalls on oversized entries (#18728)
add ce6c1f5f477 Fix pipe sink metrics lifecycle race (#18722)
add b2cc8b52126 Fix metrics lost after metric service restart and
conflicting metric series (#18748)
add 9e40726175d Reuse tablet device ranges during writes (#18734)
add d74b2744ed1 Fix schema region snapshot memory accounting (#18750)
add bd3109ef1ba Fix tag index query for pre-deleted timeseries (#18751)
add afb90593d1c Fix subscription TsFile deduplication and poll concurrency
(#18758)
add 864321f86a7 Fix async subscription commits after close (#18757)
add 3227bc1a219 [Subscription] Increase consensus catch-up batch size
(#18739)
add 3154bffd068 [Subscription] Prevent unsubscribe from blocking on
prefetch cleanup (#18742)
add 4092a780097 Fix pipe TsFile transfer when mod file is missing (#18756)
add 61e405bbfdb Revert "Show pre-deleted table schemas and improve write
errors (#18626)" (#18762)
add f510a924968 Fix ordering propagation around table and window functions
(#18749)
add 50d86cf4161 Fix flaky heartbeat executor bound test (#18773)
add 825bf9e6b8b Stop data region write retry promptly (#18730)
add 94694d92f25 Avoid redundant TsFile table schema registration (#18731)
add daf9dd8d771 Reject duplicate schema region IDs during recovery (#18754)
add 166883a1b2e Fix semantic error for unsupported table INSERT time
expressions (#18759)
add f8bfcffc9ba Fix subscription stalls after consumer disconnect (#18760)
add ef9bb521ccf Fix subscription cache memory configuration (#18761)
add abd499334f0 [Subscription] Bound pending WAL gap replay per round
(#18766)
add 8f1bed8246c [Subscription] Consolidate poll queue fixes (#18771)
add 5d389dd6e86 Fix subscription WAL retention at replay cursor (#18769)
add 5a9c6b9f293 Fix SHOW TTL wildcard path scope (#18763)
add ec72c599ce6 Show pre-delete tables in SHOW TABLES and reject
modifications on them (#18770)
add 0c9a5ee0916 Optimize tag index timeseries lookup (#18753)
add 2f9f9cab1b7 Fix TTL expired data ratio in settle compaction (#18777)
add b777d3c3f3d [Subscription] Reuse uncovered committed WAL retention
boundary (#18778)
add e163f3bc802 Stabilize subscription heartbeat executor test (#18782)
add df27bbc5001 Fix table delete routing to region leaders (#18779)
add acb801e163e [Subscription] Prevent consumers from idling on dry
regions (#18738)
add 0c9fb83974f [Fix] Prevent silent subscription data loss on WAL replay
gaps (#18741)
add ce14b310e1d [Subscription] Flush lingering batch before WAL gap retry
(#18785)
add bbe63644769 Revert "[Fix] Prevent silent subscription data loss on WAL
replay gaps (#18741)" (#18786)
add 5756dc831ae Build: upgrade Develocity Maven extension (#18790)
add 40e7ce62936 Reject truncated Thrift containers before allocation
(#18631)
add 28c193871de Update extra-enforcer-rules to 1.12.1 and drop its
maven-dependency-tree pin (#18796)
add a1c0e90b546 Fix nonexistent file paths in Python client README and
correct doc typos (#18797)
add 3a42dddc3f6 Upgrade Docker base image to eclipse-temurin:17-jre-jammy
(#18795)
add d20082b1615 [Misc] Add generic extension points to reduce cross-branch
conflicts (#18683)
add 4473a133d08 Fix table rename on a DataNode that missed the pre-release
(#18800)
add 48233ea92dd [Fix] Isolate FileReaderManager reader I/O with per-file
locks (#18788)
add 59d9e3e10ad Bump at.yawk.lz4:lz4-java from 1.11.1 to 1.11.4 (#18798)
add 620be2861b8 Bump com.fasterxml.jackson.core:jackson-core from 2.18.9
to 2.18.11 (#18789)
add eb0e3f1f208 Fix duplicate DataRegion scheduling after recovery (#18803)
add 1a834815784 Fix read lock leak in disk usage statistics (#18807)
add 94f99d6516a Extend the node state machine and persist node statuses
(#18801)
add cb0269d9fde Standardize ConfigRegionStateMachine log messages (#18811)
add 99a3e06c76b [Fix] Preserve absent local search index during
subscription WAL replay (#18805)
add 83f6428629d Fix subscription WAL replay cursor boundaries (#18810)
add 24fb54f7e77 Bump Thrift to 0.25.0 (#18793)
add 21d53dd015c Bound subscription memory borrowing and report admission
failures (#18812)
add b94aa09ab66 [Fix] Prevent consensus subscription teardown from
blocking unsubscribe (#18804)
add 054f5dedae5 [Subscription] Report retained WAL file gaps and retry
transient reads (#18818)
add f16e5b36fb5 Eliminate OPC UA sink test port allocation race (#18817)
add 741a13a5d24 Remove some printed errMsg when stop DN (#18799)
add abcbf2ed525 [Subscription] Release exhausted TsFile parsers before
batch ACK (#18820)
add 6819c8beb9f [Fix] Remap failed-measurement indices when reordering
insert columns (#18819)
add e3c4a4e5178 [Pipe] Support region-level realtime downgrading (#18441)
add fea5bd2490a Fix oversized subscription requests with slicing (#18695)
add 2751ee133b4 Retry failed procedure rollback without losing state
(#18822)
add 312c205c8b5 Fix schema region NPE during DataNode shutdown (#18821)
add 0f91bed7544 Fix schema existence check fail-open behavior (#18755)
add 5c27559f02f Add subscription stall diagnostics and reduce WAL prefetch
overhead (#18808)
add 045622d045d Merge origin/master into air-gap-udp-transport
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 12 +-
.mvn/extensions.xml | 2 +-
LICENSE-binary | 25 +-
architecture-test/pom.xml | 284 +
.../db/utils/TSDataTypeSwitchArchitectureTest.java | 23 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
dependencies.json | 3 -
distribution/pom.xml | 9 +
distribution/src/assembly/library-pipe.xml | 51 +
docker/ReadMe.md | 4 +-
docker/src/main/Dockerfile-1.0.0-confignode | 2 +-
docker/src/main/Dockerfile-1.0.0-datanode | 2 +-
docker/src/main/Dockerfile-1.0.0-standalone | 2 +-
docker/src/main/Dockerfile-1c1d | 2 +-
example/pom.xml | 1 -
.../org/apache/iotdb/DataMigrationExample.java | 64 +-
.../main/java/org/apache/iotdb/TabletExample.java | 56 +-
example/udf/pom.xml | 6 +
.../java/org/apache/iotdb/udf/UDAFExample.java | 106 +-
.../v1/handler/StatementConstructionHandler.java | 113 +-
.../rest/protocol/utils/InsertRowDataUtils.java | 109 +-
.../iotdb/rest/protocol/utils/TypeServices.java | 162 +
.../v1/handler/StatementConstructionHandler.java | 113 +-
.../v2/handler/StatementConstructionHandler.java | 113 +-
.../protocol/v2/handler/FastLastHandlerTest.java | 5 +-
integration-test/pom.xml | 7 +
.../apache/iotdb/db/query/udf/example/TwoSum.java | 44 +-
.../apache/iotdb/db/query/udf/example/UDAFAvg.java | 112 +-
.../apache/iotdb/db/query/udf/example/UDAFSum.java | 112 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 12 +
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 +
.../it/env/cluster/config/MppDataNodeConfig.java | 15 +
.../env/remote/config/RemoteConfigNodeConfig.java | 5 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 11 +
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 31 +-
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 60 +-
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 743 +++
.../it/cluster/IoTDBNodeStatusPersistenceIT.java | 379 ++
.../confignode/it/cluster/NodeStatusTestAgent.java | 203 +
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 3 +-
.../it/partition/IoTDBPartitionCreationIT.java | 58 +-
.../it/partition/IoTDBPartitionDurableIT.java | 49 +-
.../IoTDBProactiveRegionGroupDistributionIT.java | 1471 +++++
.../IoTDBProactiveRegionGroupExtensionIT.java | 368 ++
.../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 9 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 123 +-
.../IoTDBRemoveConfigNodeSchemaPartitionIT.java | 262 +
.../it/IoTDBRecreatedTimeseriesCompactionIT.java | 125 +
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 24 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 68 +
.../db/it/last/IoTDBLastQueryVirtualRegionIT.java | 137 +
.../auto/basic/IoTDBShowReceiversLifecycleIT.java | 2 +
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 70 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 17 +-
.../iotdb/pipe/it/single/IoTDBShowReceiversIT.java | 6 +-
.../it/db/it/IoTDBDeletionTableClusterIT.java | 152 +
.../relational/it/db/it/IoTDBInsertTableIT.java | 117 +
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 10 +-
.../it/db/it/IoTDBOrderingPropertyIT.java | 486 ++
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 70 +-
.../it/db/it/IoTDBWindowFunction3IT.java | 6 +-
.../relational/it/db/it/IoTDBWindowFunctionIT.java | 40 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 86 +
...AbstractIoTDBMPPDataExchangeLargeTsBlockIT.java | 98 +
.../IoTDBMPPDataExchangeLargeTsBlock128KIT.java | 51 +
...ableAggregationQueryWithNetworkPartitionIT.java | 5 +-
.../query/view/recent/IoTDBTableViewQueryIT.java | 9 +-
.../IoTDBTableViewQueryWithCachedDeviceIT.java | 3 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 1 +
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 46 +-
.../iotdb/session/it/IoTDBConnectionsIT.java | 53 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 21 +-
...TDBConsensusSubscriptionUnsubscribeTableIT.java | 253 +
.../event/dml/insertion/TsFileInsertionEvent.java | 5 +
.../java/org/apache/iotdb/udf/api/access/Row.java | 7 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 30 +-
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 4 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 4 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 79 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 67 +-
.../java/org/apache/iotdb/cli/AbstractCliTest.java | 44 +
iotdb-client/client-py/README.md | 6 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 39 +-
.../org/apache/iotdb/isession/TypeServices.java | 68 +
iotdb-client/jdbc/README.md | 23 -
iotdb-client/jdbc/osgi.bnd | 31 -
iotdb-client/jdbc/pom.xml | 81 -
iotdb-client/jdbc/src/main/feature/feature.xml | 36 -
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 5 +-
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 4 +-
.../main/java/org/apache/iotdb/jdbc/Activator.java | 42 -
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 56 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 62 +-
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 79 -
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 2 -
.../resources/META-INF/services/java.sql.Driver | 20 +
.../iotdb/jdbc/DriverServiceRegistrationTest.java | 32 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 39 +
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 177 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 96 +-
.../org/apache/iotdb/rpc/NonOpenTransport.java | 6 +
.../rpc/TCompressedElasticFramedTransport.java | 4 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 74 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 27 +
.../java/org/apache/iotdb/rpc/TypeServices.java | 162 +
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 41 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java | 176 +
.../iotdb/rpc/TElasticFramedTransportReadTest.java | 266 +
.../iotdb/rpc/TElasticFramedTransportTest.java | 101 +
.../iotdb/rpc/stmt/PreparedParameterSerdeTest.java | 12 +
.../java/org/apache/iotdb/session/Session.java | 167 +-
.../iotdb/session/util/SessionTypeServices.java | 435 ++
.../apache/iotdb/session/util/SessionUtils.java | 299 +-
.../java/org/apache/iotdb/session/SessionTest.java | 43 +
.../iotdb/session/util/SessionUtilsTest.java | 21 +
.../subscription/i18n/SubscriptionMessages.java | 6 +
.../subscription/i18n/SubscriptionMessages.java | 6 +
.../rpc/subscription/config/ConsumerConfig.java | 4 +
.../rpc/subscription/config/ConsumerConstant.java | 3 +-
.../SubscriptionConsumerFencedException.java | 51 +
.../payload/request/PipeSubscribeRequestType.java | 1 +
.../payload/request/PipeSubscribeSliceReq.java | 169 +
.../request/PipeSubscribeSliceReqBuilder.java | 80 +
.../request/PipeSubscribeSliceReqHandler.java | 141 +
.../SubscriptionSessionConnection.java | 8 +
.../base/AbstractSubscriptionConsumer.java | 224 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 2 +-
.../base/AbstractSubscriptionProvider.java | 209 +-
.../base/AbstractSubscriptionProviders.java | 115 +-
.../base/AbstractSubscriptionPullConsumer.java | 33 +-
.../base/AbstractSubscriptionPushConsumer.java | 4 +-
.../base/SubscriptionExecutorServiceManager.java | 68 +
.../tree/SubscriptionTreePullConsumer.java | 2 +-
.../tree/SubscriptionTreePushConsumer.java | 2 +-
.../payload/SubscriptionRecordHandler.java | 76 +-
.../session/subscription/payload/TypeServices.java | 115 +
.../payload/request/PipeSubscribeSliceReqTest.java | 203 +
...SubscriptionConsumerHeartbeatIsolationTest.java | 341 ++
.../base/SubscriptionConsumerLifecycleTest.java | 568 +-
.../base/SubscriptionProviderSlicingTest.java | 232 +
.../base/SubscriptionProviderStatusTest.java | 72 +
.../subscription/payload/TypeServicesTest.java | 69 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 53 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 53 +
.../aggregation/CentralMomentAccumulator.java | 35 +-
.../aggregation/CorrelationAccumulator.java | 20 +-
.../aggregation/CovarianceAccumulator.java | 20 +-
.../aggregation/RegressionAccumulator.java | 20 +-
.../execution/aggregation/VarianceAccumulator.java | 115 +-
.../operator/RowReferenceTsBlockManager.java | 12 +-
.../process/AbstractLinearFillOperator.java | 15 +-
.../process/TableLinearFillWithGroupOperator.java | 18 +-
.../process/TableNextFillWithGroupOperator.java | 5 +
.../operator/process/TableStreamSortOperator.java | 4 +-
.../execution/operator/process/TopKOperator.java | 95 +-
.../process/join/merge/MergeSortComparator.java | 46 +-
.../merge/comparator/JoinKeyComparatorFactory.java | 36 +-
.../process/window/TopKRankingOperator.java | 12 +-
.../process/window/function/value/LagFunction.java | 36 -
.../window/function/value/LeadFunction.java | 36 -
.../window/function/value/ValueWindowFunction.java | 9 +
.../process/window/partition/frame/RangeFrame.java | 294 +-
.../operator/process/window/utils/ColumnList.java | 9 +
.../process/window/utils/RowComparator.java | 174 +-
.../relational/MergeSortFullOuterJoinOperator.java | 6 +-
.../AbstractApproxMostFrequentAccumulator.java | 2 +-
.../AbstractApproxPercentileAccumulator.java | 64 +-
.../relational/aggregation/AccumulatorFactory.java | 64 +-
.../ApproxCountDistinctAccumulator.java | 54 +-
.../relational/aggregation/AvgAccumulator.java | 207 +-
.../relational/aggregation/ExtremeAccumulator.java | 165 +-
.../relational/aggregation/FirstAccumulator.java | 248 +-
.../relational/aggregation/FirstByAccumulator.java | 226 +-
.../relational/aggregation/LastAccumulator.java | 282 +-
.../relational/aggregation/LastByAccumulator.java | 222 +-
.../relational/aggregation/MaxAccumulator.java | 193 +-
.../relational/aggregation/MinAccumulator.java | 193 +-
.../aggregation/PercentileAccumulator.java | 132 +-
.../relational/aggregation/SumAccumulator.java | 204 +-
.../aggregation/TableCentralMomentAccumulator.java | 51 +-
.../aggregation/TableCorrelationAccumulator.java | 33 +-
.../aggregation/TableCovarianceAccumulator.java | 33 +-
.../aggregation/TableMaxMinByBaseAccumulator.java | 352 +-
.../aggregation/TableModeAccumulator.java | 667 +--
.../aggregation/TableRegressionAccumulator.java | 33 +-
.../aggregation/TableVarianceAccumulator.java | 226 +-
.../source/relational/aggregation/Utils.java | 62 +-
...AbstractGroupedApproxPercentileAccumulator.java | 58 +-
.../GroupedApproxCountDistinctAccumulator.java | 74 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 133 +-
.../grouped/GroupedCentralMomentAccumulator.java | 38 +-
.../grouped/GroupedCorrelationAccumulator.java | 29 +-
.../grouped/GroupedCovarianceAccumulator.java | 29 +-
.../grouped/GroupedExtremeAccumulator.java | 337 +-
.../grouped/GroupedFirstAccumulator.java | 458 +-
.../grouped/GroupedFirstByAccumulator.java | 463 +-
.../grouped/GroupedLastAccumulator.java | 457 +-
.../grouped/GroupedLastByAccumulator.java | 463 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 368 +-
.../grouped/GroupedMaxMinByBaseAccumulator.java | 903 +---
.../aggregation/grouped/GroupedMinAccumulator.java | 494 +-
.../grouped/GroupedModeAccumulator.java | 323 +-
.../grouped/GroupedPercentileAccumulator.java | 78 +-
.../grouped/GroupedRegressionAccumulator.java | 29 +-
.../aggregation/grouped/GroupedSumAccumulator.java | 125 +-
.../grouped/GroupedVarianceAccumulator.java | 177 +-
.../aggregation/grouped/array/BinaryBigArray.java | 7 +
.../aggregation/grouped/array/BooleanBigArray.java | 5 +
.../aggregation/grouped/array/DoubleBigArray.java | 5 +
.../aggregation/grouped/array/FloatBigArray.java | 5 +
.../aggregation/grouped/array/IntBigArray.java | 5 +
.../aggregation/grouped/array/LongBigArray.java | 5 +
.../grouped/rate/GroupedNaiveDeltaAccumulator.java | 49 +-
.../rate/GroupedNaiveIncreaseAccumulator.java | 49 +-
.../grouped/rate/GroupedNaiveIrateAccumulator.java | 31 +-
.../grouped/rate/GroupedNaiveRateAccumulator.java | 46 +-
.../rate/GroupedOrderedDeltaAccumulator.java | 50 +-
.../rate/GroupedOrderedIncreaseAccumulator.java | 50 +-
.../rate/GroupedOrderedIrateAccumulator.java | 31 +-
.../rate/GroupedOrderedRateAccumulator.java | 47 +-
.../aggregation/rate/NaiveDeltaAccumulator.java | 47 +-
.../aggregation/rate/NaiveIncreaseAccumulator.java | 47 +-
.../aggregation/rate/NaiveIrateAccumulator.java | 29 +-
.../aggregation/rate/NaiveRateAccumulator.java | 44 +-
.../aggregation/rate/OrderedDeltaAccumulator.java | 47 +-
.../rate/OrderedIncreaseAccumulator.java | 47 +-
.../aggregation/rate/OrderedIrateAccumulator.java | 30 +-
.../aggregation/rate/OrderedRateAccumulator.java | 44 +-
.../aggregation/rate/RateFunctionValidation.java | 56 +-
.../relational/ColumnTransformerBuilder.java | 123 +-
.../calc/plan/planner/CommonOperatorUtils.java | 129 +-
.../calc/plan/planner/TableOperatorGenerator.java | 148 +-
.../AbstractGreatestLeastColumnTransformer.java | 47 +-
.../multi/BinaryGreatestColumnTransformer.java | 2 +-
.../column/multi/BinaryLeastColumnTransformer.java | 2 +-
.../multi/BooleanGreatestColumnTransformer.java | 2 +-
.../multi/BooleanLeastColumnTransformer.java | 2 +-
.../multi/DoubleGreatestColumnTransformer.java | 2 +-
.../column/multi/DoubleLeastColumnTransformer.java | 2 +-
.../multi/FloatGreatestColumnTransformer.java | 2 +-
.../column/multi/FloatLeastColumnTransformer.java | 2 +-
.../multi/Int32GreatestColumnTransformer.java | 2 +-
.../column/multi/Int32LeastColumnTransformer.java | 2 +-
.../multi/Int64GreatestColumnTransformer.java | 2 +-
.../column/multi/Int64LeastColumnTransformer.java | 2 +-
.../dag/column/unary/InColumnTransformer.java | 220 +-
.../AbstractCastFunctionColumnTransformer.java | 370 +-
.../scalar/CastFunctionColumnTransformer.java | 56 +-
.../unary/scalar/FormatColumnTransformer.java | 37 +-
.../unary/scalar/RoundColumnTransformer.java | 37 +-
.../scalar/RoundFunctionColumnTransformer.java | 39 +-
.../scalar/TryCastFunctionColumnTransformer.java | 58 +-
.../transformation/dag/util/CastFunctionUtils.java | 251 +-
.../datastructure/row/SerializableRowList.java | 64 +-
.../datastructure/tv/SerializableTVList.java | 40 +-
.../org/apache/iotdb/calc/utils/TypeServices.java | 5675 ++++++++++++++++++++
.../aggregation/LastDescendingInputTest.java | 108 +
.../aggregation/NumericBatchAggregationTest.java | 224 +
.../aggregation/NumericMomentBatchTest.java | 157 +
.../relational/aggregation/SumAccumulatorTest.java | 140 +
.../aggregation/VarianceAccumulatorTest.java | 125 +
.../GroupedApproxCountDistinctMaskTest.java | 50 +
.../aggregation/rate/RateBatchInputTest.java | 253 +
.../column/unary/scalar/NumericCastBatchTest.java | 184 +
.../apache/iotdb/calc/utils/TypeServicesTest.java | 416 ++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 65 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 31 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 9 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 68 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 31 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 18 +-
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 4 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 7 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 70 +-
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 9 +
.../request/ConfigPhysicalPlanVisitor.java | 8 +
.../write/confignode/UpdateNodeStatusPlan.java | 104 +
.../write/table/SetTableColumnPropertiesPlan.java | 80 +
.../partition/GetRegionGroupsByTimeResp.java | 25 +
.../statemachine/ConfigRegionStateMachine.java | 16 +-
.../confignode/manager/ClusterQuotaManager.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 199 +-
.../apache/iotdb/confignode/manager/IManager.java | 18 +-
.../iotdb/confignode/manager/ProcedureManager.java | 572 +-
.../confignode/manager/RetryFailedTasksThread.java | 3 +-
.../iotdb/confignode/manager/load/LoadManager.java | 76 +-
.../manager/load/balancer/RegionBalancer.java | 12 +-
.../partition/DataPartitionPolicyTable.java | 18 +-
.../manager/load/cache/AbstractLoadCache.java | 9 +-
.../confignode/manager/load/cache/LoadCache.java | 140 +-
.../load/cache/consensus/ConsensusGroupCache.java | 3 +-
.../load/cache/node/AINodeHeartbeatCache.java | 48 -
.../manager/load/cache/node/BaseNodeCache.java | 84 +-
.../load/cache/node/ConfigNodeHeartbeatCache.java | 39 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 57 +-
.../load/cache/node/NodeHeartbeatSample.java | 7 +-
.../manager/load/cache/node/NodeStatistics.java | 17 +
.../manager/load/cache/region/RegionCache.java | 3 +-
.../load/cache/region/RegionGroupCache.java | 2 +-
.../manager/load/service/StatisticsService.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 25 +-
.../manager/partition/PartitionManager.java | 106 +-
.../partition/RegionGroupExtensionPolicy.java | 4 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 20 +-
.../PipeConfigNodeRemainingTimeMetrics.java | 20 +-
.../PipeTemporaryMetaInCoordinatorMetrics.java | 18 +-
.../metric/sink/PipeConfigRegionSinkMetrics.java | 17 +-
.../source/PipeConfigRegionSourceMetrics.java | 17 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 26 +
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 7 +
.../pipe/source/ConfigRegionListeningFilter.java | 2 +
.../manager/schema/ClusterSchemaManager.java | 79 +-
.../runtime/SubscriptionRuntimeCoordinator.java | 7 +-
.../persistence/executor/ConfigPlanExecutor.java | 82 +-
.../confignode/persistence/node/NodeInfo.java | 115 +-
.../partition/DatabasePartitionTable.java | 16 +
.../persistence/partition/PartitionInfo.java | 12 +
.../schema/CNPhysicalPlanGenerator.java | 48 +-
.../persistence/schema/CNSnapshotFileType.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 17 +-
.../confignode/persistence/schema/ConfigMTree.java | 78 +-
.../iotdb/confignode/procedure/Procedure.java | 14 +
.../confignode/procedure/ProcedureExecutor.java | 15 +
.../procedure/env/ConfigNodeProcedureEnv.java | 7 +-
.../procedure/env/RegionMaintainHandler.java | 24 +-
.../procedure/env/RemoveDataNodeHandler.java | 71 +-
.../procedure/impl/StateMachineProcedure.java | 6 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 1 +
.../impl/node/RemoveDataNodesProcedure.java | 6 +-
.../procedure/impl/schema/SchemaUtils.java | 26 +-
.../table/AbstractAlterOrDropTableProcedure.java | 19 +
...re.java => AbstractSetPropertiesProcedure.java} | 71 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 2 +-
.../impl/schema/table/RenameTableProcedure.java | 2 +-
.../table/SetTableColumnPropertiesProcedure.java | 107 +
.../schema/table/SetTablePropertiesProcedure.java | 218 +-
.../procedure/store/ProcedureFactory.java | 9 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../confignode/service/ConfigNodeShutdownHook.java | 162 +-
.../heartbeat/DataNodeHeartbeatHandlerTest.java | 100 +
.../conf/RegionGroupExtensionPolicyConfigTest.java | 106 +
.../request/ConfigPhysicalPlanSerDeTest.java | 67 +
.../manager/ClusterSchemaManagerTest.java | 89 +
.../ConfigManagerRegionGroupPolicyReloadTest.java | 150 +
.../manager/ConfigManagerShutdownReportTest.java | 161 +
.../ProcedureManagerReconstructRegionTest.java | 169 -
.../ProcedureManagerRegionOperationTest.java | 401 ++
.../manager/ProcedureManagerTableTaskTest.java | 225 +
.../confignode/manager/ProcedureManagerTest.java | 41 +
.../manager/RetryFailedTasksThreadTest.java | 107 +
.../confignode/manager/load/LoadManagerTest.java | 115 +-
.../manager/load/balancer/RegionBalancerTest.java | 144 +
.../DataPartitionPolicyTableProactiveTest.java | 190 +
.../router/priority/GreedyPriorityTest.java | 2 +-
.../priority/LeaderPriorityBalancerTest.java | 2 +-
.../load/cache/ConsensusGroupCacheTest.java | 2 +-
.../load/cache/LoadCacheNodeStatusTest.java | 336 ++
.../cache/LoadCachePersistedNodeStatusTest.java | 898 ++++
.../manager/load/cache/NodeCacheTest.java | 228 +-
.../manager/node/NodeManagerStatusReasonTest.java | 133 +
.../PartitionManagerProactiveExtensionTest.java | 811 +++
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 86 +
.../metric/PipeConfigNodeMetricsRestartTest.java | 184 +
.../SubscriptionRuntimeCoordinatorTest.java | 119 +
.../persistence/CNPhysicalPlanGeneratorTest.java | 20 +
.../iotdb/confignode/persistence/NodeInfoTest.java | 269 +
.../persistence/schema/ClusterSchemaInfoTest.java | 119 +
.../persistence/schema/ConfigMTreeTest.java | 31 +
.../confignode/procedure/STMProcedureTest.java | 108 +
.../procedure/env/ConfigNodeProcedureEnvTest.java | 93 +
.../procedure/env/RegionMaintainHandlerTest.java | 303 ++
.../impl/node/RemoveDataNodePersistenceTest.java | 581 ++
.../procedure/impl/schema/SchemaUtilsTest.java | 91 +
.../service/ConfigNodeShutdownHookTest.java | 346 ++
iotdb-core/consensus/pom.xml | 5 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 4 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 4 +
.../consensus/iot/IoTConsensusServerImpl.java | 7 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 104 +-
.../subscription/SubscriptionQueueAdmission.java | 25 +
.../subscription/SubscriptionQueueRegistry.java | 60 +-
.../SubscriptionQueueRejectionReason.java | 42 +
.../SubscriptionWalRetentionCalculator.java | 10 +-
.../consensus/pipe/IoTConsensusV2ServerImpl.java | 5 +
.../pipe/metric/IoTConsensusV2ServerMetrics.java | 3 -
.../consensus/ratis/metrics/CounterProxy.java | 8 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 34 +-
.../ratis/metrics/MetricRegistryManager.java | 14 +
.../consensus/ratis/metrics/RatisMetricSet.java | 8 +-
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 7 +-
.../LogDispatcherThreadMetricsTest.java | 146 +
.../metric/IoTConsensusV2ServerMetricsTest.java | 107 +
.../ratis/metrics/RatisMetricSetTest.java | 134 +
iotdb-core/datanode/pom.xml | 45 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 24 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 123 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 57 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 5 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 155 +
.../iotdb/db/i18n/StorageEngineMessages.java | 30 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 23 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 120 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 57 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 5 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 154 +
.../iotdb/db/i18n/StorageEngineMessages.java | 30 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 20 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 30 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 77 +-
.../dataregion/DataRegionStateMachine.java | 8 +-
.../iotdb/db/lbac/AllowAllLBACAccessControl.java | 47 +
.../apache/iotdb/db/lbac/ILBACAccessControl.java | 74 +
.../db/partition/DataPartitionTableGenerator.java | 8 +-
.../dataregion/PipeDataRegionSinkConstructor.java | 3 -
.../agent/task/connection/PipeEventCollector.java | 10 +
.../event/common/row/PipeDataTypeTransformer.java | 34 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 29 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 31 +-
.../pipe/event/common/tablet/PipeTabletUtils.java | 35 +-
.../tablet/parser/TabletInsertionEventParser.java | 209 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 201 +-
.../parser/scan/SinglePageWholeChunkReader.java | 41 +-
.../scan/TsFileInsertionEventScanParser.java | 128 +-
...ileInsertionEventTableParserTabletIterator.java | 68 +-
.../overview/PipeDataNodeSinglePipeMetrics.java | 20 +-
.../overview/PipeTsFileToTabletsMetrics.java | 16 +-
.../metric/processor/PipeProcessorMetrics.java | 19 +-
.../schema/PipeSchemaRegionListenerMetrics.java | 16 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 16 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 16 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 19 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 13 +-
.../metric/source/PipeDataRegionSourceMetrics.java | 20 +-
.../processor/aggregate/AggregateProcessor.java | 159 +-
.../aggregate/TimeSeriesRuntimeState.java | 23 +
.../CustomizedReadableIntermediateResults.java | 164 +-
.../numeric/AbstractSameTypeNumericOperator.java | 119 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 13 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 36 +-
.../transform/converter/ValueConverter.java | 141 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 95 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 10 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 53 +-
.../request/PipeTransferTabletBatchReqV2.java | 3 +
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 3 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 73 +-
.../db/pipe/sink/protocol/opcda/OpcDaSink.java | 9 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 109 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 13 +-
.../PipeTransferTabletInsertionEventHandler.java | 6 +-
.../async/handler/PipeTransferTsFileHandler.java | 100 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 7 +-
.../sink/util/PipeTabletEventTransferUtils.java | 97 +
.../pipe/sink/util/TabletStatementConverter.java | 128 +-
.../db/pipe/sink/util/cacher/LeaderCacheUtils.java | 42 +-
.../sink/util/sorter/PipeInsertEventSorter.java | 106 +-
.../PipeRealtimeDataRegionHybridSource.java | 668 ++-
.../realtime/PipeRealtimeDataRegionSource.java | 35 +
.../PipeRealtimeDataRegionTsFileSource.java | 150 +-
.../matcher/CachedSchemaPatternMatcher.java | 41 +-
.../iotdb/db/protocol/session/ClientSession.java | 23 +
.../iotdb/db/protocol/session/IClientSession.java | 3 +
.../db/protocol/session/InternalClientSession.java | 5 +
.../db/protocol/session/MqttClientSession.java | 5 +
.../db/protocol/session/RestClientSession.java | 5 +
.../handler/RPCServiceThriftHandlerMetrics.java | 37 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 135 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 126 +-
.../execution/aggregation/AccumulatorFactory.java | 34 +-
.../execution/aggregation/AvgAccumulator.java | 105 +-
.../execution/aggregation/ExtremeAccumulator.java | 264 +-
.../aggregation/FirstValueAccumulator.java | 336 +-
.../aggregation/FirstValueDescAccumulator.java | 79 +-
.../aggregation/LastValueAccumulator.java | 327 +-
.../aggregation/LastValueDescAccumulator.java | 89 +-
.../aggregation/MaxMinByBaseAccumulator.java | 315 +-
.../execution/aggregation/MaxValueAccumulator.java | 286 +-
.../execution/aggregation/MinValueAccumulator.java | 287 +-
.../execution/aggregation/SumAccumulator.java | 100 +-
.../db/queryengine/execution/driver/Driver.java | 6 +
.../execution/exchange/MPPDataExchangeManager.java | 44 +
.../execution/exchange/sink/SinkChannel.java | 49 +-
.../execution/exchange/source/SourceHandle.java | 158 +-
.../execution/executor/RegionWriteExecutor.java | 36 +-
.../fragment/FakedFragmentInstanceContext.java | 84 +-
.../fragment/FragmentInstanceContext.java | 181 +-
.../fragment/FragmentInstanceExecution.java | 11 +-
.../FragmentInstanceFinishedException.java} | 26 +-
.../execution/operator/AggregationUtil.java | 34 +-
.../process/InsertTabletStatementGenerator.java | 137 +-
.../operator/process/TransformOperator.java | 43 +-
.../process/last/LastQueryCollectOperator.java | 12 +-
.../execution/operator/source/SeriesScanUtil.java | 530 +-
.../InformationSchemaContentSupplierFactory.java | 67 +-
.../relational/LastQueryAggTableScanOperator.java | 28 +-
.../operator/window/WindowManagerFactory.java | 62 +-
.../execution/schedule/DriverScheduler.java | 9 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +
.../analyze/cache/partition/PartitionCache.java | 2 +-
.../plan/analyze/schema/SchemaValidator.java | 56 +-
.../execution/config/TableConfigTaskVisitor.java | 69 +
.../config/executor/ClusterConfigTaskExecutor.java | 66 +-
.../config/executor/IConfigTaskExecutor.java | 9 +
.../config/metadata/ShowClusterDetailsTask.java | 63 +-
.../execution/config/metadata/ShowClusterTask.java | 40 +-
.../config/metadata/ShowConfigNodesTask.java | 28 +-
.../config/metadata/ShowDataNodesTask.java | 30 +-
.../AlterTableSetColumnPropertiesTask.java | 55 +
.../visitor/ExistUnknownTypeInExpression.java | 2 +-
.../visitor/GetMeasurementExpressionVisitor.java | 6 +
.../predicate/ConvertPredicateToFilterVisitor.java | 47 +-
.../plan/planner/OperatorGeneratorUtil.java | 28 +-
.../plan/planner/OperatorTreeGenerator.java | 51 +-
.../planner/plan/node/write/InsertRowNode.java | 218 +-
.../planner/plan/node/write/InsertTabletNode.java | 352 +-
.../relational/analyzer/StatementAnalyzer.java | 162 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 85 +-
.../AdditionalInformationSchemaProvider.java | 59 +
...dditionalInformationSchemaProviderRegistry.java | 25 +-
.../relational/metadata/TableMetadataImpl.java | 11 +-
.../distribute/TableDistributedPlanGenerator.java | 594 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 40 +-
.../DataNodeLocationSupplierFactory.java | 9 +
.../planner/optimizations/SortElimination.java | 65 +-
.../optimizations/TableFunctionOrdering.java | 79 +
.../TransformAggregationToStreamable.java | 5 +-
.../optimizations/TransformSortToStreamSort.java | 45 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/DefaultTraversalVisitor.java | 9 +
.../relational/sql/ast/SetColumnProperties.java | 140 +
.../plan/relational/sql/parser/AstBuilder.java | 16 +-
.../relational/sql/util/DataNodeSqlFormatter.java | 25 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 169 +-
.../plan/statement/crud/InsertBaseStatement.java | 46 +
.../plan/statement/crud/InsertRowStatement.java | 29 +-
.../plan/statement/crud/InsertRowsStatement.java | 17 +
.../plan/statement/crud/InsertTabletStatement.java | 69 +-
...ializableRowRecordListBackedMultiColumnRow.java | 2 +-
.../dag/input/ConstantInputReader.java | 63 +-
.../unary/ArithmeticNegationTransformer.java | 41 +-
.../dag/transformer/unary/InTransformer.java | 131 +-
.../unary/scalar/CastFunctionTransformer.java | 530 +-
.../unary/scalar/DiffFunctionTransformer.java | 42 +-
.../unary/scalar/RoundFunctionTransformer.java | 45 +-
.../transformation/dag/util/TransformUtils.java | 119 +-
.../transformation/dag/util/TypeUtils.java | 61 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 32 +-
.../schemaengine/metric/SchemaEngineMemMetric.java | 7 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 7 +-
.../rescon/MemSchemaEngineStatistics.java | 4 +
.../schemaengine/schemaregion/ISchemaRegion.java | 10 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 101 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 42 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 6 +
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 11 +-
.../schemaengine/schemaregion/tag/TagManager.java | 55 +-
.../db/schemaengine/table/DataNodeTableCache.java | 35 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 2 +
.../iotdb/db/service/DataNodeShutdownHook.java | 6 +-
.../iotdb/db/service/metrics/CacheMetrics.java | 17 +
.../db/service/metrics/DataNodeMetricsHelper.java | 1 +
.../metrics/IoTDBInternalLocalReporter.java | 1 +
.../iotdb/db/service/metrics/WritingMetrics.java | 80 +-
.../db/service/metrics/file/TsFileMetrics.java | 22 +
.../iotdb/db/storageengine/StorageEngine.java | 38 +-
.../db/storageengine/dataregion/DataRegion.java | 39 +-
.../dataregion/DataRegionMetrics.java | 49 +-
.../execute/utils/CompactionPathUtils.java | 2 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 42 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 32 +-
.../utils/writer/AbstractCompactionWriter.java | 92 +-
.../schedule/CompactionScheduleTaskManager.java | 10 +-
.../selector/impl/SettleSelectorImpl.java | 5 +-
.../dataregion/memtable/AbstractMemTable.java | 32 +-
.../memtable/AlignedReadOnlyMemChunk.java | 126 +-
.../memtable/AlignedWritableMemChunk.java | 394 +-
.../dataregion/memtable/IMemTable.java | 10 +
.../dataregion/memtable/ReadOnlyMemChunk.java | 92 +-
.../dataregion/memtable/TsFileProcessor.java | 102 +-
.../memtable/TsFileProcessorInfoMetrics.java | 55 +-
.../dataregion/memtable/WritableMemChunk.java | 124 +-
.../dataregion/modification/TagPredicate.java | 24 +
.../dataregion/read/control/FileReaderManager.java | 698 ++-
.../read/reader/chunk/MemAlignedPageReader.java | 52 +-
.../read/reader/chunk/MemPageReader.java | 84 +-
.../dataregion/snapshot/SnapshotTaker.java | 6 +-
.../dataregion/tsfile/TsFileLock.java | 27 +-
.../dataregion/utils/DiskUsageStatisticUtil.java | 12 +-
.../dataregion/utils/TsFileResourceUtils.java | 11 +-
.../dataregion/wal/buffer/WALBuffer.java | 40 +-
.../wal/checkpoint/CheckpointManager.java | 4 +-
.../dataregion/wal/io/WALByteBufReader.java | 24 +-
.../dataregion/wal/io/WALFileVersion.java | 19 +
.../dataregion/wal/io/WALInputStream.java | 82 +-
.../dataregion/wal/io/WALMetaData.java | 98 +-
.../storageengine/dataregion/wal/io/WALReader.java | 21 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 17 +-
.../storageengine/dataregion/wal/node/WALNode.java | 12 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 54 +-
.../dataregion/wal/recover/WALRepairWriter.java | 125 +-
.../db/storageengine/load/LoadTsFileManager.java | 78 +-
.../load/LoadTsFilePieceNodeAssembler.java | 170 +
.../load/memory/LoadTsFileMemoryBlock.java | 20 +-
.../load/metrics/ActiveLoadingFilesMetricsSet.java | 6 +
.../ActiveLoadingFilesNumberMetricsSet.java | 16 +-
.../load/metrics/LoadTsFileMemMetricSet.java | 19 +-
.../load/splitter/AlignedChunkData.java | 94 +-
.../splitter/BatchedAlignedValueChunkData.java | 81 +-
.../load/splitter/NonAlignedChunkData.java | 71 +-
.../rescon/memory/PrimitiveArrayManager.java | 89 +-
.../agent/SubscriptionBrokerAgent.java | 8 +
.../agent/SubscriptionConsumerAgent.java | 147 +-
.../agent/SubscriptionReceiverAgent.java | 98 +-
.../broker/ConsensusSubscriptionBroker.java | 58 +-
.../subscription/broker/ISubscriptionBroker.java | 3 +
.../db/subscription/broker/SubscriptionBroker.java | 14 +-
.../broker/SubscriptionPrefetchingQueue.java | 107 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 28 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 11 +-
.../consensus/ConsensusLogToTabletConverter.java | 85 +-
.../consensus/ConsensusPrefetchingQueue.java | 983 +++-
.../broker/consensus/ProgressWALIterator.java | 319 +-
.../consensus/SubscriptionQueueTimeTracker.java | 119 +
.../batch/SubscriptionPipeTabletEventBatch.java | 21 +-
.../event/cache/SubscriptionPollResponseCache.java | 24 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 182 +-
.../subscription/metric/SubscriptionMetrics.java | 34 +
.../SubscriptionPrefetchingQueueMetrics.java | 55 +-
.../receiver/SubscriptionReceiver.java | 13 +
.../receiver/SubscriptionReceiverV1.java | 160 +-
.../resource/SubscriptionMemoryManager.java | 368 +-
.../ConsensusSubscriptionPrefetchExecutor.java | 10 +
.../task/subtask/ConsensusPrefetchSubtask.java | 12 +
.../java/org/apache/iotdb/db/tools/ImportWAL.java | 1728 ++++++
.../iotdb/db/tools/TableWALDeleteConverter.java | 226 +
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 45 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 33 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 157 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 30 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 9 +
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 446 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 166 +-
.../org/apache/iotdb/db/utils/TabletDecoder.java | 80 +-
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 67 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 31 +-
.../org/apache/iotdb/db/utils/TypeServices.java | 4457 +++++++++++++++
.../db/utils/datastructure/AlignedTVList.java | 687 +--
.../iotdb/db/utils/datastructure/BinaryTVList.java | 7 +-
.../db/utils/datastructure/BooleanTVList.java | 7 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 8 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 6 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 7 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 7 +-
.../MergeSortMultiAlignedTVListIterator.java | 62 +-
.../MergeSortMultiTVListIterator.java | 49 +-
.../datastructure/MultiAlignedTVListIterator.java | 71 +-
.../utils/datastructure/MultiTVListIterator.java | 129 +-
.../iotdb/db/utils/datastructure/TVList.java | 334 +-
.../db/utils/windowing/window/WindowImpl.java | 75 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 84 -
.../org/apache/iotdb/db/auth/entity/UserTest.java | 53 -
.../org/apache/iotdb/db/conf/PropertiesTest.java | 28 +
.../dataregion/DataRegionStateMachineTest.java | 53 +-
.../schemaRegion/SchemaRegionManagementTest.java | 38 +-
.../SchemaRegionSimpleRecoverTest.java | 76 +
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 3 +-
.../db/pipe/event/common/row/PipeRowTest.java | 115 +
.../db/pipe/metric/PipeMetricsRestartTest.java | 426 ++
.../PipeSchemaRegionListenerMetricsTest.java | 116 +
.../metric/sink/PipeDataRegionSinkMetricsTest.java | 98 +
.../pattern/CachedSchemaPatternMatcherTest.java | 83 +
.../aggregate/TimeSeriesRuntimeStateTest.java | 76 +
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 75 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 70 +
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 93 -
.../thrift/async/IoTDBDataRegionAsyncSinkTest.java | 49 +
...peTransferTabletInsertNodeEventHandlerTest.java | 105 +
.../PipeTransferTsFileHandlerCleanupTest.java | 56 +
.../sink/util/cacher/LeaderCacheUtilsTest.java | 89 +
.../db/pipe/source/PipeRealtimeExtractTest.java | 1277 ++++-
.../db/protocol/session/QueryOwnershipTest.java | 343 ++
.../DataNodeInternalRPCServiceImplDiskTest.java | 43 +-
.../DataNodeInternalRPCServiceImplLoadTest.java | 94 +
...eInternalRPCServiceImplSetSystemStatusTest.java | 91 +
.../queryengine/execution/ConfigExecutionTest.java | 27 +
.../SinkChannelFailurePropagationTest.java | 12 +-
.../execution/exchange/SinkChannelTest.java | 16 +-
.../execution/exchange/SourceHandleTest.java | 265 +-
.../db/queryengine/execution/exchange/Utils.java | 7 +
.../executor/RegionWriteExecutorTest.java | 268 +
.../fragment/FileReaderReferenceLifecycleTest.java | 189 +
.../RegionQueryInitializationLockTest.java | 280 +
.../fragment/RegionScanTimeSliceTest.java | 96 +
.../operator/LastQueryCollectOperatorTest.java | 140 +
.../process/TableStreamSortOperatorTest.java | 63 +
.../process/fill/GroupedFillOperatorTest.java | 174 +
.../process/window/TopKRankingOperatorTest.java | 75 +-
.../source/SeriesScanUtilCancellationTest.java | 557 ++
.../schedule/DefaultDriverSchedulerTest.java | 81 +
.../metadata/ShowClusterDetailsTaskTest.java | 172 +
.../config/metadata/ShowClusterTaskTest.java | 168 +
.../config/metadata/ShowConfigNodesTaskTest.java | 121 +
.../config/metadata/ShowDataNodesTaskTest.java | 114 +
.../ConvertPredicateToFilterVisitorTest.java | 104 +
.../plan/planner/LastQueryCacheTest.java | 236 +
.../node/write/InsertTabletNodeSerdeTest.java | 71 +
.../plan/relational/analyzer/AnalyzerTest.java | 138 +
.../plan/relational/planner/PlanTester.java | 6 +-
.../planner/WindowFunctionOptimizationTest.java | 12 +-
.../OrderingPropertyPropagationTest.java | 481 ++
.../optimizations/TableFunctionSortTest.java | 263 +
.../load/LoadTsFileDispatcherImplTest.java | 225 +
.../crud/InsertStatementPartialInsertTest.java | 28 +
.../dag/adapter/RowGetDoubleTest.java | 98 +
.../dag/input/ConstantInputReaderTest.java | 78 +
.../dag/util/TransformUtilsTest.java | 117 +
.../iotdb/db/schemaengine/SchemaEngineTest.java | 57 +
.../metric/SchemaMemMetricTableTest.java | 133 +
.../mtree/impl/mem/MTreeBelowSGMemoryImplTest.java | 14 +
.../impl/pbtree/MTreeBelowSGCachedImplTest.java | 18 +-
.../tag/TagManagerPerformanceTest.java | 258 +
.../schemaregion/tag/TagManagerTest.java | 64 +
.../schemaengine/table/DataNodeTableCacheTest.java | 114 +
.../metrics/DataNodeMetricsRestartTest.java | 290 +
.../db/service/metrics/file/TsFileMetricsTest.java | 148 +
.../buffer/TimeSeriesMetadataCacheTest.java | 4 +-
.../storageengine/dataregion/DataRegionTest.java | 43 +
.../dataregion/DatabaseMemMetricsTest.java | 144 +
.../utils/writer/AbstractCompactionWriterTest.java | 125 +-
.../compaction/utils/CompactionCheckerUtils.java | 9 +-
.../compaction/utils/CompactionUtilsTest.java | 43 +-
...gnedFlushDuplicateTimeCheckPerformanceTest.java | 238 +
.../dataregion/memtable/MemTableFlushTaskTest.java | 83 +
.../dataregion/memtable/PrimitiveMemTableTest.java | 23 +-
.../TabletDeviceRangeReusePerformanceTest.java | 283 +
.../dataregion/memtable/TsFileProcessorTest.java | 110 +
...FileTableSchemaRegistrationPerformanceTest.java | 230 +
.../control/FileReaderManagerConcurrencyTest.java | 871 +++
.../read/reader/common/AscFakedSeriesReader.java | 8 +-
.../read/reader/common/DescFakedSeriesReader.java | 8 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 10 +-
.../dataregion/tsfile/TsFileLockTest.java | 108 +
.../dataregion/utils/TableDiskUsageTest.java | 8 +
.../dataregion/wal/buffer/WALBufferCommonTest.java | 27 +
.../wal/buffer/WALBufferRollRecoveryTest.java | 4 +-
.../dataregion/wal/io/WALFileTest.java | 274 +-
.../wal/recover/WALRepairWriterTest.java | 140 +-
.../load/LoadTsFilePieceNodeAssemblerTest.java | 215 +
.../rescon/disk/FolderManagerTest.java | 57 +-
.../agent/SubscriptionConsumerAgentTest.java | 114 +
.../agent/SubscriptionReceiverAgentTest.java | 412 +-
...onsensusSubscriptionBrokerPayloadLimitTest.java | 67 +
.../SubscriptionBrokerAgentPayloadLimitTest.java | 14 +
...sFileDeduplicationBlockingPendingQueueTest.java | 68 +
.../ConsensusLogToTabletConverterTest.java | 55 +
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 417 +-
.../ConsensusPrefetchingQueueSeekTest.java | 241 +
.../consensus/ConsensusPrefetchingQueueTest.java | 1301 ++++-
...nsensusPrefetchingQueueWalBackpressureTest.java | 148 +-
.../broker/consensus/ProgressWALIteratorTest.java | 418 +-
.../SubscriptionWalPrefetchPerformanceTest.java | 380 ++
.../SubscriptionPipeTabletEventBatchTest.java | 256 +
.../cache/SubscriptionPollResponseCacheTest.java | 60 +
...susSubscriptionPrefetchingQueueMetricsTest.java | 88 +
.../metric/SubscriptionMetricsRestartTest.java | 275 +
.../receiver/SubscriptionReceiverV1Test.java | 196 +-
.../resource/SubscriptionMemoryManagerTest.java | 122 +
.../org/apache/iotdb/db/tools/ImportWALTest.java | 2070 +++++++
.../db/tools/TableWALDeleteConverterTest.java | 318 ++
.../iotdb/db/utils/QueryDataSetUtilsTest.java | 109 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 132 +-
.../utils/TSDataTypeSwitchArchitectureTest.java} | 24 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
.../apache/iotdb/db/utils/TypeServicesTest.java | 305 ++
.../db/utils/datastructure/AlignedTVListTest.java | 90 +
.../src/test/resources/iotdb-system.properties | 3 +
iotdb-core/metrics/core/pom.xml | 5 +
.../metrics/core/reporter/IoTDBJmxReporter.java | 115 +-
.../iotdb/metrics/core/type/IoTDBAutoGauge.java | 5 +-
.../core/utils/IoTDBMetricObjNameFactory.java | 38 +-
.../metrics/core/utils/ObjectNameFactory.java | 45 +
.../metrics/core/MetricManagerLifecycleTest.java | 339 ++
.../core/reporter/IoTDBJmxReporterTest.java | 205 +
.../metrics/core/type/IoTDBAutoGaugeTest.java | 68 +
.../core/utils/IoTDBMetricObjNameFactoryTest.java | 123 +
.../iotdb/metrics/AbstractMetricManager.java | 215 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 86 +-
.../metrics/metricsets/system/SystemMetrics.java | 13 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 1 +
.../resources/conf/edge/iotdb-system.properties | 1 +
.../conf/iotdb-system.properties.template | 119 +-
.../apache/iotdb/commons/i18n/ClientMessages.java | 3 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 6 +
.../apache/iotdb/commons/i18n/LBACMessages.java | 32 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 -
.../apache/iotdb/commons/i18n/ServiceMessages.java | 2 +
.../apache/iotdb/commons/i18n/ClientMessages.java | 3 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 6 +
.../apache/iotdb/commons/i18n/LBACMessages.java | 32 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 -
.../apache/iotdb/commons/i18n/ServiceMessages.java | 2 +
.../commons/audit/UserDataTransferErrorCode.java | 3 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 64 -
.../org/apache/iotdb/commons/auth/entity/User.java | 64 -
.../commons/auth/role/LocalFileRoleAccessor.java | 69 +-
.../commons/auth/user/LocalFileUserAccessor.java | 6 +-
.../apache/iotdb/commons/client/ClientManager.java | 19 +-
.../iotdb/commons/client/ClientManagerMetrics.java | 200 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 102 +-
.../apache/iotdb/commons/cluster/RegionStatus.java | 5 +
.../commons/concurrent/ThreadPoolMetrics.java | 74 +-
.../WrappedScheduledExecutorService.java | 4 +-
.../WrappedSingleThreadExecutorService.java | 4 +-
.../WrappedSingleThreadScheduledExecutor.java | 4 +-
.../threadpool/WrappedThreadPoolExecutor.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 63 +-
.../iotdb/commons/conf/CommonDescriptor.java | 16 +-
.../apache/iotdb/commons/disk/FolderManager.java | 14 +-
.../commons/disk/strategy/DirectoryStrategy.java | 4 +-
.../commons/enums/HandleSystemErrorStrategy.java | 6 +-
.../exception/table/TableInDeletionException.java | 47 +-
.../commons/lbac/LBACAccessDeniedException.java | 56 +
.../iotdb/commons/lbac/LBACRuntimeException.java | 26 +-
.../apache/iotdb/commons/lbac/RequiredLabels.java | 79 +
.../commons/lbac/operation/LabelAccessType.java | 9 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 31 +-
.../apache/iotdb/commons/path/PathPatternUtil.java | 6 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 7 -
.../pipe/config/constant/PipeSinkConstant.java | 7 +-
.../pipe/config/constant/PipeSourceConstant.java | 5 +
.../pipe/metric/PipeEventCommitMetrics.java | 20 +-
.../execution/MemoryEstimationHelper.java | 13 +
.../function/TableBuiltinTableFunction.java | 34 +-
.../plan/relational/metadata/ColumnSchema.java | 13 +-
.../plan/relational/type/InternalTypeManager.java | 67 +-
.../schema/column/ColumnHeaderConstant.java | 2 +
.../table/AlterOrDropTableOperationType.java | 5 +-
.../commons/schema/table/InformationSchema.java | 41 +
.../apache/iotdb/commons/schema/table/TsTable.java | 2 +
.../service/metric/JvmGcMonitorMetrics.java | 38 +-
.../commons/service/metric/MetricService.java | 13 +-
.../iotdb/commons/service/metric/enums/Metric.java | 26 +
.../iotdb/commons/service/metric/enums/Tag.java | 1 +
.../iotdb/commons/udf/builtin/TypeServices.java | 671 +++
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 106 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 105 +-
.../commons/udf/builtin/UDTFChangePoints.java | 178 +-
.../commons/udf/builtin/UDTFCommonDerivative.java | 41 +-
.../udf/builtin/UDTFCommonValueDifference.java | 42 +-
.../iotdb/commons/udf/builtin/UDTFConst.java | 267 +-
.../udf/builtin/UDTFContinuouslySatisfy.java | 79 +-
.../iotdb/commons/udf/builtin/UDTFDerivative.java | 11 +
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 53 +-
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 39 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 53 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 40 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 162 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 36 +-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 149 +-
.../udf/builtin/UDTFNonNegativeDerivative.java | 48 +-
.../builtin/UDTFNonNegativeValueDifference.java | 49 +-
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 153 +-
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 136 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 65 +-
.../commons/udf/builtin/UDTFValueDifference.java | 12 +
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 42 +-
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 32 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 107 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 371 +-
.../commons/client/ClientManagerMetricsTest.java | 580 ++
.../iotdb/commons/cluster/NodeStatusTest.java | 91 +
.../commons/concurrent/ThreadPoolMetricsTest.java | 157 +
.../iotdb/commons/conf/CommonConfigTest.java | 230 +-
...ubscriptionCacheMemoryUsagePercentageTest.java} | 30 +-
.../iotdb/commons/path/PathPatternNodeTest.java | 71 +
.../pipe/metric/PipeEventCommitMetricsTest.java | 99 +
.../relational/type/InternalTypeManagerTest.java | 61 +
.../service/metric/JvmGcMonitorMetricsTest.java | 72 +
.../service/metric/MetricReporterSwitchTest.java | 166 +
.../service/metric/MetricServiceRestartTest.java | 218 +
.../commons/udf/utils/MasterRepairUtilTest.java | 94 +
.../udf/utils/UDFDataTypeTransformerTest.java | 71 +
.../src/main/thrift/confignode.thrift | 21 +-
.../src/main/thrift/datanode.thrift | 11 +
.../opc-ua-sink-example}/pom.xml | 21 +-
.../java/org/apache/iotdb/opcua/ClientExample.java | 0
.../apache/iotdb/opcua/ClientExampleRunner.java | 0
.../java/org/apache/iotdb/opcua/ClientTest.java | 0
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 0
library-pipe/opc-ua-sink/README.md | 82 +
.../consensus => library-pipe/opc-ua-sink}/pom.xml | 169 +-
.../iotdb/pipe/plugin/sink}/opcua/OpcUaSink.java | 91 +-
.../plugin/sink}/opcua/client/ClientRunner.java | 2 +-
.../opcua/client/IoTDBKeyStoreLoaderClient.java | 2 +-
.../sink}/opcua/client/IoTDBOpcUaClient.java | 10 +-
.../sink}/opcua/server/OpcUaKeyStoreLoader.java | 2 +-
.../plugin/sink}/opcua/server/OpcUaNameSpace.java | 143 +-
.../sink}/opcua/server/OpcUaServerBuilder.java | 2 +-
.../sink/opcua/server/OpcUaTypeServices.java | 145 +
.../pipe/plugin/sink/opcua/OpcUaSinkTest.java | 242 +
.../sink}/opcua/OpcUaSinkTsFileMetadataTest.java | 2 +-
.../opcua/OpcUaSinkTsFilePerformanceTest.java | 6 +-
.../sink}/opcua/client/ClientRunnerTest.java | 2 +-
.../sink}/opcua/client/IoTDBOpcUaClientTest.java | 9 +-
.../opcua/server/OpcUaNameSpaceMetadataTest.java | 9 +-
.../sink}/opcua/server/OpcUaServerBuilderTest.java | 2 +-
.../server/OpcUaTcpNoneCompatibilityTest.java | 2 +-
.../sink/opcua/server/OpcUaTypeServicesTest.java | 29 +-
library-pipe/pom.xml | 68 +
library-udf/pom.xml | 5 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 15 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 12 +
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 62 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 53 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 38 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 218 +-
.../iotdb/library/dprofile/UDAFQuantile.java | 137 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 99 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 299 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 50 +-
.../dprofile/util/ExactOrderStatistics.java | 210 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 36 +-
.../iotdb/library/drepair/UDTFValueFill.java | 36 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 37 +-
.../library/frequency/UDFEnvelopeAnalysis.java | 45 +-
.../apache/iotdb/library/match/UDAFDTWMatch.java | 26 +-
.../iotdb/library/match/UDAFPatternMatch.java | 25 +-
.../apache/iotdb/library/util/TypeServices.java | 317 ++
.../java/org/apache/iotdb/library/util/Util.java | 79 +-
.../org/apache/iotdb/library/UDFEnvelopeTest.java | 23 +
licenses/Bouncy Castle Licence | 17 +
pom.xml | 68 +-
scripts/tools/README.md | 156 +
.../tools/import-wal.sh | 65 +-
scripts/tools/windows/import-wal.bat | 43 +
943 files changed, 75328 insertions(+), 28069 deletions(-)
create mode 100644 architecture-test/pom.xml
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java
=>
architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchArchitectureTest.java
(56%)
create mode 100644
architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRule.java
create mode 100644
architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRuleTest.java
create mode 100644 distribution/src/assembly/library-pipe.xml
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/utils/TypeServices.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBNodeStatusFailoverIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBNodeStatusPersistenceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/NodeStatusTestAgent.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBProactiveRegionGroupDistributionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBProactiveRegionGroupExtensionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/removeconfignode/IoTDBRemoveConfigNodeSchemaPartitionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRecreatedTimeseriesCompactionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryVirtualRegionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBOrderingPropertyIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/AbstractIoTDBMPPDataExchangeLargeTsBlockIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBMPPDataExchangeLargeTsBlock128KIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionUnsubscribeTableIT.java
create mode 100644
iotdb-client/isession/src/main/java/org/apache/iotdb/isession/TypeServices.java
delete mode 100644 iotdb-client/jdbc/osgi.bnd
delete mode 100644 iotdb-client/jdbc/src/main/feature/feature.xml
delete mode 100644
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/Activator.java
delete mode 100644
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java
create mode 100644
iotdb-client/jdbc/src/main/resources/META-INF/services/java.sql.Driver
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java
=>
iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/DriverServiceRegistrationTest.java
(51%)
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TypeServices.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TElasticFramedTransportReadTest.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/SessionTypeServices.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionConsumerFencedException.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSliceReq.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSliceReqBuilder.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSliceReqHandler.java
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/payload/TypeServices.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSliceReqTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerHeartbeatIsolationTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionProviderSlicingTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionProviderStatusTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/payload/TypeServicesTest.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/TypeServices.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/LastDescendingInputTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/NumericBatchAggregationTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/NumericMomentBatchTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/SumAccumulatorTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/VarianceAccumulatorTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedApproxCountDistinctMaskTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateBatchInputTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/transformation/dag/column/unary/scalar/NumericCastBatchTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/utils/TypeServicesTest.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/confignode/UpdateNodeStatusPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/SetTableColumnPropertiesPlan.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/{SetTablePropertiesProcedure.java
=> AbstractSetPropertiesProcedure.java} (76%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTableColumnPropertiesProcedure.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/client/async/handlers/heartbeat/DataNodeHeartbeatHandlerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/RegionGroupExtensionPolicyConfigTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerRegionGroupPolicyReloadTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerShutdownReportTest.java
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerReconstructRegionTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerRegionOperationTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerTableTaskTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/RetryFailedTasksThreadTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/RegionBalancerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/partition/DataPartitionPolicyTableProactiveTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCacheNodeStatusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCachePersistedNodeStatusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeManagerStatusReasonTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/partition/PartitionManagerProactiveExtensionTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeMetricsRestartTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/subscription/runtime/SubscriptionRuntimeCoordinatorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnvTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/RegionMaintainHandlerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodePersistenceTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/SchemaUtilsTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/service/ConfigNodeShutdownHookTest.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueAdmission.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRejectionReason.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcherThreadMetricsTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetricsTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricSetTest.java
create mode 100644
iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/ImportWALMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/ImportWALMessages.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/lbac/AllowAllLBACAccessControl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/lbac/ILBACAccessControl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/PipeTabletEventTransferUtils.java
rename
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/sink/opcua/OpcUaSink.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceFinishedException.java}
(52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/AlterTableSetColumnPropertiesTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/information/AdditionalInformationSchemaProvider.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/ConfigNodeConfig.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/information/AdditionalInformationSchemaProviderRegistry.java
(54%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionOrdering.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/SetColumnProperties.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFilePieceNodeAssembler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/SubscriptionQueueTimeTracker.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/TableWALDeleteConverter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/TypeServices.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/RoleTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/UserTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/PipeMetricsRestartTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/schema/PipeSchemaRegionListenerMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/sink/PipeDataRegionSinkMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/processor/aggregate/TimeSeriesRuntimeStateTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTabletInsertNodeEventHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/session/QueryOwnershipTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplLoadTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplSetSystemStatusTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FileReaderReferenceLifecycleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/RegionQueryInitializationLockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/RegionScanTimeSliceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/LastQueryCollectOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/GroupedFillOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/SeriesScanUtilCancellationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterDetailsTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowConfigNodesTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowDataNodesTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ConvertPredicateToFilterVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LastQueryCacheTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/OrderingPropertyPropagationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionSortTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/adapter/RowGetDoubleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/input/ConstantInputReaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/util/TransformUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/SchemaEngineTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/metric/SchemaMemMetricTableTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManagerPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/DataNodeMetricsRestartTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/file/TsFileMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/DatabaseMemMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedFlushDuplicateTimeCheckPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TabletDeviceRangeReusePerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileTableSchemaRegistrationPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/control/FileReaderManagerConcurrencyTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileLockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFilePieceNodeAssemblerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueueTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueSeekTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/SubscriptionWalPrefetchPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/cache/SubscriptionPollResponseCacheTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/metric/SubscriptionMetricsRestartTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/ImportWALTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/TableWALDeleteConverterTest.java
copy
iotdb-core/{confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java
=>
datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchArchitectureTest.java}
(50%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRule.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRuleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TypeServicesTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/MetricManagerLifecycleTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/reporter/IoTDBJmxReporterTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/type/IoTDBAutoGaugeTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/utils/IoTDBMetricObjNameFactoryTest.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/LBACMessages.java
create mode 100644
iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/LBACMessages.java
copy
integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteConfigNodeConfig.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/TableInDeletionException.java
(51%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACAccessDeniedException.java
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACRuntimeException.java
(65%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/RequiredLabels.java
rename iotdb-client/jdbc/src/main/resources/services/META-INF/java.sql.Driver
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/operation/LabelAccessType.java
(88%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/TypeServices.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/ClientManagerMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/cluster/NodeStatusTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/concurrent/ThreadPoolMetricsTest.java
copy
iotdb-core/{confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java
=>
node-commons/src/test/java/org/apache/iotdb/commons/conf/CommonDescriptorSubscriptionCacheMemoryUsagePercentageTest.java}
(54%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/path/PathPatternNodeTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/metric/PipeEventCommitMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/queryengine/plan/relational/type/InternalTypeManagerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/JvmGcMonitorMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/MetricReporterSwitchTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/MetricServiceRestartTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/MasterRepairUtilTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/UDFDataTypeTransformerTest.java
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/pom.xml
(82%)
rename {example/pipe-opc-ua-sink =>
library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientExample.java
(100%)
rename {example/pipe-opc-ua-sink =>
library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientExampleRunner.java
(100%)
rename {example/pipe-opc-ua-sink =>
library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientTest.java
(100%)
rename {example/pipe-opc-ua-sink =>
library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/IoTDBKeyStoreLoaderClient.java
(100%)
create mode 100644 library-pipe/opc-ua-sink/README.md
copy {iotdb-core/consensus => library-pipe/opc-ua-sink}/pom.xml (50%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSink.java
(91%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/ClientRunner.java
(99%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBKeyStoreLoaderClient.java
(98%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBOpcUaClient.java
(98%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaKeyStoreLoader.java
(98%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaNameSpace.java
(85%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaServerBuilder.java
(99%)
create mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServices.java
create mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSinkTest.java
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSinkTsFileMetadataTest.java
(99%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSinkTsFilePerformanceTest.java
(98%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/ClientRunnerTest.java
(98%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBOpcUaClientTest.java
(97%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaNameSpaceMetadataTest.java
(95%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaServerBuilderTest.java
(99%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaTcpNoneCompatibilityTest.java
(98%)
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java
=>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServicesTest.java
(52%)
create mode 100644 library-pipe/pom.xml
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/util/TypeServices.java
create mode 100644 licenses/Bouncy Castle Licence
create mode 100644 scripts/tools/README.md
copy docker/src/main/Dockerfile-1.0.0-standalone =>
scripts/tools/import-wal.sh (50%)
create mode 100644 scripts/tools/windows/import-wal.bat
