This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch IOTDB-4619
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 71c85ad049 fix ut
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 236dceb3ba Merge remote-tracking branch 'origin/master' into IOTDB-4619
add 60861b12fd fix ut
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/cli/StartClientScriptIT.java | 3 +
.../iotdb/confignode/persistence/TriggerInfo.java | 2 +-
.../multileader/MultiLeaderConsensus.java | 12 +
.../multileader/MultiLeaderServerImpl.java | 31 +
.../service/MultiLeaderRPCServiceProcessor.java | 31 +
.../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 +-
pom.xml | 1 +
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 | 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 | 73 +
.../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 | 231 +++
.../idtable/IDTableWithDeviceIDListImplTest.java | 212 ++
.../tagIndex/TagTagInvertedIndexTest.java | 184 ++
.../db/metadata/idtable/entry/DiskSchemaEntry.java | 9 +
.../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 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 3 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 75 +-
.../src/main/thrift/mutlileader.thrift | 10 +
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 3 +
110 files changed, 10134 insertions(+), 566 deletions(-)
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
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/DeletionRequest.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/InsertionRequest.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/QueryRequest.java
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
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemChunk.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemChunkGroup.java
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
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/DeletionProcessor.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/InsertionProcessor.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/QueryProcessor.java
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
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/DeleteRequestContext.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/FlushRequestContext.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/InsertRequestContext.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/QueryRequestContext.java
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
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/IRecoverable.java
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
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/DeleteLevelProcessor.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/FlushLevelProcessor.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/ILevelProcessor.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/InsertLevelProcessor.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/LevelProcessorChain.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/QueryLevelProcessor.java
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
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/QueryManager.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/RecoverManager.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/WALManager.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IDeletionRequest.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IInsertionRequest.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IQueryRequest.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IRequest.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/RequestType.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/response/IResponse.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/BFSAccessStrategy.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/IAccessStrategy.java
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
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALReader.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALRecord.java
create mode 100644
schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALWriter.java
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/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
