This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/AggregationPushDown
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 398649e7dce fix all IT
add 9acb400337b fix
add 74eb4e2e392 Pipe: Fixed the bug that pure data transfer is forbidden
when SchemaRegion is in Simple consensus (#12397)
add 638be8ae212 Pipe: Added batch to schema snapshot execution in template
activation and timeseries creation & Fixed the bug that the
"CreateMultiTimeSeries" group with alias is not idempotent (#12380)
add bd22fe65461 Pipe: distinguish between old and new process subtasks
before and after stuck restart to avoid unexpected hashmap override and removal
(#12400)
add c36f7144be7 Fixed concurrency issues with RegionMigration thread pool
(#12403)
add 4d7362659d6 Fixed insertTablet http api lost data event return
SUCCESS_STATUS (#12387)
add ed6f56b25ab Fix partition cache after region migration (#12404)
add e1e0055c940 Fix IoTDBTimezoneIT
add c911c406bd1 Pipe: Fixed FileNotFoundException caused by processing
files deleted by compaction & Changed the "isEmpty()" judgement to avoid
"getDevice()" attempts to read from a deleted file when using fileTimeIndex
(#12405)
add 719834aea89 Pipe: refine procedure timeout message (#12402)
add f5cf782df5b Pipe: Two stage aggregate framework &
count-point-processor plugin (#12328)
add 03064328b43 Change log level and opt error msg for source path of view
is deleted (#12409)
add e715db52084 Pipe: remove unnecessary fsync operations for file pieces'
transferring (#12410)
add c232ee02239 fix pipe snapshot parser
add 8064ac58aa3 Pipe: Properly handle OUT_OF_TTL status code on receiver
side when data syncing (#12414)
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 7a1a9834621 Merge remote-tracking branch 'origin/master' into
lmh/AggregationPushDown
No new revisions were added by this update.
Summary of changes:
.git-blame-ignore-revs | 1 +
.github/workflows/grafana-plugin.yml | 68 -
.gitignore | 7 -
codecov.yml | 1 -
distribution/pom.xml | 133 -
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/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 +
.../it/env/cluster/config/MppCommonConfig.java | 18 +
.../env/cluster/config/MppSharedCommonConfig.java | 21 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 1 +
.../it/env/remote/config/RemoteCommonConfig.java | 15 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../iotdb/itbase/runtime/ClusterTestStatement.java | 38 +-
.../IoTDBRegionMigrateReliabilityITFramework.java | 8 +-
.../org/apache/iotdb/db/it/IoTDBTimeZoneIT.java | 2 +-
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 4 +-
.../db/it/aggregation/minby/IoTDBMinByIT.java | 4 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 1 +
.../apache/iotdb/db/it/schema/IoTDBTagLimitIT.java | 196 +
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 4 +-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 6 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 4 +-
.../main/java/org/apache/iotdb/udf/api/State.java | 3 +-
.../main/java/org/apache/iotdb/udf/api/UDAF.java | 3 +-
.../cli/src/assembly/resources/sbin/start-cli.bat | 2 +-
.../cli/src/assembly/resources/tools/backup.bat | 125 -
.../cli/src/assembly/resources/tools/backup.sh | 134 -
.../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 +-
.../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 | 1 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 33 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 12 +-
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 -
.../apache/iotdb/web/grafana/bean/TimeValues.java | 47 -
.../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 -
.../grafana/service/DatabaseConnectService.java | 33 -
.../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 -
.../org/apache/iotdb/hadoop/tsfile/IReaderSet.java | 38 -
.../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 -
.../hive-connector/src/test/resources/logback.xml | 39 -
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 -
.../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 | 1 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/ConfigPhysicalPlanVisitor.java | 6 +
.../consensus/request/auth/AuthorPlan.java | 3 +
.../response/pipe/task/PipeTableResp.java | 8 +-
.../confignode/manager/PermissionManager.java | 3 +-
.../iotdb/confignode/manager/ProcedureManager.java | 78 +-
.../manager/consensus/ConsensusManager.java | 13 +-
.../manager/load/balancer/RouteBalancer.java | 14 +-
.../router/leader/MinCostFlowLeaderBalancer.java | 5 +-
.../confignode/manager/load/cache/LoadCache.java | 4 +-
.../manager/load/cache/node/BaseNodeCache.java | 8 +-
.../manager/partition/PartitionManager.java | 1 +
.../receiver/IoTDBConfigNodeReceiverAgent.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 5 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 53 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 46 +-
.../pipe/execution/PipeConfigNodeSubtask.java | 1 +
.../execution/PipeConfigNodeSubtaskExecutor.java | 4 +-
.../extractor/ConfigRegionListeningFilter.java | 5 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 13 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 1 +
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 9 +
.../iotdb/confignode/persistence/AuthorInfo.java | 3 +
.../persistence/executor/ConfigPlanExecutor.java | 4 +-
.../confignode/persistence/node/NodeInfo.java | 24 +-
.../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/RegionMaintainHandler.java | 10 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 2 +-
.../impl/region/AddRegionPeerProcedure.java | 1 +
.../impl/region/RemoveRegionPeerProcedure.java | 8 +-
.../procedure/scheduler/ProcedureScheduler.java | 4 +-
.../confignode/persistence/AuthorInfoTest.java | 21 +
.../persistence/CNPhysicalPlanGeneratorTest.java | 3 +
.../org/apache/iotdb/consensus/IConsensus.java | 8 +
.../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 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 5 +
.../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 +-
.../src/assembly/resources/conf/datanode-env.bat | 14 +-
.../src/assembly/resources/conf/datanode-env.sh | 3 -
.../assembly/resources/conf/logback-datanode.xml | 15 -
.../assembly/resources/sbin/remove-datanode.bat | 2 +-
.../src/assembly/resources/sbin/start-datanode.bat | 40 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 1 +
.../db/consensus/DataRegionConsensusImpl.java | 257 +-
.../metadata/DataTypeMismatchException.java | 7 +-
.../metadata/view/BrokenViewException.java | 13 +-
.../PipeDataRegionProcessorConstructor.java | 3 +
.../agent/receiver/PipeDataNodeReceiverAgent.java | 5 -
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 17 +-
.../request/PipeTransferTabletInsertNodeReq.java | 46 +-
.../airgap/IoTDBDataRegionAirGapConnector.java | 9 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 5 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 14 +-
.../connector/protocol/opcua/OpcUaConnector.java | 4 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 10 +-
.../protocol/websocket/WebSocketConnector.java | 17 +-
.../websocket/WebSocketConnectorServer.java | 5 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 4 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 64 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 44 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 122 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 5 +
.../tablet/TabletInsertionDataContainer.java | 15 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 34 +
.../tsfile/TsFileInsertionDataContainer.java | 4 +-
.../common/tsfile/TsFileInsertionPointCounter.java | 169 +
.../common/watermark/PipeWatermarkEvent.java} | 21 +-
.../dataregion/DataRegionWatermarkInjector.java | 76 +
.../dataregion/IoTDBDataRegionExtractor.java | 82 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 24 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 10 +-
.../realtime/epoch/TsFileEpochManager.java | 23 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 13 +-
.../processor/aggregate/AggregateProcessor.java | 2 +-
.../sdt/SwingingDoorTrendingFilter.java | 1 +
.../pipe/processor/twostage/combiner/Combiner.java | 107 +
.../twostage/combiner/PipeCombineHandler.java | 198 +
.../combiner/PipeCombineHandlerManager.java | 163 +
.../twostage/exchange/payload/CombineRequest.java | 139 +
.../payload/FetchCombineResultRequest.java | 119 +
.../payload/FetchCombineResultResponse.java | 99 +
.../twostage/exchange/payload/RequestType.java | 16 +-
.../receiver/TwoStageAggregateReceiver.java | 82 +
.../exchange/sender/TwoStageAggregateSender.java | 235 +
.../processor/twostage/operator/CountOperator.java | 36 +-
.../pipe/processor/twostage/operator/Operator.java | 11 +-
.../twostage/plugin/TwoStageCountProcessor.java | 391 +
.../processor/twostage/state/CountState.java} | 26 +-
.../db/pipe/processor/twostage/state/State.java} | 11 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 11 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 1 -
.../protocol/thrift/IoTDBDataNodeReceiver.java | 72 +-
.../thrift/IoTDBDataNodeReceiverAgent.java | 3 +
.../visitor/PipePlanToStatementVisitor.java | 105 +-
.../visitor/PipeStatementTSStatusVisitor.java | 69 +-
.../visitor/PipeStatementToBatchVisitor.java | 185 +
.../pipe/task/connection/PipeEventCollector.java | 3 +-
.../subtask/processor/PipeProcessorSubtask.java | 57 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 1 +
.../rest/utils/InsertTabletSortDataUtils.java | 17 +-
.../iotdb/db/protocol/session/SessionManager.java | 1 +
.../common/schematree/ClusterSchemaTree.java | 1 +
.../timerangeiterator/ITimeRangeIterator.java | 4 +-
.../execution/exchange/sink/SinkChannel.java | 2 +
.../exchange/source/LocalSourceHandle.java | 1 +
.../execution/executor/RegionWriteExecutor.java | 12 +-
.../fragment/FragmentInstanceContext.java | 3 +
.../queryengine/execution/memory/MemoryPool.java | 2 +
.../process/AbstractConsumeAllOperator.java | 5 +-
.../operator/process/LinearFillOperator.java | 1 +
.../operator/process/MergeSortOperator.java | 4 +-
.../process/join/FullOuterTimeJoinOperator.java | 4 +-
.../process/join/InnerTimeJoinOperator.java | 1 +
.../metric/DataExchangeCostMetricSet.java | 1 +
.../metric/QueryExecutionMetricSet.java | 3 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 1 +
.../queryengine/plan/analyze/ExpressionUtils.java | 3 +-
.../analyze/cache/partition/PartitionCache.java | 6 +
.../cache/partition/StorageGroupCacheResult.java | 2 +
.../plan/analyze/schema/ISchemaComputation.java | 8 +-
.../plan/execution/IQueryExecution.java | 4 +-
.../queryengine/plan/execution/QueryExecution.java | 4 +-
.../visitor/CompleteMeasurementSchemaVisitor.java | 6 +-
.../visitor/TransformToViewExpressionVisitor.java | 6 +
.../plan/optimization/AggregationPushDown.java | 9 +
.../plan/planner/OperatorTreeGenerator.java | 34 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 8 +
.../plan/planner/plan/node/PlanNodeType.java | 4 +
.../metedata/write/view/CreateLogicalViewNode.java | 1 +
.../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 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 40 +-
.../plan/statement/crud/InsertBaseStatement.java | 1 +
.../metadata/view/AlterLogicalViewStatement.java | 1 +
.../row/ElasticSerializableRowRecordList.java | 1 +
.../tv/ElasticSerializableTVList.java | 1 +
.../schemaengine/schemaregion/ISchemaRegion.java | 4 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 46 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 42 +-
.../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 | 215 +-
.../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 | 12 +-
.../db/service/metrics/CompactionMetrics.java | 2 +
.../db/storageengine/dataregion/DataRegion.java | 158 +-
.../dataregion/ILastFlushTimeMap.java | 3 +
.../impl/ReadChunkCompactionPerformer.java | 17 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 146 +-
.../compaction/selector/estimator/FileInfo.java | 1 +
.../compaction/tool/ListTimeRangeImpl.java | 1 +
.../dataregion/memtable/AbstractMemTable.java | 3 +
.../dataregion/memtable/DeviceIDFactory.java | 1 +
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 4 +-
.../dataregion/memtable/TsFileProcessor.java | 92 +
.../dataregion/read/control/FileReaderManager.java | 2 +
.../dataregion/snapshot/SnapshotLoader.java | 12 +-
.../dataregion/tsfile/TsFileResource.java | 26 +-
.../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 +
.../rescon/memory/TimePartitionManager.java | 14 +
.../agent/SubscriptionBrokerAgent.java | 4 +-
.../broker/SerializedEnrichedEvent.java | 4 +-
.../broker/SubscriptionPrefetchingQueue.java | 28 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 4 +-
.../db/tools/schema/SRStatementGenerator.java | 103 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 1 +
.../java/org/apache/iotdb/db/utils/MathUtils.java | 1 +
.../db/auth/user/LocalFileUserManagerTest.java | 8 +
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 3 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 1 +
.../extractor/IoTDBDataRegionExtractorTest.java | 32 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 3 +-
.../operator/RawDataAggregationOperatorTest.java | 1 +
.../schedule/DefaultDriverSchedulerTest.java | 3 +-
.../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 +-
.../cross/RewriteCompactionFileSelectorTest.java | 5 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 22 +-
...nkCompactionPerformerWithAlignedSeriesTest.java | 55 +-
.../settle/SettleRequestHandlerTest.java | 3 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 80 +-
.../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 +
.../db/utils/SchemaRegionSnapshotParserTest.java | 86 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 3 +
.../iotdb/metrics/core/IoTDBMetricManager.java | 1 +
.../metrics/core/reporter/IoTDBJmxReporter.java | 5 +
.../iotdb/metrics/core/uitls/IoTDBCachedGauge.java | 5 +
.../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 | 15 +-
.../assembly/resources/sbin/destroy-confignode.bat | 2 +-
.../assembly/resources/sbin/destroy-datanode.bat | 2 +-
.../src/assembly/resources/sbin/health_check.bat | 40 +-
.../src/assembly/resources/sbin/health_check.sh | 23 +-
.../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 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 12 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 2 +
.../org/apache/iotdb/commons/auth/entity/Role.java | 1 +
.../iotdb/commons/auth/user/BasicUserManager.java | 17 +-
.../iotdb/commons/auth/user/IUserManager.java | 3 +-
.../commons/auth/user/LocalFileUserAccessor.java | 1 +
.../client/property/ThriftClientProperty.java | 2 +
.../commons/concurrent/IoTDBThreadPoolFactory.java | 12 -
.../apache/iotdb/commons/conf/CommonConfig.java | 59 +
.../iotdb/commons/conf/CommonDescriptor.java | 34 +
.../commons/consensus/index/ProgressIndex.java | 11 +-
.../commons/consensus/index/ProgressIndexType.java | 7 +-
.../consensus/index/impl/HybridProgressIndex.java | 4 +
.../consensus/index/impl/MetaProgressIndex.java | 2 +-
.../consensus/index/impl/StateProgressIndex.java | 234 +
.../index/impl/TimeWindowStateProgressIndex.java | 4 +-
.../iotdb/commons/exception/IoTDBException.java | 1 +
.../commons/executable/ExecutableManager.java | 1 +
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +-
.../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 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 30 +
.../config/constant/PipeExtractorConstant.java | 4 +
.../config/constant/PipeProcessorConstant.java | 2 +
.../request/IoTDBConnectorRequestVersion.java | 1 +
.../commons/pipe/event/PipeSnapshotEvent.java | 19 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 35 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 2 +
.../TwoStageCountProcessor.java} | 8 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 20 +-
.../commons/pipe/task/meta/PipeStaticMeta.java | 29 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 28 +-
.../task/subtask/PipeAbstractConnectorSubtask.java | 4 +-
.../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 +-
.../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 +
.../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 | 41 +-
655 files changed, 6902 insertions(+), 38469 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
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 iotdb-client/cli/src/assembly/resources/tools/backup.bat
delete mode 100755 iotdb-client/cli/src/assembly/resources/tools/backup.sh
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/bean/TimeValues.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/DatabaseConnectService.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/IReaderSet.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/hive-connector/src/test/resources/logback.xml
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/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/TsFileInsertionPointCounter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/compaction/schedule/constant/CompactionType.java
=> pipe/event/common/watermark/PipeWatermarkEvent.java} (68%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/DataRegionWatermarkInjector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/combiner/Combiner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/combiner/PipeCombineHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/combiner/PipeCombineHandlerManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/payload/CombineRequest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/payload/FetchCombineResultRequest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/payload/FetchCombineResultResponse.java
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/response/PipeSubscribeResponseType.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/payload/RequestType.java
(77%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/receiver/TwoStageAggregateReceiver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/exchange/sender/TwoStageAggregateSender.java
rename
iotdb-connector/grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/operator/CountOperator.java
(52%)
rename
iotdb-connector/spark-tsfile/src/test/scala/org/apache/iotdb/spark/constant/TestConstant.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/operator/Operator.java
(79%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessor.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{schemaengine/template/alter/TemplateAlterInfo.java
=> pipe/processor/twostage/state/CountState.java} (69%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/IProcedureFactory.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/state/State.java}
(79%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementToBatchVisitor.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/index/impl/StateProgressIndex.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/{downsampling/SwingingDoorTrendingSamplingProcessor.java
=> twostage/TwoStageCountProcessor.java} (79%)
