This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/disableView in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3796ed6c1fb642a80642d0778b5d7a67952a94f7 Merge: 1d1c014b93b 634f0395421 Author: Minghui Liu <[email protected]> AuthorDate: Mon May 29 14:49:41 2023 +0800 Merge remote-tracking branch 'origin/master' into lmh/disableView .github/workflows/client-cpp.yml | 8 +- .github/workflows/client-go.yml | 2 +- .github/workflows/client-python.yml | 6 +- .github/workflows/grafana-plugin.yml | 4 +- .github/workflows/influxdb-protocol.yml | 2 +- .gitignore | 9 + .gitmodules | 6 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 18 +- client-go | 1 - .../confignode/client/DataNodeRequestType.java | 5 + .../client/async/AsyncDataNodeClientPool.java | 21 + .../client/async/handlers/AsyncClientHandler.java | 3 + .../iotdb/confignode/manager/ConfigManager.java | 12 + .../apache/iotdb/confignode/manager/IManager.java | 3 + .../iotdb/confignode/manager/ProcedureManager.java | 47 + .../pipe/runtime/PipeRuntimeCoordinator.java | 5 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 9 +- .../runtime/PipeHandleMetaChangeProcedure.java | 10 +- .../impl/pipe/task/CreatePipeProcedureV2.java | 7 +- .../impl/schema/DeleteLogicalViewProcedure.java | 353 +++++ .../state/schema/DeleteLogicalViewState.java | 9 +- .../procedure/store/ProcedureFactory.java | 6 + .../confignode/procedure/store/ProcedureType.java | 5 +- .../iotdb/confignode/service/ConfigNode.java | 2 + .../thrift/ConfigNodeRPCServiceProcessor.java | 6 + .../request/ConfigPhysicalPlanSerDeTest.java | 9 +- .../iotdb/confignode/persistence/PipeInfoTest.java | 3 +- .../runtime/PipeHandleMetaChangeProcedureTest.java | 7 +- .../consensus/iot/IoTConsensusServerImpl.java | 7 + distribution/src/assembly/all.xml | 4 +- distribution/src/assembly/cli.xml | 4 +- distribution/src/assembly/client-cpp.xml | 2 +- distribution/src/assembly/grafana-connector.xml | 2 +- distribution/src/assembly/grafana-plugin.xml | 2 +- distribution/src/assembly/spark-connector.xml | 4 +- docker/src/main/DockerCompose/start-1c1d.sh | 2 +- docs/UserGuide/Monitor-Alert/Metric-Tool.md | 3 +- docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 13 +- example/session/pom.xml | 6 + .../org/apache/iotdb/DataMigrationExample.java | 142 +- grafana-plugin/go.sum | 660 --------- influxdb-protocol/pom.xml | 140 -- .../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 411 ------ .../iotdb/influxdb/IoTDBInfluxDBFactory.java | 70 - .../iotdb/influxdb/protocol/dto/SessionPoint.java | 85 -- .../protocol/impl/IoTDBInfluxDBService.java | 99 -- .../influxdb/protocol/util/ParameterUtils.java | 36 - .../iotdb/influxdb/session/InfluxDBSession.java | 279 ---- .../influxdb/integration/IoTDBInfluxDBIT.java | 207 --- integration-test/pom.xml | 6 + integration-test/src/assembly/mpp-test.xml | 4 +- .../it/IoTDBConfigNodeConsensusEfficiencyIT.java | 2 - .../confignode/it/utils/ConfigNodeTestUtils.java | 1 + integration/README.md | 120 -- integration/checkstyle.xml | 217 --- integration/import-control.xml | 29 - integration/pom.xml | 295 ---- integration/src/assembly/cluster.xml | 47 - .../db/engine/trigger/example/Accumulator.java | 96 -- .../iotdb/db/engine/trigger/example/Counter.java | 97 -- .../iotdb/db/query/udf/example/Accumulator.java | 102 -- .../apache/iotdb/db/query/udf/example/Adder.java | 92 -- .../apache/iotdb/db/query/udf/example/Counter.java | 88 -- .../db/query/udf/example/ExampleUDFConstant.java | 31 - .../org/apache/iotdb/db/query/udf/example/Max.java | 74 - .../iotdb/db/query/udf/example/Multiplier.java | 63 - .../SlidingSizeWindowConstructorTester0.java | 59 - .../SlidingSizeWindowConstructorTester1.java | 64 - .../SlidingTimeWindowConstructionTester.java | 72 - .../db/query/udf/example/TerminateTester.java | 67 - .../iotdb/db/query/udf/example/ValidateTester.java | 44 - .../iotdb/db/query/udf/example/WindowStartEnd.java | 66 - .../iotdb/integration/env/ClusterEnvBase.java | 279 ---- .../iotdb/integration/env/ClusterEnvConfig.java | 154 -- .../apache/iotdb/integration/env/ClusterNode.java | 179 --- .../iotdb/integration/env/ConfigFactory.java | 52 - .../apache/iotdb/integration/env/EnvFactory.java | 57 - .../iotdb/integration/env/FiveNodeCluster1Env.java | 64 - .../iotdb/integration/env/RemoteEnvConfig.java | 23 - .../iotdb/integration/env/RemoteServerEnv.java | 107 -- .../apache/iotdb/itbase/category/ClusterTest.java | 21 - .../apache/iotdb/itbase/category/RemoteTest.java | 21 - .../org/apache/iotdb/itbase/env/BaseConfig.java | 112 -- .../java/org/apache/iotdb/itbase/env/BaseEnv.java | 39 - .../apache/iotdb/db/integration/IOTDBInsertIT.java | 200 --- .../IoTDBAlignedTimeSeriesCompactionIT.java | 564 ------- .../iotdb/db/integration/IoTDBCheckConfigIT.java | 142 -- .../iotdb/db/integration/IoTDBClearCacheIT.java | 171 --- .../apache/iotdb/db/integration/IoTDBCloseIT.java | 191 --- .../iotdb/db/integration/IoTDBCompactionIT.java | 338 ----- .../integration/IoTDBCompactionWithIDTableIT.java | 352 ----- .../iotdb/db/integration/IoTDBCompressTypeIT.java | 101 -- .../db/integration/IoTDBContinuousQueryIT.java | 544 ------- .../apache/iotdb/db/integration/IoTDBDaemonIT.java | 456 ------ .../iotdb/db/integration/IoTDBDisableAlignIT.java | 392 ----- .../apache/iotdb/db/integration/IoTDBFillIT.java | 1227 --------------- .../db/integration/IoTDBFlushQueryMergeIT.java | 197 --- .../iotdb/db/integration/IoTDBKillQueryIT.java | 80 - .../iotdb/db/integration/IoTDBLargeDataIT.java | 373 ----- .../apache/iotdb/db/integration/IoTDBLastIT.java | 629 -------- .../iotdb/db/integration/IoTDBMaxTimeQueryIT.java | 139 -- .../IoTDBMultiOverlappedChunkInUnseqIT.java | 110 -- .../db/integration/IoTDBMultiOverlappedPageIT.java | 166 --- .../iotdb/db/integration/IoTDBMultiSeriesIT.java | 471 ------ .../db/integration/IoTDBMultiStatementsIT.java | 187 --- .../db/integration/IoTDBNewTsFileCompactionIT.java | 1078 -------------- .../db/integration/IoTDBOverlappedPageIT.java | 194 --- .../iotdb/db/integration/IoTDBQueryTimeoutIT.java | 156 -- .../db/integration/IoTDBQueryWithIDTableIT.java | 290 ---- .../db/integration/IoTDBRemovePartitionIT.java | 331 ----- .../db/integration/IoTDBRepeatPatternNameIT.java | 67 - .../db/integration/IoTDBRewriteTsFileToolIT.java | 618 -------- .../db/integration/IoTDBRpcCompressionIT.java | 140 -- .../iotdb/db/integration/IoTDBSensorUpdateIT.java | 87 -- .../db/integration/IoTDBSessionTimeoutIT.java | 84 -- .../IoTDBSetSystemReadOnlyWritableIT.java | 258 ---- .../integration/IoTDBSizeTieredCompactionIT.java | 1370 ----------------- .../integration/IoTDBSortedShowTimeseriesIT.java | 339 ----- .../iotdb/db/integration/IoTDBTimePartitionIT.java | 90 -- .../iotdb/db/integration/IoTDBTracingIT.java | 84 -- .../apache/iotdb/db/integration/IoTDBTtlIT.java | 354 ----- .../db/integration/IoTDBUDFWindowQueryIT.java | 808 ---------- .../db/integration/IoTDBUDTFHybridQueryIT.java | 160 -- .../db/integration/IoTDBUDTFNonAlignQueryIT.java | 341 ----- .../db/integration/IoTDBUnseqOverlappedPageIT.java | 127 -- .../iotdb/db/integration/IoTDBVersionIT.java | 68 - .../iotdb/db/integration/env/StandaloneEnv.java | 93 -- .../db/integration/env/StandaloneEnvConfig.java | 133 -- .../versionadaption/IoTDBDDLVersionAdaptionIT.java | 362 ----- .../IoTDBDeletionVersionAdaptionIT.java | 303 ---- .../IoTDBQueryVersionAdaptionIT.java | 320 ---- .../session/IoTDBSessionAlignedABDeviceIT.java | 235 --- .../session/IoTDBSessionAlignedAggregationIT.java | 263 ---- .../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 196 --- .../iotdb/session/IoTDBSessionIteratorIT.java | 354 ----- .../src/test/resources/iotdb-datanode.properties | 24 - integration/src/test/resources/logback-test.xml | 58 - {external-api => iotdb-api/external-api}/pom.xml | 2 +- .../iotdb/external/api/IPropertiesLoader.java | 0 .../iotdb/external/api/ISeriesNumerMonitor.java | 0 .../external/api/thrift/JudgableServerContext.java | 0 .../external/api/thrift/ServerContextFactory.java | 0 .../external-pipe-api}/pom.xml | 2 +- .../apache/iotdb/pipe/external/api/DataType.java | 0 .../external/api/ExternalPipeSinkWriterStatus.java | 0 .../pipe/external/api/IExternalPipeSinkWriter.java | 0 .../api/IExternalPipeSinkWriterFactory.java | 0 {pipe-api => iotdb-api/pipe-api}/pom.xml | 2 +- .../org/apache/iotdb/pipe/api/PipeCollector.java | 0 .../org/apache/iotdb/pipe/api/PipeConnector.java | 0 .../java/org/apache/iotdb/pipe/api/PipePlugin.java | 0 .../org/apache/iotdb/pipe/api/PipeProcessor.java | 0 .../java/org/apache/iotdb/pipe/api/access/Row.java | 0 .../apache/iotdb/pipe/api/access/RowIterator.java | 0 .../iotdb/pipe/api/collector/EventCollector.java | 0 .../iotdb/pipe/api/collector/RowCollector.java | 0 .../api/customizer/PipeParameterValidator.java | 0 .../iotdb/pipe/api/customizer/PipeParameters.java | 0 .../api/customizer/PipeRuntimeConfiguration.java | 0 .../iotdb/pipe/api/customizer/PipeStrategy.java | 0 .../PipeCollectorRuntimeConfiguration.java | 0 .../PipeConnectorRuntimeConfiguration.java | 0 .../connector/parallel/ParallelStrategy.java | 0 .../retry/EqualRetryIntervalStrategy.java | 0 .../retry/ExponentialRetryIntervalStrategy.java | 0 .../customizer/connector/retry/RetryStrategy.java | 0 .../customizer/connector/reuse/ReuseStrategy.java | 0 .../PipeProcessorRuntimeConfiguration.java | 0 .../org/apache/iotdb/pipe/api/event/Event.java | 0 .../org/apache/iotdb/pipe/api/event/EventType.java | 0 .../event/dml/insertion/TabletInsertionEvent.java | 0 .../event/dml/insertion/TsFileInsertionEvent.java | 0 .../PipeAttributeNotProvidedException.java | 0 .../api/exception/PipeConnectionException.java | 0 .../iotdb/pipe/api/exception/PipeException.java | 0 .../api/exception/PipeManagementException.java | 0 .../exception/PipeParameterNotValidException.java | 0 .../exception/PipeRuntimeCriticalException.java | 0 .../pipe/api/exception/PipeRuntimeException.java | 0 .../exception/PipeRuntimeNonCriticalException.java | 0 .../exception/PipeStrategyNotValidException.java | 0 .../org/apache/iotdb/pipe/api/type/Binary.java | 0 .../java/org/apache/iotdb/pipe/api/type/Type.java | 0 .../subscription-api}/pom.xml | 2 +- .../api/SubscriptionConfiguration.java | 0 .../subscription/api/SubscriptionFactory.java | 0 .../iotdb/subscription/api/consumer/Consumer.java | 0 .../api/consumer/pull/PullConsumer.java | 0 .../api/consumer/push/DataArrivalListener.java | 0 .../api/consumer/push/ExceptionListener.java | 0 .../api/consumer/push/PushConsumer.java | 0 .../api/dataset/SubscriptionDataSet.java | 0 .../api/exception/SubscriptionException.java | 0 .../SubscriptionStrategyNotValidException.java | 0 .../api/strategy/SubscriptionStrategy.java | 0 .../disorder/DisorderHandlingStrategy.java | 0 .../api/strategy/disorder/IntolerableStrategy.java | 0 .../api/strategy/disorder/WatermarkStrategy.java | 0 .../strategy/topic/MultipleConnectionStrategy.java | 0 .../api/strategy/topic/SingleTopicStrategy.java | 0 .../api/strategy/topic/TopicsStrategy.java | 0 {trigger-api => iotdb-api/trigger-api}/pom.xml | 2 +- .../java/org/apache/iotdb/trigger/api/Trigger.java | 0 .../iotdb/trigger/api/TriggerAttributes.java | 0 .../iotdb/trigger/api/enums/FailureStrategy.java | 0 .../iotdb/trigger/api/enums/TriggerEvent.java | 0 .../iotdb/trigger/api/enums/TriggerType.java | 0 {udf-api => iotdb-api/udf-api}/pom.xml | 2 +- .../main/java/org/apache/iotdb/udf/api/UDF.java | 0 .../main/java/org/apache/iotdb/udf/api/UDTF.java | 0 .../java/org/apache/iotdb/udf/api/access/Row.java | 0 .../apache/iotdb/udf/api/access/RowIterator.java | 0 .../org/apache/iotdb/udf/api/access/RowWindow.java | 0 .../iotdb/udf/api/collector/PointCollector.java | 0 .../api/customizer/config/UDFConfigurations.java | 0 .../api/customizer/config/UDTFConfigurations.java | 0 .../parameter/UDFParameterValidator.java | 0 .../api/customizer/parameter/UDFParameters.java | 0 .../api/customizer/strategy/AccessStrategy.java | 0 .../strategy/MappableRowByRowAccessStrategy.java | 0 .../strategy/RowByRowAccessStrategy.java | 0 .../strategy/SessionTimeWindowAccessStrategy.java | 0 .../strategy/SlidingSizeWindowAccessStrategy.java | 0 .../strategy/SlidingTimeWindowAccessStrategy.java | 0 .../strategy/StateWindowAccessStrategy.java | 0 .../UDFAttributeNotProvidedException.java | 0 .../iotdb/udf/api/exception/UDFException.java | 0 .../UDFInputSeriesDataTypeNotValidException.java | 0 .../UDFInputSeriesIndexNotValidException.java | 0 .../UDFInputSeriesNumberNotValidException.java | 0 .../udf/api/exception/UDFManagementException.java | 0 .../UDFOutputSeriesDataTypeNotValidException.java | 0 .../exception/UDFParameterNotValidException.java | 0 .../java/org/apache/iotdb/udf/api/type/Binary.java | 0 .../java/org/apache/iotdb/udf/api/type/Type.java | 0 {cli => iotdb-client/cli}/pom.xml | 2 +- {cli => iotdb-client/cli}/src/assembly/cli.xml | 0 .../src/assembly/resources/conf/logback-cli.xml | 0 .../cli}/src/assembly/resources/sbin/start-cli.bat | 0 .../cli}/src/assembly/resources/sbin/start-cli.sh | 0 .../src/assembly/resources/tools/export-csv.bat | 0 .../src/assembly/resources/tools/export-csv.sh | 0 .../src/assembly/resources/tools/export-tsfile.bat | 0 .../src/assembly/resources/tools/export-tsfile.sh | 0 .../src/assembly/resources/tools/import-csv.bat | 0 .../src/assembly/resources/tools/import-csv.sh | 0 .../src/assembly/resources/tools/load-tsfile.bat | 0 .../src/assembly/resources/tools/load-tsfile.sh | 0 .../java/org/apache/iotdb/cli/AbstractCli.java | 0 .../src/main/java/org/apache/iotdb/cli/Cli.java | 0 .../apache/iotdb/cli/IoTDBSyntaxHighlighter.java | 0 .../org/apache/iotdb/cli/utils/IoTPrinter.java | 0 .../org/apache/iotdb/cli/utils/JlineUtils.java | 0 .../apache/iotdb/exception/ArgsErrorException.java | 0 .../org/apache/iotdb/tool/AbstractCsvTool.java | 0 .../org/apache/iotdb/tool/AbstractTsFileTool.java | 0 .../main/java/org/apache/iotdb/tool/ExportCsv.java | 0 .../java/org/apache/iotdb/tool/ExportTsFile.java | 0 .../main/java/org/apache/iotdb/tool/ImportCsv.java | 0 .../java/org/apache/iotdb/cli/AbstractCliIT.java | 0 .../java/org/apache/iotdb/cli/AbstractScript.java | 0 .../iotdb/tool/integration/ExportCsvTestIT.java | 0 .../iotdb/tool/integration/ImportCsvTestIT.java | 0 .../apache/iotdb/tool/unit/WriteCsvFileTestUT.java | 0 .../cli}/src/test/resources/logback.xml | 0 {client-cpp => iotdb-client/client-cpp}/README.md | 0 {client-cpp => iotdb-client/client-cpp}/pom.xml | 24 +- .../client-cpp}/src/assembly/client-cpp.xml | 0 .../client-cpp}/src/main/CMakeLists.txt | 0 .../client-cpp}/src/main/Session.cpp | 0 .../client-cpp}/src/main/Session.h | 0 .../client-cpp}/src/test/CMakeLists.txt | 0 .../client-cpp}/src/test/cpp/sessionIT.cpp | 0 .../client-cpp}/src/test/main.cpp | 0 iotdb-client/client-go | 1 + {client-py => iotdb-client/client-py}/.flake8 | 0 {client-py => iotdb-client/client-py}/.gitignore | 0 {client-py => iotdb-client/client-py}/README.md | 0 .../client-py}/SessionAlignedTimeseriesExample.py | 0 .../client-py}/SessionExample.py | 0 .../client-py}/iotdb/IoTDBContainer.py | 0 .../client-py}/iotdb/Session.py | 0 .../client-py}/iotdb/__init__.py | 0 .../client-py}/iotdb/dbapi/Connection.py | 0 .../client-py}/iotdb/dbapi/Cursor.py | 0 .../client-py}/iotdb/dbapi/Exceptions.py | 0 .../client-py}/iotdb/dbapi/__init__.py | 0 .../client-py}/iotdb/dbapi/tests/__init__.py | 0 .../iotdb/dbapi/tests/test_connection.py | 0 .../client-py}/iotdb/dbapi/tests/test_cursor.py | 0 .../client-py}/iotdb/sqlalchemy/IoTDBDialect.py | 0 .../iotdb/sqlalchemy/IoTDBIdentifierPreparer.py | 0 .../iotdb/sqlalchemy/IoTDBSQLCompiler.py | 0 .../iotdb/sqlalchemy/IoTDBTypeCompiler.py | 0 .../client-py}/iotdb/sqlalchemy/__init__.py | 0 .../client-py}/iotdb/sqlalchemy/tests/__init__.py | 0 .../iotdb/sqlalchemy/tests/test_dialect.py | 0 .../client-py}/iotdb/template/InternalNode.py | 0 .../client-py}/iotdb/template/MeasurementNode.py | 0 .../client-py}/iotdb/template/Template.py | 0 .../client-py}/iotdb/template/TemplateNode.py | 0 .../client-py}/iotdb/template/TemplateQueryType.py | 0 .../client-py}/iotdb/template/__init__.py | 0 .../client-py}/iotdb/tsfile/__init__.py | 0 .../client-py}/iotdb/tsfile/common/__init__.py | 0 .../iotdb/tsfile/common/constant/TsFileConstant.py | 0 .../iotdb/tsfile/common/constant/__init__.py | 0 .../client-py}/iotdb/tsfile/utils/Pair.py | 0 .../iotdb/tsfile/utils/ReadWriteIOUtils.py | 0 .../client-py}/iotdb/tsfile/utils/__init__.py | 0 .../client-py}/iotdb/utils/BitMap.py | 0 .../client-py}/iotdb/utils/Field.py | 0 .../iotdb/utils/IoTDBConnectionException.py | 0 .../client-py}/iotdb/utils/IoTDBConstants.py | 0 .../client-py}/iotdb/utils/IoTDBRpcDataSet.py | 0 .../client-py}/iotdb/utils/NumpyTablet.py | 0 .../client-py}/iotdb/utils/RowRecord.py | 0 .../client-py}/iotdb/utils/SessionDataSet.py | 0 .../client-py}/iotdb/utils/Tablet.py | 0 .../client-py}/iotdb/utils/__init__.py | 0 {client-py => iotdb-client/client-py}/pom.xml | 6 +- .../client-py}/pyproject.toml | 0 {client-py => iotdb-client/client-py}/release.sh | 0 .../client-py}/requirements.txt | 0 .../client-py}/requirements_dev.txt | 0 {client-py => iotdb-client/client-py}/setup.py | 0 .../client-py}/tests/__init__.py | 0 .../tests/tablet_performance_comparison.py | 0 .../client-py}/tests/test_aligned_timeseries.py | 0 .../client-py}/tests/test_dataframe.py | 0 .../client-py}/tests/test_delete_data.py | 0 .../client-py}/tests/test_numpy_tablet.py | 0 .../client-py}/tests/test_one_device.py | 0 .../client-py}/tests/test_session.py | 0 .../client-py}/tests/test_tablet.py | 0 .../client-py}/tests/test_template.py | 0 .../client-py}/tests/test_todf.py | 0 .../compile-tools}/README.md | 0 .../compile-tools}/pom.xml | 2 +- .../compile-tools}/thrift/pom.xml | 0 {isession => iotdb-client/isession}/pom.xml | 1 + .../java/org/apache/iotdb/isession/ISession.java | 0 .../org/apache/iotdb/isession/SessionConfig.java | 0 .../org/apache/iotdb/isession/SessionDataSet.java | 8 + .../apache/iotdb/isession/pool/ISessionPool.java | 0 .../iotdb/isession/pool/SessionDataSetWrapper.java | 0 .../apache/iotdb/isession/template/Template.java | 0 .../iotdb/isession/template/TemplateNode.java | 0 .../apache/iotdb/isession/util/SystemStatus.java | 0 .../org/apache/iotdb/isession/util/Version.java | 0 {jdbc => iotdb-client/jdbc}/README.md | 0 {jdbc => iotdb-client/jdbc}/osgi.bnd | 0 {jdbc => iotdb-client/jdbc}/pom.xml | 2 +- .../jdbc}/src/main/feature/feature.xml | 0 .../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 0 .../main/java/org/apache/iotdb/jdbc/Activator.java | 0 .../main/java/org/apache/iotdb/jdbc/Config.java | 0 .../main/java/org/apache/iotdb/jdbc/Constant.java | 0 .../src/main/java/org/apache/iotdb/jdbc/Field.java | 0 .../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 0 .../org/apache/iotdb/jdbc/IoTDBConnection.java | 0 .../apache/iotdb/jdbc/IoTDBConnectionParams.java | 0 .../org/apache/iotdb/jdbc/IoTDBDataSource.java | 0 .../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 0 .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 0 .../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 0 .../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 0 .../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 0 .../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 0 .../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 0 .../org/apache/iotdb/jdbc/IoTDBSQLException.java | 0 .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 0 .../org/apache/iotdb/jdbc/IoTDBTracingInfo.java | 0 .../org/apache/iotdb/jdbc/IoTDBURLException.java | 0 .../java/org/apache/iotdb/jdbc/StringUtils.java | 0 .../src/main/java/org/apache/iotdb/jdbc/Utils.java | 0 .../org/apache/iotdb/jdbc/WatermarkEncoder.java | 0 .../resources/services/META-INF/java.sql.Driver | 0 .../test/java/org/apache/iotdb/jdbc/BatchTest.java | 0 .../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 0 .../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 0 .../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 0 .../iotdb/jdbc/IoTDBPreparedStatementTest.java | 0 .../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 0 .../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 0 .../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 0 {service-rpc => iotdb-client/service-rpc}/pom.xml | 2 +- .../org/apache/iotdb/rpc/AutoResizingBuffer.java | 0 .../iotdb/rpc/AutoScalingBufferReadTransport.java | 0 .../iotdb/rpc/AutoScalingBufferWriteTransport.java | 0 .../apache/iotdb/rpc/BatchExecutionException.java | 0 .../iotdb/rpc/ConfigNodeConnectionException.java | 0 .../apache/iotdb/rpc/ConfigurableTByteBuffer.java | 0 .../iotdb/rpc/InfluxDBSynchronizedHandler.java | 0 .../apache/iotdb/rpc/IoTDBConnectionException.java | 0 .../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 0 .../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 0 .../apache/iotdb/rpc/NoValidValueException.java | 0 .../org/apache/iotdb/rpc/NonOpenTransport.java | 0 .../org/apache/iotdb/rpc/RedirectException.java | 0 .../main/java/org/apache/iotdb/rpc/RpcStat.java | 0 .../org/apache/iotdb/rpc/RpcTransportFactory.java | 0 .../main/java/org/apache/iotdb/rpc/RpcUtils.java | 0 .../iotdb/rpc/StatementExecutionException.java | 0 .../org/apache/iotdb/rpc/SynchronizedHandler.java | 0 .../rpc/TCompressedElasticFramedTransport.java | 0 .../org/apache/iotdb/rpc/TConfigurationConst.java | 0 .../apache/iotdb/rpc/TElasticFramedTransport.java | 0 .../iotdb/rpc/TNonblockingSocketWrapper.java | 0 .../java/org/apache/iotdb/rpc/TSStatusCode.java | 0 .../iotdb/rpc/TSnappyElasticFramedTransport.java | 0 .../java/org/apache/iotdb/rpc/TSocketWrapper.java | 0 .../rpc/TimeoutChangeableTFastFramedTransport.java | 0 .../TimeoutChangeableTSnappyFramedTransport.java | 0 .../iotdb/rpc/TimeoutChangeableTransport.java | 0 .../org/apache/iotdb/rpc/TSStatusCodeTest.java | 0 {session => iotdb-client/session}/pom.xml | 2 +- .../org/apache/iotdb/session/InsertConsumer.java | 0 .../java/org/apache/iotdb/session/Session.java | 0 .../apache/iotdb/session/SessionConnection.java | 0 .../org/apache/iotdb/session/pool/SessionPool.java | 0 .../iotdb/session/template/InternalNode.java | 0 .../iotdb/session/template/MeasurementNode.java | 0 .../iotdb/session/template/TemplateQueryType.java | 0 .../apache/iotdb/session/util/SessionUtils.java | 0 .../org/apache/iotdb/session/util/ThreadUtils.java | 0 .../apache/iotdb/session/SessionCacheLeaderUT.java | 0 .../java/org/apache/iotdb/session/TabletTest.java | 0 .../apache/iotdb/session/pool/SessionPoolTest.java | 0 .../apache/iotdb/session/util/ThreadUtilsTest.java | 0 .../src/test/resources/iotdb-common.properties | 0 .../src/test/resources/iotdb-datanode.properties | 0 .../session}/src/test/resources/logback.xml | 0 .../flink-iotdb-connector}/README.md | 0 .../flink-iotdb-connector}/pom.xml | 2 +- .../iotdb/flink/DefaultIoTSerializationSchema.java | 0 .../main/java/org/apache/iotdb/flink/Event.java | 0 .../java/org/apache/iotdb/flink/IoTDBSink.java | 0 .../java/org/apache/iotdb/flink/IoTDBSource.java | 0 .../apache/iotdb/flink/IoTSerializationSchema.java | 0 .../apache/iotdb/flink/options/IoTDBOptions.java | 0 .../iotdb/flink/options/IoTDBSinkOptions.java | 0 .../iotdb/flink/options/IoTDBSourceOptions.java | 0 .../flink/DefaultIoTSerializationSchemaTest.java | 0 .../iotdb/flink/IoTDBSinkBatchInsertTest.java | 0 .../iotdb/flink/IoTDBSinkBatchTimerTest.java | 0 .../apache/iotdb/flink/IoTDBSinkInsertTest.java | 0 .../flink-tsfile-connector}/README.md | 0 .../flink-tsfile-connector}/pom.xml | 2 +- .../apache/iotdb/flink/tsfile/RowRecordParser.java | 0 .../iotdb/flink/tsfile/RowRowRecordParser.java | 0 .../iotdb/flink/tsfile/RowTSRecordConverter.java | 0 .../iotdb/flink/tsfile/TSRecordConverter.java | 0 .../iotdb/flink/tsfile/TSRecordOutputFormat.java | 0 .../iotdb/flink/tsfile/TsFileInputFormat.java | 0 .../iotdb/flink/tsfile/TsFileOutputFormat.java | 0 .../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 0 .../RowTSRecordOutputFormatIntegrationTest.java | 0 .../flink/tsfile/RowTSRecordOutputFormatTest.java | 0 .../flink/tsfile/RowTsFileConnectorTestBase.java | 0 .../RowTsFileInputFormatIntegrationTest.java | 0 .../flink/tsfile/RowTsFileInputFormatTest.java | 0 .../flink/tsfile/RowTsFileInputFormatTestBase.java | 0 .../tsfile/RowTsFileOutputFormatTestBase.java | 0 .../util/TSFileConfigUtilCompletenessTest.java | 0 .../apache/iotdb/flink/util/TsFileWriteUtil.java | 0 .../grafana-connector}/img/add_data_source.png | Bin .../grafana-connector}/img/add_graph.png | Bin .../grafana-connector}/img/edit_data_source.png | Bin .../grafana-connector}/pom.xml | 2 +- .../grafana-connector}/readme.md | 0 .../grafana-connector}/readme_zh.md | 0 .../web/grafana/TsfileWebDemoApplication.java | 0 .../apache/iotdb/web/grafana/bean/TimeValues.java | 0 .../iotdb/web/grafana/conf/MyConfiguration.java | 0 .../controller/DatabaseConnectController.java | 0 .../org/apache/iotdb/web/grafana/dao/BasicDao.java | 0 .../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 0 .../web/grafana/interceptor/LoginInterceptor.java | 0 .../grafana/service/DatabaseConnectService.java | 0 .../service/impl/DatabaseConnectServiceImpl.java | 0 .../src/main/resources/application.properties | 0 .../web/grafana/dao/impl/BasicDaoImplTest.java | 0 .../grafana-plugin}/.gitignore | 0 .../grafana-plugin}/.prettierrc.js | 0 .../grafana-plugin}/CHANGELOG.md | 0 .../grafana-plugin}/LICENSE | 0 .../grafana-plugin}/Magefile.go | 0 .../grafana-plugin}/README.md | 0 .../grafana-plugin}/backend-compile.bat | 0 .../grafana-plugin}/backend-compile.sh | 0 .../grafana-plugin}/go.mod | 0 .../grafana-plugin}/jest.config.js | 0 .../grafana-plugin}/package.json | 0 .../grafana-plugin}/pkg/main.go | 0 .../pkg/plugin/iotdb_resource_handler.go | 0 .../grafana-plugin}/pkg/plugin/plugin.go | 0 .../grafana-plugin}/pom.xml | 2 +- .../grafana-plugin}/src/ConfigEditor.tsx | 0 .../grafana-plugin}/src/QueryEditor.tsx | 0 .../src/componments/AggregateFun.tsx | 0 .../src/componments/ControlValue.tsx | 0 .../grafana-plugin}/src/componments/FillValue.tsx | 0 .../grafana-plugin}/src/componments/Form.tsx | 0 .../grafana-plugin}/src/componments/FromValue.tsx | 0 .../grafana-plugin}/src/componments/GroupBy.tsx | 0 .../src/componments/SelectValue.tsx | 0 .../grafana-plugin}/src/componments/TimeSeries.tsx | 0 .../grafana-plugin}/src/componments/WhereValue.tsx | 0 .../grafana-plugin}/src/datasource.ts | 0 .../grafana-plugin}/src/functions.ts | 0 .../grafana-plugin}/src/img/addIoTDBDataSource.png | Bin .../grafana-plugin}/src/img/logo.svg | 0 .../grafana-plugin}/src/img/showData.png | Bin .../grafana-plugin}/src/module.ts | 0 .../grafana-plugin}/src/plugin.json | 0 .../grafana-plugin}/src/types.ts | 0 .../grafana-plugin}/tsconfig.json | 0 .../grafana-plugin}/yarn.lock | 0 {hadoop => iotdb-connector/hadoop}/README.md | 0 {hadoop => iotdb-connector/hadoop}/pom.xml | 2 +- .../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 0 .../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 0 .../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 0 .../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 0 .../org/apache/iotdb/hadoop/tsfile/IReaderSet.java | 0 .../iotdb/hadoop/tsfile/TSFHadoopException.java | 0 .../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 0 .../apache/iotdb/hadoop/tsfile/TSFInputSplit.java | 0 .../iotdb/hadoop/tsfile/TSFOutputFormat.java | 0 .../iotdb/hadoop/tsfile/TSFRecordReader.java | 0 .../iotdb/hadoop/tsfile/TSFRecordWriter.java | 0 .../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 0 .../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 0 .../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 0 .../iotdb/hadoop/tsfile/TsFileTestHelper.java | 0 .../iotdb/hadoop/tsfile/constant/TestConstant.java | 0 .../hadoop}/src/test/resources/logback.xml | 0 .../hive-connector}/pom.xml | 2 +- .../org/apache/iotdb/hive/TSFHiveInputFormat.java | 0 .../org/apache/iotdb/hive/TSFHiveOutputFormat.java | 0 .../org/apache/iotdb/hive/TSFHiveRecordReader.java | 0 .../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 0 .../org/apache/iotdb/hive/TsFileDeserializer.java | 0 .../java/org/apache/iotdb/hive/TsFileSerDe.java | 0 .../apache/iotdb/hive/TsFileSerDeException.java | 0 .../apache/iotdb/hive/TSFHiveInputFormatTest.java | 0 .../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 0 .../apache/iotdb/hive/TsFileDeserializerTest.java | 0 .../org/apache/iotdb/hive/TsFileSerDeTest.java | 0 .../org/apache/iotdb/hive/TsFileTestHelper.java | 0 .../apache/iotdb/hive/constant/TestConstant.java | 0 .../hive-connector}/src/test/resources/logback.xml | 0 .../spark-iotdb-connector}/pom.xml | 2 +- .../spark-iotdb-connector}/scala_2.11/pom.xml | 2 +- .../spark-iotdb-connector}/scala_2.12/pom.xml | 2 +- .../org/apache/iotdb/spark/db/Converter.scala | 0 .../org/apache/iotdb/spark/db/DataFrameTools.scala | 0 .../org/apache/iotdb/spark/db/DefaultSource.scala | 0 .../org/apache/iotdb/spark/db/IoTDBOptions.scala | 0 .../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 0 .../org/apache/iotdb/spark/db/IoTDBRelation.scala | 0 .../org/apache/iotdb/spark/db/SQLConstant.scala | 0 .../org/apache/iotdb/spark/db/Transformer.scala | 0 .../scala/org/apache/iotdb/spark/db/package.scala | 0 .../spark-tsfile}/pom.xml | 2 +- .../iotdb/spark/tsfile/io/TsFileOutputFormat.java | 0 .../iotdb/spark/tsfile/io/TsFileRecordWriter.java | 0 .../org/apache/iotdb/spark/tsfile/qp/Executor.java | 0 .../iotdb/spark/tsfile/qp/QueryProcessor.java | 0 .../spark/tsfile/qp/common/BasicOperator.java | 0 .../spark/tsfile/qp/common/FilterOperator.java | 0 .../iotdb/spark/tsfile/qp/common/Operator.java | 0 .../iotdb/spark/tsfile/qp/common/SQLConstant.java | 0 .../iotdb/spark/tsfile/qp/common/SingleQuery.java | 0 .../iotdb/spark/tsfile/qp/common/TSQueryPlan.java | 0 .../qp/exception/BasicOperatorException.java | 0 .../tsfile/qp/exception/DNFOptimizeException.java | 0 .../qp/exception/LogicalOptimizeException.java | 0 .../tsfile/qp/exception/MergeFilterException.java | 0 .../qp/exception/QueryOperatorException.java | 0 .../qp/exception/QueryProcessorException.java | 0 .../tsfile/qp/exception/RemoveNotException.java | 0 .../tsfile/qp/optimizer/DNFFilterOptimizer.java | 0 .../tsfile/qp/optimizer/IFilterOptimizer.java | 0 .../qp/optimizer/MergeSingleFilterOptimizer.java | 0 .../tsfile/qp/optimizer/PhysicalOptimizer.java | 0 .../tsfile/qp/optimizer/RemoveNotOptimizer.java | 0 .../org/apache/iotdb/spark/tsfile/Converter.scala | 0 .../apache/iotdb/spark/tsfile/DefaultSource.scala | 0 .../iotdb/spark/tsfile/NarrowConverter.scala | 0 .../spark/tsfile/NarrowTsFileOutputWriter.scala | 0 .../apache/iotdb/spark/tsfile/Transformer.scala | 0 .../iotdb/spark/tsfile/TsFileWriterFactory.scala | 0 .../apache/iotdb/spark/tsfile/WideConverter.scala | 0 .../spark/tsfile/WideTsFileOutputWriter.scala | 0 .../org/apache/iotdb/spark/tsfile/package.scala | 0 .../apache/iotdb/spark/constant/TestConstant.java | 0 .../org/apache/iotdb/spark/tool/TsFileExample.java | 0 .../apache/iotdb/spark/tool/TsFileWriteTool.java | 0 .../apache/iotdb/spark/tsfile/ConverterTest.scala | 0 .../apache/iotdb/spark/tsfile/HDFSInputTest.java | 0 .../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 0 .../zeppelin-interpreter}/IoTDB-Zeppelin-Demo.zpln | 0 .../zeppelin-interpreter}/pom.xml | 2 +- .../apache/zeppelin/iotdb/IoTDBInterpreter.java | 0 .../src/main/resources/interpreter-setting.json | 0 {openapi => iotdb-protocol/openapi}/pom.xml | 2 +- .../src/main/openapi3/iotdb_rest_common.yaml | 0 .../openapi}/src/main/openapi3/iotdb_rest_v1.yaml | 0 .../openapi}/src/main/openapi3/iotdb_rest_v2.yaml | 0 .../thrift-commons}/pom.xml | 2 +- .../thrift-commons}/src/main/thrift/common.thrift | 0 .../thrift-confignode}/pom.xml | 2 +- .../src/main/thrift/confignode.thrift | 8 + .../thrift-influxdb}/README.md | 0 .../thrift-influxdb}/pom.xml | 2 +- .../src/main/thrift/influxdb.thrift | 0 .../thrift-iot-consensus}/pom.xml | 2 +- .../src/main/thrift/iotconsensus.thrift | 0 .../thrift-mlnode}/pom.xml | 2 +- .../thrift-mlnode}/src/main/thrift/mlnode.thrift | 0 {thrift => iotdb-protocol/thrift}/README.md | 0 {thrift => iotdb-protocol/thrift}/pom.xml | 2 +- .../thrift}/rpc-changelist.md | 0 .../thrift}/src/main/thrift/client.thrift | 0 .../thrift}/src/main/thrift/datanode.thrift | 21 + .../apache/iotdb/metrics/config/MetricConfig.java | 7 + .../iotdb/metrics/metricsets/UpTimeMetrics.java | 29 +- .../resources/conf/iotdb-common.properties | 5 +- .../iotdb/commons/concurrent/ThreadName.java | 1 + .../apache/iotdb/commons/conf/CommonConfig.java | 10 + .../iotdb/commons/conf/CommonDescriptor.java | 3 + .../index/ComparableConsensusRequest.java | 10 +- .../commons/consensus/index/ProgressIndex.java | 79 + .../commons/consensus/index/ProgressIndexType.java | 79 + .../consensus/index/impl/IoTProgressIndex.java | 167 +++ .../consensus/index/impl/MinimumProgressIndex.java | 87 ++ .../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 67 +- .../commons/schema/view/LogicalViewSchema.java | 30 + .../commons/pipe/task/meta/PipeMetaDeSerTest.java | 7 +- pom.xml | 68 +- rewrite-tsfile-tool/pom.xml | 83 -- .../src/assembly/resources/sbin/rewrite-tsfile.bat | 60 - .../src/assembly/resources/sbin/rewrite-tsfile.sh | 48 - rewrite-tsfile-tool/src/assembly/rewriteTsFile.xml | 40 - .../java/org/apache/iotdb/RewriteTsFileTool.java | 914 ------------ schema-engine-rocksdb/README.md | 38 - schema-engine-rocksdb/pom.xml | 79 - .../resources/conf/schema-rocksdb.properties | 94 -- .../src/assembly/schema-engine-rocksdb.xml | 44 - .../schemaregion/rocksdb/CheckKeyResult.java | 50 - .../schemaregion/rocksdb/RSchemaConfLoader.java | 185 --- .../schemaregion/rocksdb/RSchemaConstants.java | 76 - .../schemaregion/rocksdb/RSchemaLogger.java | 61 - .../rocksdb/RSchemaReadWriteHandler.java | 515 ------- .../schemaregion/rocksdb/RSchemaRegion.java | 1558 -------------------- .../schemaregion/rocksdb/RSchemaUtils.java | 592 -------- .../schemaregion/rocksdb/mnode/RDatabaseMNode.java | 117 -- .../schemaregion/rocksdb/mnode/RDeviceMNode.java | 171 --- .../schemaregion/rocksdb/mnode/RInternalMNode.java | 171 --- .../schemaregion/rocksdb/mnode/RMNode.java | 230 --- .../schemaregion/rocksdb/mnode/RMNodeType.java | 49 - .../rocksdb/mnode/RMNodeValueType.java | 47 - .../rocksdb/mnode/RMeasurementMNode.java | 249 ---- .../schemaregion/rocksdb/MRocksDBBenchmark.java | 98 -- .../schemaregion/rocksdb/MRocksDBUnitTest.java | 265 ---- .../rocksdb/RSchemaReadWriteHandlerTest.java | 77 - .../rocksdb/RocksDBBenchmarkEngine.java | 144 -- .../schemaregion/rocksdb/RocksDBBenchmarkTask.java | 109 -- .../schemaregion/rocksdb/RocksDBTestUtils.java | 72 - schema-engine-tag/README.md | 190 --- schema-engine-tag/pom.xml | 81 - .../assembly/resources/conf/schema-tag.properties | 33 - .../src/assembly/schema-engine-tag.xml | 44 - .../metadata/tagSchemaRegion/TagSchemaRegion.java | 611 -------- .../tagSchemaRegion/config/TagSchemaConfig.java | 55 - .../config/TagSchemaDescriptor.java | 93 -- .../idtable/IDTableWithDeviceIDListImpl.java | 138 -- .../tagIndex/ITagInvertedIndex.java | 61 - .../tagIndex/Request/InsertionRequest.java | 59 - .../tagSchemaRegion/tagIndex/TagInvertedIndex.java | 183 --- .../tagIndex/deletion/MemChunkDeletion.java | 57 - .../tagIndex/deletion/MemChunkGroupDeletion.java | 68 - .../tagIndex/deletion/MemTableDeletion.java | 77 - .../tagIndex/deletion/MemTableGroupDeletion.java | 66 - .../tagIndex/insertion/MemChunkGroupInsertion.java | 65 - .../tagIndex/insertion/MemChunkInsertion.java | 58 - .../tagIndex/insertion/MemTableGroupInsertion.java | 74 - .../tagIndex/insertion/MemTableInsertion.java | 67 - .../tagIndex/memtable/MemChunk.java | 54 - .../tagIndex/memtable/MemChunkGroup.java | 56 - .../tagIndex/memtable/MemTable.java | 87 -- .../tagIndex/memtable/MemTableGroup.java | 102 -- .../tagIndex/query/MemChunkGroupQuery.java | 61 - .../tagIndex/query/MemChunkQuery.java | 67 - .../tagIndex/query/MemTableGroupQuery.java | 59 - .../tagIndex/query/MemTableQuery.java | 72 - .../tagIndex/response/QueryResponse.java | 71 - .../tagSchemaRegion/tagIndex/wal/WALEntry.java | 134 -- .../tagSchemaRegion/tagIndex/wal/WALManager.java | 141 -- .../utils/MeasurementPathUtils.java | 80 - .../utils/PathTagConverterUtils.java | 70 - .../utils/ShowTimeSeriesResultUtils.java | 82 -- .../iotdb/lsm/annotation/DeletionProcessor.java | 36 - .../iotdb/lsm/annotation/InsertionProcessor.java | 36 - .../iotdb/lsm/annotation/QueryProcessor.java | 36 - .../applicationcontext/ApplicationContext.java | 61 - .../ApplicationContextGenerator.java | 119 -- .../requestcontext/DeleteRequestContext.java | 34 - .../requestcontext/FlushRequestContext.java | 33 - .../requestcontext/InsertRequestContext.java | 34 - .../requestcontext/QueryRequestContext.java | 34 - .../lsm/context/requestcontext/RequestContext.java | 108 -- .../org/apache/iotdb/lsm/engine/ILSMEngine.java | 73 - .../org/apache/iotdb/lsm/engine/IRecoverable.java | 34 - .../org/apache/iotdb/lsm/engine/LSMEngine.java | 176 --- .../apache/iotdb/lsm/engine/LSMEngineBuilder.java | 290 ---- .../lsm/levelProcess/BasicLevelProcessor.java | 79 - .../lsm/levelProcess/DeleteLevelProcessor.java | 39 - .../lsm/levelProcess/FlushLevelProcessor.java | 38 - .../iotdb/lsm/levelProcess/ILevelProcessor.java | 41 - .../lsm/levelProcess/InsertLevelProcessor.java | 39 - .../lsm/levelProcess/LevelProcessorChain.java | 45 - .../lsm/levelProcess/QueryLevelProcessor.java | 39 - .../apache/iotdb/lsm/manager/BasicLSMManager.java | 55 - .../apache/iotdb/lsm/manager/DeletionManager.java | 48 - .../org/apache/iotdb/lsm/manager/ILSMManager.java | 58 - .../apache/iotdb/lsm/manager/InsertionManager.java | 48 - .../org/apache/iotdb/lsm/manager/QueryManager.java | 32 - .../apache/iotdb/lsm/manager/RecoverManager.java | 49 - .../org/apache/iotdb/lsm/manager/WALManager.java | 126 -- .../apache/iotdb/lsm/request/IDeletionRequest.java | 30 - .../iotdb/lsm/request/IInsertionRequest.java | 30 - .../apache/iotdb/lsm/request/IQueryRequest.java | 35 - .../org/apache/iotdb/lsm/request/IRequest.java | 61 - .../org/apache/iotdb/lsm/request/RequestType.java | 27 - .../org/apache/iotdb/lsm/response/IResponse.java | 46 - .../iotdb/lsm/strategy/BFSAccessStrategy.java | 66 - .../apache/iotdb/lsm/strategy/IAccessStrategy.java | 36 - .../lsm/strategy/PostOrderAccessStrategy.java | 56 - .../iotdb/lsm/strategy/PreOrderAccessStrategy.java | 54 - .../iotdb/lsm/strategy/RBFSAccessStrategy.java | 85 -- .../java/org/apache/iotdb/lsm/wal/IWALReader.java | 48 - .../java/org/apache/iotdb/lsm/wal/IWALRecord.java | 50 - .../java/org/apache/iotdb/lsm/wal/IWALWriter.java | 47 - .../java/org/apache/iotdb/lsm/wal/WALReader.java | 99 -- .../java/org/apache/iotdb/lsm/wal/WALWriter.java | 111 -- .../tagSchemaRegion/TagSchemaRegionTest.java | 233 --- .../idtable/IDTableWithDeviceIDListImplTest.java | 213 --- .../tagIndex/TagTagInvertedIndexTest.java | 184 --- .../apache/iotdb/db/client/ConfigNodeClient.java | 22 + .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 5 +- .../IoTConsensusDataRegionStateMachine.java | 11 +- .../db/engine/storagegroup/TsFileProcessor.java | 39 +- .../db/engine/storagegroup/TsFileResource.java | 58 + .../db/metadata/cache/DataNodeSchemaCache.java | 22 +- .../cache/DeviceUsingTemplateSchemaCache.java | 7 + .../iotdb/db/metadata/cache/SchemaCacheEntry.java | 9 + .../db/metadata/cache/TimeSeriesSchemaCache.java | 70 +- .../db/metadata/mnode/mem/info/BasicMNodeInfo.java | 2 +- .../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 60 +- .../plan/schemaregion/SchemaRegionPlanType.java | 3 + .../plan/schemaregion/SchemaRegionPlanVisitor.java | 17 + .../impl/SchemaRegionPlanDeserializer.java | 25 + .../impl/SchemaRegionPlanSerializer.java | 37 + .../impl/SchemaRegionPlanTxtSerializer.java | 25 + .../impl/write/DeleteLogicalViewPlanImpl.java | 25 +- .../impl/write/PreDeleteLogicalViewPlanImpl.java | 25 +- .../RollbackPreDeleteLogicalViewPlanImpl.java | 28 +- .../impl/write/SchemaRegionWritePlanFactory.java | 29 + .../write/view/IDeleteLogicalViewPlan.java} | 22 +- .../write/view/IPreDeleteLogicalViewPlan.java | 39 +- .../view/IRollbackPreDeleteLogicalViewPlan.java | 34 +- .../reader/SchemaReaderLimitOffsetWrapper.java | 86 ++ .../db/metadata/schemaregion/ISchemaRegion.java | 7 + .../schemaregion/SchemaRegionMemoryImpl.java | 93 +- .../schemaregion/SchemaRegionSchemaFileImpl.java | 15 + .../iotdb/db/metadata/view/ViewPathType.java | 9 +- .../apache/iotdb/db/metadata/view/ViewPaths.java | 97 ++ .../metadata/visitor/SchemaExecutionVisitor.java | 44 +- .../db/mpp/common/header/ColumnHeaderConstant.java | 13 + .../db/mpp/common/header/DatasetHeaderFactory.java | 4 + .../mpp/common/schematree/ClusterSchemaTree.java | 43 + .../common/schematree/IMeasurementSchemaInfo.java | 3 + .../common/schematree/MeasurementSchemaInfo.java | 9 + .../schematree/node/SchemaMeasurementNode.java | 8 + .../execution/exchange/MPPDataExchangeManager.java | 10 +- .../mpp/execution/exchange/SharedTsBlockQueue.java | 16 +- .../execution/executor/RegionWriteExecutor.java | 2 +- .../schema/source/LogicalViewSchemaSource.java | 175 +++ .../schema/source/SchemaSourceFactory.java | 5 + .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 168 ++- .../analyze/schema/ClusterSchemaFetchExecutor.java | 19 + .../plan/analyze/schema/ISchemaComputation.java | 39 + .../mpp/plan/analyze/schema/ISchemaValidation.java | 9 + .../plan/analyze/schema/NormalSchemaFetcher.java | 206 ++- .../plan/execution/config/ConfigTaskVisitor.java | 24 + .../config/executor/ClusterConfigTaskExecutor.java | 206 +++ .../config/executor/IConfigTaskExecutor.java | 12 + .../config/metadata/ShowVariablesTask.java | 4 + .../config/metadata/view/AlterLogicalViewTask.java | 44 + .../metadata/view/DeleteLogicalViewTask.java | 46 + .../metadata/view/RenameLogicalViewTask.java | 45 + .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 99 +- .../db/mpp/plan/planner/LogicalPlanBuilder.java | 9 + .../db/mpp/plan/planner/LogicalPlanVisitor.java | 52 +- .../db/mpp/plan/planner/OperatorTreeGenerator.java | 20 + .../mpp/plan/planner/plan/node/PlanNodeType.java | 20 +- .../db/mpp/plan/planner/plan/node/PlanVisitor.java | 25 +- .../metedata/read/LogicalViewSchemaScanNode.java | 126 ++ .../view/ConstructLogicalViewBlackListNode.java | 91 ++ .../write/{ => view}/CreateLogicalViewNode.java | 2 +- .../metedata/write/view/DeleteLogicalViewNode.java | 91 ++ .../view/RollbackLogicalViewBlackListNode.java | 91 ++ .../plan/node/write/InsertMultiTabletsNode.java | 7 + .../plan/planner/plan/node/write/InsertNode.java | 20 +- .../planner/plan/node/write/InsertRowsNode.java | 7 + .../plan/node/write/InsertRowsOfOneDeviceNode.java | 7 + .../iotdb/db/mpp/plan/statement/StatementType.java | 3 + .../db/mpp/plan/statement/StatementVisitor.java | 24 +- .../plan/statement/crud/InsertBaseStatement.java | 93 ++ .../crud/InsertMultiTabletsStatement.java | 17 + .../plan/statement/crud/InsertRowStatement.java | 128 +- .../crud/InsertRowsOfOneDeviceStatement.java | 21 + .../plan/statement/crud/InsertRowsStatement.java | 17 + .../plan/statement/crud/InsertTabletStatement.java | 135 +- .../metadata/view/AlterLogicalViewStatement.java | 115 ++ .../{ => view}/CreateLogicalViewStatement.java | 122 +- .../metadata/view/DeleteLogicalViewStatement.java | 66 + .../metadata/view/RenameLogicalViewStatement.java | 73 + .../metadata/view/ShowLogicalViewStatement.java | 62 + .../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 41 +- .../core/collector/IoTDBDataRegionCollector.java | 9 +- .../PipeHistoricalDataRegionTsFileCollector.java | 22 +- .../realtime/PipeRealtimeDataRegionCollector.java | 11 + .../PipeRealtimeDataRegionHybridCollector.java | 4 +- .../realtime/assigner/PipeDataRegionAssigner.java | 7 +- .../listener/PipeInsertionDataNodeListener.java | 10 +- .../impl/iotdb/v1/IoTDBThriftConnectorV1.java | 3 +- .../iotdb/db/pipe/core/event/EnrichedEvent.java | 76 +- .../core/event/impl/PipeTabletInsertionEvent.java | 100 +- .../core/event/impl/PipeTsFileInsertionEvent.java | 71 +- .../event/realtime/PipeRealtimeCollectEvent.java | 49 +- .../realtime/PipeRealtimeCollectEventFactory.java | 7 +- .../db/pipe/resource/PipeResourceManager.java | 9 + .../{ => file}/PipeFileResourceManager.java | 2 +- .../db/pipe/resource/wal/PipeWALResource.java | 162 ++ .../pipe/resource/wal/PipeWALResourceManager.java | 111 ++ .../org/apache/iotdb/db/pipe/task/PipeBuilder.java | 26 +- .../org/apache/iotdb/db/pipe/task/PipeTask.java | 7 +- .../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 15 +- .../db/pipe/task/stage/PipeTaskCollectorStage.java | 11 +- .../db/pipe/task/stage/PipeTaskProcessorStage.java | 3 +- .../db/pipe/task/subtask/PipeConnectorSubtask.java | 9 +- .../db/service/metrics/DataNodeMetricsHelper.java | 2 + .../impl/DataNodeInternalRPCServiceImpl.java | 91 ++ .../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 8 +- .../java/org/apache/iotdb/db/wal/node/WALNode.java | 4 +- .../{WALPipeHandler.java => WALEntryHandler.java} | 22 +- .../db/wal/utils/listener/WALFlushListener.java | 10 +- .../TsFileResourceProgressIndexTest.java | 173 +++ .../execution/exchange/LocalSinkChannelTest.java | 14 +- .../execution/exchange/LocalSourceHandleTest.java | 14 +- .../execution/exchange/SharedTsBlockQueueTest.java | 7 +- .../collector/CachedSchemaPatternMatcherTest.java | 14 +- .../core/collector/PipeRealtimeCollectTest.java | 18 +- .../pipe/resource/PipeFileResourceManagerTest.java | 1 + ...peHandlerTest.java => WALEntryHandlerTest.java} | 18 +- .../iotdb/db/wal/utils/WALInsertNodeCacheTest.java | 8 +- 870 files changed, 5591 insertions(+), 34790 deletions(-)
