This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/TableModelGrammar
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b8f590cf890 Merge branch 'ty/TableModelGrammar' of
github.com:apache/iotdb into ty/TableModelGrammar
add 05a602c940a Fix statistics error when loading snapshot
add 7cd361d0f7f Pipe: Fixed air gap receiver non-closing problem when
client exits in sender side (#12425)
add 0f16cab3b08 Pipe: handle insert data type mismatch exceptions as
idempotent exceptions when partial insert is enabled (#12432)
add 9e5f0396e10 Load: Execute tsfile serially to avoid concurrent
serialization of the resource file (#12434)
add 9e1a0a7c203 Fix the -tf args description in ExportData (#12436)
add a5f8279d621 Ensuring IoTconsensus data consistency during region
migration (#12438)
add da86ec37de8 Add hot reload for IoTConsensus transit snapshot rate
limiter and fix init (#12430)
add c5717846148 Fix the conflict between Files.walk and delete file &&
Catch UncheckedIOException && some other bugs (#12429)
add 85f47e09d2e Normalize LoadCache interfaces (#12421)
add 5923181a068 Revert "Normalize LoadCache interfaces (#12421)" (#12440)
add aad793f8bd0 empty commit
add fc5b46dae17 Log InsertRowsNode in WAL (#12271)
add c2837425ad6 Allowing create statement from bad connection (#12444)
add 9ea369559b8 [IOTDB-1667] Speed up the deletion of database by avoiding
flush (#12445)
add b75627e1203 pref(bat): support space in path (#12435)
add 352269f3ded update spotless version (#12345)
add 65fbf47897b add blame (#12449)
add 5d8deac225f Ensuring IoTconsensus data consistency during region
migration (#12448)
add 789cc6983f1 Modify initConfigManager() (#12452)
add a5ed1745e7f fix compaction selector ut (#12442)
add 5c25ef63b78 Bump golang.org/x/net in /iotdb-connector/grafana-plugin
(#12379)
add 7726741c61b Fix the issue of obtaining Windows directory permissions,
fix the issue of allocating IoTDB memory for configuration, and add the -- help
command (#12450)
add e857bccf54d Remove backup (#12455)
add ab8a33cfc7f Feature/move stuff to the extras repository take 2 (#12373)
add b91abb51644 Revert "Modify initConfigManager() (#12452)"
add 7df7e5cfa95 Lift the storage limit for tag and attribute management
(#12447)
add f4e498f1685 Bump org.bouncycastle:bcprov-jdk18on from 1.75 to 1.78
(#12458)
add f1b42deb387 Fix PartialPath#intersectWithPrefixPattern return wrong
result (#12465)
add 57a6ff4b44f add alter view statement in snapshot parser
add c63a940a74c remove connector it (#12471)
add 6f29fcf26d8 Pipe: Fixed connector subtask manager to allow restarted
DataRegions to reuse connectors from other not restarted DataRegions (#12470)
add 46319bd403b Pipe IT: Return directly when SQL retry failed in IT to
avoid potential fake failure interference (#12468)
add 2db087dc0fd Subscription: randomly generate consumer group id and
consumer id if not exist & validate topic config ahead on DN (#12467)
add f7f34de5d3f Load: Avoid NPE when load task ends after clean task's
execution (#12474)
add 139720d7f9a Limit direct buffer memory cost when create consensus
region (#12431)
add e383b0faf5b Fix region migration code (#12472)
add 1a16b6d333a Normalize LoadCache interfaces (#12441)
add 07578e14d70 Fixed backup path detection and optimized output log file
names (#12454)
add 093512b84fb Remove a line of log (#12480)
add a6676d3d529 Fix insertion cross space compaction recover null pointer
exception (#12439)
add 318348e2202 Enhance estimate of FI memory usage
add b8fd82182d2 Implement new plan optimizer: AggregationPushDown
add 411203c52d2 Remove restrictions on the number and length of tags and
attributes
add 3cca91d2e51 fixed start cli output log issue (#12483)
add 4cb0a3965b4 Pipe: Allowed the transfer of logical view alter statement
in schema snapshot (#12488)
add 7036e9ff935 Pipe: dynamically adjust connection timeout to handle
SocketTimeoutException & Avoid resource cleaning when load task is in process
(#12485)
add 3782215a21d Fix redundant lock taking during create multi timeseries
add 7bbd83d4042 [IOTDB-6326] Normalize the table headers of Auth related
statement
add e737aeb6693 Fix tsfile flush error when drop database or remove peer
(#12493)
add a7aaeb4c75d modify direct buffer memory proportion (#12496)
add d675ba14ab5 Pipe: Globally adjust timeout when syncing huge tsfiles &
Speed up file transfer after sync task failed (#12491)
add 5c434dc6a31 Pipe: Changed the hybrid switching status to avoid first
data is not synced realtime in hybrid mode (#12495)
add ddd10057fd7 Load: Add LoadTsfilePointRateLimiter to control load
tsfile throughput rate (#12356)
add dc323ffed6e Fix insert rows mem control error
add c486e3fd1a9 fixed backup bug (#12504)
add 5d916c08e94 Fix timeout doesn't take effect while using builder to
build session
add 679fc98021f Pipe: fix infinite loop with lock when retrying syncing
tsfiles in async connector (which may cause selector & connector worker
deadlock) (#12501)
add c710efbb51d Adjust some access modifier of confignode (#12505)
add 214d8d2d77d Pipe: fix pipe plugin instance not closed issue after
failed initialization (#12509)
add 5e6737108dd Bump org.springframework:spring-web from 5.3.33 to 5.3.34
(#12506)
add 0df3700054b add allow compaction check when inner space compaction
task after start (#12494)
add b80aa0ae708 Degrade configNode leader redirection log level and avoid
meaningless log print when ConfigNodeClient is first constructed. (#12510)
add be6e889312a [IOTDB-6325] Support RegionScan for active metadata
queries [FE Part]
add 234dab783ee Fix return value of fetch schmea with incorrect template
info
add e2bd04d87c4 Pipe: Fix iterator.hasNext() == true after removal from
empty ConcurrentIterableLinkedQueue (#12514)
add feb61e8d83a Pipe: Fix InsertRowsNode is not supported in batch mode
(#12517)
add 6d445f92a1e Pipe: Degraded the lock in PipeEventCollector to avoid
waitForTsFileClose() blocking pipe drop (#12518)
add c893101de1b Pipe: cache leader support batch mode (#12486)
add 741a218fb75 fix filter push down is not valid in template align by
device situation
add c12c84101c8 Fixed invalid links in En version & CH version for README
(#12512)
add 98d185d5694 fixed default parameters, output ulimit as empty, remove
excess logs from the bat script (#12522)
add 3e57c3fc78c Adjust the hard connection error log information to debug
level (#12523)
add f16df817848 Add new optimization rule: remove `Project` under
`RawDataAggregation`
add 2cb13ed1613 Pipe: timely restart pipes according to the deletion of
original TsFiles (#12406)
add 48d87bc4fd8 Pipe: Fixed the bug that events that do not trigger
collection in processorSubtask may not be reported & the pipes that extract
deletion in dataRegion extractor may be auto-restarted (#12497)
add d506eb78cb4 Load: Update TsFile Resource when
enable_auto_create_schema and verify schema are FALSE in Analysis Stage (#12525)
add 8f23949384d Change TsFile version
add 796dd5a5399 add transformStatus method in TsFileResource (#12526)
add 504810cd406 Pipe: Fixed the bug that schema region and config region
cannot report progress (#12528)
add 257d9aabac0 [IOTDB-6327] Random choosing available nodes to send sql
requests
add cfe19176edb Fix compaction write rate can not hot load
add e3aa4d8954c Pipe: RPC compression for data sync connectors (SNAPPY,
GZIP, LZ4, ZSTD and LZMA2) (#12519)
add 44ed96111ab Add device number metric
add 58331a6c73d bump ratis to 3.1.0-snapshot (#12533)
add b50ec7d64a4 Revert "bump ratis to 3.1.0-snapshot (#12533)"
add e0eea1d14bf JDBC: Fix maxRows cannot be set to 0 (#12540)
add 2f1ca39f391 Fix non-root user query data returns unexpected path
add 29fab685489 Pipe IT: Added flush on
IoTDBPipeExtractorIT#testExtractorPatternMatch() to avoid pipe on previous
follower getting unclosed historical tsfile from the old leader (#12534)
add 8562eead2bc add remote storage block for tiered storage (#12535)
add 95708409a01 [RatisConsensus] Use empty map for create peer (#12463)
add 9f92b1ae829 bump ratis 3.1.0-d09cbac-SNAPSHOT (#12547)
add 81382d71c05 Fix client cpp IT warning (#12548)
add 9f61a4e2aca Feat/jenkins auto redeploy (#12542)
add e1ea758f173 ODBC: Add example to the example module (#12544)
add f9292455bce Fixed deadlock problem caused by concurrent auto create
schema and delete database (#12489)
add 318718dad28 Bump org.jacoco:jacoco-maven-plugin from 0.8.10 to 0.8.12
(#12457)
add d81972227d9 Check duplicated measurements in one row for all insert
APIs
add 337bfe5b891 Pipe IT: Fix
IoTDBPipeClusterIT#testCreatePipesWithSameConnector() fails because the thread
is interrupted or encountered non-pipe exceptions (#12553)
add 70f18ccc4e2 Load Tsfile Tool: load does not delete the source tsfile
by default (#12549)
add 9d564e33618 Pipe: implemented ChangingValueSamplingProcessor (#12466)
add b0306420a10 Pipe: Fix RPC payload compression in
PipeTransferTsFileInsertionEventHandler (#12558)
add e4f4ed03113 Pipe: Added metrics to schema transfer / remaining event /
remaining time (#12478)
add 77d61207f6c Pipe IT: Fix CN connection timeout in IT is not functional
(#12563)
add 3b0dfcd1736 Pipe: Enable realtime first strategy in data transfer
(#12559)
add cabdec75b63 Fixed restart error when DataRegion is RatisConsensus
(#12554)
add 49dc7650e80 Pipe: Support parsing pattern when tranferring schema
plans (#12464)
add bb80f6cea14 Fix Python IT (#12567)
add 8150f7bde1d Pipe: Adjust the reloading logic to restart all the pipes
when deleted tsfiles are linked too many (#12566)
add 7d4dd9e1427 Pipe: Fix insertNode.getDevicePath() is not handled
correctly for insertRowsNode (NPE) (#12569)
add f1d8fce46c2 Pipe: Fix PipeSetTTLPlan is not handled correctly (#12571)
add 9a29af7ce1d [IOTDB-6325] Support RegionScan for active metadata
queries [BE Part One]
add 40934ddc572 Pipe: Add completion signal to historical events & allow
all data regions' completion signal to drop the pipe (#12490)
add 0ebac6b7e11 Modify strategy of wait task time limitation & Fix proc id
(#12552)
add b2c5680f3d3 [RatisConsensus] add ut for force snapshot (#12560)
add 911d7b673a6 Pipe: Fixed the bug that schema region listening queue is
not cleared when the schema region is deleted / migrated (#12575)
new 30c3639a547 fix conflicts
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.git-blame-ignore-revs | 1 +
.github/workflows/client-cpp.yml | 7 +-
.github/workflows/grafana-plugin.yml | 68 -
.gitignore | 7 -
Jenkinsfile | 2 +-
README.md | 2 +-
README_ZH.md | 4 +-
codecov.yml | 1 -
distribution/pom.xml | 133 -
distribution/src/assembly/all.xml | 7 +
distribution/src/assembly/cli.xml | 7 +
distribution/src/assembly/flink-sql-connector.xml | 41 -
distribution/src/assembly/grafana-connector.xml | 48 -
distribution/src/assembly/grafana-plugin.xml | 38 -
distribution/src/assembly/spark-connector.xml | 48 -
docker/ReadMe.md | 44 -
.../GrafanaPlugin/Dockerfile-0.14.0-iotdb | 42 -
.../DockerCompose/GrafanaPlugin/docker-compose.yml | 48 -
.../main/DockerCompose/docker-compose-grafana.yml | 50 -
docker/src/main/Dockerfile-0.12.6-grafana | 41 -
.../src/main/Dockerfile-0.13.3-grafana-connector | 41 -
example/flink-sql/pom.xml | 99 -
.../org/apache/iotdb/example/BatchSinkExample.java | 74 -
.../apache/iotdb/example/BoundedScanExample.java | 52 -
.../java/org/apache/iotdb/example/CDCExample.java | 54 -
.../org/apache/iotdb/example/LookupExample.java | 77 -
.../apache/iotdb/example/StreamingSinkExample.java | 68 -
example/flink/README.md | 40 -
example/flink/pom.xml | 61 -
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 101 -
.../org/apache/iotdb/flink/FlinkIoTDBSource.java | 93 -
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 128 -
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 81 -
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 129 -
.../iotdb/flink/FlinkTsFileStreamSource.java | 84 -
.../java/org/apache/iotdb/flink/TsFileUtils.java | 107 -
example/hadoop/pom.xml | 38 -
.../org/apache/iotdb/hadoop/tsfile/Constant.java | 32 -
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 136 -
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 185 -
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 140 -
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 77 -
example/kafka/pom.xml | 48 -
example/kafka/readme.md | 75 -
.../main/java/org/apache/iotdb/kafka/Constant.java | 68 -
.../main/java/org/apache/iotdb/kafka/Consumer.java | 136 -
.../org/apache/iotdb/kafka/ConsumerThread.java | 164 -
.../main/java/org/apache/iotdb/kafka/Producer.java | 63 -
example/odbc/.gitignore | 344 +
example/odbc/ODBC-Example.sln | 35 +
example/odbc/ODBC-Example/ODBC-Example.csproj | 40 +
example/odbc/ODBC-Example/ODBC_Example.cs | 84 +
example/odbc/README.md | 81 +
example/pom.xml | 15 +-
example/pulsar/pom.xml | 55 -
.../java/org/apache/iotdb/pulsar/Constant.java | 67 -
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 111 -
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 161 -
.../org/apache/iotdb/pulsar/PulsarProducer.java | 55 -
example/rabbitmq/pom.xml | 47 -
example/rabbitmq/readme.md | 63 -
.../java/org/apache/iotdb/rabbitmq/Constant.java | 72 -
.../iotdb/rabbitmq/RabbitMQChannelUtils.java | 52 -
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 139 -
.../apache/iotdb/rabbitmq/RabbitMQProducer.java | 49 -
example/rocketmq/pom.xml | 48 -
example/rocketmq/readme.md | 83 -
.../java/org/apache/iotdb/rocketmq/Constant.java | 70 -
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 208 -
.../apache/iotdb/rocketmq/RocketMQProducer.java | 100 -
.../org/apache/iotdb/DataMigrationExample.java | 4 +-
.../iotdb/HybridTimeseriesSessionExample.java | 1 +
.../iotdb/SyntaxConventionRelatedExample.java | 1 +
integration-test/pom.xml | 61 +-
.../it/env/cluster/config/MppCommonConfig.java | 12 +
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 -
.../env/cluster/config/MppSharedCommonConfig.java | 14 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 1 +
.../it/env/remote/config/RemoteCommonConfig.java | 10 +
.../env/remote/config/RemoteConfigNodeConfig.java | 5 -
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 -
.../iotdb/itbase/runtime/ClusterTestStatement.java | 38 +-
.../IoTDBRegionMigrateReliabilityITFramework.java | 8 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 5 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 4 +-
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 4 +-
.../db/it/aggregation/minby/IoTDBMinByIT.java | 4 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 29 +
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 4 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 1 +
.../apache/iotdb/db/it/schema/IoTDBTagLimitIT.java | 150 +
.../org/apache/iotdb/flink/it/AbstractTest.java | 46 -
.../java/org/apache/iotdb/flink/it/SinkTest.java | 163 -
.../java/org/apache/iotdb/flink/it/SourceTest.java | 192 -
.../test/java/org/apache/iotdb/flink/it/Utils.java | 94 -
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeAutoDropIT.java | 80 +
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 67 +-
...T.java => IoTDBPipeConnectorCompressionIT.java} | 115 +-
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 17 +-
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 51 +-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 4 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 12 +-
.../pipe/it/manual/AbstractPipeDualManualIT.java | 4 +-
.../iotdb/pipe/it/manual/IoTDBPipeInclusionIT.java | 56 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 41 +-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 36 +-
.../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 28 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 2 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 134 +
.../org/apache/iotdb/spark/it/AbstractTest.java | 55 -
.../java/org/apache/iotdb/spark/it/ReadTest.java | 145 -
.../test/java/org/apache/iotdb/spark/it/Utils.java | 95 -
.../java/org/apache/iotdb/spark/it/WriteTest.java | 116 -
.../it/dual/AbstractSubscriptionDualIT.java | 4 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 4 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 47 +
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 390 -
.../parameter/PipeParameterValidator.java | 4 +-
.../main/java/org/apache/iotdb/udf/api/State.java | 3 +-
.../main/java/org/apache/iotdb/udf/api/UDAF.java | 3 +-
.../src/assembly/resources/conf/logback-backup.xml | 30 +-
.../cli/src/assembly/resources/sbin/start-cli.bat | 2 +-
.../cli/src/assembly/resources/tools/backup.bat | 14 +-
.../cli/src/assembly/resources/tools/backup.sh | 6 +-
.../src/assembly/resources/tools/export-data.bat | 6 +-
.../src/assembly/resources/tools/export-tsfile.bat | 6 +-
.../src/assembly/resources/tools/import-data.bat | 6 +-
.../src/assembly/resources/tools/load-tsfile.bat | 2 +-
.../java/org/apache/iotdb/tool/ExportData.java | 2 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 4 +-
.../java/org/apache/iotdb/tool/ImportData.java | 3 +-
.../org/apache/iotdb/tool/IoTDBDataBackTool.java | 329 +-
iotdb-client/client-py/requirements_dev.txt | 3 +-
.../org/apache/iotdb/isession/INodeSupplier.java | 3 +
.../java/org/apache/iotdb/isession/ISession.java | 36 +-
.../org/apache/iotdb/isession/SessionConfig.java | 1 +
.../apache/iotdb/isession/pool/ISessionPool.java | 52 +-
.../iotdb/isession/pool/SessionDataSetWrapper.java | 1 +
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 4 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 1 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 1 +
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 11 +-
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 1 +
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 1 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 5 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 1 +
.../rpc/subscription/config/ConsumerConfig.java | 8 +
.../response/PipeSubscribeHandshakeResp.java | 26 +-
.../apache/iotdb/session/DummyNodesSupplier.java | 12 +
.../org/apache/iotdb/session/NodesSupplier.java | 26 +-
.../apache/iotdb/session/QueryEndPointPolicy.java | 11 +-
.../org/apache/iotdb/session/RoundRobinPolicy.java | 20 +-
.../java/org/apache/iotdb/session/Session.java | 56 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 21 +-
.../session/subscription/SubscriptionConsumer.java | 30 +-
.../subscription/SubscriptionEndpointsSyncer.java | 9 +-
.../session/subscription/SubscriptionProvider.java | 25 +-
.../SubscriptionSessionConnection.java | 6 +-
.../java/org/apache/iotdb/session/SessionTest.java | 6 +
iotdb-connector/flink-iotdb-connector/README.md | 58 -
iotdb-connector/flink-iotdb-connector/pom.xml | 84 -
.../iotdb/flink/DefaultIoTSerializationSchema.java | 130 -
.../main/java/org/apache/iotdb/flink/Event.java | 70 -
.../java/org/apache/iotdb/flink/IoTDBSink.java | 213 -
.../java/org/apache/iotdb/flink/IoTDBSource.java | 100 -
.../apache/iotdb/flink/IoTSerializationSchema.java | 32 -
.../apache/iotdb/flink/options/IoTDBOptions.java | 70 -
.../iotdb/flink/options/IoTDBSinkOptions.java | 106 -
.../iotdb/flink/options/IoTDBSourceOptions.java | 51 -
.../flink/DefaultIoTSerializationSchemaTest.java | 54 -
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 116 -
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 83 -
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 72 -
iotdb-connector/flink-sql-iotdb-connector/pom.xml | 124 -
.../flink/sql/client/IoTDBWebSocketClient.java | 92 -
.../org/apache/iotdb/flink/sql/common/Options.java | 64 -
.../org/apache/iotdb/flink/sql/common/Utils.java | 177 -
.../sql/exception/IllegalIoTDBPathException.java | 25 -
.../sql/exception/IllegalSchemaException.java | 25 -
.../sql/exception/IllegalUrlPathException.java | 25 -
.../exception/UnsupportedDataTypeException.java | 25 -
.../sql/factory/IoTDBDynamicTableFactory.java | 230 -
.../sql/function/IoTDBBoundedScanFunction.java | 167 -
.../flink/sql/function/IoTDBCDCSourceFunction.java | 297 -
.../flink/sql/function/IoTDBLookupFunction.java | 149 -
.../flink/sql/function/IoTDBSinkFunction.java | 143 -
.../flink/sql/provider/IoTDBDynamicTableSink.java | 64 -
.../sql/provider/IoTDBDynamicTableSource.java | 76 -
.../iotdb/flink/sql/wrapper/TabletWrapper.java | 47 -
.../org.apache.flink.table.factories.Factory | 20 -
iotdb-connector/flink-tsfile-connector/README.md | 177 -
iotdb-connector/flink-tsfile-connector/pom.xml | 158 -
.../apache/iotdb/flink/tsfile/RowRecordParser.java | 46 -
.../iotdb/flink/tsfile/RowRowRecordParser.java | 121 -
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 168 -
.../iotdb/flink/tsfile/TSRecordConverter.java | 60 -
.../iotdb/flink/tsfile/TSRecordOutputFormat.java | 98 -
.../iotdb/flink/tsfile/TsFileInputFormat.java | 174 -
.../iotdb/flink/tsfile/TsFileOutputFormat.java | 136 -
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 65 -
.../RowTSRecordOutputFormatIntegrationTest.java | 54 -
.../flink/tsfile/RowTSRecordOutputFormatTest.java | 75 -
.../flink/tsfile/RowTsFileConnectorTestBase.java | 77 -
.../RowTsFileInputFormatIntegrationTest.java | 108 -
.../flink/tsfile/RowTsFileInputFormatTest.java | 88 -
.../flink/tsfile/RowTsFileInputFormatTestBase.java | 49 -
.../tsfile/RowTsFileOutputFormatTestBase.java | 119 -
.../util/TSFileConfigUtilCompletenessTest.java | 102 -
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 233 -
.../src/test/resources/log4j.properties | 28 -
.../grafana-connector/img/add_data_source.png | Bin 108927 -> 0 bytes
.../grafana-connector/img/add_graph.png | Bin 364163 -> 0 bytes
.../grafana-connector/img/edit_data_source.png | Bin 177869 -> 0 bytes
iotdb-connector/grafana-connector/pom.xml | 257 -
iotdb-connector/grafana-connector/readme.md | 192 -
iotdb-connector/grafana-connector/readme_zh.md | 195 -
.../web/grafana/TsfileWebDemoApplication.java | 30 -
.../iotdb/web/grafana/conf/MyConfiguration.java | 47 -
.../controller/DatabaseConnectController.java | 196 -
.../org/apache/iotdb/web/grafana/dao/BasicDao.java | 34 -
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 208 -
.../web/grafana/interceptor/LoginInterceptor.java | 64 -
.../service/impl/DatabaseConnectServiceImpl.java | 46 -
.../src/main/resources/application.properties | 39 -
.../web/grafana/dao/impl/BasicDaoImplTest.java | 53 -
iotdb-connector/grafana-plugin/.gitignore | 33 -
iotdb-connector/grafana-plugin/.prettierrc.js | 20 -
iotdb-connector/grafana-plugin/CHANGELOG.md | 24 -
iotdb-connector/grafana-plugin/LICENSE | 201 -
iotdb-connector/grafana-plugin/Magefile.go | 32 -
iotdb-connector/grafana-plugin/README.md | 177 -
iotdb-connector/grafana-plugin/backend-compile.bat | 31 -
iotdb-connector/grafana-plugin/backend-compile.sh | 48 -
iotdb-connector/grafana-plugin/go.mod | 107 -
iotdb-connector/grafana-plugin/jest.config.js | 24 -
iotdb-connector/grafana-plugin/package.json | 31 -
iotdb-connector/grafana-plugin/pkg/main.go | 40 -
.../pkg/plugin/iotdb_resource_handler.go | 170 -
.../grafana-plugin/pkg/plugin/plugin.go | 430 -
iotdb-connector/grafana-plugin/pom.xml | 116 -
.../grafana-plugin/src/ConfigEditor.tsx | 108 -
iotdb-connector/grafana-plugin/src/QueryEditor.tsx | 343 -
.../src/componments/AggregateFun.tsx | 44 -
.../src/componments/ControlValue.tsx | 38 -
.../grafana-plugin/src/componments/FillValue.tsx | 38 -
.../grafana-plugin/src/componments/Form.tsx | 42 -
.../grafana-plugin/src/componments/FromValue.tsx | 110 -
.../grafana-plugin/src/componments/GroupBy.tsx | 58 -
.../grafana-plugin/src/componments/SelectValue.tsx | 110 -
.../grafana-plugin/src/componments/TimeSeries.tsx | 82 -
.../grafana-plugin/src/componments/WhereValue.tsx | 39 -
iotdb-connector/grafana-plugin/src/datasource.ts | 106 -
iotdb-connector/grafana-plugin/src/functions.ts | 20 -
.../grafana-plugin/src/img/addIoTDBDataSource.png | Bin 43760 -> 0 bytes
iotdb-connector/grafana-plugin/src/img/logo.svg | 271 -
.../grafana-plugin/src/img/showData.png | Bin 170827 -> 0 bytes
iotdb-connector/grafana-plugin/src/module.ts | 25 -
iotdb-connector/grafana-plugin/src/plugin.json | 50 -
iotdb-connector/grafana-plugin/src/types.ts | 68 -
iotdb-connector/grafana-plugin/tsconfig.json | 9 -
iotdb-connector/grafana-plugin/yarn.lock | 11194 -------------------
iotdb-connector/hadoop/README.md | 212 -
iotdb-connector/hadoop/pom.xml | 191 -
.../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 115 -
.../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 455 -
.../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 114 -
.../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 108 -
.../iotdb/hadoop/tsfile/TSFHadoopException.java | 45 -
.../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 297 -
.../apache/iotdb/hadoop/tsfile/TSFInputSplit.java | 39 -
.../iotdb/hadoop/tsfile/TSFOutputFormat.java | 58 -
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 260 -
.../iotdb/hadoop/tsfile/TSFRecordWriter.java | 62 -
.../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 202 -
.../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 229 -
.../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 71 -
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 122 -
.../iotdb/hadoop/tsfile/constant/TestConstant.java | 28 -
.../hadoop/src/test/resources/logback.xml | 41 -
iotdb-connector/hive-connector/pom.xml | 139 -
.../org/apache/iotdb/hive/TSFHiveInputFormat.java | 56 -
.../org/apache/iotdb/hive/TSFHiveOutputFormat.java | 75 -
.../org/apache/iotdb/hive/TSFHiveRecordReader.java | 158 -
.../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 71 -
.../org/apache/iotdb/hive/TsFileDeserializer.java | 159 -
.../java/org/apache/iotdb/hive/TsFileSerDe.java | 169 -
.../apache/iotdb/hive/TsFileSerDeException.java | 40 -
.../apache/iotdb/hive/TSFHiveInputFormatTest.java | 111 -
.../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 159 -
.../apache/iotdb/hive/TsFileDeserializerTest.java | 126 -
.../org/apache/iotdb/hive/TsFileSerDeTest.java | 149 -
.../org/apache/iotdb/hive/TsFileTestHelper.java | 127 -
.../apache/iotdb/hive/constant/TestConstant.java | 28 -
iotdb-connector/pom.xml | 66 -
iotdb-connector/spark-iotdb-connector/pom.xml | 140 -
.../spark-iotdb-connector/scala_2.11/pom.xml | 50 -
.../spark-iotdb-connector/scala_2.12/pom.xml | 51 -
.../org/apache/iotdb/spark/db/Converter.scala | 89 -
.../org/apache/iotdb/spark/db/DataFrameTools.scala | 131 -
.../org/apache/iotdb/spark/db/DefaultSource.scala | 61 -
.../org/apache/iotdb/spark/db/IoTDBOptions.scala | 43 -
.../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 137 -
.../org/apache/iotdb/spark/db/IoTDBRelation.scala | 117 -
.../org/apache/iotdb/spark/db/Transformer.scala | 172 -
iotdb-connector/spark-tsfile/pom.xml | 114 -
.../iotdb/spark/tsfile/io/TsFileRecordWriter.java | 61 -
.../org/apache/iotdb/spark/tsfile/qp/Executor.java | 51 -
.../iotdb/spark/tsfile/qp/QueryProcessor.java | 195 -
.../spark/tsfile/qp/common/BasicOperator.java | 66 -
.../spark/tsfile/qp/common/FilterOperator.java | 161 -
.../iotdb/spark/tsfile/qp/common/SQLConstant.java | 138 -
.../iotdb/spark/tsfile/qp/common/SingleQuery.java | 65 -
.../iotdb/spark/tsfile/qp/common/TSQueryPlan.java | 68 -
.../qp/exception/BasicOperatorException.java | 29 -
.../tsfile/qp/exception/DNFOptimizeException.java | 29 -
.../qp/exception/LogicalOptimizeException.java | 29 -
.../tsfile/qp/exception/MergeFilterException.java | 28 -
.../qp/exception/QueryOperatorException.java | 28 -
.../qp/exception/QueryProcessorException.java | 37 -
.../tsfile/qp/exception/RemoveNotException.java | 29 -
.../tsfile/qp/optimizer/DNFFilterOptimizer.java | 154 -
.../tsfile/qp/optimizer/IFilterOptimizer.java | 31 -
.../qp/optimizer/MergeSingleFilterOptimizer.java | 133 -
.../tsfile/qp/optimizer/PhysicalOptimizer.java | 250 -
.../tsfile/qp/optimizer/RemoveNotOptimizer.java | 92 -
.../org/apache/iotdb/spark/tsfile/Converter.scala | 144 -
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 292 -
.../iotdb/spark/tsfile/NarrowConverter.scala | 596 -
.../spark/tsfile/NarrowTsFileOutputWriter.scala | 50 -
.../apache/iotdb/spark/tsfile/Transformer.scala | 175 -
.../iotdb/spark/tsfile/TsFileWriterFactory.scala | 42 -
.../apache/iotdb/spark/tsfile/WideConverter.scala | 504 -
.../spark/tsfile/WideTsFileOutputWriter.scala | 53 -
.../org/apache/iotdb/spark/tsfile/package.scala | 62 -
.../org/apache/iotdb/spark/tool/TsFileExample.java | 111 -
.../apache/iotdb/spark/tool/TsFileWriteTool.java | 280 -
.../apache/iotdb/spark/tsfile/ConverterTest.scala | 270 -
.../apache/iotdb/spark/tsfile/HDFSInputTest.java | 81 -
.../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 641 --
.../zeppelin-interpreter/IoTDB-Zeppelin-Demo.zpln | 377 -
iotdb-connector/zeppelin-interpreter/pom.xml | 90 -
.../apache/zeppelin/iotdb/IoTDBInterpreter.java | 296 -
.../src/main/resources/interpreter-setting.json | 70 -
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 12 +-
iotdb-core/confignode/pom.xml | 4 +
.../src/assembly/resources/conf/confignode-env.bat | 14 +-
.../assembly/resources/sbin/remove-confignode.bat | 2 +-
.../assembly/resources/sbin/start-confignode.bat | 10 +-
.../assembly/resources/sbin/stop-confignode.bat | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 3 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../consensus/request/auth/AuthorPlan.java | 21 +-
.../pipe/payload/PipeDeleteLogicalViewPlan.java | 11 +-
.../pipe/payload/PipeDeleteTimeSeriesPlan.java | 11 +-
.../request/write/pipe/payload/PipeSetTTLPlan.java | 103 +
.../iotdb/confignode/manager/ConfigManager.java | 39 +-
.../iotdb/confignode/manager/ProcedureManager.java | 32 +-
.../manager/consensus/ConsensusManager.java | 20 +-
.../iotdb/confignode/manager/load/LoadManager.java | 58 +-
.../manager/load/balancer/RouteBalancer.java | 9 +-
.../router/leader/AbstractLeaderBalancer.java | 48 +-
.../router/leader/GreedyLeaderBalancer.java | 14 +-
.../router/leader/MinCostFlowLeaderBalancer.java | 142 +-
.../confignode/manager/load/cache/LoadCache.java | 183 +-
.../consensus/ConsensusGroupHeartbeatSample.java | 7 +
.../cache/consensus/ConsensusGroupStatistics.java | 7 +
.../manager/load/cache/node/BaseNodeCache.java | 8 +-
.../manager/load/cache/node/NodeStatistics.java | 4 +-
.../manager/load/cache/region/RegionCache.java | 3 +-
.../load/cache/region/RegionGroupCache.java | 30 +-
.../load/cache/region/RegionHeartbeatSample.java | 7 +
.../manager/load/service/EventService.java | 133 +-
.../manager/load/service/HeartbeatService.java | 16 +-
.../iotdb/confignode/manager/node/NodeManager.java | 13 +-
.../manager/partition/PartitionManager.java | 1 +
.../payload/PipeTransferConfigSnapshotSealReq.java | 33 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 29 +-
.../protocol/IoTDBConfigRegionConnector.java | 22 +-
.../runtime/PipeRuntimeCoordinator.java | 18 +-
.../runtime/heartbeat/PipeHeartbeat.java | 61 +
.../{ => heartbeat}/PipeHeartbeatParser.java | 51 +-
.../{ => heartbeat}/PipeHeartbeatScheduler.java | 20 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 1 +
.../pipe/execution/PipeConfigNodeSubtask.java | 122 +-
.../execution/PipeConfigNodeSubtaskExecutor.java | 4 +-
.../extractor/ConfigRegionListeningFilter.java | 8 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 54 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 287 +
.../pipe/metric/PipeConfigNodeListenerMetrics.java | 67 +
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 14 +-
.../metric/PipeConfigNodeRemainingTimeMetrics.java | 169 +
.../PipeConfigNodeRemainingTimeOperator.java | 119 +
.../metric/PipeConfigRegionConnectorMetrics.java | 157 +
.../metric/PipeConfigRegionExtractorMetrics.java | 139 +
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 45 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 55 +-
.../manager/schema/ClusterSchemaManager.java | 36 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 10 +-
.../persistence/executor/ConfigPlanExecutor.java | 11 +-
.../confignode/persistence/node/NodeInfo.java | 31 +-
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/PartitionInfo.java | 1 +
.../persistence/partition/RegionGroup.java | 4 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 89 +-
.../persistence/schema/ClusterSchemaInfo.java | 8 +-
.../iotdb/confignode/procedure/Procedure.java | 32 +-
.../confignode/procedure/ProcedureExecutor.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 38 +-
.../procedure/env/RegionMaintainHandler.java | 54 +-
.../impl/node/AddConfigNodeProcedure.java | 2 +-
.../impl/region/AddRegionPeerProcedure.java | 47 +-
.../impl/region/CreateRegionGroupsProcedure.java | 9 +-
.../impl/region/RemoveRegionPeerProcedure.java | 14 +-
.../procedure/scheduler/ProcedureScheduler.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 28 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 69 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 111 +-
.../confignode/manager/load/FakeSubscriber.java | 92 +
.../confignode/manager/load/LoadManagerTest.java | 295 +
.../router/leader/CFDLeaderBalancerTest.java | 34 +-
.../router/leader/GreedyLeaderBalancerTest.java | 30 +-
.../leader/LeaderBalancerComparisonTest.java | 39 +-
.../manager/load/cache/RegionGroupCacheTest.java | 23 +-
.../connector/PipeConfigNodeThriftRequestTest.java | 2 +-
.../extractor/IoTDBConfigRegionExtractorTest.java | 7 +-
...eConfigPhysicalPlanPatternParseVisitorTest.java | 408 +
.../org/apache/iotdb/consensus/IConsensus.java | 11 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 17 +-
.../consensus/iot/IoTConsensusServerImpl.java | 39 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 3 +-
.../iot/service/IoTConsensusRPCService.java | 7 +-
.../iot/snapshot/IoTConsensusRateLimiter.java | 5 +-
.../apache/iotdb/consensus/ratis/DiskGuardian.java | 65 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 118 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 9 +
.../iotdb/consensus/ratis/utils/RetryPolicy.java | 1 +
.../iotdb/consensus/simple/SimpleConsensus.java | 5 +
.../apache/iotdb/consensus/iot/ReplicateTest.java | 55 +-
.../iotdb/consensus/ratis/DiskGuardianTest.java | 28 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 15 +
.../apache/iotdb/consensus/ratis/TestUtils.java | 21 +
iotdb-core/datanode/pom.xml | 4 +
.../src/assembly/resources/conf/datanode-env.bat | 17 +-
.../assembly/resources/sbin/remove-datanode.bat | 2 +-
.../src/assembly/resources/sbin/start-datanode.bat | 41 +-
.../src/assembly/resources/sbin/start-datanode.sh | 1 +
.../src/assembly/resources/sbin/stop-datanode.bat | 4 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 22 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 33 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 25 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 1 +
.../db/consensus/DataRegionConsensusImpl.java | 257 +-
.../schemaregion/SchemaExecutionVisitor.java | 25 +-
.../metadata/DataTypeMismatchException.java | 7 +-
.../PipeDataRegionProcessorConstructor.java | 4 +
.../runtime/PipeSchemaRegionListenerManager.java | 44 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 240 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 14 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 2 +-
.../client/IoTDBDataNodeSyncClientManager.java | 9 +
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 29 -
...ferBatchReqBuilder.java => PipeEventBatch.java} | 61 +-
.../builder/PipeTransferBatchReqBuilder.java | 220 +-
.../evolvable/request/PipeTransferPlanNodeReq.java | 1 +
.../request/PipeTransferSchemaSnapshotSealReq.java | 32 +-
.../request/PipeTransferTabletBatchReq.java | 23 +-
.../request/PipeTransferTabletBinaryReq.java | 57 +-
.../request/PipeTransferTabletInsertNodeReq.java | 13 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 12 +-
.../airgap/IoTDBDataRegionAirGapConnector.java | 24 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 17 +-
.../async/IoTDBDataRegionAsyncConnector.java | 210 +-
.../PipeTransferTabletBatchEventHandler.java | 24 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 3 +-
.../PipeTransferTsFileInsertionEventHandler.java | 55 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 5 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 83 +-
.../thrift/sync/IoTDBSchemaRegionConnector.java | 17 +-
.../db/pipe/connector/util/LeaderCacheUtils.java | 69 +
.../event/common/heartbeat/PipeHeartbeatEvent.java | 34 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 2 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 11 +-
.../tablet/TabletInsertionDataContainer.java | 32 +-
.../event/common/terminate/PipeTerminateEvent.java | 94 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 4 +-
.../tsfile/TsFileInsertionDataContainer.java | 29 +-
.../common/tsfile/TsFileInsertionPointCounter.java | 10 +-
.../dataregion/DataRegionWatermarkInjector.java | 2 +-
.../dataregion/IoTDBDataRegionExtractor.java | 55 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 56 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 32 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 74 +-
.../dataregion/realtime/epoch/TsFileEpoch.java | 4 +-
.../realtime/epoch/TsFileEpochManager.java | 23 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 34 +-
.../schemaregion/PipePlanPatternParseVisitor.java | 284 +
.../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 20 +-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 219 +
.../PipeDataNodeRemainingEventAndTimeOperator.java | 190 +
...cs.java => PipeDataRegionConnectorMetrics.java} | 91 +-
...cs.java => PipeDataRegionExtractorMetrics.java} | 129 +-
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 57 +-
.../metric/PipeSchemaRegionConnectorMetrics.java | 159 +
.../metric/PipeSchemaRegionExtractorMetrics.java | 144 +
.../metric/PipeSchemaRegionListenerMetrics.java | 135 +
.../pipe/pattern/CachedSchemaPatternMatcher.java | 10 +-
.../downsampling/changing/ChangingValueFilter.java | 95 +
.../changing/ChangingValueSamplingProcessor.java | 199 +
.../sdt/SwingingDoorTrendingFilter.java | 5 +-
.../exchange/sender/TwoStageAggregateSender.java | 2 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 13 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 67 +-
.../visitor/PipePlanToStatementVisitor.java | 2 +-
.../visitor/PipeStatementPatternParseVisitor.java | 136 +
.../visitor/PipeStatementTSStatusVisitor.java | 12 +
.../pipe/resource/tsfile/PipeTsFileResource.java | 33 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 35 +-
.../iotdb/db/pipe/task/PipeDataNodeTask.java | 20 +-
.../pipe/task/connection/PipeEventCollector.java | 131 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 4 +-
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 13 +
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 4 +-
.../subtask/connector/PipeConnectorSubtask.java | 88 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 8 +-
.../connector/PipeConnectorSubtaskManager.java | 68 +-
.../PipeRealtimePriorityBlockingQueue.java | 136 +
.../subtask/processor/PipeProcessorSubtask.java | 53 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 35 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 1 +
.../rest/utils/InsertTabletSortDataUtils.java | 1 +
.../iotdb/db/protocol/session/SessionManager.java | 1 +
.../impl/DataNodeInternalRPCServiceImpl.java | 19 +-
.../thrift/impl/DataNodeRegionManager.java | 2 +
.../queryengine/common/TimeseriesSchemaInfo.java | 123 +
.../common/header/ColumnHeaderConstant.java | 10 +
.../common/schematree/ClusterSchemaTree.java | 32 +-
.../common/schematree/DeviceSchemaInfo.java | 4 +
.../queryengine/common/schematree/ISchemaTree.java | 2 +
.../common/schematree/node/SchemaInternalNode.java | 5 +
.../schematree/node/SchemaMeasurementNode.java | 6 +
.../common/schematree/node/SchemaNode.java | 2 +
.../execution/MemoryEstimationHelper.java | 87 +
.../timerangeiterator/ITimeRangeIterator.java | 4 +-
.../queryengine/execution/driver/DataDriver.java | 25 +-
.../execution/driver/DataDriverContext.java | 4 +-
.../queryengine/execution/exchange/sink/ISink.java | 3 +-
.../execution/exchange/sink/LocalSinkChannel.java | 11 +
.../execution/exchange/sink/ShuffleSinkHandle.java | 14 +
.../execution/exchange/sink/SinkChannel.java | 16 +
.../execution/exchange/source/ISourceHandle.java | 3 +-
.../exchange/source/LocalSourceHandle.java | 14 +-
.../execution/exchange/source/SourceHandle.java | 13 +
.../fragment/FragmentInstanceContext.java | 152 +-
.../execution/fragment/QueryContext.java | 62 +-
.../execution/load/AlignedChunkData.java | 3 +
.../execution/load/LoadTsFileManager.java | 71 +-
.../execution/load/LoadTsFileRateLimiter.java | 79 +
.../execution/load/NonAlignedChunkData.java | 3 +
.../queryengine/execution/memory/MemoryPool.java | 2 +
.../execution/operator/ExplainAnalyzeOperator.java | 21 +-
.../queryengine/execution/operator/Operator.java | 3 +-
.../execution/operator/OperatorContext.java | 15 +-
.../process/AbstractConsumeAllOperator.java | 5 +-
.../process/AggregationMergeSortOperator.java | 17 +
.../operator/process/AggregationOperator.java | 16 +
.../operator/process/ColumnInjectOperator.java | 12 +
.../operator/process/DeviceViewIntoOperator.java | 13 +
.../operator/process/DeviceViewOperator.java | 14 +
.../execution/operator/process/FillOperator.java | 11 +
.../operator/process/FilterAndProjectOperator.java | 13 +
.../execution/operator/process/IntoOperator.java | 20 +
.../execution/operator/process/LimitOperator.java | 11 +
.../operator/process/LinearFillOperator.java | 13 +
.../operator/process/MergeSortOperator.java | 21 +-
.../execution/operator/process/OffsetOperator.java | 11 +
.../operator/process/ProjectOperator.java | 11 +
.../process/RawDataAggregationOperator.java | 13 +
.../operator/process/SingleDeviceViewOperator.java | 11 +
.../process/SlidingWindowAggregationOperator.java | 12 +
.../execution/operator/process/SortOperator.java | 14 +
.../operator/process/TagAggregationOperator.java | 19 +
.../execution/operator/process/TopKOperator.java | 16 +
.../operator/process/TransformOperator.java | 14 +
.../process/join/FullOuterTimeJoinOperator.java | 24 +-
.../process/join/HorizontallyConcatOperator.java | 17 +
.../process/join/InnerTimeJoinOperator.java | 18 +
.../process/join/LeftOuterTimeJoinOperator.java | 14 +
.../last/AlignedUpdateLastCacheOperator.java | 16 +
.../AlignedUpdateViewPathLastCacheOperator.java | 6 +
.../process/last/LastQueryCollectOperator.java | 16 +
.../process/last/LastQueryMergeOperator.java | 18 +
.../operator/process/last/LastQueryOperator.java | 17 +
.../process/last/LastQuerySortOperator.java | 17 +
.../process/last/LastQueryTransformOperator.java | 15 +
.../process/last/UpdateLastCacheOperator.java | 16 +
.../last/UpdateViewPathLastCacheOperator.java | 6 +
.../schema/CountGroupByLevelMergeOperator.java | 14 +
.../schema/CountGroupByLevelScanOperator.java | 18 +-
.../operator/schema/CountMergeOperator.java | 12 +
.../schema/NodeManageMemoryMergeOperator.java | 12 +
.../operator/schema/NodePathsConvertOperator.java | 12 +
.../operator/schema/NodePathsCountOperator.java | 12 +
.../operator/schema/SchemaCountOperator.java | 12 +
.../operator/schema/SchemaFetchMergeOperator.java | 15 +
.../operator/schema/SchemaFetchScanOperator.java | 12 +
.../operator/schema/SchemaQueryMergeOperator.java | 13 +
.../schema/SchemaQueryOrderByHeatOperator.java | 14 +
.../operator/schema/SchemaQueryScanOperator.java | 14 +
.../schema/source/TimeSeriesSchemaSource.java | 2 +-
.../operator/sink/IdentitySinkOperator.java | 16 +
.../operator/sink/ShuffleHelperOperator.java | 16 +
.../source/AbstractDataSourceOperator.java | 5 +-
.../AlignedSeriesAggregationScanOperator.java | 16 +
.../operator/source/AlignedSeriesScanOperator.java | 18 +-
.../operator/source/DataSourceOperator.java | 4 +-
.../operator/source/ExchangeOperator.java | 13 +
.../operator/source/LastCacheScanOperator.java | 12 +
.../source/SeriesAggregationScanOperator.java | 16 +
.../operator/source/SeriesScanOperator.java | 13 +
.../execution/operator/source/SeriesScanUtil.java | 16 +-
.../operator/source/ShowQueriesOperator.java | 12 +
.../source/relational/TableScanOperator.java | 22 +-
.../metric/DataExchangeCostMetricSet.java | 1 +
.../metric/QueryExecutionMetricSet.java | 3 +
.../db/queryengine/plan/analyze/Analysis.java | 29 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 247 +-
.../queryengine/plan/analyze/ExpressionUtils.java | 3 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 39 +-
.../analyze/cache/partition/PartitionCache.java | 6 +-
.../cache/partition/StorageGroupCacheResult.java | 2 +
.../plan/analyze/schema/ClusterSchemaFetcher.java | 7 +-
.../plan/analyze/schema/ISchemaComputation.java | 8 +-
.../plan/analyze/schema/ISchemaFetcher.java | 16 +
.../plan/execution/IQueryExecution.java | 4 +-
.../queryengine/plan/execution/QueryExecution.java | 4 +-
.../config/executor/ClusterConfigTaskExecutor.java | 31 +-
.../plan/execution/memory/MemorySourceHandle.java | 9 +
.../visitor/TransformToViewExpressionVisitor.java | 6 +
.../plan/optimization/AggregationPushDown.java | 483 +
.../plan/optimization/ColumnInjectionPushDown.java | 30 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 47 +-
.../plan/planner/LocalExecutionPlanContext.java | 52 +
.../plan/planner/LocalExecutionPlanner.java | 27 +-
.../plan/planner/LogicalPlanBuilder.java | 385 +-
.../plan/planner/LogicalPlanVisitor.java | 238 +-
.../queryengine/plan/planner/LogicalPlanner.java | 6 +-
.../plan/planner/OperatorTreeGenerator.java | 327 +-
.../plan/planner/TemplatedLogicalPlanBuilder.java | 5 +-
.../distribution/DistributionPlanContext.java | 4 +
.../planner/distribution/ExchangeNodeAdder.java | 18 +
.../plan/planner/distribution/SourceRewriter.java | 70 +-
.../ConsumeAllChildrenPipelineMemoryEstimator.java | 28 +-
...umeChildrenOneByOnePipelineMemoryEstimator.java | 69 +
.../planner/memory/PipelineMemoryEstimator.java | 79 +
.../memory/PipelineMemoryEstimatorFactory.java | 51 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 22 +
.../plan/planner/plan/node/PlanNodeId.java | 12 +-
.../plan/planner/plan/node/PlanNodeType.java | 30 +-
.../plan/planner/plan/node/PlanVisitor.java | 25 +
.../metedata/write/view/CreateLogicalViewNode.java | 1 +
.../planner/plan/node/process/ProjectNode.java | 6 +-
.../plan/node/process/RawDataAggregationNode.java | 323 +
.../planner/plan/node/process/RegionMergeNode.java | 128 +
.../node/process/join/FullOuterTimeJoinNode.java | 5 +
.../source/AlignedSeriesAggregationScanNode.java | 6 +-
.../plan/node/source/DeviceRegionScanNode.java | 175 +
.../planner/plan/node/source/RegionScanNode.java | 94 +
.../plan/node/source/TimeseriesRegionScanNode.java | 329 +
.../planner/plan/node/write/DeleteDataNode.java | 21 +
.../plan/planner/plan/node/write/InsertNode.java | 2 +
.../planner/plan/node/write/InsertRowNode.java | 28 +-
.../planner/plan/node/write/InsertRowsNode.java | 85 +-
.../planner/plan/node/write/InsertTabletNode.java | 1 +
.../planner/plan/parameter/SeriesScanOptions.java | 4 +-
.../relational/analyzer/ExpressionAnalyzer.java | 9 +-
.../plan/relational/metadata/DeviceEntry.java | 14 +-
.../plan/relational/planner/node/LimitNode.java | 1 +
.../scheduler/FragmentInstanceDispatcherImpl.java | 4 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 195 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 40 +-
.../plan/statement/crud/InsertBaseStatement.java | 18 +-
.../crud/InsertMultiTabletsStatement.java | 15 +
.../plan/statement/crud/InsertRowStatement.java | 11 +
.../crud/InsertRowsOfOneDeviceStatement.java | 7 +
.../plan/statement/crud/InsertRowsStatement.java | 7 +
.../plan/statement/crud/InsertStatement.java | 35 +-
.../plan/statement/crud/InsertTabletStatement.java | 11 +
.../plan/statement/crud/LoadTsFileStatement.java | 4 +-
.../statement/metadata/CountDevicesStatement.java | 16 +
.../metadata/CountTimeSeriesStatement.java | 15 +
.../metadata/CreateAlignedTimeSeriesStatement.java | 55 +
.../statement/metadata/ShowDevicesStatement.java | 14 +
.../metadata/ShowTimeSeriesStatement.java | 16 +-
.../metadata/view/AlterLogicalViewStatement.java | 1 +
.../row/ElasticSerializableRowRecordList.java | 1 +
.../tv/ElasticSerializableTVList.java | 1 +
.../schemaengine/metric/SchemaEngineMemMetric.java | 15 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 21 +
.../rescon/ISchemaEngineStatistics.java | 2 +
.../rescon/MemSchemaEngineStatistics.java | 14 +
.../rescon/MemSchemaRegionStatistics.java | 3 +
.../schemaengine/schemaregion/ISchemaRegion.java | 4 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 63 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 60 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 1 +
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 6 +-
.../mtree/impl/mem/mnode/info/MeasurementInfo.java | 3 +
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 1 +
.../mtree/impl/pbtree/flush/Scheduler.java | 1 +
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 1 +
.../impl/pbtree/schemafile/SegmentedPage.java | 1 +
.../schemafile/pagemgr/BTreePageManager.java | 4 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 5 +-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 1 +
.../schemaengine/schemaregion/tag/TagLogFile.java | 203 +-
.../schemaengine/schemaregion/tag/TagManager.java | 162 +-
.../schemaregion/utils/ResourceByPathUtils.java | 88 +-
.../view/visitor/TransformToExpressionVisitor.java | 6 +
.../write/req/view/ICreateLogicalViewPlan.java | 8 +-
.../db/service/DataNodeServerCommandLine.java | 7 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +-
.../org/apache/iotdb/db/service/RPCService.java | 7 +-
.../iotdb/db/service/RegionMigrateService.java | 8 +
.../db/service/metrics/CompactionMetrics.java | 2 +
.../iotdb/db/storageengine/StorageEngine.java | 6 +-
.../db/storageengine/dataregion/DataRegion.java | 446 +-
.../dataregion/IDataRegionForQuery.java | 19 +-
.../dataregion/ILastFlushTimeMap.java | 3 +
.../dataregion/VirtualDataRegion.java | 26 +
.../impl/ReadChunkCompactionPerformer.java | 5 +-
.../execute/task/AbstractCompactionTask.java | 12 +-
.../execute/task/InnerSpaceCompactionTask.java | 3 +
.../task/InsertionCrossSpaceCompactionTask.java | 13 +-
.../compaction/schedule/CompactionTaskManager.java | 6 +-
.../compaction/selector/estimator/FileInfo.java | 1 +
.../compaction/tool/ListTimeRangeImpl.java | 1 +
.../dataregion/memtable/AbstractMemTable.java | 326 +
.../memtable/AlignedWritableMemChunk.java | 4 +
.../dataregion/memtable/DeviceIDFactory.java | 1 +
.../dataregion/memtable/IMemTable.java | 27 +-
.../dataregion/memtable/IWritableMemChunk.java | 4 +-
.../dataregion/memtable/TsFileProcessor.java | 549 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 3 +
.../dataregion/read/IQueryDataSource.java | 12 +-
.../dataregion/read/QueryDataSource.java | 11 +-
.../read/QueryDataSourceForRegionScan.java | 64 +
.../dataregion/read/QueryDataSourceType.java | 10 +-
.../dataregion/read/control/FileReaderManager.java | 2 +
.../dataregion/read/filescan/IChunkHandle.java | 35 +-
.../dataregion/read/filescan/IFileScanHandle.java | 99 +
.../filescan/impl/ClosedFileScanHandleImpl.java | 211 +
.../filescan/impl/DiskAlignedChunkHandleImpl.java | 81 +
.../read/filescan/impl/DiskChunkHandleImpl.java | 137 +
.../filescan/impl/MemAlignedChunkHandleImpl.java | 72 +
.../read/filescan/impl/MemChunkHandleImpl.java | 43 +-
.../filescan/impl/UnclosedFileScanHandleImpl.java | 180 +
.../read/filescan/model/AbstractChunkOffset.java | 39 +-
.../model/AbstractDeviceChunkMetaData.java | 23 +-
.../read/filescan/model/AlignedChunkOffset.java | 52 +
.../model/AlignedDeviceChunkMetaData.java} | 26 +-
.../read/filescan/model/ChunkOffset.java} | 46 +-
.../read/filescan/model/DeviceChunkMetaData.java} | 25 +-
.../read/filescan/model/DeviceStartEndTime.java | 33 +-
.../dataregion/tsfile/TsFileResource.java | 29 +-
.../dataregion/tsfile/TsFileResourceBlockType.java | 1 +
.../generator/SimpleFileVersionController.java | 2 +
.../dataregion/tsfile/timeindex/ITimeIndex.java | 8 +-
.../dataregion/utils/SharedTimeDataBuffer.java | 91 +
.../utils/TsFileDeviceStartEndTimeIterator.java | 52 +
.../dataregion/wal/allocation/ElasticStrategy.java | 1 +
.../wal/allocation/FirstCreateStrategy.java | 1 +
.../wal/allocation/RoundRobinStrategy.java | 1 +
.../dataregion/wal/buffer/WALBuffer.java | 6 +
.../dataregion/wal/buffer/WALEntry.java | 6 +
.../dataregion/wal/buffer/WALEntryType.java | 7 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 1 +
.../wal/checkpoint/CheckpointManager.java | 5 +
.../dataregion/wal/node/IWALNode.java | 4 +
.../dataregion/wal/node/WALFakeNode.java | 6 +
.../storageengine/dataregion/wal/node/WALNode.java | 16 +
.../dataregion/wal/recover/WALNodeRecoverTask.java | 23 +-
.../dataregion/wal/recover/WALRecoverManager.java | 2 +
.../wal/recover/file/TsFilePlanRedoer.java | 25 +
.../file/UnsealedTsFileRecoverPerformer.java | 4 +
.../wal/utils/listener/AbstractResultListener.java | 1 +
.../db/storageengine/rescon/disk/TierManager.java | 5 +
.../db/storageengine/rescon/memory/SystemInfo.java | 34 +
.../rescon/memory/TimePartitionManager.java | 14 +
.../agent/SubscriptionBrokerAgent.java | 4 +-
.../broker/SerializedEnrichedEvent.java | 4 +-
.../db/subscription/broker/SubscriptionBroker.java | 4 +-
.../broker/SubscriptionPrefetchingQueue.java | 6 +-
.../receiver/SubscriptionReceiverV1.java | 39 +-
.../task/stage/SubscriptionTaskConnectorStage.java | 4 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 6 +-
.../SubscriptionConnectorSubtaskLifeCycle.java | 4 +-
.../SubscriptionConnectorSubtaskManager.java | 71 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 4 +-
.../db/tools/schema/SRStatementGenerator.java | 71 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 1 +
.../java/org/apache/iotdb/db/utils/MathUtils.java | 1 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 20 +
.../apache/iotdb/db/utils/ModificationUtils.java | 96 +
.../db/utils/datastructure/AlignedTVList.java | 7 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 3 +-
.../db/utils/datastructure/BooleanTVList.java | 3 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 3 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 3 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 3 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TVList.java | 18 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 3 +-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 55 +
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 1 +
.../connector/PipeDataNodeThriftRequestTest.java | 2 +-
.../PipeStatementPatternParseVisitorTest.java | 161 +
.../PipeConnectorSubtaskExecutorTest.java | 4 +-
.../extractor/IoTDBDataRegionExtractorTest.java | 18 +-
.../extractor/PipePlanPatternParseVisitorTest.java | 428 +
.../db/pipe/pattern/IoTDBPipePatternTest.java | 46 +-
.../db/pipe/pattern/PrefixPipePatternTest.java | 46 +-
.../resource/PipeTsFileResourceManagerTest.java | 16 +-
.../queryengine/execution/exchange/StubSink.java | 8 +
.../AlignedSeriesAggregationScanOperatorTest.java | 3 +-
.../execution/operator/FillOperatorTest.java | 15 +
.../operator/LastQueryMergeOperatorTest.java | 20 +
.../execution/operator/LinearFillOperatorTest.java | 35 +
.../operator/RawDataAggregationOperatorTest.java | 1 +
.../process/join/InnerTimeJoinOperatorTest.java | 60 +
.../join/LeftOuterTimeJoinOperatorTest.java | 30 +
.../schedule/DefaultDriverSchedulerTest.java | 3 +-
.../plan/optimization/AggregationPushDownTest.java | 334 +
.../optimization/ColumnInjectionPushDownTest.java | 214 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 6 +-
.../plan/optimization/OptimizationTestUtil.java | 36 +-
.../plan/optimization/PredicatePushDownTest.java | 6 +-
.../plan/optimization/TestPlanBuilder.java | 48 +-
.../plan/planner/PipelineBuilderTest.java | 572 +
.../distribution/AggregationAlignByDeviceTest.java | 70 +-
.../distribution/AggregationDistributionTest.java | 4 +-
.../AlignByDeviceOrderByLimitOffsetTest.java | 18 +-
.../planner/distribution/AlignedByDeviceTest.java | 435 +-
.../distribution/RegionScanPlanningTest.java | 149 +
.../logical/DataQueryLogicalPlannerTest.java | 394 +-
.../logical/RegionScanLogicalPlannerTest.java | 206 +
.../logical/SchemaQueryLogicalPlannerTest.java | 11 +-
.../node/write/InsertRowsNodeSerdeTest.java | 58 +
.../storageengine/dataregion/DataRegionTest.java | 97 +-
.../iotdb/db/storageengine/dataregion/TTLTest.java | 4 +-
.../compaction/CompactionSchedulerTest.java | 8 +
.../CompactionSchedulerWithFastPerformerTest.java | 8 +
.../TsFileValidationCorrectnessTests.java | 1 +
.../cross/CrossSpaceCompactionSelectorTest.java | 44 +-
...actionWithReadPointPerformerValidationTest.java | 8 +-
.../InsertionCrossSpaceCompactionRecoverTest.java | 82 +
.../cross/RewriteCompactionFileSelectorTest.java | 5 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 22 +-
...nkCompactionPerformerWithAlignedSeriesTest.java | 55 +-
.../settle/SettleRequestHandlerTest.java | 3 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 10 +-
.../dataregion/memtable/TsFileProcessorTest.java | 200 +
.../dataregion/wal/io/WALFileTest.java | 66 +
.../wal/node/ConsensusReqReaderTest.java | 89 +-
.../dataregion/wal/node/WALEntryHandlerTest.java | 271 +-
.../wal/recover/WALRecoverManagerTest.java | 49 +-
.../wal/recover/WALRecoverWriterTest.java | 93 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 5 +-
.../rescon/memory/TimePartitionManagerTest.java | 3 +
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 2 +
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 3 +
.../iotdb/metrics/core/IoTDBMetricManager.java | 1 +
.../metrics/core/reporter/IoTDBJmxReporter.java | 9 +-
.../apache/iotdb/metrics/core/type/IoTDBRate.java | 2 +-
.../core/{uitls => utils}/IoTDBCachedGauge.java | 7 +-
.../{uitls => utils}/IoTDBCachedGaugeMBean.java | 2 +-
.../IoTDBMetricObjNameFactory.java | 2 +-
.../core/{uitls => utils}/IoTDBMovingAverage.java | 2 +-
.../core/{uitls => utils}/ObjectNameFactory.java | 2 +-
.../iotdb/metrics/AbstractMetricManager.java | 3 +
.../iotdb/metrics/AbstractMetricService.java | 5 +
.../apache/iotdb/metrics/config/MetricConfig.java | 11 +
.../reporter/iotdb/IoTDBSessionReporter.java | 1 +
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 4 +
iotdb-core/node-commons/pom.xml | 7 +-
.../resources/conf/iotdb-common.properties | 5 +-
.../assembly/resources/sbin/destroy-confignode.bat | 2 +-
.../assembly/resources/sbin/destroy-datanode.bat | 2 +-
.../src/assembly/resources/sbin/health_check.bat | 38 +-
.../src/assembly/resources/sbin/health_check.sh | 24 +-
.../assembly/resources/sbin/start-standalone.bat | 4 +-
.../assembly/resources/sbin/stop-standalone.bat | 4 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 1 +
.../iotdb/commons/auth/user/BasicUserManager.java | 1 +
.../commons/auth/user/LocalFileUserAccessor.java | 1 +
.../iotdb/commons/client/ClientPoolFactory.java | 2 +-
.../async/AsyncPipeDataTransferServiceClient.java | 13 +-
.../client/property/ThriftClientProperty.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 73 +-
.../iotdb/commons/conf/CommonDescriptor.java | 23 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 4 -
.../commons/consensus/index/ProgressIndex.java | 4 +-
.../index/impl/TimeWindowStateProgressIndex.java | 4 +-
.../iotdb/commons/exception/IoTDBException.java | 1 +
.../commons/executable/ExecutableManager.java | 1 +
.../apache/iotdb/commons/path/AlignedFullPath.java | 11 +
.../org/apache/iotdb/commons/path/AlignedPath.java | 6 +
.../org/apache/iotdb/commons/path/IFullPath.java | 3 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 4 +
.../iotdb/commons/path/NonAlignedFullPath.java | 11 +
.../org/apache/iotdb/commons/path/PartialPath.java | 18 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 5 +-
.../apache/iotdb/commons/path/PatternTreeMap.java | 42 +
.../org/apache/iotdb/commons/path/fa/IFAState.java | 12 +-
.../iotdb/commons/path/fa/IFATransition.java | 4 +-
.../apache/iotdb/commons/path/fa/IPatternFA.java | 12 +-
.../commons/path/fa/match/IStateMatchInfo.java | 28 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 10 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 75 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 30 +-
.../config/constant/PipeConnectorConstant.java | 22 +
.../config/constant/PipeExtractorConstant.java | 6 +
.../config/constant/PipeProcessorConstant.java | 11 +
.../pipe/connector/client/IoTDBClientManager.java | 45 +
.../connector/client/IoTDBSyncClientManager.java | 4 +-
.../pipe/connector/compressor/PipeCompressor.java} | 51 +-
.../compressor/PipeCompressorFactory.java | 80 +
.../connector/compressor/PipeGZIPCompressor.java} | 33 +-
.../connector/compressor/PipeLZ4Compressor.java} | 33 +-
.../connector/compressor/PipeLZMA2Compressor.java} | 33 +-
.../compressor/PipeSnappyCompressor.java} | 33 +-
.../connector/compressor/PipeZSTDCompressor.java} | 33 +-
.../payload/thrift/request/PipeRequestType.java | 3 +
.../thrift/request/PipeTransferCompressedReq.java | 146 +
.../connector/protocol/IoTDBAirGapConnector.java | 9 +-
.../pipe/connector/protocol/IoTDBConnector.java | 62 +
.../connector/protocol/IoTDBSslSyncConnector.java | 8 +-
.../queue/ConcurrentIterableLinkedQueue.java | 20 +-
.../listening/AbstractPipeListeningQueue.java | 11 +-
.../AbstractSerializableListeningQueue.java | 35 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 20 +-
...ritePlanEvent.java => ProgressReportEvent.java} | 71 +-
.../commons/pipe/extractor/IoTDBExtractor.java | 23 +-
.../extractor/IoTDBNonDataRegionExtractor.java | 89 +-
.../pipe/metric/PipeEventCommitMetrics.java | 32 +-
.../commons/pipe/pattern/IoTDBPipePattern.java | 99 +-
.../iotdb/commons/pipe/pattern/PipePattern.java | 17 +-
.../commons/pipe/pattern/PrefixPipePattern.java | 20 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 4 +
.../ChangingValueSamplingProcessor.java | 22 +-
.../pipe/progress/PipeEventCommitManager.java | 58 +-
.../commons/pipe/progress/PipeEventCommitter.java | 29 +-
.../iotdb/commons/pipe/task/meta/PipeMeta.java | 38 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 2 +-
.../commons/pipe/task/meta/PipeTemporaryMeta.java} | 35 +-
.../task/subtask/PipeAbstractConnectorSubtask.java | 4 +-
.../pipe/task/subtask/PipeReportableSubtask.java | 2 +-
.../commons/schema/node/info/IDeviceInfo.java | 8 +-
.../commons/schema/node/role/IDeviceMNode.java | 8 +-
.../schema/view/viewExpression/ViewExpression.java | 4 +-
.../binary/BinaryViewExpression.java | 2 +
.../binary/arithmetic/AdditionViewExpression.java | 1 +
.../arithmetic/ArithmeticBinaryViewExpression.java | 1 +
.../binary/arithmetic/DivisionViewExpression.java | 1 +
.../binary/arithmetic/ModuloViewExpression.java | 1 +
.../arithmetic/MultiplicationViewExpression.java | 1 +
.../arithmetic/SubtractionViewExpression.java | 1 +
.../compare/CompareBinaryViewExpression.java | 1 +
.../binary/logic/LogicBinaryViewExpression.java | 1 +
.../view/viewExpression/leaf/NullViewOperand.java | 4 +-
.../viewExpression/leaf/TimeSeriesViewOperand.java | 2 +
.../viewExpression/leaf/TimestampViewOperand.java | 4 +-
.../multi/FunctionViewExpression.java | 2 +
.../ternary/BetweenViewExpression.java | 2 +
.../ternary/TernaryViewExpression.java | 2 +
.../viewExpression/unary/InViewExpression.java | 2 +
.../viewExpression/unary/IsNullViewExpression.java | 2 +
.../viewExpression/unary/LikeViewExpression.java | 2 +
.../unary/LogicNotViewExpression.java | 1 +
.../unary/NegationViewExpression.java | 1 +
.../unary/RegularViewExpression.java | 2 +
.../viewExpression/unary/UnaryViewExpression.java | 1 +
.../visitor/ViewExpressionVisitor.java | 6 +
.../iotdb/commons/service/StartupChecks.java | 1 +
.../iotdb/commons/service/ThriftService.java | 7 +-
.../iotdb/commons/service/metric/enums/Metric.java | 9 +
.../meta/consumer/ConsumerGroupMeta.java | 4 +-
.../commons/subscription/meta/topic/TopicMeta.java | 4 +-
.../iotdb/commons/trigger/TriggerInformation.java | 2 +
.../apache/iotdb/commons/trigger/TriggerTable.java | 1 +
.../udf/builtin/BuiltinAggregationFunction.java | 8 +-
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 2 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 1 +
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 1 +
.../apache/iotdb/commons/path/PartialPathTest.java | 8 +
.../ConcurrentIterableLinkedQueueTest.java | 84 +-
.../src/main/thrift/datanode.thrift | 2 +
.../iotdb/library/anomaly/util/MissDetector.java | 56 +-
.../library/anomaly/util/StreamMissDetector.java | 4 +-
.../iotdb/library/anomaly/util/WindowDetect.java | 8 +-
.../library/dquality/util/TimeSeriesQuality.java | 8 +-
.../iotdb/library/frequency/util/DWTUtil.java | 2 +
pom.xml | 51 +-
1009 files changed, 22780 insertions(+), 43169 deletions(-)
delete mode 100644 .github/workflows/grafana-plugin.yml
delete mode 100644 distribution/src/assembly/flink-sql-connector.xml
delete mode 100644 distribution/src/assembly/grafana-connector.xml
delete mode 100644 distribution/src/assembly/grafana-plugin.xml
delete mode 100644 distribution/src/assembly/spark-connector.xml
delete mode 100644
docker/src/main/DockerCompose/GrafanaPlugin/Dockerfile-0.14.0-iotdb
delete mode 100644
docker/src/main/DockerCompose/GrafanaPlugin/docker-compose.yml
delete mode 100644 docker/src/main/DockerCompose/docker-compose-grafana.yml
delete mode 100644 docker/src/main/Dockerfile-0.12.6-grafana
delete mode 100644 docker/src/main/Dockerfile-0.13.3-grafana-connector
delete mode 100644 example/flink-sql/pom.xml
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/BatchSinkExample.java
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/BoundedScanExample.java
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/CDCExample.java
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/LookupExample.java
delete mode 100644
example/flink-sql/src/main/java/org/apache/iotdb/example/StreamingSinkExample.java
delete mode 100644 example/flink/README.md
delete mode 100644 example/flink/pom.xml
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSource.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/TsFileUtils.java
delete mode 100644 example/hadoop/pom.xml
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/Constant.java
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TsFileHelper.java
delete mode 100644
example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TsFileWriteToHDFS.java
delete mode 100644 example/kafka/pom.xml
delete mode 100644 example/kafka/readme.md
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/Constant.java
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/Consumer.java
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/ConsumerThread.java
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/Producer.java
create mode 100644 example/odbc/.gitignore
create mode 100644 example/odbc/ODBC-Example.sln
create mode 100644 example/odbc/ODBC-Example/ODBC-Example.csproj
create mode 100644 example/odbc/ODBC-Example/ODBC_Example.cs
create mode 100644 example/odbc/README.md
delete mode 100644 example/pulsar/pom.xml
delete mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/Constant.java
delete mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumer.java
delete mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumerThread.java
delete mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarProducer.java
delete mode 100644 example/rabbitmq/pom.xml
delete mode 100644 example/rabbitmq/readme.md
delete mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/Constant.java
delete mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQChannelUtils.java
delete mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQConsumer.java
delete mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQProducer.java
delete mode 100644 example/rocketmq/pom.xml
delete mode 100644 example/rocketmq/readme.md
delete mode 100644
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Constant.java
delete mode 100644
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQConsumer.java
delete mode 100644
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQProducer.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBTagLimitIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/flink/it/AbstractTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/flink/it/SinkTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/flink/it/SourceTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/flink/it/Utils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeAutoDropIT.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/{IoTDBPipeProcessorIT.java
=> IoTDBPipeConnectorCompressionIT.java} (54%)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/spark/it/AbstractTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/spark/it/ReadTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/spark/it/Utils.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/spark/it/WriteTest.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/zeppelin/it/IoTDBInterpreterIT.java
rename iotdb-connector/hive-connector/src/test/resources/logback.xml =>
iotdb-client/cli/src/assembly/resources/conf/logback-backup.xml (56%)
mode change 100755 => 100644
iotdb-client/cli/src/assembly/resources/tools/backup.sh
rename
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/QueryEndPointPolicy.java
(80%)
rename
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/DatabaseConnectService.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/RoundRobinPolicy.java
(68%)
delete mode 100644 iotdb-connector/flink-iotdb-connector/README.md
delete mode 100644 iotdb-connector/flink-iotdb-connector/pom.xml
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/Event.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBOptions.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSourceOptions.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java
delete mode 100644
iotdb-connector/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkInsertTest.java
delete mode 100644 iotdb-connector/flink-sql-iotdb-connector/pom.xml
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/client/IoTDBWebSocketClient.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Options.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Utils.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalIoTDBPathException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalSchemaException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalUrlPathException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/UnsupportedDataTypeException.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/factory/IoTDBDynamicTableFactory.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBBoundedScanFunction.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBCDCSourceFunction.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBLookupFunction.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBSinkFunction.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSink.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSource.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/TabletWrapper.java
delete mode 100644
iotdb-connector/flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 iotdb-connector/flink-tsfile-connector/README.md
delete mode 100644 iotdb-connector/flink-tsfile-connector/pom.xml
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRecordParser.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowRowRecordParser.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordConverter.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TSRecordOutputFormat.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/TsFileOutputFormat.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/util/TSFileConfigUtil.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatIntegrationTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileConnectorTestBase.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatIntegrationTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTestBase.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileOutputFormatTestBase.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TSFileConfigUtilCompletenessTest.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/util/TsFileWriteUtil.java
delete mode 100644
iotdb-connector/flink-tsfile-connector/src/test/resources/log4j.properties
delete mode 100644 iotdb-connector/grafana-connector/img/add_data_source.png
delete mode 100644 iotdb-connector/grafana-connector/img/add_graph.png
delete mode 100644 iotdb-connector/grafana-connector/img/edit_data_source.png
delete mode 100644 iotdb-connector/grafana-connector/pom.xml
delete mode 100644 iotdb-connector/grafana-connector/readme.md
delete mode 100644 iotdb-connector/grafana-connector/readme_zh.md
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/conf/MyConfiguration.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/interceptor/LoginInterceptor.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java
delete mode 100644
iotdb-connector/grafana-connector/src/main/resources/application.properties
delete mode 100644
iotdb-connector/grafana-connector/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java
delete mode 100644 iotdb-connector/grafana-plugin/.gitignore
delete mode 100644 iotdb-connector/grafana-plugin/.prettierrc.js
delete mode 100644 iotdb-connector/grafana-plugin/CHANGELOG.md
delete mode 100644 iotdb-connector/grafana-plugin/LICENSE
delete mode 100644 iotdb-connector/grafana-plugin/Magefile.go
delete mode 100644 iotdb-connector/grafana-plugin/README.md
delete mode 100644 iotdb-connector/grafana-plugin/backend-compile.bat
delete mode 100755 iotdb-connector/grafana-plugin/backend-compile.sh
delete mode 100644 iotdb-connector/grafana-plugin/go.mod
delete mode 100644 iotdb-connector/grafana-plugin/jest.config.js
delete mode 100644 iotdb-connector/grafana-plugin/package.json
delete mode 100644 iotdb-connector/grafana-plugin/pkg/main.go
delete mode 100644
iotdb-connector/grafana-plugin/pkg/plugin/iotdb_resource_handler.go
delete mode 100644 iotdb-connector/grafana-plugin/pkg/plugin/plugin.go
delete mode 100644 iotdb-connector/grafana-plugin/pom.xml
delete mode 100644 iotdb-connector/grafana-plugin/src/ConfigEditor.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/QueryEditor.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/AggregateFun.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/ControlValue.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/componments/FillValue.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/componments/Form.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/componments/FromValue.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/componments/GroupBy.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/SelectValue.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/TimeSeries.tsx
delete mode 100644
iotdb-connector/grafana-plugin/src/componments/WhereValue.tsx
delete mode 100644 iotdb-connector/grafana-plugin/src/datasource.ts
delete mode 100644 iotdb-connector/grafana-plugin/src/functions.ts
delete mode 100644
iotdb-connector/grafana-plugin/src/img/addIoTDBDataSource.png
delete mode 100644 iotdb-connector/grafana-plugin/src/img/logo.svg
delete mode 100644 iotdb-connector/grafana-plugin/src/img/showData.png
delete mode 100644 iotdb-connector/grafana-plugin/src/module.ts
delete mode 100644 iotdb-connector/grafana-plugin/src/plugin.json
delete mode 100644 iotdb-connector/grafana-plugin/src/types.ts
delete mode 100644 iotdb-connector/grafana-plugin/tsconfig.json
delete mode 100644 iotdb-connector/grafana-plugin/yarn.lock
delete mode 100644 iotdb-connector/hadoop/README.md
delete mode 100644 iotdb-connector/hadoop/pom.xml
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSConfUtil.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSFile.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSInput.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSOutput.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopException.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplit.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFOutputFormat.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java
delete mode 100644
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/record/HDFSTSRecord.java
delete mode 100644
iotdb-connector/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopTest.java
delete mode 100644
iotdb-connector/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplitTest.java
delete mode 100644
iotdb-connector/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TsFileTestHelper.java
delete mode 100644
iotdb-connector/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/constant/TestConstant.java
delete mode 100644 iotdb-connector/hadoop/src/test/resources/logback.xml
delete mode 100644 iotdb-connector/hive-connector/pom.xml
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveInputFormat.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveOutputFormat.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordReader.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordWriter.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileDeserializer.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDe.java
delete mode 100644
iotdb-connector/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDeException.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TSFHiveInputFormatTest.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TSFHiveRecordReaderTest.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TsFileDeserializerTest.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TsFileSerDeTest.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/TsFileTestHelper.java
delete mode 100644
iotdb-connector/hive-connector/src/test/java/org/apache/iotdb/hive/constant/TestConstant.java
delete mode 100644 iotdb-connector/pom.xml
delete mode 100644 iotdb-connector/spark-iotdb-connector/pom.xml
delete mode 100644 iotdb-connector/spark-iotdb-connector/scala_2.11/pom.xml
delete mode 100644 iotdb-connector/spark-iotdb-connector/scala_2.12/pom.xml
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/Converter.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/DataFrameTools.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/DefaultSource.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBOptions.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBRDD.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/IoTDBRelation.scala
delete mode 100644
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/Transformer.scala
delete mode 100644 iotdb-connector/spark-tsfile/pom.xml
delete mode 100644
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/io/TsFileRecordWriter.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/Executor.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/QueryProcessor.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/BasicOperator.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/FilterOperator.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/SQLConstant.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/SingleQuery.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/TSQueryPlan.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/BasicOperatorException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/DNFOptimizeException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/LogicalOptimizeException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/MergeFilterException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/QueryOperatorException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/QueryProcessorException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/exception/RemoveNotException.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/DNFFilterOptimizer.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/IFilterOptimizer.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/MergeSingleFilterOptimizer.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/PhysicalOptimizer.java
delete mode 100755
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/RemoveNotOptimizer.java
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/Converter.scala
delete mode 100755
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/DefaultSource.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/NarrowConverter.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/NarrowTsFileOutputWriter.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/Transformer.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/TsFileWriterFactory.scala
delete mode 100755
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/WideConverter.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/WideTsFileOutputWriter.scala
delete mode 100755
iotdb-connector/spark-tsfile/src/main/scala/org/apache/iotdb/spark/tsfile/package.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tool/TsFileExample.java
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tool/TsFileWriteTool.java
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tsfile/ConverterTest.scala
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tsfile/HDFSInputTest.java
delete mode 100644
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/tsfile/TSFileSuit.scala
delete mode 100644
iotdb-connector/zeppelin-interpreter/IoTDB-Zeppelin-Demo.zpln
delete mode 100644 iotdb-connector/zeppelin-interpreter/pom.xml
delete mode 100644
iotdb-connector/zeppelin-interpreter/src/main/java/org/apache/zeppelin/iotdb/IoTDBInterpreter.java
delete mode 100644
iotdb-connector/zeppelin-interpreter/src/main/resources/interpreter-setting.json
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeSetTTLPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeat.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/{
=> heartbeat}/PipeHeartbeatParser.java (88%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/{
=> heartbeat}/PipeHeartbeatScheduler.java (90%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeListenerMetrics.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeRemainingTimeMetrics.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeRemainingTimeOperator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigRegionConnectorMetrics.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigRegionExtractorMetrics.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/FakeSubscriber.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/LoadManagerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanPatternParseVisitorTest.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/IoTDBThriftSyncPipeTransferBatchReqBuilder.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/builder/{PipeTransferBatchReqBuilder.java
=> PipeEventBatch.java} (76%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/LeaderCacheUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/terminate/PipeTerminateEvent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/schemaregion/PipePlanPatternParseVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeRemainingEventAndTimeOperator.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{PipeConnectorMetrics.java
=> PipeDataRegionConnectorMetrics.java} (77%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{PipeExtractorMetrics.java
=> PipeDataRegionExtractorMetrics.java} (72%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeSchemaRegionConnectorMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeSchemaRegionExtractorMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeSchemaRegionListenerMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/changing/ChangingValueFilter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/changing/ChangingValueSamplingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementPatternParseVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeRealtimePriorityBlockingQueue.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/TimeseriesSchemaInfo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/MemoryEstimationHelper.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileRateLimiter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/AggregationPushDown.java
rename
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/ConsumeAllChildrenPipelineMemoryEstimator.java
(57%)
mode change 100755 => 100644
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/ConsumeChildrenOneByOnePipelineMemoryEstimator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/PipelineMemoryEstimator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/PipelineMemoryEstimatorFactory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/RawDataAggregationNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/RegionMergeNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/DeviceRegionScanNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/RegionScanNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/TimeseriesRegionScanNode.java
rename
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/SQLConstant.scala
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/IQueryDataSource.java
(83%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/QueryDataSourceForRegionScan.java
rename
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalOptionException.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/QueryDataSourceType.java
(82%)
rename
iotdb-connector/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/package.scala
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/IChunkHandle.java
(52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/IFileScanHandle.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/impl/ClosedFileScanHandleImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/impl/DiskAlignedChunkHandleImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/impl/DiskChunkHandleImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/impl/MemAlignedChunkHandleImpl.java
rename
iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/io/TsFileOutputFormat.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/impl/MemChunkHandleImpl.java
(50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/impl/UnclosedFileScanHandleImpl.java
rename
iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/SchemaWrapper.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/model/AbstractChunkOffset.java
(53%)
rename example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Utils.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/model/AbstractDeviceChunkMetaData.java
(66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/model/AlignedChunkOffset.java
copy
iotdb-core/{metrics/core/src/main/java/org/apache/iotdb/metrics/core/uitls/IoTDBCachedGaugeMBean.java
=>
datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/model/AlignedDeviceChunkMetaData.java}
(52%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/path/IFullPath.java
=>
datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/model/ChunkOffset.java}
(50%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/connector/payload/evolvable/builder/IoTDBThriftAsyncPipeTransferBatchReqBuilder.java
=> storageengine/dataregion/read/filescan/model/DeviceChunkMetaData.java} (55%)
rename
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/model/DeviceStartEndTime.java
(58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/SharedTimeDataBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/TsFileDeviceStartEndTimeIterator.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/connector/PipeStatementPatternParseVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/extractor/PipePlanPatternParseVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/optimization/AggregationPushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/RegionScanPlanningTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/logical/RegionScanLogicalPlannerTest.java
rename
iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/{uitls =>
utils}/IoTDBCachedGauge.java (98%)
rename
iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/{uitls =>
utils}/IoTDBCachedGaugeMBean.java (95%)
rename
iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/{uitls =>
utils}/IoTDBMetricObjNameFactory.java (98%)
rename
iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/{uitls =>
utils}/IoTDBMovingAverage.java (98%)
rename
iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/{uitls =>
utils}/ObjectNameFactory.java (96%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResourceBlockType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeCompressor.java}
(50%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeCompressorFactory.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/AbstractDataSourceOperator.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeGZIPCompressor.java}
(51%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/AbstractDataSourceOperator.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeLZ4Compressor.java}
(51%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/AbstractDataSourceOperator.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeLZMA2Compressor.java}
(51%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/AbstractDataSourceOperator.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeSnappyCompressor.java}
(51%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/AbstractDataSourceOperator.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeZSTDCompressor.java}
(51%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/thrift/request/PipeTransferCompressedReq.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/event/{PipeWritePlanEvent.java
=> ProgressReportEvent.java} (51%)
rename
iotdb-connector/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/IReaderSet.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/downsampling/ChangingValueSamplingProcessor.java
(58%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupStatistics.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeTemporaryMeta.java}
(53%)
