You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2023/05/25 12:18:53 UTC
[iotdb] 05/05: Merge branch 'master' of github.com:apache/iotdb into pipe-wal-resource-management
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 <ro...@apache.org>
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(-)