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 c34ea18e34a Add indexScan and fetchSchema hack
add 88e8800487f Bump jinja2 from 3.1.4 to 3.1.5 in /iotdb-core/ainode
(#14530)
add e54e8cc3988 increase the memory used in UT (#14528)
add 615da741337 Fixed the bug that database "root" in tree model can be
created
add 1ca1f9c0b91 Fixed the bug that nodes with non-trivial wildcards are
not correctly handled in mods setting (#12978)
add 6b53f75482e Fix load data region snapshot miss some writing metrics
(#14532)
add 1464446ca6d DataRegionMetric was not deleted when the DataRegion was
removed (#14506)
add 3ae23550d61 [region migration] Log optimization (#14536)
add 17729a987b2 [remove datanode] Remove LoadScore sort to fix
RegionPriority order (#14527)
add d2f95b87e65 Pipe: Receiver write table model data type conversion test
(#14499)
add 159e558eadd Subscription: improve `createTopic` API with nullable
properties or when if not exists cond is set (#14516)
add 99221da8ca8 Load: detect region replica set changes due to Region
Migration (#14104)
add 54ab67c2f41 [Py-client] rename table concept (#14531)
add 4e76b3d1333 Add database name for table model CLI
add 266c3b08fdc Compaction task can not stopped when abort compaction
(#14538)
add 3238ec257a1 Add the used memory calculation for
DescPriorityMergeReader which is missed before (#14548)
add 530dd0bc653 [IoTConsensus] Refine IoTConsensus Configuration logs
(#14542)
add 80e564b6ef5 Pipe: Fixed the issue of NPE caused by unexpected
exceptions thrown during the use of AsyncClient. (#14556)
add f156ca9f284 Remove ' in create model uri
add 949fd17bb3f Add branches name pattern that will trigger CI (#14567)
add 2c4bb243956 Fix that config changes rejected by DN will be written to
CN's config (#14551)
add c4f8ee9a168 Fix the issue that the cache key used for queries may
conflict. (#14560)
add 81a58c0e890 Rename table concept (#14537)
add f1199fa3fdf Compaction Read Metric and rate limit are bypassed due to
parent class modification (#14559)
add 755516f1eb1 refactor(client-cpp): TableModel ID->TAG,
MEASUREMENT->FIELD (#14546)
add 1a0d4c6294c Parameter Naming Adjustment for the Table Model of REST
Service (#14571)
add 7e1152938c4 fix: UDAFPatternMatch add validate (#14573)
add 8a4f600bf76 Add High Level Memory Threshold Metrics (#14568)
add fd721d656eb Detect singular frame lengths in TElasticFramedTransport
(#14570)
add d83dd4f5e24 Pipe: Ensure the idempotency of the historical activation
batch (#14566)
add e95f4c5869a Bind 0.0.0.0 for all Thrift Service to enhance
extensibility #14577
add 554d7d86978 Close Aggregation and State to release resource
add d865a2c24e3 Fix RatisConsensus client==null exception when stopping
datanode #14578
add 94e0f30598f Parameter Naming Adjustment for the Table Model of REST
Service example (#14575)
add 4f19e6c3720 Use schema last cache to speed up the last and last_by
aggregations in table model
add fc36adbb6f6 Fixed the timeout of device schema fetch to the timeout of
the caller query/write operation
add 81d32f6d679 Pipe: Fixed the NPE for pipe heartbeat when there are
nodes shutting down (#14584)
add 0ad33adbae3 Revert "Fix that config changes rejected by DN will be
written to CN's config (#14551)" (#14589)
add 779d58bd608 Supplement deletion-related tests and bug fixes (#14315)
add 6eaaf5a4fdf Pipe: Fixed the NPE of schema sync in historical transfer
(#14588)
add f7dcbc2008d Bump logback from 1.3.14 to 1.3.15 (#14596)
add dd4d2be1723 Load: Support auto data type conversion when data type
mismatch detected during analysis stage (#14529)
add f3ebf521b78 Optimized the error log for database inconsistency when
adjusting max region group num
add 88a59690581 Pipe: fix the problems that unable to start when cannot
parse reboot times (#14594)
add 88a99aa6472 Rename config page_cache_deletion_buffer_queue_capacity to
deletion_ahead_log_buffer_queue_capacity (#14600)
add 90e7a809d02 Add annotation for prepareFinal method in
GroupedAccumulator
new 57029e8dfc0 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:
.github/workflows/cluster-it-1c1d.yml | 2 +-
.github/workflows/cluster-it-1c1d1a.yml | 4 +-
.github/workflows/cluster-it-1c3d.yml | 4 +-
.github/workflows/compile-check.yml | 4 +-
.github/workflows/dependency-check.yml | 4 +-
.github/workflows/multi-language-client.yml | 4 +-
.github/workflows/pipe-it-2cluster.yml | 4 +-
.github/workflows/sonar-codecov.yml | 4 +-
.github/workflows/table-cluster-it-1c1d.yml | 6 +-
.github/workflows/table-cluster-it-1c3d.yml | 4 +-
.github/workflows/todos-check.yml | 2 +-
.github/workflows/unit-test.yml | 6 +-
example/client-cpp-example/pom.xml | 4 +
example/client-cpp-example/src/CMakeLists.txt | 3 +
.../src/TableModelSessionExample.cpp | 129 +--
.../java/org/apache/iotdb/TableHttpExample.java | 4 +-
.../java/org/apache/iotdb/TableHttpsExample.java | 4 +-
.../org/apache/iotdb/TableModelSessionExample.java | 14 +-
.../apache/iotdb/TableModelSessionPoolExample.java | 28 +-
.../apache/iotdb/udf/AggregateFunctionExample.java | 2 +-
.../apache/iotdb/udf/ScalarFunctionExample.java | 2 +-
integration-test/pom.xml | 44 +-
.../org/apache/iotdb/itbase/category/ManualIT.java | 9 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 73 +-
.../iotdb/db/it/schema/IoTDBCreateDatabaseIT.java | 193 ++++
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 153 ----
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 51 ++
.../manual/IoTDBPipeTypeConversionISessionIT.java | 2 +-
.../IoTDBPipeTypeConversionISessionIT.java | 498 +++++++++++
.../it/tablemodel/IoTDBPipeTypeConversionIT.java | 632 ++++++++++++++
.../pipe/it/tablemodel/IoTDBPipeWithLoadIT.java | 58 +-
.../iotdb/pipe/it/tablemodel/TableModelUtils.java | 20 +-
.../it/db/it/IoTDBCaseWhenThenTableIT.java | 6 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 968 +++++++++++++++++++--
.../it/db/it/IoTDBDisableDeletionTableIT.java | 120 ---
.../it/db/it/IoTDBExecuteBatchTableIT.java | 26 +-
.../it/db/it/IoTDBFlushQueryTableIT.java | 30 +-
.../it/db/it/IoTDBInsertAlignedValuesTableIT.java | 122 ++-
.../relational/it/db/it/IoTDBInsertTableIT.java | 267 +++---
.../it/db/it/IoTDBMultiDeviceTableIT.java | 90 +-
...va => IoTDBMultiTAGsWithAttributesTableIT.java} | 135 ++-
.../relational/it/db/it/IoTDBRecoverTableIT.java | 16 +-
.../it/db/it/IoTDBRecoverUnclosedTableIT.java | 16 +-
.../relational/it/db/it/IoTDBRestartTableIT.java | 51 +-
.../udf/IoTDBUserDefinedAggregateFunctionIT.java | 2 +-
.../it/udf/IoTDBUserDefinedScalarFunctionIT.java | 4 +-
.../it/query/old/IoTDBDatetimeFormatTableIT.java | 2 +-
.../it/query/old/IoTDBFilterBetweenTableIT.java | 2 +-
.../it/query/old/IoTDBFilterNullTableIT.java | 2 +-
.../it/query/old/IoTDBFilterTableIT.java | 10 +-
.../it/query/old/IoTDBNestedQueryTableIT.java | 6 +-
.../it/query/old/IoTDBSimpleQueryTableIT.java | 39 +-
.../alignbydevice/IoTDBAlignByDeviceTableIT.java | 2 +-
.../IoTDBAlignByDeviceWithTemplateTableIT.java | 2 +-
...oTDBOrderByLimitOffsetAlignByDeviceTableIT.java | 4 +-
.../IoTDBOrderByWithAlignByDeviceTableIT.java | 6 +-
.../IoTDBAlignedOffsetLimitPushDownTableIT.java | 2 +-
.../it/query/old/aligned/TableUtils.java | 2 +-
.../scalar/IoTDBCastFunctionTableIT.java | 6 +-
.../scalar/IoTDBCastFunctionTableSpecialIT.java | 2 +-
.../scalar/IoTDBDiffFunctionTableIT.java | 2 +-
.../scalar/IoTDBReplaceFunctionTableIT.java | 2 +-
.../scalar/IoTDBRoundFunctionTableIT.java | 2 +-
.../scalar/IoTDBScalarFunctionTableIT.java | 62 +-
.../scalar/IoTDBSubStringFunctionTableIT.java | 2 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 36 +-
.../it/query/old/query/IoTDBArithmeticTableIT.java | 4 +-
.../it/query/old/query/IoTDBFuzzyQueryTableIT.java | 2 +-
.../it/query/old/query/IoTDBInTableIT.java | 4 +-
...oTDBNoSelectExpressionAfterAnalyzedTableIT.java | 2 +-
.../query/old/query/IoTDBNullOperandTableIT.java | 2 +-
.../it/query/old/query/IoTDBPaginationTableIT.java | 4 +-
.../it/query/old/query/IoTDBQueryDemoTableIT.java | 2 +-
.../IoTDBQueryWithComplexValueFilterTableIT.java | 2 +-
.../it/query/old/query/IoTDBResultSetTableIT.java | 6 +-
.../query/IoTDBSelectCompareExpressionTableIT.java | 2 +-
.../it/query/recent/IoTDBFillTableIT.java | 6 +-
.../it/query/recent/IoTDBGapFillTableIT.java | 2 +-
.../it/query/recent/IoTDBNullIdQueryIT.java | 4 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 32 +-
.../recent/subquery/SubqueryDataSetUtils.java | 4 +-
.../it/rest/it/IoTDBRestServiceCaseWhenThenIT.java | 6 +-
.../it/rest/it/IoTDBRestServiceFlushQueryIT.java | 34 +-
.../relational/it/rest/it/IoTDBRestServiceIT.java | 54 +-
.../it/IoTDBRestServiceInsertAlignedValuesIT.java | 67 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 18 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 14 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 56 +-
.../it/session/IoTDBSessionRelationalIT.java | 282 +++---
.../it/session/IoTDBTableModelSessionIT.java | 8 +-
.../pool/IoTDBInsertTableSessionPoolIT.java | 57 +-
.../session/pool/IoTDBTableModelSessionPoolIT.java | 4 +-
.../udf/api/relational/AggregateFunction.java | 3 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 26 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 4 +-
iotdb-client/client-cpp/src/main/Session.h | 37 +-
iotdb-client/client-cpp/src/main/TableSession.cpp | 2 +-
iotdb-client/client-cpp/src/main/TableSession.h | 2 +-
.../src/test/cpp/sessionRelationalIT.cpp | 26 +-
iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 2 +-
iotdb-client/client-py/iotdb/utils/Tablet.py | 6 +-
.../client-py/table_model_session_example.py | 2 +-
.../client-py/table_model_session_pool_example.py | 2 +-
.../tests/integration/test_relational_session.py | 14 +-
.../tests/integration/test_tablemodel_insert.py | 408 ++++-----
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 4 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 15 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
.../iotdb/rpc/TElasticFramedTransportTest.java | 71 ++
.../session/subscription/SubscriptionSession.java | 8 +-
.../iotdb/session/SessionCacheLeaderTest.java | 12 +-
.../ainode/iotdb/ainode/model/model_factory.py | 2 -
iotdb-core/ainode/poetry.lock | 8 +-
.../iotdb/confignode/manager/load/LoadManager.java | 9 -
.../manager/load/balancer/RouteBalancer.java | 7 +-
.../router/priority/GreedyPriorityBalancer.java | 42 +-
.../router/priority/IPriorityBalancer.java | 5 +-
.../router/priority/LeaderPriorityBalancer.java | 21 +-
.../confignode/manager/load/cache/LoadCache.java | 16 -
.../load/cache/node/DataNodeHeartbeatCache.java | 3 +-
.../runtime/PipeRuntimeCoordinator.java | 4 +-
.../runtime/heartbeat/PipeHeartbeat.java | 8 +-
.../persistence/schema/ClusterSchemaInfo.java | 6 +-
.../confignode/persistence/schema/ConfigMTree.java | 2 +-
.../procedure/env/RegionMaintainHandler.java | 29 +-
.../impl/region/AddRegionPeerProcedure.java | 12 +-
.../impl/region/RegionMigrateProcedure.java | 34 +-
.../impl/region/RemoveRegionPeerProcedure.java | 22 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 10 +-
.../router/priority/GreedyPriorityTest.java | 13 +-
.../priority/LeaderPriorityBalancerTest.java | 65 +-
.../persistence/schema/ConfigMTreeTest.java | 8 +-
.../schema/table/AddTableColumnProcedureTest.java | 4 +-
.../schema/table/CreateTableProcedureTest.java | 8 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 8 +-
.../consensus/iot/IoTConsensusServerImpl.java | 28 +-
.../service/IoTConsensusRPCServiceProcessor.java | 6 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 23 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 29 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 22 +-
.../schemaregion/SchemaExecutionVisitor.java | 5 +-
.../db/exception/VerifyMetadataException.java | 12 +-
...va => VerifyMetadataTypeMismatchException.java} | 8 +-
.../{ => load}/LoadEmptyFileException.java | 2 +-
.../db/exception/{ => load}/LoadFileException.java | 2 +-
.../{ => load}/LoadReadOnlyException.java | 2 +-
.../LoadRuntimeOutOfMemoryException.java | 2 +-
.../{ => load}/PartitionViolationException.java | 2 +-
.../load/RegionReplicaSetChangedException.java} | 22 +-
.../agent/runtime/SimpleProgressIndexAssigner.java | 36 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 4 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 2 +-
.../tablet/parser/TabletInsertionEventParser.java | 8 +-
...ileInsertionEventTableParserTabletIterator.java | 2 +-
.../protocol/legacy/loader/DeletionLoader.java | 2 +-
.../protocol/legacy/loader/TsFileLoader.java | 3 +-
.../pipeconsensus/PipeConsensusReceiver.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 1 +
.../transform/converter/ValueConverter.java | 4 +-
.../statement/PipeConvertedInsertRowStatement.java | 7 +
.../PipeConvertedInsertTabletStatement.java | 7 +
.../visitor/PipeStatementExceptionVisitor.java | 2 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 2 +-
.../table/v1/handler/RequestValidationHandler.java | 20 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 12 +-
.../execution/fragment/QueryContext.java | 18 +-
.../schema/source/TableDeviceFetchSource.java | 2 +-
.../schema/source/TableDeviceQuerySource.java | 2 +-
...ator.java => AbstractAggTableScanOperator.java} | 419 +++++----
.../AbstractDefaultAggTableScanOperator.java | 109 +++
.../relational/AbstractTableScanOperator.java | 4 +-
...lator.java => DefaultAggTableScanOperator.java} | 29 +-
.../relational/LastQueryAggTableScanOperator.java | 424 +++++++++
.../TableAggregationTableScanOperator.java | 78 --
...eeAlignedDeviceViewAggregationScanOperator.java | 47 +-
.../relational/aggregation/AccumulatorFactory.java | 10 +-
.../aggregation/AggregationOperator.java | 1 +
.../relational/aggregation/LastAccumulator.java | 22 +-
.../relational/aggregation/LastByAccumulator.java | 28 +-
.../aggregation/LastByDescAccumulator.java | 5 +
.../aggregation/LastDescAccumulator.java | 9 +-
.../relational/aggregation/TableAccumulator.java | 4 +
.../relational/aggregation/TableAggregator.java | 16 +
.../UserDefinedAggregateFunctionAccumulator.java | 6 +
.../aggregation/grouped/GroupedAccumulator.java | 8 +
.../aggregation/grouped/GroupedAggregator.java | 4 +
.../GroupedUserDefinedAggregateAccumulator.java | 6 +
.../grouped/HashAggregationOperator.java | 1 +
.../grouped/StreamingAggregationOperator.java | 1 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 24 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 4 -
.../plan/analyze/load/LoadTsFileAnalyzer.java | 78 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 9 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 2 +-
.../load/LoadTsFileToTreeModelAnalyzer.java | 9 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 2 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 36 +-
.../config/executor/ClusterConfigTaskExecutor.java | 11 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 8 +-
.../plan/planner/OperatorTreeGenerator.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 288 ++++--
.../plan/planner/plan/node/write/InsertNode.java | 8 +-
.../plan/node/write/RelationalDeleteDataNode.java | 47 +-
.../planner/plan/parameter/SeriesScanOptions.java | 12 +
.../relational/analyzer/StatementAnalyzer.java | 7 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 2 +-
.../schema/CheckSchemaPredicateVisitor.java | 4 +-
.../ConvertSchemaPredicateToFilterVisitor.java | 4 +-
.../plan/relational/metadata/TableSchema.java | 2 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 9 +-
.../fetcher/TableHeaderSchemaValidator.java | 24 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 2 +-
.../plan/relational/planner/RelationPlanner.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 4 +-
.../relational/planner/node/TableScanNode.java | 7 +-
.../PushLimitOffsetIntoTableScan.java | 5 +-
.../optimizations/PushPredicateIntoTableScan.java | 4 +-
.../TransformAggregationToStreamable.java | 4 +-
.../optimizations/TransformSortToStreamSort.java | 5 +-
.../sql/ast/AbstractQueryDeviceWithCache.java | 2 +-
.../plan/relational/sql/ast/ColumnDefinition.java | 2 +-
.../plan/relational/sql/ast/LoadTsFile.java | 16 +-
.../relational/sql/ast/WrappedInsertStatement.java | 10 +-
.../plan/relational/sql/parser/AstBuilder.java | 16 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 134 ++-
.../plan/statement/crud/InsertBaseStatement.java | 13 +-
.../plan/statement/crud/LoadTsFileStatement.java | 70 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 82 +-
.../db/service/metrics/file/TsFileMetrics.java | 49 +-
.../metrics/memory/ThresholdMemoryMetrics.java | 194 +++++
.../iotdb/db/storageengine/StorageEngine.java | 13 +-
.../db/storageengine/buffer/BloomFilterCache.java | 28 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 27 +-
.../buffer/TimeSeriesMetadataCache.java | 56 +-
.../db/storageengine/dataregion/DataRegion.java | 42 +-
.../performer/impl/FastCompactionPerformer.java | 15 +
.../execute/task/CrossSpaceCompactionTask.java | 2 +
.../execute/task/InnerSpaceCompactionTask.java | 32 +-
.../task/InsertionCrossSpaceCompactionTask.java | 2 +
.../task/RepairUnsortedFileCompactionTask.java | 2 +
.../execute/utils/CompactionPathUtils.java | 15 +-
.../execute/utils/CompactionTableSchema.java | 4 +-
.../compaction/execute/utils/CompactionUtils.java | 46 +
.../executor/fast/SeriesCompactionExecutor.java | 10 +-
.../compaction/io/CompactionTsFileReader.java | 14 +-
.../compaction/io/CompactionTsFileWriter.java | 2 +-
.../compaction/schedule/CompactionTaskManager.java | 4 +-
.../compaction/schedule/CompactionWorker.java | 7 +-
.../dataregion/memtable/AbstractMemTable.java | 4 +-
.../dataregion/memtable/TsFileProcessor.java | 27 +-
.../dataregion/modification/ModificationFile.java | 31 +-
.../reader/common/CachedPriorityMergeReader.java | 97 ---
.../reader/common/DescPriorityMergeReader.java | 16 +-
.../read/reader/common/PriorityMergeReader.java | 22 +-
.../dataregion/tsfile/TsFileResource.java | 38 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 2 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 2 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 2 +-
.../db/storageengine/load/LoadTsFileManager.java | 2 +-
.../load/active/ActiveLoadTsFileLoader.java | 1 +
.../load/config/LoadTsFileConfigurator.java | 29 +-
.../LoadConvertedInsertTabletStatement.java | 52 ++
...ertedInsertTabletStatementExceptionVisitor.java | 51 ++
...vertedInsertTabletStatementTSStatusVisitor.java | 65 ++
...leStatementDataTypeConvertExecutionVisitor.java | 143 +++
...eeStatementDataTypeConvertExecutionVisitor.java | 130 +++
.../converter/LoadTsFileDataTypeConverter.java | 107 +++
.../memory/LoadTsFileDataCacheMemoryBlock.java | 2 +-
.../load/memory/LoadTsFileMemoryManager.java | 2 +-
.../load/splitter/TsFileSplitter.java | 35 +-
.../db/tools/schema/SRStatementGenerator.java | 4 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 3 +-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 41 +-
.../SchemaRegionSimpleRecoverTest.java | 4 +-
.../db/pipe/consensus/DeletionRecoverTest.java | 3 +-
.../db/pipe/consensus/DeletionResourceTest.java | 9 +-
.../plan/parser/StatementGeneratorTest.java | 11 +-
.../node/write/InsertRowsNodeSerdeTest.java | 22 +-
.../node/write/InsertTabletNodeSerdeTest.java | 16 +-
.../planner/node/write/WritePlanNodeSplitTest.java | 2 +-
.../node/write/RelationalDeleteDataNodeTest.java | 3 +-
.../plan/relational/analyzer/TSBSMetadata.java | 38 +-
.../plan/relational/analyzer/TestMatadata.java | 18 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 32 +-
.../plan/relational/sql/ast/InsertTabletTest.java | 4 +-
.../plan/statement/InsertStatementTest.java | 45 +-
.../plan/statement/StatementTestUtils.java | 14 +-
.../iotdb/db/storageengine/StorageEngineTest.java | 2 +
.../storageengine/buffer/BloomFilterCacheTest.java | 29 +-
.../BatchedCompactionWithTsFileSplitterTest.java | 15 +-
.../compaction/CompactionWorkerTest.java | 33 +
.../inner/InnerSequenceCompactionSpeedTest.java | 43 +
.../repair/RepairUnsortedFileCompactionTest.java | 53 ++
.../CompactionTableModelTestFileWriter.java | 2 +-
.../CompactionTableSchemaCollectorTest.java | 44 +-
.../TableModelCompactionWithTTLTest.java | 9 +-
.../compaction/utils/CompactionCheckerUtils.java | 30 +-
.../modification/ModificationFileTest.java | 242 +++++-
...SeriesReader.java => AscFakedSeriesReader.java} | 28 +-
.../read/reader/common/DescFakedSeriesReader.java | 54 ++
.../reader/common/PriorityMergeReaderTest.java | 113 ++-
.../reader/common/PriorityMergeReaderTest2.java | 59 --
.../dataregion/tsfile/TsFileResourceTest.java | 144 +++
.../dataregion/wal/io/WALFileTest.java | 2 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 4 +-
.../conf/iotdb-system.properties.template | 11 +-
.../apache/iotdb/commons/client/ThriftClient.java | 17 +-
.../commons/exception/IllegalPathException.java | 4 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 105 ++-
.../apache/iotdb/commons/path/PathPatternUtil.java | 9 +-
.../commons/schema/table/InformationSchema.java | 16 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 10 +-
...entColumnSchema.java => FieldColumnSchema.java} | 18 +-
.../{IdColumnSchema.java => TagColumnSchema.java} | 16 +-
.../schema/table/column/TsTableColumnCategory.java | 24 +-
.../table/column/TsTableColumnSchemaUtil.java | 16 +-
.../service/AbstractThriftServiceThread.java | 7 +-
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../iotdb/commons/service/metric/enums/Tag.java | 4 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 16 +-
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 2 +-
.../iotdb/library/match/PatternExecutor.java | 2 +-
.../iotdb/library/match/UDAFPatternMatch.java | 62 +-
.../org/apache/iotdb/library/UDAFPatternTest.java | 70 ++
pom.xml | 4 +-
329 files changed, 7790 insertions(+), 3426 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/LoadEmptyFileException.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/category/ManualIT.java
(81%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBCreateDatabaseIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBCreateStorageGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeTypeConversionISessionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeTypeConversionIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDisableDeletionTableIT.java
rename
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/{IoTDBMultiIDsWithAttributesTableIT.java
=> IoTDBMultiTAGsWithAttributesTableIT.java} (92%)
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TElasticFramedTransportTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{LoadEmptyFileException.java
=> VerifyMetadataTypeMismatchException.java} (76%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadEmptyFileException.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadFileException.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadReadOnlyException.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/LoadRuntimeOutOfMemoryException.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{ =>
load}/PartitionViolationException.java (96%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/IllegalPathException.java
=>
datanode/src/main/java/org/apache/iotdb/db/exception/load/RegionReplicaSetChangedException.java}
(58%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{AbstractAggregationTableScanOperator.java
=> AbstractAggTableScanOperator.java} (75%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/AbstractDefaultAggTableScanOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{aggregation/grouped/GroupedAccumulator.java
=> DefaultAggTableScanOperator.java} (62%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/LastQueryAggTableScanOperator.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableAggregationTableScanOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/memory/ThresholdMemoryMetrics.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/CachedPriorityMergeReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatementExceptionVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatementTSStatusVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTableStatementDataTypeConvertExecutionVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileDataTypeConverter.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/{FakedSeriesReader.java
=> AscFakedSeriesReader.java} (79%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/DescFakedSeriesReader.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/PriorityMergeReaderTest2.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/column/{MeasurementColumnSchema.java
=> FieldColumnSchema.java} (85%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/column/{IdColumnSchema.java
=> TagColumnSchema.java} (78%)
