This is an automated email from the ASF dual-hosted git repository.
zyk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0fba3c55ef Update grafana dashboard (#7746)
add 8ff0b58ccb [IOTDB-4520] The tag schema region is implemented and
supports the influxdb protocol (#7424)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/influxdb/InfluxDBExample.java | 2 +-
.../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 +-
101 files changed, 8009 insertions(+), 181 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
