This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-wal-resource-management in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 384786b6a84af3777c56f694036c6c5a50397307 Merge: 77ce31eb61d 05a54dc13d3 Author: Steve Yurong Su <[email protected]> AuthorDate: Thu May 25 19:57:19 2023 +0800 Merge branch 'master' of github.com:apache/iotdb into pipe-wal-resource-management .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 +- client-go | 1 - .../heartbeat/DataNodeHeartbeatHandler.java | 10 +- .../consensus/request/ConfigPhysicalPlan.java | 6 +- .../consensus/request/ConfigPhysicalPlanType.java | 1 + .../PipeHandleLeaderChangePlan.java | 2 +- .../pipe/runtime/PipeHandleMetaChangePlan.java | 67 + .../iotdb/confignode/manager/ConfigManager.java | 1 + .../iotdb/confignode/manager/ProcedureManager.java | 22 + .../manager/load/service/HeartbeatService.java | 16 +- .../iotdb/confignode/manager/node/NodeManager.java | 4 +- .../manager/partition/PartitionMetrics.java | 35 +- .../pipe/runtime/PipeRuntimeCoordinator.java | 21 + .../manager/schema/ClusterSchemaManager.java | 3 +- .../persistence/executor/ConfigPlanExecutor.java | 7 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 13 +- .../persistence/pipe/PipeTaskOperation.java | 2 +- .../procedure/env/DataNodeRemoveHandler.java | 2 + .../runtime/PipeHandleLeaderChangeProcedure.java | 2 +- .../runtime/PipeHandleMetaChangeProcedure.java | 285 ++++ .../impl/schema/DeleteDatabaseProcedure.java | 4 +- .../procedure/store/ProcedureFactory.java | 6 + .../confignode/procedure/store/ProcedureType.java | 3 +- .../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 8 +- .../thrift/ConfigNodeRPCServiceMetrics.java | 8 +- .../request/ConfigPhysicalPlanSerDeTest.java | 44 +- .../iotdb/confignode/persistence/PipeInfoTest.java | 1 - .../runtime/PipeHandleMetaChangeProcedureTest.java | 96 ++ .../consensus/iot/IoTConsensusServerImpl.java | 87 +- .../consensus/iot/IoTConsensusServerMetrics.java | 327 ++-- .../consensus/iot/client/DispatchLogHandler.java | 25 +- .../consensus/iot/logdispatcher/LogDispatcher.java | 32 +- .../logdispatcher/LogDispatcherThreadMetrics.java | 194 ++- .../ratis/ApplicationStateMachineProxy.java | 2 +- .../iotdb/consensus/simple/SimpleConsensus.java | 2 +- 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 +- grafana-plugin/go.sum | 660 --------- influxdb-protocol/pom.xml | 140 -- .../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 411 ------ .../iotdb/influxdb/IoTDBInfluxDBFactory.java | 70 - .../protocol/constant/InfluxDBConstant.java | 25 - .../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 - 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 - .../iotdb/itbase/category/LocalStandaloneTest.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 | 0 .../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 | 3 - .../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 | 7 - .../apache/iotdb/session/SessionConnection.java | 0 .../org/apache/iotdb/session/pool/SessionPool.java | 16 - .../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 | 1 + .../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 | 2 + .../java/org/apache/iotdb/metrics/type/Gauge.java | 1 - .../apache/iotdb/commons/conf/CommonConfig.java | 10 + .../iotdb/commons/conf/CommonDescriptor.java | 3 + .../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 13 +- .../schema/view/viewExpression/ViewExpression.java | 2 + .../{enums => }/PerformanceOverviewMetrics.java | 4 +- .../iotdb/commons/service/metric/enums/Metric.java | 192 +-- .../iotdb/commons/service/metric/enums/Tag.java | 26 +- 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/DeletionRequest.java | 55 - .../tagIndex/Request/InsertionRequest.java | 59 - .../tagIndex/Request/QueryRequest.java | 46 - .../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 --- .../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +- .../org/apache/iotdb/db/engine/StorageEngine.java | 4 +- .../apache/iotdb/db/engine/cache/ChunkCache.java | 11 +- .../db/engine/cache/TimeSeriesMetadataCache.java | 7 +- .../execute/task/AbstractCompactionTask.java | 6 +- .../execute/task/CrossSpaceCompactionTask.java | 4 +- .../execute/task/InnerSpaceCompactionTask.java | 4 +- .../readchunk/AlignedSeriesCompactionExecutor.java | 8 +- .../readchunk/SingleSeriesCompactionExecutor.java | 10 +- .../utils/writer/AbstractCompactionWriter.java | 4 +- .../schedule/constant/CompactionType.java | 17 +- .../schedule/constant/ProcessChunkType.java | 17 +- .../iotdb/db/engine/flush/FlushManagerMetrics.java | 8 +- .../iotdb/db/engine/flush/MemTableFlushTask.java | 3 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 11 +- .../db/engine/storagegroup/DataRegionMetrics.java | 8 +- .../db/engine/storagegroup/TsFileProcessor.java | 21 +- .../metadata/cache/DataNodeSchemaCacheMetrics.java | 12 +- .../db/metadata/metric/SchemaEngineMemMetric.java | 5 +- .../impl/write/CreateLogicalViewPlanImpl.java | 6 +- .../impl/write/SchemaRegionWritePlanFactory.java | 2 + .../schemaregion/SchemaRegionMemoryImpl.java | 10 + .../iotdb/db/mpp/aggregation/Aggregator.java | 15 +- .../db/mpp/common/header/ColumnHeaderConstant.java | 2 + .../mpp/common/schematree/ClusterSchemaTree.java | 27 +- .../db/mpp/common/schematree/ISchemaTree.java | 7 + .../iotdb/db/mpp/execution/driver/DataDriver.java | 3 +- .../iotdb/db/mpp/execution/driver/Driver.java | 5 +- .../execution/exchange/MPPDataExchangeManager.java | 22 +- .../exchange/MPPDataExchangeServiceMetrics.java | 8 - ...MppDataExchangeServiceThriftHandlerMetrics.java | 35 +- .../execution/exchange/sink/LocalSinkChannel.java | 7 +- .../execution/exchange/sink/ShuffleSinkHandle.java | 8 +- .../mpp/execution/exchange/sink/SinkChannel.java | 15 +- .../exchange/source/LocalSourceHandle.java | 11 +- .../execution/exchange/source/SourceHandle.java | 21 +- .../execution/executor/RegionWriteExecutor.java | 2 +- .../fragment/FragmentInstanceManager.java | 8 +- .../iotdb/db/mpp/execution/memory/MemoryPool.java | 12 +- .../execution/operator/source/SeriesScanUtil.java | 9 +- .../db/mpp/execution/schedule/DriverScheduler.java | 9 +- .../iotdb/db/mpp/metric/ChunkCacheMetrics.java | 14 +- .../db/mpp/metric/DataExchangeCostMetricSet.java | 345 +++-- .../db/mpp/metric/DataExchangeCountMetricSet.java | 200 ++- .../db/mpp/metric/DriverSchedulerMetricSet.java | 88 +- .../db/mpp/metric/QueryExecutionMetricSet.java | 206 ++- .../iotdb/db/mpp/metric/QueryMetricsManager.java | 122 +- .../db/mpp/metric/QueryPlanCostMetricSet.java | 86 +- .../db/mpp/metric/QueryResourceMetricSet.java | 77 +- .../db/mpp/metric/SeriesScanCostMetricSet.java | 1117 +++++++++----- .../mpp/metric/TimeSeriesMetadataCacheMetrics.java | 22 +- .../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 27 + .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 277 +++- .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 4 +- .../db/mpp/plan/analyze/ExpressionAnalyzer.java | 37 + .../db/mpp/plan/analyze/cache/PartitionCache.java | 52 +- .../db/mpp/plan/execution/QueryExecution.java | 17 +- .../config/metadata/ShowVariablesTask.java | 4 + .../iotdb/db/mpp/plan/expression/Expression.java | 20 + .../plan/expression/binary/BinaryExpression.java | 22 + .../plan/expression/binary/WhenThenExpression.java | 7 + .../db/mpp/plan/expression/leaf/LeafOperand.java | 5 + .../plan/expression/multi/FunctionExpression.java | 21 + .../expression/other/CaseWhenThenExpression.java | 17 + .../plan/expression/ternary/BetweenExpression.java | 9 + .../plan/expression/ternary/TernaryExpression.java | 18 +- .../db/mpp/plan/expression/unary/InExpression.java | 26 +- .../plan/expression/unary/IsNullExpression.java | 5 + .../mpp/plan/expression/unary/LikeExpression.java | 5 + .../plan/expression/unary/LogicNotExpression.java | 9 + .../plan/expression/unary/NegationExpression.java | 11 + .../plan/expression/unary/RegularExpression.java | 5 + .../mpp/plan/expression/unary/UnaryExpression.java | 6 +- .../visitor/CompleteMeasurementSchemaVisitor.java | 112 ++ .../RemoveWildcardAndViewInExpressionVisitor.java | 95 ++ .../RemoveWildcardAndViewInFilterVisitor.java | 109 ++ .../visitor/ReplaceLogicalViewVisitor.java | 188 +++ .../db/mpp/plan/parser/StatementGenerator.java | 2 +- .../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 4 +- .../plan/scheduler/AsyncSendPlanNodeHandler.java | 2 +- .../db/mpp/plan/scheduler/ClusterScheduler.java | 7 +- .../scheduler/FixedRateFragInsStateTracker.java | 14 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 10 +- .../plan/scheduler/IFragInstanceStateTracker.java | 4 +- .../mpp/plan/scheduler/SimpleQueryTerminator.java | 52 +- .../metadata/CreateLogicalViewStatement.java | 26 +- .../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 31 + .../query/reader/chunk/DiskAlignedChunkLoader.java | 10 +- .../db/query/reader/chunk/DiskChunkLoader.java | 10 +- .../query/reader/chunk/MemAlignedChunkLoader.java | 10 +- .../db/query/reader/chunk/MemChunkLoader.java | 10 +- .../metadata/DiskAlignedChunkMetadataLoader.java | 11 +- .../chunk/metadata/DiskChunkMetadataLoader.java | 11 +- .../metadata/MemAlignedChunkMetadataLoader.java | 10 +- .../chunk/metadata/MemChunkMetadataLoader.java | 9 +- .../service/DataNodeInternalRPCServiceMetrics.java | 8 +- .../apache/iotdb/db/service/RPCServiceMetrics.java | 8 +- .../iotdb/db/service/metrics/CacheMetrics.java | 144 ++ .../db/service/metrics/CompactionMetrics.java | 396 ++++- .../db/service/metrics/DataNodeMetricsHelper.java | 20 +- .../iotdb/db/service/metrics/SystemMetrics.java | 43 +- .../iotdb/db/service/metrics/WritingMetrics.java | 574 +++++++- .../metrics/recorder/CacheMetricsRecorder.java | 57 - .../metrics/recorder/CompactionMetricsManager.java | 240 --- .../metrics/recorder/WritingMetricsManager.java | 351 ----- .../InternalServiceThriftHandlerMetrics.java | 8 +- .../handler/RPCServiceThriftHandlerMetrics.java | 8 +- .../impl/DataNodeInternalRPCServiceImpl.java | 4 + .../org/apache/iotdb/db/utils/FileLoaderUtils.java | 17 +- .../java/org/apache/iotdb/db/wal/WALManager.java | 6 +- .../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 4 +- .../iotdb/db/wal/checkpoint/CheckpointManager.java | 4 +- .../iotdb/db/wal/checkpoint/CheckpointType.java | 16 +- .../java/org/apache/iotdb/db/wal/node/WALNode.java | 4 +- .../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 2 +- .../mpp/plan/analyze/ExpressionAnalyzerTest.java | 4 +- 872 files changed, 5322 insertions(+), 36649 deletions(-)
