This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch TreeToTableView
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 716e8ff9fb4 Add FE implement
add f013e975933 Remove redundant trim (#14502)
add a04c752bc24 fix compaction task comparator & fix the conflicts between
inner compaction selection conditions (#14495)
add f215c4225a1 Revert "[IOTDB-6353] replace cglib to byte-buddy (#14426)"
(#14497)
add 81db737e325 Add lock for insertSeparatorToWAL (#14478)
add 50241423ef8 Apply new configurations in memory before update file
(#14500)
add aee90fb8442 Separate table/tree model database & Added
SchemaRegionGroupNum / dataRegionGroupNum in table databases details &
Optimized the message for table flush operation with database
add 1bb5667a549 add Content-Type in prometheus reporter (#14507)
add 97046f9023c Encountering empty tablets during batch export of tsfile
does not affect subsequent export tasks (#14484)
new 20f3fed8c32 resolve conflicts
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
dependencies.json | 2 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 8 +
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 1 -
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 4 +-
.../pipe/it/tablemodel/IoTDBPipeClusterIT.java | 3 +-
.../it/db/it/IoTDBFlushQueryTableIT.java | 8 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 57 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 4 +-
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 31 +-
.../confignode/conf/ConfigNodeDescriptor.java | 600 ++---
.../request/read/database/CountDatabasePlan.java | 15 +-
.../request/read/database/GetDatabasePlan.java | 7 +-
.../database/AdjustMaxRegionGroupNumPlan.java | 20 +-
.../request/write/quota/SetSpaceQuotaPlan.java | 2 +-
.../write/region/CreateRegionGroupsPlan.java | 39 +-
.../statemachine/ConfigRegionStateMachine.java | 4 +-
.../exception/NoAvailableRegionGroupException.java | 2 +-
.../confignode/manager/ClusterQuotaManager.java | 8 +-
.../iotdb/confignode/manager/ConfigManager.java | 128 +-
.../apache/iotdb/confignode/manager/IManager.java | 6 +-
.../iotdb/confignode/manager/ProcedureManager.java | 9 +-
.../iotdb/confignode/manager/load/LoadManager.java | 4 +-
.../manager/load/balancer/PartitionBalancer.java | 18 +-
.../manager/load/balancer/RegionBalancer.java | 28 +-
.../confignode/manager/load/cache/LoadCache.java | 2 +-
.../manager/partition/PartitionManager.java | 143 +-
.../manager/schema/ClusterSchemaManager.java | 102 +-
.../persistence/executor/ConfigPlanExecutor.java | 14 +-
.../partition/DatabasePartitionTable.java | 5 +-
.../persistence/partition/PartitionInfo.java | 47 +-
.../persistence/schema/ClusterSchemaInfo.java | 324 +--
.../confignode/persistence/schema/ConfigMTree.java | 57 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 15 +-
.../impl/region/CreateRegionGroupsProcedure.java | 51 +-
.../impl/schema/AlterLogicalViewProcedure.java | 2 +-
.../impl/schema/DeactivateTemplateProcedure.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 2 +-
.../impl/schema/table/CreateTableProcedure.java | 119 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 33 +-
.../schema/table/DropTableColumnProcedure.java | 23 +-
.../impl/schema/table/DropTableProcedure.java | 43 +-
.../procedure/state/schema/CreateTableState.java | 1 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 75 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 21 +-
.../confignode/persistence/PartitionInfoTest.java | 16 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 2 +-
.../persistence/schema/ConfigMTreeTest.java | 15 +-
.../schema/table/AddTableColumnProcedureTest.java | 2 +-
.../schema/table/CreateTableProcedureTest.java | 3 +-
.../schema/table/DeleteDevicesProcedureTest.java | 2 +-
.../schema/table/DropTableColumnProcedureTest.java | 2 +-
.../impl/schema/table/DropTableProcedureTest.java | 2 +-
.../table/RenameTableColumnProcedureTest.java | 2 +-
.../table/SetTablePropertiesProcedureTest.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2475 ++++++--------------
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 92 +-
.../dataregion/DataExecutionVisitor.java | 4 +
.../exception/metadata/DatabaseModelException.java | 53 -
.../deletion/persist/PageCacheDeletionBuffer.java | 2 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 6 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 9 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 4 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 5 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../thrift/impl/DataNodeRegionManager.java | 14 +-
.../db/queryengine/plan/analyze/Analysis.java | 27 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 69 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 21 -
.../plan/analyze/ClusterPartitionFetcher.java | 75 +-
.../db/queryengine/plan/analyze/IAnalysis.java | 2 +-
.../plan/analyze/IPartitionFetcher.java | 16 +-
.../analyze/cache/partition/PartitionCache.java | 101 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 5 +-
.../queryengine/plan/execution/QueryExecution.java | 4 +-
.../execution/config/TableConfigTaskVisitor.java | 7 +-
.../config/executor/ClusterConfigTaskExecutor.java | 45 +-
.../relational/AbstractAlterOrDropTableTask.java | 4 +-
.../metadata/relational/CreateTableTask.java | 4 +-
.../config/metadata/relational/ShowDBTask.java | 13 +-
.../plan/execution/config/sys/FlushTask.java | 18 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 12 +-
.../distribution/WriteFragmentParallelPlanner.java | 2 +-
.../node/write/RelationalInsertTabletNode.java | 14 +-
.../plan/relational/analyzer/Analysis.java | 54 +-
.../relational/metadata/TableMetadataImpl.java | 18 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 63 +-
.../plan/relational/planner/RelationPlanner.java | 5 +-
.../distribute/TableDistributedPlanGenerator.java | 67 +-
.../node/schema/CreateOrUpdateTableDeviceNode.java | 5 +-
.../schema/TableDeviceAttributeUpdateNode.java | 9 +-
.../optimizations/PushPredicateIntoTableScan.java | 38 +-
.../queryengine/plan/relational/sql/ast/Flush.java | 4 +-
.../plan/relational/sql/parser/AstBuilder.java | 46 +-
.../statement/metadata/ShowDatabaseStatement.java | 6 -
.../plan/statement/sys/FlushStatement.java | 33 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 60 +-
.../schemaregion/ISchemaRegionParams.java | 3 +-
.../schemaregion/SchemaRegionParams.java | 11 +-
.../GeneralRegionAttributeSecurityService.java | 6 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 13 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 6 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 2 +-
.../db/schemaengine/table/DataNodeTableCache.java | 45 +-
.../schemaengine/table/InformationSchemaUtils.java | 3 +-
.../iotdb/db/storageengine/StorageEngine.java | 27 +-
.../db/storageengine/dataregion/DataRegion.java | 33 +-
.../DefaultCompactionTaskComparatorImpl.java | 16 +-
.../impl/NewSizeTieredCompactionSelector.java | 2 +-
.../wal/allocation/FirstCreateStrategy.java | 1 +
.../storageengine/dataregion/wal/node/WALNode.java | 8 +-
.../db/tools/schema/SRStatementGenerator.java | 3 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 4 +-
.../SchemaRegionSimpleRecoverTest.java | 5 +-
.../schemaRegion/SchemaRegionTableDeviceTest.java | 10 +-
.../schemaRegion/SchemaRegionTestUtil.java | 3 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../plan/analyze/FakePartitionFetcherImpl.java | 5 -
.../plan/analyze/cache/PartitionCacheTest.java | 8 +-
.../plan/planner/distribution/Util.java | 5 -
.../plan/planner/distribution/Util2.java | 5 -
.../plan/relational/analyzer/AnalyzerTest.java | 49 +-
.../analyzer/MockTableModelDataPartition.java | 17 +-
.../plan/relational/analyzer/TSBSMetadata.java | 5 -
.../plan/relational/analyzer/TestMatadata.java | 68 +-
.../DataNodeInternalRPCServiceImplTest.java | 3 +-
.../compaction/CompactionTaskComparatorTest.java | 2 +-
.../NewSizeTieredCompactionSelectorTest.java | 30 +
.../org/apache/iotdb/db/tools/MLogParserTest.java | 5 +-
.../db/utils/SchemaRegionSnapshotParserTest.java | 89 +-
.../reporter/prometheus/PrometheusReporter.java | 5 +-
iotdb-core/node-commons/pom.xml | 4 +-
.../commons/client/sync/ByteBuddyEnhancer.java | 75 -
.../sync/SyncThriftClientWithErrorHandler.java | 30 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 22 +-
.../iotdb/commons/partition/DataPartition.java | 55 +-
.../iotdb/commons/partition/SchemaPartition.java | 10 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 11 +-
.../schema/column/ColumnHeaderConstant.java | 9 +-
.../commons/schema/table/InformationSchema.java | 5 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 8 +-
.../src/main/thrift/confignode.thrift | 4 +-
pom.xml | 8 +-
143 files changed, 2458 insertions(+), 3938 deletions(-)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/DatabaseModelException.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/ByteBuddyEnhancer.java
