This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch opt_getDataRegionReplicaSetForWriting
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 843d8cc670 optimize some usage of map
add 152c10bf67 [IOTDB-5882] Support create empty schema template (#9858)
add dd86d1aca2 fix only loading one data directory when start iotdb (#9791)
add 4f5bca4215 Update status code and document about SCHEMA_QUOTA_EXCEEDED
(#9867)
add c9db11cca0 [IOTDB-5881] Support path contains filter in show
timeseries and show devices (#9857)
add e2aa814482 [IOTDB-5884] Throw Exception when alter template with
duplicate measurement (#9864)
add a70d3c827e [IOTDB-5862] optimize thrift metrics precision
add ab43262e39 [IOTDB-5885] Add exception when measurement already exists
in schema template (#9866)
add 54a3ca765a add a note to clarify that connecting to iotdb requires
changing the RPC address (#9868)
add 1e6475dac1 [IOTDB-5888] Fix some logs didn't consider timestamp
precision (#9870)
add da53260b3e [IOTDB-5892] Support keyword VIEW as identifiers (#9875)
add b4002f3f7d [IOTDB-5881] Schema query supports case-insensitive path
contains filter (#9877)
add e66c4e502b Support schema cache when querying all measurement of
devices using template (#9871)
add 8111c1fd18 [To rel/1.1][IOTDB-5880] Catch Throwable in SessionPool
(#9856) (#9873)
add 1cd0caf3de [IOTDB-5871]Prevent large seq files from participating
cross space compaction (#9842)
add 188be935ab fix not releasing read lock when fail to allocate memory
for compaction task (#9872) (#9880)
add ef10a20a3e Support logic view - move schema validation to analyze
phase (#9767)
add 6a08bfb676 fix compilation problem (#9883)
add 1ac19b25b5 Merge branch 'master' of https://github.com/apache/iotdb
into opt_getDataRegionReplicaSetForWriting
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 39 ++-
.../manager/schema/ClusterSchemaManager.java | 32 ++-
docs/UserGuide/Operate-Metadata/Node.md | 4 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 65 +++--
docs/UserGuide/QuickStart/QuickStart.md | 2 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 12 +-
docs/UserGuide/Reference/Keywords.md | 1 +
docs/UserGuide/Reference/Status-Codes.md | 2 +
docs/zh/UserGuide/Operate-Metadata/Node.md | 4 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 60 +++-
docs/zh/UserGuide/QuickStart/QuickStart.md | 3 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 8 +-
docs/zh/UserGuide/Reference/Keywords.md | 1 +
docs/zh/UserGuide/Reference/Status-Codes.md | 258 ++++++++---------
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 9 +
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 99 ++++++-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 45 +++
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 3 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 10 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 20 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 92 ++++++
.../resources/conf/iotdb-common.properties | 3 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 47 ++-
.../apache/iotdb/commons/path/PathPatternNode.java | 2 +-
.../apache/iotdb/commons/path/PathPatternUtil.java | 52 ++++
.../iotdb/commons/path/fa/nfa/SimpleNFA.java | 3 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 72 +++++
.../filter/SchemaFilterType.java} | 36 ++-
.../commons/schema/filter/SchemaFilterVisitor.java | 54 ++++
.../schema/filter/impl/PathContainsFilter.java | 64 +++++
.../commons/schema/filter/impl/TagFilter.java | 83 ++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 +-
.../exception/CompactionExceptionHandler.java | 2 +-
.../execute/task/CrossSpaceCompactionTask.java | 39 +--
.../execute/task/InnerSpaceCompactionTask.java | 6 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 26 +-
.../impl/SizeTieredCompactionSelector.java | 2 +-
.../utils/CrossSpaceCompactionCandidate.java | 6 +-
.../memtable/AlignedWritableMemChunkGroup.java | 10 +-
.../db/engine/memtable/WritableMemChunkGroup.java | 10 +-
.../db/engine/settle/SettleRequestHandler.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 12 +-
.../db/engine/storagegroup/TsFileResource.java | 8 +-
.../engine/storagegroup/TsFileResourceStatus.java | 3 +-
.../db/exception/query/OutOfTTLException.java | 4 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 4 +
.../cache/DeviceUsingTemplateSchemaCache.java | 32 +++
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 12 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 15 +-
.../db/metadata/mtree/traverser/Traverser.java | 7 +
.../mtree/traverser/basic/EntityTraverser.java | 31 +-
.../traverser/basic/MeasurementTraverser.java | 30 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 37 +--
.../impl/read/ShowDevicesPlanImpl.java | 15 +-
.../impl/read/ShowTimeSeriesPlanImpl.java | 37 +--
.../plan/schemaregion/read/IShowDevicesPlan.java | 4 +
.../schemaregion/read/IShowTimeSeriesPlan.java | 7 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 5 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 5 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 16 +-
.../metadata/template/ClusterTemplateManager.java | 4 +-
.../template/alter/TemplateExtendInfo.java | 78 +++++
.../execution/executor/RegionWriteExecutor.java | 40 +--
.../operator/schema/source/DeviceSchemaSource.java | 13 +-
.../schema/source/SchemaSourceFactory.java | 27 +-
.../schema/source/TimeSeriesSchemaSource.java | 17 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 16 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 94 +++++-
.../analyze/schema/AutoCreateSchemaExecutor.java | 10 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 50 +++-
.../mpp/plan/analyze/schema/SchemaValidator.java | 27 +-
.../db/mpp/plan/execution/QueryExecution.java | 10 +-
.../config/executor/ClusterConfigTaskExecutor.java | 21 ++
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 70 +++--
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 47 ++-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 85 +++---
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 21 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 23 +-
.../metedata/read/LevelTimeSeriesCountNode.java | 47 +--
.../node/metedata/read/TimeSeriesCountNode.java | 43 +--
.../metedata/read/TimeSeriesSchemaScanNode.java | 95 ++----
.../planner/plan/node/write/BatchInsertNode.java | 33 ---
.../plan/node/write/InsertMultiTabletsNode.java | 22 +-
.../plan/planner/plan/node/write/InsertNode.java | 126 +-------
.../planner/plan/node/write/InsertRowNode.java | 171 ++---------
.../planner/plan/node/write/InsertRowsNode.java | 33 +--
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 32 +--
.../planner/plan/node/write/InsertTabletNode.java | 145 ++--------
.../scheduler/FragmentInstanceDispatcherImpl.java | 5 +-
.../plan/statement/crud/InsertBaseStatement.java | 157 +++++++++-
.../crud/InsertMultiTabletsStatement.java | 30 ++
.../plan/statement/crud/InsertRowStatement.java | 183 +++++++++++-
.../crud/InsertRowsOfOneDeviceStatement.java | 42 +++
.../plan/statement/crud/InsertRowsStatement.java | 41 +++
.../plan/statement/crud/InsertTabletStatement.java | 155 +++++++++-
.../metadata/CountLevelTimeSeriesStatement.java | 30 +-
.../metadata/CountTimeSeriesStatement.java | 30 +-
.../statement/metadata/ShowDevicesStatement.java | 10 +
.../metadata/ShowTimeSeriesStatement.java | 30 +-
.../db/service/thrift/ProcessorWithMetrics.java | 6 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 4 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 4 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 2 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 2 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 6 +-
.../db/tools/validate/TsFileValidationTool.java | 16 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../org/apache/iotdb/db/utils/UpgradeUtils.java | 2 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 4 -
.../iotdb/db/engine/cache/ChunkCacheTest.java | 4 +-
.../engine/compaction/AbstractCompactionTest.java | 6 +-
.../db/engine/compaction/MemoryControlTest.java | 75 +++++
.../cross/CrossSpaceCompactionExceptionTest.java | 2 +-
.../cross/CrossSpaceCompactionSelectorTest.java | 171 +++++++++++
.../CrossSpaceCompactionWithFastPerformerTest.java | 6 +-
...eCompactionWithFastPerformerValidationTest.java | 4 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 6 +-
.../db/engine/compaction/cross/MergeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 46 +--
.../inner/AbstractInnerSpaceCompactionTest.java | 4 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../compaction/inner/InnerCompactionTest.java | 4 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 10 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 12 +-
.../db/engine/snapshot/IoTDBSnapshotTest.java | 2 +-
.../db/engine/storagegroup/DataRegionTest.java | 16 +-
.../engine/storagegroup/FakedTsFileResource.java | 2 +-
.../db/engine/storagegroup/TsFileResourceTest.java | 2 +-
.../schemaRegion/SchemaRegionBasicTest.java | 118 +++++++-
.../schemaRegion/SchemaRegionTestUtil.java | 4 +-
.../execution/operator/AlignedSeriesTestUtil.java | 6 +-
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 7 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 120 +++++++-
.../distribution/DistributionPlannerBasicTest.java | 10 +-
.../read/DeviceSchemaScanNodeSerdeTest.java | 3 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 8 +-
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 3 +-
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 10 +-
.../query/reader/series/SeriesReaderTestUtil.java | 6 +-
.../series/SeriesScanLimitOffsetPushDownTest.java | 8 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 12 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 25 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 27 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 26 +-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 32 ++-
.../file/UnsealedTsFileRecoverPerformerTest.java | 5 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 319 ++++++++++++++++++++-
152 files changed, 3308 insertions(+), 1571 deletions(-)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/PathPatternUtil.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/SchemaFilter.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/{pipe/task/meta/PipeStatus.java
=> schema/filter/SchemaFilterType.java} (62%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/SchemaFilterVisitor.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/PathContainsFilter.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/TagFilter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/BatchInsertNode.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/MemoryControlTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionSelectorTest.java
