This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch feature/leader-write
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9a4bca0725a remove consensus point calculate
add a8411f66837 Fix Concurrency Instability When IoTConsensus
LogDispatcher Exits (#12411)
add 544a3bccbb9 update Export/ImportDataTestIT (#12399)
add 1d30805f266 Pipe: Added check for wal disable and ratis consensus when
enabling data region processing (#12407)
add 447bf54a356 revert -XX:GuaranteedSafepointInterval=0 option (#12417)
add 95384d4a9eb Randomly choosing coordinator of add region (#12416)
add d23729f876a [RatisConsensus] update ratis snapshot version (#12419)
add 98b2272dbc1 Pipe: Reduce exception messages to avoid excess rpc
payload and show pipe response (#12415)
add 52bc1889d53 Copy tsfile, its resources, and mods to the same directory
when using multiple data directories (#12420)
add d866bc5dbaf fix snapshot parser null point.
add 1b981972bd7 Pipe: Support InsertRows in
PipeInsertNodeTabletInsertionEvent (#12286)
add 3d87ecc1346 Refactor MultiTsFileDeviceIterator.MeasurementIterator
(#12221)
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 3968c40419a Merge branch 'master' into feature/leader-write
No new revisions were added by this update.
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 | 139 -
.../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 -
.../main/java/org/apache/iotdb/rocketmq/Utils.java | 39 -
.../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/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 | 52 +-
.../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 +
.../apache/iotdb/tools/it/ExportDataTestIT.java | 6 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 4 +-
.../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 +-
.../org/apache/iotdb/tool/AbstractDataTool.java | 1 +
.../java/org/apache/iotdb/tool/ExportData.java | 21 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 4 +-
.../java/org/apache/iotdb/tool/ImportData.java | 74 +-
.../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 | 22 +-
.../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/IllegalOptionException.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/SchemaWrapper.java | 46 -
.../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 | 166 -
.../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 | 121 -
.../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 | 126 -
.../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/SQLConstant.scala | 27 -
.../org/apache/iotdb/spark/db/Transformer.scala | 172 -
.../scala/org/apache/iotdb/spark/db/package.scala | 36 -
iotdb-connector/spark-tsfile/pom.xml | 114 -
.../iotdb/spark/tsfile/io/TsFileOutputFormat.java | 45 -
.../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/Operator.java | 44 -
.../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 | 251 -
.../tsfile/qp/optimizer/RemoveNotOptimizer.java | 92 -
.../org/apache/iotdb/spark/tsfile/Converter.scala | 144 -
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 293 -
.../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 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/ConfigPhysicalPlanVisitor.java | 6 +
.../consensus/request/auth/AuthorPlan.java | 24 +-
.../pipe/payload/PipeDeleteLogicalViewPlan.java | 11 +-
.../pipe/payload/PipeDeleteTimeSeriesPlan.java | 11 +-
.../request/write/pipe/payload/PipeSetTTLPlan.java | 103 +
.../response/pipe/task/PipeTableResp.java | 8 +-
.../iotdb/confignode/manager/ConfigManager.java | 39 +-
.../confignode/manager/PermissionManager.java | 3 +-
.../iotdb/confignode/manager/ProcedureManager.java | 35 +-
.../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 +
.../receiver/IoTDBConfigNodeReceiverAgent.java | 6 +-
.../payload/PipeTransferConfigSnapshotSealReq.java | 33 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 34 +-
.../protocol/IoTDBConfigRegionConnector.java | 22 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 54 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 46 +-
.../pipe/execution/PipeConfigNodeSubtask.java | 122 +-
.../execution/PipeConfigNodeSubtaskExecutor.java | 4 +-
.../extractor/ConfigRegionListeningFilter.java | 13 +-
.../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 | 46 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 62 +-
.../manager/schema/ClusterSchemaManager.java | 36 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 10 +-
.../persistence/executor/ConfigPlanExecutor.java | 12 +-
.../confignode/persistence/node/NodeInfo.java | 31 +-
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/PartitionInfo.java | 1 +
.../persistence/partition/RegionGroup.java | 4 +-
.../schema/CNPhysicalPlanGenerator.java | 9 +-
.../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 | 17 +-
.../impl/node/AddConfigNodeProcedure.java | 2 +-
.../impl/pipe/task/AlterPipeProcedureV2.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 +
.../persistence/CNPhysicalPlanGeneratorTest.java | 3 +
.../org/apache/iotdb/consensus/IConsensus.java | 11 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 17 +-
.../consensus/iot/IoTConsensusServerImpl.java | 39 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 11 +-
.../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 | 49 +-
iotdb-core/datanode/pom.xml | 4 +
.../src/assembly/resources/conf/datanode-env.bat | 14 +-
.../src/assembly/resources/conf/datanode-env.sh | 3 -
.../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 | 35 +-
.../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 +-
.../metadata/DataTypeMismatchException.java | 7 +-
.../PipeDataRegionProcessorConstructor.java | 4 +
.../runtime/PipeSchemaRegionListenerManager.java | 44 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 137 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 14 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 2 +-
.../client/IoTDBDataNodeSyncClientManager.java | 9 +
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 36 -
...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 | 59 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 12 +-
.../airgap/IoTDBDataRegionAirGapConnector.java | 33 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 22 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 14 +-
.../connector/protocol/opcua/OpcUaConnector.java | 4 +-
.../async/IoTDBDataRegionAsyncConnector.java | 210 +-
.../PipeTransferTabletBatchEventHandler.java | 24 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 3 +-
.../PipeTransferTsFileInsertionEventHandler.java | 55 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 5 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 93 +-
.../thrift/sync/IoTDBSchemaRegionConnector.java | 17 +-
.../protocol/websocket/WebSocketConnector.java | 17 +-
.../websocket/WebSocketConnectorServer.java | 5 +-
.../db/pipe/connector/util/LeaderCacheUtils.java | 69 +
.../event/common/heartbeat/PipeHeartbeatEvent.java | 34 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 4 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 11 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 44 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 132 +-
.../tablet/TabletInsertionDataContainer.java | 47 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 13 +-
.../tsfile/TsFileInsertionDataContainer.java | 32 +-
.../common/tsfile/TsFileInsertionPointCounter.java | 10 +-
.../dataregion/DataRegionWatermarkInjector.java | 2 +-
.../dataregion/IoTDBDataRegionExtractor.java | 98 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 38 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 74 +-
.../dataregion/realtime/epoch/TsFileEpoch.java | 4 +-
.../realtime/epoch/TsFileEpochManager.java | 23 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 34 +-
.../schemaregion/PipePlanPatternParseVisitor.java | 282 +
.../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 +-
.../processor/aggregate/AggregateProcessor.java | 2 +-
.../downsampling/changing/ChangingValueFilter.java | 95 +
.../changing/ChangingValueSamplingProcessor.java | 199 +
.../sdt/SwingingDoorTrendingFilter.java | 5 +-
.../exchange/sender/TwoStageAggregateSender.java | 2 +-
.../twostage/plugin/TwoStageCountProcessor.java | 3 +
.../protocol/airgap/IoTDBAirGapReceiver.java | 13 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 80 +-
.../visitor/PipePlanToStatementVisitor.java | 105 +-
.../visitor/PipeStatementPatternParseVisitor.java | 136 +
.../visitor/PipeStatementTSStatusVisitor.java | 12 +
.../pipe/resource/tsfile/PipeTsFileResource.java | 33 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 35 +-
.../pipe/task/connection/PipeEventCollector.java | 132 +-
.../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 | 89 +-
.../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 +-
.../queryengine/common/TimeseriesSchemaInfo.java | 123 +
.../common/header/ColumnHeaderConstant.java | 12 +
.../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/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 | 3 +
.../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 +
.../AlignedSeriesAggregationScanOperator.java | 16 +
.../operator/source/AlignedSeriesScanOperator.java | 13 +
.../operator/source/ExchangeOperator.java | 13 +
.../operator/source/LastCacheScanOperator.java | 12 +
.../source/SeriesAggregationScanOperator.java | 16 +
.../operator/source/SeriesScanOperator.java | 13 +
.../execution/operator/source/SeriesScanUtil.java | 19 +-
.../operator/source/ShowQueriesOperator.java | 12 +
.../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 | 384 +-
.../plan/planner/LogicalPlanVisitor.java | 238 +-
.../queryengine/plan/planner/LogicalPlanner.java | 6 +-
.../plan/planner/OperatorTreeGenerator.java | 326 +-
.../plan/planner/TemplatedLogicalPlanBuilder.java | 5 +-
.../distribution/DistributionPlanContext.java | 4 +
.../planner/distribution/ExchangeNodeAdder.java | 18 +
.../plan/planner/distribution/SourceRewriter.java | 70 +-
.../ConsumeAllChildrenPipelineMemoryEstimator.java | 33 +-
...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 | 23 +-
.../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 | 336 +
.../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 | 94 +-
.../planner/plan/node/write/InsertTabletNode.java | 1 +
.../planner/plan/parameter/SeriesScanOptions.java | 4 +-
.../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 | 2 +
.../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 | 238 +-
.../dataregion/ILastFlushTimeMap.java | 3 +
.../impl/ReadChunkCompactionPerformer.java | 17 +-
.../execute/task/AbstractCompactionTask.java | 12 +-
.../execute/task/InnerSpaceCompactionTask.java | 3 +
.../task/InsertionCrossSpaceCompactionTask.java | 13 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 146 +-
.../compaction/schedule/CompactionTaskManager.java | 6 +-
.../compaction/selector/estimator/FileInfo.java | 1 +
.../compaction/tool/ListTimeRangeImpl.java | 1 +
.../dataregion/memtable/AbstractMemTable.java | 6 +
.../dataregion/memtable/DeviceIDFactory.java | 1 +
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 4 +-
.../dataregion/memtable/TsFileProcessor.java | 233 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 3 +
.../dataregion/read/control/FileReaderManager.java | 2 +
.../dataregion/snapshot/SnapshotLoader.java | 12 +-
.../dataregion/tsfile/TsFileResource.java | 29 +-
.../dataregion/tsfile/TsFileResourceBlockType.java | 1 +
.../generator/SimpleFileVersionController.java | 2 +
.../dataregion/tsfile/timeindex/ITimeIndex.java | 8 +-
.../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 | 34 +-
.../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 | 84 +-
.../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/metadata/MetaUtilsTest.java | 3 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 1 +
.../connector/PipeDataNodeThriftRequestTest.java | 2 +-
.../PipeStatementPatternParseVisitorTest.java | 161 +
.../PipeConnectorSubtaskExecutorTest.java | 4 +-
.../extractor/IoTDBDataRegionExtractorTest.java | 48 +-
.../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 | 101 +-
.../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 | 80 +-
.../dataregion/memtable/TsFileProcessorTest.java | 200 +
.../dataregion/wal/WALManagerTest.java | 5 +
.../dataregion/wal/io/WALFileTest.java | 66 +
.../wal/node/ConsensusReqReaderTest.java | 89 +-
.../dataregion/wal/node/WALEntryHandlerTest.java | 271 +-
.../dataregion/wal/node/WALNodeTest.java | 5 +
.../wal/node/WalDeleteOutdatedNewTest.java | 5 +
.../wal/recover/WALRecoverManagerTest.java | 52 +-
.../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 +-
.../src/assembly/resources/sbin/start-all.sh | 2 +-
.../assembly/resources/sbin/start-standalone.bat | 4 +-
.../src/assembly/resources/sbin/stop-all.sh | 2 +-
.../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 +
.../org/apache/iotdb/commons/path/AlignedPath.java | 6 +
.../apache/iotdb/commons/path/MeasurementPath.java | 4 +
.../org/apache/iotdb/commons/path/PartialPath.java | 18 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 5 +-
.../apache/iotdb/commons/path/PatternTreeMap.java | 1 +
.../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/PipeProcessorConstant.java | 11 +
.../pipe/connector/client/IoTDBClientManager.java | 45 +
.../connector/client/IoTDBSyncClientManager.java | 4 +-
.../pipe/connector/compressor/PipeCompressor.java} | 39 +-
.../compressor/PipeCompressorFactory.java | 80 +
.../connector/compressor/PipeGZIPCompressor.java | 47 +
.../connector/compressor/PipeLZ4Compressor.java | 47 +
.../connector/compressor/PipeLZMA2Compressor.java | 47 +
.../connector/compressor/PipeSnappyCompressor.java | 47 +
.../connector/compressor/PipeZSTDCompressor.java | 47 +
.../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 +-
.../AbstractSerializableListeningQueue.java | 10 +
.../commons/pipe/event/PipeSnapshotEvent.java | 19 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 55 +-
...SnapshotEvent.java => ProgressReportEvent.java} | 68 +-
.../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 +-
.../commons/pipe/task/meta/PipeStaticMeta.java | 29 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 30 +-
.../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 +-
.../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 | 53 +-
979 files changed, 20588 insertions(+), 43217 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
delete mode 100644
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Utils.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
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/IllegalOptionException.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/SchemaWrapper.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/SQLConstant.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-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/package.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/TsFileOutputFormat.java
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/Operator.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/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/IoTDBThriftAsyncPipeTransferBatchReqBuilder.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/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/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/ConsumeAllChildrenPipelineMemoryEstimator.java
(57%)
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
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%)
copy
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%)
rename
iotdb-core/{metrics/core/src/main/java/org/apache/iotdb/metrics/core/uitls/IoTDBCachedGaugeMBean.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
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeGZIPCompressor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeLZ4Compressor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeLZMA2Compressor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeSnappyCompressor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeZSTDCompressor.java
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/{PipeSnapshotEvent.java
=> ProgressReportEvent.java} (52%)
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%)
