This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch
beyyes/confignode_ratis_addNewNodeToExistedGroup
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 03aad5ff0d add ADD_NEW_NODE impl for ConfigNodeProcedure
add 55c1ea0edf [IOTDB-4721] Modify Create UDF process on ConfigNode (#7730)
add b268472003 [IOTDB-4756] Register UDF when restart/register DataNode
add ac8283a814 [IOTDB-4616] Support serialization and deserialization for
confignode standalone mode (#7731)
add 3dda1ab202 [IOTDB-4757][IOTDB-4754]Fix concurrent register schema bug
and show timeseries null element (#7728)
add 9f8bcc7692 [IOTDB-4651] Remove Predefined Metric Sets and Add
MultiLeader metrics. (#7602)
add 3130ce9a5f [IOTDB-4660] Implement IntoOperator & ITs (#7665)
add da959a6f24 [IOTDB-4713] Log TException in ConfigNodeClient (#7729)
add 56ef925047 [IOTDB-4667] update the detailed usage method to the
cpp-client readme doc (#7640)
add c26f6559e8 [IOTDB-4722][IOTDB-4723]modify Show & Drop UDF process on
ConfigNode
add baed39decc [IOTDB-4693] Support broken tsfile rewrite (#7677)
add 89e5957683 Change AsyncDataNodeInternalServiceClient level from info
to error and make it simple (#7747)
add dff3d3727e [IOTDB-4679] Unable to connect to iotdb in private-network
using port-mapping (#7721)
add 0767935311 [IOTDB-4758]Delete snapshot after region migration (#7739)
add e259e26cd2 Ignore some old standalone style IT (#7753)
add 0fba3c55ef Update grafana dashboard (#7746)
add 8ff0b58ccb [IOTDB-4520] The tag schema region is implemented and
supports the influxdb protocol (#7424)
add 72c8c18cd5 [IOTDB-4616] Support serialization and deserialization for
confignode standalone mode (#7670)
add 43cbe3a2b8 [IOTDB-4631] [IOTDB-4777] Fixed the bug of concurrent
DataNode deletion (#7744)
add fb1e23b574 [IOTDB-4633] Fix bugs of longToBytes in BytesUtils of
tsfile (#7669)
add 4320baa030 [RatisConsensus] fix snapshot param mistake
add a78085d313 [IOTDB-4644] Support modifying DataNode's RPC IP:Port
(#7620)
add 40e8dd244c Merge branch 'master' into
beyyes/confignode_ratis_addNewNodeToExistedGroup
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/cli/StartClientScriptIT.java | 3 +
client-cpp/README.md | 41 +-
client-py/tests/test_dataframe.py | 4 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 10 +
.../confignode/conf/ConfigNodeDescriptor.java | 8 +-
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 4 +-
.../request/read/GetFunctionTablePlan.java | 25 +-
.../request/write/datanode/UpdateDataNodePlan.java | 71 +
.../request/write/function/CreateFunctionPlan.java | 52 +-
.../consensus/response/DataNodeRegisterResp.java | 3 +-
.../consensus/response/FunctionTableResp.java | 70 +
.../statemachine/PartitionRegionStateMachine.java | 73 +-
.../iotdb/confignode/manager/ConfigManager.java | 39 +-
.../iotdb/confignode/manager/ConsensusManager.java | 179 +-
.../apache/iotdb/confignode/manager/IManager.java | 15 +-
.../iotdb/confignode/manager/TriggerManager.java | 4 +-
.../iotdb/confignode/manager/UDFManager.java | 109 +-
.../iotdb/confignode/manager/load/LoadManager.java | 2 +-
.../manager/load/LoadManagerMetrics.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 63 +-
.../manager/partition/PartitionManager.java | 2 +-
.../iotdb/confignode/persistence/UDFInfo.java | 119 +-
.../persistence/executor/ConfigPlanExecutor.java | 7 +-
.../persistence/metric/NodeInfoMetrics.java | 4 +-
.../persistence/metric/PartitionInfoMetrics.java | 4 +-
.../confignode/persistence/node/NodeInfo.java | 22 +-
.../persistence/partition/PartitionInfo.java | 6 +-
.../iotdb/confignode/procedure/Procedure.java | 6 +-
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 12 +-
.../procedure/env/DataNodeRemoveHandler.java | 26 +-
.../impl/node/RemoveDataNodeProcedure.java | 12 +-
.../confignode/procedure/scheduler/LockQueue.java | 10 +-
.../procedure/state/RemoveDataNodeState.java | 1 +
.../iotdb/confignode/service/ConfigNode.java | 12 +-
.../service/thrift/ConfigNodeRPCService.java | 2 +-
.../thrift/ConfigNodeRPCServiceHandler.java | 2 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 39 +-
.../confignode/writelog/io/BatchLogReader.java | 76 +
.../iotdb/confignode/writelog/io/ILogReader.java | 39 +-
.../writelog/io/SingleFileLogReader.java | 156 ++
.../request/ConfigPhysicalPlanSerDeTest.java | 26 +
.../resources/confignode1conf/iotdb-metric.yml | 5 -
.../resources/confignode2conf/iotdb-metric.yml | 5 -
.../resources/confignode3conf/iotdb-metric.yml | 5 -
.../multileader/MultiLeaderConsensus.java | 12 +
.../multileader/MultiLeaderServerImpl.java | 96 +
.../multileader/MultiLeaderServerMetrics.java | 88 +
.../multileader/client/DispatchLogHandler.java | 15 +
.../multileader/logdispatcher/LogDispatcher.java | 23 +
.../logdispatcher/LogDispatcherThreadMetrics.java | 95 +
.../logdispatcher/MultiLeaderMemoryManager.java | 10 +-
.../MultiLeaderMemoryManagerMetrics.java | 41 +-
.../service/MultiLeaderRPCServiceProcessor.java | 31 +
docs/UserGuide/API/Interface-Comparison.md | 44 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 2 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 6 -
docs/zh/UserGuide/API/Interface-Comparison.md | 44 +-
.../UserGuide/API/Programming-Java-Native-API.md | 2 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 7 -
.../org/apache/iotdb/influxdb/InfluxDBExample.java | 2 +-
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 277 ++-
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 2141 +++++++++++++++++---
.../influxdb/integration/IoTDBInfluxDBIT.java | 7 +-
integration-test/checkstyle.xml | 2 +-
integration-test/import-control.xml | 1 +
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 20 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 20 +
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 42 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 8 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 8 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 8 +-
.../confignode/it/IoTDBClusterPartitionIT.java | 19 +-
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 148 +-
.../iotdb/confignode/it/IoTDBConfigNodeIT.java | 61 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 18 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 115 ++
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 4 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 13 +
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 59 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 528 +++++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 10 +
.../src/test/resources/logback-test.xml | 2 +-
.../db/integration/IoTDBRewriteTsFileToolIT.java | 523 ++++-
.../apache/iotdb/session/pool/SessionPoolTest.java | 4 +-
integration/src/test/resources/logback-test.xml | 2 +-
metrics/ReadMe.md | 9 +-
.../resources/conf/iotdb-confignode-metric.yml | 5 -
.../resources/conf/iotdb-datanode-metric.yml | 5 -
.../iotdb/metrics/AbstractMetricService.java | 19 +-
.../iotdb/metrics/DoNothingMetricService.java | 6 -
.../apache/iotdb/metrics/config/MetricConfig.java | 15 -
.../metrics/config/MetricConfigDescriptor.java | 1 -
.../jvm/JvmClassLoaderMetrics.java | 2 +-
.../{predefined => }/jvm/JvmCompileMetrics.java | 2 +-
.../{predefined => }/jvm/JvmGcMetrics.java | 2 +-
.../{predefined => }/jvm/JvmMemoryMetrics.java | 2 +-
.../{predefined => }/jvm/JvmMetrics.java | 2 +-
.../{predefined => }/jvm/JvmThreadMetrics.java | 2 +-
.../metricsets/{predefined => }/jvm/JvmUtils.java | 2 +-
.../{predefined => }/logback/LogbackMetrics.java | 2 +-
.../logback/MetricsTurboFilter.java | 2 +-
.../iotdb/metrics/config/MetricConfigTest.java | 1 -
.../interface/src/test/resources/iotdb-metric.yml | 8 -
node-commons/pom.xml | 16 +
.../async/AsyncDataNodeInternalServiceClient.java | 2 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 -
.../commons/service/metric}/MetricService.java | 35 +-
.../service/metric}/MetricServiceMBean.java | 2 +-
.../commons/service/metric}/enums/Metric.java | 9 +-
.../commons/service/metric}/enums/Operation.java | 2 +-
.../iotdb/commons/service/metric}/enums/Tag.java | 3 +-
.../org/apache/iotdb/commons/udf/UDFTable.java | 33 +-
.../commons/udf/service/UDFManagementService.java | 21 +-
pom.xml | 1 +
.../java/org/apache/iotdb/RewriteTsFileTool.java | 620 ++++--
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 | 986 +++++++++
.../tagSchemaRegion/config/TagSchemaConfig.java | 55 +
.../config/TagSchemaDescriptor.java | 93 +
.../idtable/IDTableWithDeviceIDListImpl.java | 138 ++
.../tagIndex/ITagInvertedIndex.java | 61 +
.../tagIndex/Request/DeletionRequest.java | 38 +-
.../tagIndex/Request/InsertionRequest.java | 42 +-
.../tagIndex/Request/QueryRequest.java | 29 +-
.../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 | 35 +-
.../tagIndex/memtable/MemChunkGroup.java | 37 +-
.../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 | 73 +
.../iotdb/lsm/annotation/DeletionProcessor.java | 24 +-
.../iotdb/lsm/annotation/InsertionProcessor.java | 24 +-
.../iotdb/lsm/annotation/QueryProcessor.java | 24 +-
.../applicationcontext/ApplicationContext.java | 61 +
.../ApplicationContextGenerator.java | 119 ++
.../requestcontext/DeleteRequestContext.java | 19 +-
.../requestcontext/FlushRequestContext.java | 20 +-
.../requestcontext/InsertRequestContext.java | 19 +-
.../requestcontext/QueryRequestContext.java | 19 +-
.../lsm/context/requestcontext/RequestContext.java | 108 +
.../org/apache/iotdb/lsm/engine/ILSMEngine.java | 73 +
.../org/apache/iotdb/lsm/engine/IRecoverable.java | 21 +-
.../org/apache/iotdb/lsm/engine/LSMEngine.java | 176 ++
.../apache/iotdb/lsm/engine/LSMEngineBuilder.java | 290 +++
.../lsm/levelProcess/BasicLevelProcessor.java | 79 +
.../lsm/levelProcess/DeleteLevelProcessor.java | 22 +-
.../lsm/levelProcess/FlushLevelProcessor.java | 29 +-
.../iotdb/lsm/levelProcess/ILevelProcessor.java | 25 +-
.../lsm/levelProcess/InsertLevelProcessor.java | 22 +-
.../lsm/levelProcess/LevelProcessorChain.java | 45 +
.../lsm/levelProcess/QueryLevelProcessor.java | 22 +-
.../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 | 17 +-
.../apache/iotdb/lsm/manager/RecoverManager.java | 40 +-
.../org/apache/iotdb/lsm/manager/WALManager.java | 126 ++
.../apache/iotdb/lsm/request/IDeletionRequest.java | 13 +-
.../iotdb/lsm/request/IInsertionRequest.java | 13 +-
.../apache/iotdb/lsm/request/IQueryRequest.java | 18 +-
.../org/apache/iotdb/lsm/request/IRequest.java | 58 +-
.../org/apache/iotdb/lsm/request/RequestType.java | 18 +-
.../org/apache/iotdb/lsm/response/IResponse.java | 28 +-
.../iotdb/lsm/strategy/BFSAccessStrategy.java | 66 +
.../apache/iotdb/lsm/strategy/IAccessStrategy.java | 22 +-
.../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 | 30 +-
.../java/org/apache/iotdb/lsm/wal/IWALRecord.java | 41 +-
.../java/org/apache/iotdb/lsm/wal/IWALWriter.java | 29 +-
.../java/org/apache/iotdb/lsm/wal/WALReader.java | 99 +
.../java/org/apache/iotdb/lsm/wal/WALWriter.java | 111 +
.../tagSchemaRegion/TagSchemaRegionTest.java | 231 +++
.../idtable/IDTableWithDeviceIDListImplTest.java | 212 ++
.../tagIndex/TagTagInvertedIndexTest.java | 184 ++
server/pom.xml | 10 -
.../resources/conf/iotdb-datanode.properties | 1 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 331 +++
.../iotdb/db/client/DataNodeInternalClient.java | 129 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 5 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 101 +
.../iotdb/db/engine/TsFileMetricManager.java | 7 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 2 +-
.../iotdb/db/engine/cache/ChunkCacheMetrics.java | 4 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 2 +-
.../cache/TimeSeriesMetadataCacheMetrics.java | 4 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 2 +-
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 4 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 6 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 6 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../db/engine/storagegroup/DataRegionMetrics.java | 4 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 2 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 6 +-
.../iotdb/db/exception/IntoProcessException.java | 16 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 2 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 4 +-
.../db/metadata/idtable/entry/DiskSchemaEntry.java | 9 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 247 ++-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 128 +-
.../db/metadata/rescon/SchemaResourceManager.java | 2 +-
.../rescon/SchemaStatisticsManagerMetrics.java | 4 +-
.../apache/iotdb/db/mpp/common/SessionInfo.java | 19 +
.../execution/exchange/MPPDataExchangeService.java | 2 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 4 +-
.../MPPDataExchangeServiceThriftHandler.java | 2 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 6 +-
.../fragment/FragmentInstanceContext.java | 29 +-
.../fragment/FragmentInstanceManager.java | 6 +-
.../db/mpp/execution/operator/OperatorContext.java | 5 +
.../operator/process/AbstractIntoOperator.java | 384 ++++
.../operator/process/DeviceViewIntoOperator.java | 140 ++
.../execution/operator/process/IntoOperator.java | 104 +
.../process/RawDataAggregationOperator.java | 2 +-
.../process/SingleInputAggregationOperator.java | 2 -
.../process/SlidingWindowAggregationOperator.java | 2 +-
.../schema/TimeSeriesSchemaScanOperator.java | 9 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 40 +
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 7 +
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 123 ++
.../planner/distribution/ExchangeNodeAdder.java | 6 +-
.../SimpleFragmentParallelPlanner.java | 1 +
.../plan/planner/distribution/SourceRewriter.java | 11 +-
.../distribution/WriteFragmentParallelPlanner.java | 3 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 22 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 10 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 10 +
.../metedata/read/SchemaQueryOrderByHeatNode.java | 4 +-
.../planner/plan/node/process/AggregationNode.java | 23 +-
.../planner/plan/node/process/DeviceMergeNode.java | 32 +-
.../{TimeJoinNode.java => DeviceViewIntoNode.java} | 95 +-
.../planner/plan/node/process/DeviceViewNode.java | 19 +-
.../planner/plan/node/process/ExchangeNode.java | 41 +-
.../plan/planner/plan/node/process/FillNode.java | 46 +-
.../plan/node/process/GroupByLevelNode.java | 29 +-
.../planner/plan/node/process/GroupByTagNode.java | 17 +-
.../node/process/{LimitNode.java => IntoNode.java} | 94 +-
.../plan/planner/plan/node/process/LimitNode.java | 37 +-
...tiChildNode.java => MultiChildProcessNode.java} | 23 +-
.../plan/planner/plan/node/process/OffsetNode.java | 36 +-
.../planner/plan/node/process/ProjectNode.java | 40 +-
...iChildNode.java => SingleChildProcessNode.java} | 50 +-
.../node/process/SlidingWindowAggregationNode.java | 36 +-
.../plan/planner/plan/node/process/SortNode.java | 29 +-
.../planner/plan/node/process/TimeJoinNode.java | 17 +-
.../planner/plan/node/process/TransformNode.java | 29 +-
.../node/process/last/LastQueryCollectNode.java | 4 +-
.../plan/node/process/last/LastQueryMergeNode.java | 4 +-
.../plan/node/process/last/LastQueryNode.java | 4 +-
.../parameter/DeviceViewIntoPathDescriptor.java | 11 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 10 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 6 +-
.../plan/statement/component/IntoComponent.java | 8 +-
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 18 +-
.../influxdb/handler/AbstractQueryHandler.java | 90 +-
.../protocol/influxdb/handler/NewQueryHandler.java | 114 +-
.../db/protocol/influxdb/handler/QueryHandler.java | 79 +-
.../influxdb/handler/QueryHandlerFactory.java | 45 +
.../protocol/influxdb/handler/TagQueryHandler.java | 140 ++
.../influxdb/meta/AbstractInfluxDBMetaManager.java | 46 +-
.../influxdb/meta/IInfluxDBMetaManager.java | 66 +
.../influxdb/meta/InfluxDBMetaManager.java | 71 +
.../influxdb/meta/InfluxDBMetaManagerFactory.java | 45 +
.../influxdb/meta/NewInfluxDBMetaManager.java | 55 +-
.../influxdb/meta/TagInfluxDBMetaManager.java | 191 ++
.../protocol/influxdb/util/QueryResultUtils.java | 102 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 2 +-
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 147 +-
.../db/service/DataNodeInternalRPCService.java | 2 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 4 +-
.../db/service/DataNodeServerCommandLine.java | 10 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 5 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 5 +-
.../org/apache/iotdb/db/service/RPCService.java | 2 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 4 +-
.../db/service/ResourcesInformationHolder.java | 12 +
...erviceMBean.java => DataNodeMetricsHelper.java} | 25 +-
.../metrics/{predefined => }/FileMetrics.java | 6 +-
.../metrics/{predefined => }/ProcessMetrics.java | 6 +-
.../metrics/{predefined => }/SystemMetrics.java | 6 +-
.../metrics/recorder/CacheMetricsRecorder.java | 6 +-
.../recorder/CompactionMetricsRecorder.java | 6 +-
.../db/service/thrift/ProcessorWithMetrics.java | 6 +-
.../handler/InternalServiceThriftHandler.java | 2 +-
.../InternalServiceThriftHandlerMetrics.java | 4 +-
.../thrift/handler/RPCServiceThriftHandler.java | 2 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 4 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 6 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 3 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 75 +-
.../db/service/thrift/impl/TSServiceImpl.java | 4 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeFailTest.java | 87 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 8 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 10 +-
.../plan/plan/node/process/IntoNodeSerdeTest.java | 83 +
.../plan/scheduler/StandaloneSchedulerTest.java | 18 +-
.../test/resources/datanode1conf/iotdb-metric.yml | 7 +-
.../test/resources/datanode2conf/iotdb-metric.yml | 7 +-
.../test/resources/datanode3conf/iotdb-metric.yml | 7 +-
server/src/test/resources/logback-test.xml | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
.../java/org/apache/iotdb/session/ISession.java | 4 +-
.../java/org/apache/iotdb/session/Session.java | 258 ++-
.../org/apache/iotdb/session/SessionConfig.java | 2 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 48 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 4 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 2 +-
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 2 +-
.../src/main/thrift/confignode.thrift | 46 +-
.../src/main/thrift/mutlileader.thrift | 10 +
.../org/apache/iotdb/tsfile/read/common/Path.java | 72 +-
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 6 +
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 47 +
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 3 +
344 files changed, 15603 insertions(+), 2677 deletions(-)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetFunctionTablePlan.java
(54%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/datanode/UpdateDataNodePlan.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/FunctionTableResp.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/writelog/io/BatchLogReader.java
copy
server/src/main/java/org/apache/iotdb/db/service/ResourcesInformationHolder.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/writelog/io/ILogReader.java
(50%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/writelog/io/SingleFileLogReader.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerMetrics.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcherThreadMetrics.java
copy
server/src/main/java/org/apache/iotdb/db/engine/cache/ChunkCacheMetrics.java =>
consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/MultiLeaderMemoryManagerMetrics.java
(58%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/utils/ConfigNodeTestUtils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/selectinto/IoTDBSelectInto2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/selectinto/IoTDBSelectIntoIT.java
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/jvm/JvmClassLoaderMetrics.java (97%)
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/jvm/JvmCompileMetrics.java (97%)
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/jvm/JvmGcMetrics.java (99%)
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/jvm/JvmMemoryMetrics.java (98%)
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/jvm/JvmMetrics.java (96%)
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/jvm/JvmThreadMetrics.java (98%)
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/jvm/JvmUtils.java (96%)
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/logback/LogbackMetrics.java (98%)
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/{predefined
=> }/logback/MetricsTurboFilter.java (98%)
rename {server/src/main/java/org/apache/iotdb/db/service/metrics =>
node-commons/src/main/java/org/apache/iotdb/commons/service/metric}/MetricService.java
(76%)
copy {server/src/main/java/org/apache/iotdb/db/service/metrics =>
node-commons/src/main/java/org/apache/iotdb/commons/service/metric}/MetricServiceMBean.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db/service/metrics =>
node-commons/src/main/java/org/apache/iotdb/commons/service/metric}/enums/Metric.java
(92%)
copy {server/src/main/java/org/apache/iotdb/db/service/metrics =>
node-commons/src/main/java/org/apache/iotdb/commons/service/metric}/enums/Operation.java
(96%)
copy {server/src/main/java/org/apache/iotdb/db/service/metrics =>
node-commons/src/main/java/org/apache/iotdb/commons/service/metric}/enums/Tag.java
(93%)
create mode 100644 schema-engine-tag/README.md
create mode 100644 schema-engine-tag/pom.xml
create mode 100644
schema-engine-tag/src/assembly/resources/conf/schema-tag.properties
create mode 100644 schema-engine-tag/src/assembly/schema-engine-tag.xml
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/TagSchemaRegion.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/config/TagSchemaConfig.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/config/TagSchemaDescriptor.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/idtable/IDTableWithDeviceIDListImpl.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/ITagInvertedIndex.java
copy
server/src/main/java/org/apache/iotdb/db/service/ResourcesInformationHolder.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/DeletionRequest.java
(54%)
copy
server/src/main/java/org/apache/iotdb/db/service/ResourcesInformationHolder.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/InsertionRequest.java
(52%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/QueryRequest.java
(58%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/TagInvertedIndex.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemChunkDeletion.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemChunkGroupDeletion.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemTableDeletion.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemTableGroupDeletion.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemChunkGroupInsertion.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemChunkInsertion.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemTableGroupInsertion.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemTableInsertion.java
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemChunk.java
(53%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemChunkGroup.java
(53%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemTable.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemTableGroup.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemChunkGroupQuery.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemChunkQuery.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemTableGroupQuery.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemTableQuery.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/response/QueryResponse.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/wal/WALEntry.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/wal/WALManager.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/MeasurementPathUtils.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/PathTagConverterUtils.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/ShowTimeSeriesResultUtils.java
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/DeletionProcessor.java
(58%)
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/InsertionProcessor.java
(57%)
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/QueryProcessor.java
(58%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/applicationcontext/ApplicationContext.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/applicationcontext/ApplicationContextGenerator.java
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/DeleteRequestContext.java
(64%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/FlushRequestContext.java
(64%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/InsertRequestContext.java
(64%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/QueryRequestContext.java
(65%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/RequestContext.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/ILSMEngine.java
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/IRecoverable.java
(62%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/LSMEngine.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/LSMEngineBuilder.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/BasicLevelProcessor.java
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/DeleteLevelProcessor.java
(56%)
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Operation.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/FlushLevelProcessor.java
(57%)
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/ILevelProcessor.java
(52%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/InsertLevelProcessor.java
(56%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/LevelProcessorChain.java
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/QueryLevelProcessor.java
(57%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/BasicLSMManager.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/DeletionManager.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/ILSMManager.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/InsertionManager.java
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/QueryManager.java
(63%)
rename
server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Operation.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/RecoverManager.java
(55%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/WALManager.java
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IDeletionRequest.java
(73%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IInsertionRequest.java
(73%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IQueryRequest.java
(70%)
copy
server/src/main/java/org/apache/iotdb/db/service/ResourcesInformationHolder.java
=> schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IRequest.java
(54%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/RequestType.java
(81%)
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/response/IResponse.java
(56%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/BFSAccessStrategy.java
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
=>
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/IAccessStrategy.java
(59%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/PostOrderAccessStrategy.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/PreOrderAccessStrategy.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/RBFSAccessStrategy.java
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
=> schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALReader.java
(58%)
copy
server/src/main/java/org/apache/iotdb/db/service/ResourcesInformationHolder.java
=> schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALRecord.java
(55%)
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
=> schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALWriter.java
(62%)
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/WALReader.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/WALWriter.java
create mode 100644
schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/TagSchemaRegionTest.java
create mode 100644
schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/idtable/IDTableWithDeviceIDListImplTest.java
create mode 100644
schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/TagTagInvertedIndexTest.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/client/DataNodeInternalClient.java
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/PredefinedMetric.java
=>
server/src/main/java/org/apache/iotdb/db/exception/IntoProcessException.java
(75%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/DeviceViewIntoOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/IntoOperator.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{TimeJoinNode.java
=> DeviceViewIntoNode.java} (50%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{LimitNode.java
=> IntoNode.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{MultiChildNode.java
=> MultiChildProcessNode.java} (77%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{MultiChildNode.java
=> SingleChildProcessNode.java} (59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/QueryHandlerFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/TagQueryHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/IInfluxDBMetaManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/InfluxDBMetaManagerFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/TagInfluxDBMetaManager.java
rename
server/src/main/java/org/apache/iotdb/db/service/metrics/{MetricServiceMBean.java
=> DataNodeMetricsHelper.java} (50%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{predefined =>
}/FileMetrics.java (97%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{predefined =>
}/ProcessMetrics.java (97%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{predefined =>
}/SystemMetrics.java (98%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/IntoNodeSerdeTest.java
